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

Method withLogger

reader.go:1131–1135  ·  view source on GitHub ↗
(do func(Logger))

Source from the content-addressed store, hash-verified

1129}
1130
1131func (r *Reader) withLogger(do func(Logger)) {
1132 if r.config.Logger != nil {
1133 do(r.config.Logger)
1134 }
1135}
1136
1137func (r *Reader) withErrorLogger(do func(Logger)) {
1138 if r.config.ErrorLogger != nil {

Callers 6

subscribeMethod · 0.95
commitLoopMethod · 0.95
runMethod · 0.95
OffsetMethod · 0.95
SetOffsetMethod · 0.95
withErrorLoggerMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected