()
| 62 | } |
| 63 | |
| 64 | func NewPartitionRingDesc() *PartitionRingDesc { |
| 65 | return &PartitionRingDesc{ |
| 66 | Partitions: map[int32]PartitionDesc{}, |
| 67 | Owners: map[string]OwnerDesc{}, |
| 68 | } |
| 69 | } |
| 70 | |
| 71 | // tokens returns a sort list of tokens registered by all partitions. |
| 72 | func (m *PartitionRingDesc) tokens() Tokens { |
no outgoing calls