MCPcopy
hub / github.com/IBM/sarama / appendInterceptor

Struct appendInterceptor

helpers_test.go:68–70  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

66const TestMessage = "ABC THE MESSAGE"
67
68type appendInterceptor struct {
69 i int
70}
71
72func (b *appendInterceptor) OnSend(msg *ProducerMessage) {
73 if b.i < 0 {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected