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

Method maxWait

fetch.go:186–191  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

184}
185
186func (req *FetchRequest) maxWait() time.Duration {
187 if req.MaxWait > 0 {
188 return req.MaxWait
189 }
190 return defaultMaxWait
191}
192
193type fetchRequestV2 struct {
194 ReplicaID int32

Callers 1

FetchMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected