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

Method AddBroker

metadata_response.go:404–406  ·  view source on GitHub ↗

testing API

(addr string, id int32)

Source from the content-addressed store, hash-verified

402// testing API
403
404func (r *MetadataResponse) AddBroker(addr string, id int32) {
405 r.Brokers = append(r.Brokers, &Broker{id: id, addr: addr})
406}
407
408func (r *MetadataResponse) AddTopic(topic string, err KError) *TopicMetadata {
409 var tmatch *TopicMetadata

Callers 15

TestAsyncProducerIdempotentGoldenPathFunction · 0.95
TestAsyncProducerIdempotentRetryCheckBatchFunction · 0.95
TestAsyncProducerIdempotentRetryCheckBatch_2378Function · 0.95
TestAsyncProducerIdempotentRetryBatchBackoffFunction · 0.95
TestAsyncProducerIdempotentErrorOnOutOfSeqFunction · 0.95
TestAsyncProducerIdempotentEpochRolloverFunction · 0.95
TestAsyncProducerIdempotentEpochExhaustionFunction · 0.95
TestBrokerProducerShutdownFunction · 0.95
ForMethod · 0.95
TestSyncProducerFunction · 0.80
TestSyncProducerTransactionalFunction · 0.80
TestSyncProducerBatchFunction · 0.80

Calls

no outgoing calls

Tested by 15

TestAsyncProducerIdempotentGoldenPathFunction · 0.76
TestAsyncProducerIdempotentRetryCheckBatchFunction · 0.76
TestAsyncProducerIdempotentRetryCheckBatch_2378Function · 0.76
TestAsyncProducerIdempotentRetryBatchBackoffFunction · 0.76
TestAsyncProducerIdempotentErrorOnOutOfSeqFunction · 0.76
TestAsyncProducerIdempotentEpochRolloverFunction · 0.76
TestAsyncProducerIdempotentEpochExhaustionFunction · 0.76
TestBrokerProducerShutdownFunction · 0.76
TestSyncProducerFunction · 0.64
TestSyncProducerTransactionalFunction · 0.64
TestSyncProducerBatchFunction · 0.64
TestConcurrentSyncProducerFunction · 0.64