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

Method Brokers

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

Brokers returns the current set of active brokers as retrieved from cluster metadata.

()

Source from the content-addressed store, hash-verified

37
38 // Brokers returns the current set of active brokers as retrieved from cluster metadata.
39 Brokers() []*Broker
40
41 // Broker returns the active Broker if available for the broker ID.
42 Broker(brokerID int32) (*Broker, error)

Callers 15

prepareDockerTestEnvironmentFunction · 0.95
TestSyncProducerTransactionalFunction · 0.95
TestConsumerQueueSubscriptionAfterUnrefFunction · 0.95
TestConsumerAbortNoGoroutineLeakFunction · 0.95
TestTxnProduceBumpEpochFunction · 0.95
TestTxnProduceRecordWithCommitFunction · 0.95
TestTxnProduceBatchAddPartitionFunction · 0.95
TestTxnProduceRecordWithAbortFunction · 0.95
TestTxnmgrInitProducerIdTxnFunction · 0.95
newMockTxnManagerFunction · 0.95
TestClientRefreshMetadataBrokerOfflineFunction · 0.95
TestFuncAdminAlterPartitionReassignmentsFunction · 0.95

Implementers 2

stubLeaderClientasync_producer_test.go
clientclient.go

Calls

no outgoing calls

Tested by 15

prepareDockerTestEnvironmentFunction · 0.76
TestSyncProducerTransactionalFunction · 0.76
TestConsumerQueueSubscriptionAfterUnrefFunction · 0.76
TestConsumerAbortNoGoroutineLeakFunction · 0.76
TestTxnProduceBumpEpochFunction · 0.76
TestTxnProduceRecordWithCommitFunction · 0.76
TestTxnProduceBatchAddPartitionFunction · 0.76
TestTxnProduceRecordWithAbortFunction · 0.76
TestTxnmgrInitProducerIdTxnFunction · 0.76
newMockTxnManagerFunction · 0.76
TestClientRefreshMetadataBrokerOfflineFunction · 0.76
TestFuncAdminAlterPartitionReassignmentsFunction · 0.76