(ring *PartitionRing)
| 531 | } |
| 532 | |
| 533 | func NewActivePartitionBatchRing(ring *PartitionRing) *ActivePartitionBatchRing { |
| 534 | return &ActivePartitionBatchRing{ |
| 535 | ring: ring, |
| 536 | } |
| 537 | } |
| 538 | |
| 539 | // InstancesCount returns the number of active partitions in the ring. |
| 540 | // |
no outgoing calls