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

Method String

utils.go:345–351  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

343}
344
345func (v KafkaVersion) String() string {
346 if v.version[0] == 0 {
347 return fmt.Sprintf("0.%d.%d.%d", v.version[1], v.version[2], v.version[3])
348 }
349
350 return fmt.Sprintf("%d.%d.%d", v.version[0], v.version[1], v.version[2])
351}
352
353// NewExponentialBackoff returns a function that implements an exponential backoff strategy with jitter.
354// It follows KIP-580, implementing the formula:

Callers 15

produceMsgsFunction · 0.45
consumeMsgsFunction · 0.45
testProducingMessagesFunction · 0.45
existingEnvironmentFunction · 0.45
TestVersionParsingFunction · 0.45
TestDecompressFunction · 0.45
AddrMethod · 0.45
CloseMethod · 0.45
NewMockBrokerListenerFunction · 0.45

Calls

no outgoing calls

Tested by 15

produceMsgsFunction · 0.36
consumeMsgsFunction · 0.36
testProducingMessagesFunction · 0.36
existingEnvironmentFunction · 0.36
TestVersionParsingFunction · 0.36
TestDecompressFunction · 0.36
produceWithJavaFunction · 0.36
consumeWithJavaFunction · 0.36