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

Method context

transport.go:268–273  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

266}
267
268func (t *Transport) context() context.Context {
269 if t.Context != nil {
270 return t.Context
271 }
272 return context.Background()
273}
274
275type event chan struct{}
276

Callers 1

grabPoolMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected