(b *testing.B, key string, d *ring.Desc)
| 31 | } |
| 32 | |
| 33 | func encodeMessage(b *testing.B, key string, d *ring.Desc) []byte { |
| 34 | c := ring.GetCodec() |
| 35 | val, err := c.Encode(d) |
| 36 | require.NoError(b, err) |
| 37 | |
| 38 | kvPair := memberlist.KeyValuePair{ |
| 39 | Key: key, |
| 40 | Value: val, |
| 41 | Codec: c.CodecID(), |
| 42 | } |
| 43 | |
| 44 | ser, err := kvPair.Marshal() |
| 45 | require.NoError(b, err) |
| 46 | return ser |
| 47 | } |
| 48 | |
| 49 | func generateUniqueTokens(ingester, numTokens int) []uint32 { |
| 50 | // Generate unique tokens without using ring.GenerateTokens in order to not |
no test coverage detected