12345678910111213141516171819202122232425 |
- package cluster
- // Strategy for partition to consumer assignement
- type Strategy string
- const (
- // StrategyRange is the default and assigns partition ranges to consumers.
- // Example with six partitions and two consumers:
- // C1: [0, 1, 2]
- // C2: [3, 4, 5]
- StrategyRange Strategy = "range"
- // StrategyRoundRobin assigns partitions by alternating over consumers.
- // Example with six partitions and two consumers:
- // C1: [0, 2, 4]
- // C2: [1, 3, 5]
- StrategyRoundRobin Strategy = "roundrobin"
- )
- // Error instances are wrappers for internal errors with a context and
- // may be returned through the consumer's Errors() channel
- type Error struct {
- Ctx string
- error
- }
|