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

Method Name

balance_strategy.go:49–49  ·  view source on GitHub ↗

Name uniquely identifies the strategy.

()

Source from the content-addressed store, hash-verified

47type BalanceStrategy interface {
48 // Name uniquely identifies the strategy.
49 Name() string
50
51 // Plan accepts a map of `memberID -> metadata` and a map of `topic -> partitions`
52 // and returns a distribution plan.

Callers 15

TestReadOnlyAndAllCommittedMessagesFunction · 0.65
TestConsumerGroupDeadlockFunction · 0.65
produceMsgsFunction · 0.65
consumeMsgsFunction · 0.65
testProducingMessagesFunction · 0.65
TestAsyncProducerRemoteBrokerClosedFunction · 0.65
TestConsumeMessagesTrackLeaderFunction · 0.65
TestConsumerRebalancingMultiplePartitionsFunction · 0.65
TestBalanceStrategyRangeFunction · 0.65
TestBalanceStrategyRoundRobinFunction · 0.65
joinGroupRequestMethod · 0.65
subscriptionMetadataMethod · 0.65

Implementers 4

testStatefulStrategyfunctional_consumer_group_test.go
balanceStrategybalance_strategy.go
stickyBalanceStrategybalance_strategy.go
roundRobinBalancerbalance_strategy.go

Calls

no outgoing calls

Tested by 15

TestReadOnlyAndAllCommittedMessagesFunction · 0.52
TestConsumerGroupDeadlockFunction · 0.52
produceMsgsFunction · 0.52
consumeMsgsFunction · 0.52
testProducingMessagesFunction · 0.52
TestAsyncProducerRemoteBrokerClosedFunction · 0.52
TestConsumeMessagesTrackLeaderFunction · 0.52
TestConsumerRebalancingMultiplePartitionsFunction · 0.52
TestBalanceStrategyRangeFunction · 0.52
TestBalanceStrategyRoundRobinFunction · 0.52
TestConsumerGroupNewSessionDuringOffsetLoadFunction · 0.52
TestConsumerGroupSessionDoesNotRetryForeverFunction · 0.52