()
| 1021 | } |
| 1022 | |
| 1023 | func newPartitionRingReader() *mockPartitionRingReader { |
| 1024 | return &mockPartitionRingReader{ |
| 1025 | r: mustPartitionRing(map[int32]ring.PartitionDesc{ |
| 1026 | 0: {State: ring.PartitionActive}, |
| 1027 | }), |
| 1028 | } |
| 1029 | } |
| 1030 | |
| 1031 | func newPartitionRingReaderWithPartitions(partitions map[int32]ring.PartitionDesc) *mockPartitionRingReader { |
| 1032 | return &mockPartitionRingReader{ |
no test coverage detected