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

Method Plan

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

Plan accepts a map of `memberID -> metadata` and a map of `topic -> partitions` and returns a distribution plan.

(members map[string]ConsumerGroupMemberMetadata, topics map[string][]int32)

Source from the content-addressed store, hash-verified

51 // Plan accepts a map of `memberID -> metadata` and a map of `topic -> partitions`
52 // and returns a distribution plan.
53 Plan(members map[string]ConsumerGroupMemberMetadata, topics map[string][]int32) (BalanceStrategyPlan, error)
54
55 // AssignmentData returns the serialized assignment data for the specified
56 // memberID

Callers 5

TestBalanceStrategyRangeFunction · 0.65
balanceMethod · 0.65
PlanMethod · 0.65

Implementers 4

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

Calls

no outgoing calls

Tested by 4

TestBalanceStrategyRangeFunction · 0.52
PlanMethod · 0.52