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

Function milliseconds

time.go:32–40  ·  view source on GitHub ↗
(d time.Duration)

Source from the content-addressed store, hash-verified

30}
31
32func milliseconds(d time.Duration) int32 {
33 switch {
34 case d > maxTimeout:
35 d = maxTimeout
36 case d < minTimeout:
37 d = minTimeout
38 }
39 return int32(d / time.Millisecond)
40}
41
42func deadlineToTimeout(deadline time.Time, now time.Time) time.Duration {
43 if deadline.IsZero() {

Callers 14

createTopicFunction · 0.85
deleteTopicsMethod · 0.85
FetchMethod · 0.85
testWriteFetchRequestV2Function · 0.85
recordSizeFunction · 0.85
createTopicsMethod · 0.85
writeFetchRequestV2Method · 0.85
writeFetchRequestV5Method · 0.85
writeFetchRequestV10Method · 0.85
writeProduceRequestV2Method · 0.85
writeProduceRequestV3Method · 0.85
writeProduceRequestV7Method · 0.85

Calls

no outgoing calls

Tested by 2

createTopicFunction · 0.68
testWriteFetchRequestV2Function · 0.68