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

Method complete

writer.go:1246–1249  ·  view source on GitHub ↗
(err error)

Source from the content-addressed store, hash-verified

1244}
1245
1246func (b *writeBatch) complete(err error) {
1247 b.err = err
1248 close(b.done)
1249}
1250
1251type writerRecords struct {
1252 msgs []Message

Callers 1

writeBatchMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected