MCPcopy
hub / github.com/segmentio/kafka-go / full

Method full

writer.go:1238–1240  ·  view source on GitHub ↗
(maxSize int, maxBytes int64)

Source from the content-addressed store, hash-verified

1236}
1237
1238func (b *writeBatch) full(maxSize int, maxBytes int64) bool {
1239 return b.size >= maxSize || b.bytes >= maxBytes
1240}
1241
1242func (b *writeBatch) trigger() {
1243 close(b.ready)

Callers 1

writeMessagesMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected