Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
1238
func
(b *writeBatch) full(maxSize int, maxBytes int64) bool {
1239
return
b.size >= maxSize || b.bytes >= maxBytes
1240
}
1241
1242
func
(b *writeBatch) trigger() {
1243
close(b.ready)
Callers
1
writeMessages
Method · 0.45
Calls
no outgoing calls
Tested by
no test coverage detected