MCPcopy
hub / github.com/segmentio/kafka-go / staticBalancer

Struct staticBalancer

writer_test.go:1033–1035  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1031}
1032
1033type staticBalancer struct {
1034 partition int
1035}
1036
1037func (b *staticBalancer) Balance(_ Message, partitions ...int) int {
1038 return b.partition

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected