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

Method SetBroker

mockresponses.go:168–171  ·  mockresponses.go::MockMetadataResponse.SetBroker
(addr string, brokerID int32)

Source from the content-addressed store, hash-verified

166}
167
168func (mmr *MockMetadataResponse) SetBroker(addr string, brokerID int32) *MockMetadataResponse {
169 mmr.brokers[addr] = brokerID
170 return mmr
171}
172
173func (mmr *MockMetadataResponse) SetController(brokerID int32) *MockMetadataResponse {
174 mmr.controllerID = brokerID

Callers 15

TestConsumerOffsetManualFunction · 0.80
TestConsumerMessageWithKeyFunction · 0.80
TestPauseResumeConsumptionFunction · 0.80
TestConsumerOffsetNewestFunction · 0.80
TestConsumerOffsetOldestFunction · 0.80
TestConsumerRecreateFunction · 0.80
TestConsumerDuplicateFunction · 0.80
runConsumerLeaderRefreshErrorTestWithConfigFunction · 0.80
TestConsumerInvalidTopicFunction · 0.80
TestConsumerClosePartitionWithoutLeaderFunction · 0.80
TestConsumerShutsDownOutOfRangeFunction · 0.80
TestConsumerExtraOffsetsFunction · 0.80

Calls

no outgoing calls

Tested by 15

TestConsumerOffsetManualFunction · 0.64
TestConsumerMessageWithKeyFunction · 0.64
TestPauseResumeConsumptionFunction · 0.64
TestConsumerOffsetNewestFunction · 0.64
TestConsumerOffsetOldestFunction · 0.64
TestConsumerRecreateFunction · 0.64
TestConsumerDuplicateFunction · 0.64
runConsumerLeaderRefreshErrorTestWithConfigFunction · 0.64
TestConsumerInvalidTopicFunction · 0.64
TestConsumerClosePartitionWithoutLeaderFunction · 0.64
TestConsumerShutsDownOutOfRangeFunction · 0.64
TestConsumerExtraOffsetsFunction · 0.64