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

Method ProtocolName

groupbalancer.go:26–26  ·  view source on GitHub ↗

ProtocolName of the GroupBalancer

()

Source from the content-addressed store, hash-verified

24type GroupBalancer interface {
25 // ProtocolName of the GroupBalancer
26 ProtocolName() string
27
28 // UserData provides the GroupBalancer an opportunity to embed custom
29 // UserData into the metadata.

Callers 4

findGroupBalancerFunction · 0.65
TestClientJoinGroupFunction · 0.65
TestReaderAssignTopicPartitionsFunction · 0.65
makeJoinGroupRequestMethod · 0.65

Implementers 3

RangeGroupBalancergroupbalancer.go
RoundRobinGroupBalancergroupbalancer.go
RackAffinityGroupBalancergroupbalancer.go

Calls

no outgoing calls

Tested by 2

TestClientJoinGroupFunction · 0.52
TestReaderAssignTopicPartitionsFunction · 0.52