mirror of
https://github.com/chrislusf/seaweedfs
synced 2025-06-30 00:32:47 +02:00
205d2285f3
* the subscriber would getOrGen a local partition and wait * the publisher would getOrGen a local partition. If localPartition follower is not setup, and init message has follower info, it would create followers based on init.Messages. |
||
|---|---|---|
| .. | ||
| connect_to_sub_coordinator.go | ||
| subscribe.go | ||
| subscriber.go | ||