MCPcopy
hub / github.com/grafana/dskit / TestMessageBuffer

Function TestMessageBuffer

kv/memberlist/memberlist_client_test.go:1703–1718  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

1701}
1702
1703func TestMessageBuffer(t *testing.T) {
1704 buf := []Message(nil)
1705 size := 0
1706
1707 buf, size = addMessageToBuffer(buf, size, 100, Message{Size: 50})
1708 assert.Len(t, buf, 1)
1709 assert.Equal(t, size, 50)
1710
1711 buf, size = addMessageToBuffer(buf, size, 100, Message{Size: 50})
1712 assert.Len(t, buf, 2)
1713 assert.Equal(t, size, 100)
1714
1715 buf, size = addMessageToBuffer(buf, size, 100, Message{Size: 25})
1716 assert.Len(t, buf, 2)
1717 assert.Equal(t, size, 75)
1718}
1719
1720func TestNotifyMsgResendsOnlyChanges(t *testing.T) {
1721 codec := dataCodec{}

Callers

nothing calls this directly

Calls 3

addMessageToBufferFunction · 0.85
LenMethod · 0.45
EqualMethod · 0.45

Tested by

no test coverage detected