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

Function addMessageToBuffer

kv/memberlist/memberlist_client.go:1909–1919  ·  view source on GitHub ↗
(msgs []Message, size int, limit int, msg Message)

Source from the content-addressed store, hash-verified

1907}
1908
1909func addMessageToBuffer(msgs []Message, size int, limit int, msg Message) ([]Message, int) {
1910 msgs = append(msgs, msg)
1911 size += msg.Size
1912
1913 for len(msgs) > 0 && size > limit {
1914 size -= msgs[0].Size
1915 msgs = msgs[1:]
1916 }
1917
1918 return msgs, size
1919}
1920
1921func updateTime(val int64) time.Time {
1922 if val == 0 {

Callers 3

TestMessageBufferFunction · 0.85
addReceivedMessageMethod · 0.85
addSentMessageMethod · 0.85

Calls

no outgoing calls

Tested by 1

TestMessageBufferFunction · 0.68