| 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 |
| } |