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

Method Leader

client.go:57–57  ·  view source on GitHub ↗

Leader returns the broker object that is the leader of the current topic/partition, as determined by querying the cluster metadata.

(topic string, partitionID int32)

Source from the content-addressed store, hash-verified

55 // Leader returns the broker object that is the leader of the current
56 // topic/partition, as determined by querying the cluster metadata.
57 Leader(topic string, partitionID int32) (*Broker, error)
58
59 // LeaderAndEpoch returns the leader and its epoch for the current
60 // topic/partition, as determined by querying the cluster metadata.

Callers 15

TestConsumeMessagesTrackLeaderFunction · 0.95
TestClientMetadataFunction · 0.95
TestClientMetadataWithOfflineReplicasFunction · 0.95
TestClientReceivingUnknownTopicFunction · 0.95
TestClientReceivingPartialMetadataFunction · 0.95
TestClientRefreshBehaviourFunction · 0.95
TestFuncClientMetadataFunction · 0.95
TestFuncIdempotentBufferedSequenceFunction · 0.65
validateProducerMetricsFunction · 0.65
validateConsumerMetricsFunction · 0.65
DeleteRecordsMethod · 0.65
dispatchMethod · 0.65

Implementers 2

stubLeaderClientasync_producer_test.go
clientclient.go

Calls

no outgoing calls

Tested by 11

TestConsumeMessagesTrackLeaderFunction · 0.76
TestClientMetadataFunction · 0.76
TestClientMetadataWithOfflineReplicasFunction · 0.76
TestClientReceivingUnknownTopicFunction · 0.76
TestClientReceivingPartialMetadataFunction · 0.76
TestClientRefreshBehaviourFunction · 0.76
TestFuncClientMetadataFunction · 0.76
TestFuncIdempotentBufferedSequenceFunction · 0.52
validateProducerMetricsFunction · 0.52
validateConsumerMetricsFunction · 0.52
topicWithEvenLeadersFunction · 0.52