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

Method SetController

mockresponses.go:173–176  ·  mockresponses.go::MockMetadataResponse.SetController
(brokerID int32)

Source from the content-addressed store, hash-verified

171}
172
173func (mmr *MockMetadataResponse) SetController(brokerID int32) *MockMetadataResponse {
174 mmr.controllerID = brokerID
175 return mmr
176}
177
178func (mmr *MockMetadataResponse) For(reqBody versionedDecoder) encoderWithHeader {
179 metadataRequest := reqBody.(*MetadataRequest)

Callers 15

TestAsyncProducerRecoveryWithRetriesDisabledFunction · 0.80
TestTxnmgrInitProducerIdTxnCoordinatorLoadingFunction · 0.80
TestClientControllerFunction · 0.80
TestClusterAdminFunction · 0.80
TestClusterAdminCreateTopicFunction · 0.80
TestClusterAdminCreateTopicWithInvalidTopicDetailFunction · 0.80
TestClusterAdminCreateTopicWithoutAuthorizationFunction · 0.80
TestClusterAdminListTopicsFunction · 0.80
TestClusterAdminListTopicsRetriesOnTransientConnectionErrorFunction · 0.80
TestClusterAdminListTopicsRetriesOnDescribeConfigsTimeoutFunction · 0.80
TestClusterAdminDeleteTopicFunction · 0.80
TestClusterAdminDeleteEmptyTopicFunction · 0.80

Calls

no outgoing calls

Tested by 15

TestAsyncProducerRecoveryWithRetriesDisabledFunction · 0.64
TestTxnmgrInitProducerIdTxnCoordinatorLoadingFunction · 0.64
TestClientControllerFunction · 0.64
TestClusterAdminFunction · 0.64
TestClusterAdminCreateTopicFunction · 0.64
TestClusterAdminCreateTopicWithInvalidTopicDetailFunction · 0.64
TestClusterAdminCreateTopicWithoutAuthorizationFunction · 0.64
TestClusterAdminListTopicsFunction · 0.64
TestClusterAdminListTopicsRetriesOnTransientConnectionErrorFunction · 0.64
TestClusterAdminListTopicsRetriesOnDescribeConfigsTimeoutFunction · 0.64
TestClusterAdminDeleteTopicFunction · 0.64
TestClusterAdminDeleteEmptyTopicFunction · 0.64