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

Method IsZero

protocol/cluster.go:37–39  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

35}
36
37func (c Cluster) IsZero() bool {
38 return c.ClusterID == "" && c.Controller == 0 && len(c.Brokers) == 0 && len(c.Topics) == 0
39}
40
41func (c Cluster) Format(w fmt.State, _ rune) {
42 tw := new(tabwriter.Writer)

Callers 15

ReadMethod · 0.80
WriteMethod · 0.80
connectMethod · 0.80
TestClientPipelineFunction · 0.80
writeCompressedMessagesMethod · 0.80
ApiVersionsMethod · 0.80
timestampFunction · 0.80
deadlineToTimeoutFunction · 0.80
adjustDeadlineForRTTFunction · 0.80
checkTimeoutErrFunction · 0.80
TestClientListOffsetsFunction · 0.80
writeBatchMethod · 0.80

Calls

no outgoing calls

Tested by 5

ReadMethod · 0.64
WriteMethod · 0.64
TestClientPipelineFunction · 0.64
TestClientListOffsetsFunction · 0.64
TestDefaultSignTimeFunction · 0.64