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

Method ProtocolName

groupbalancer.go:105–107  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

103type RoundRobinGroupBalancer struct{}
104
105func (r RoundRobinGroupBalancer) ProtocolName() string {
106 return "roundrobin"
107}
108
109func (r RoundRobinGroupBalancer) UserData() ([]byte, error) {
110 return nil, nil

Callers 2

TestClientLeaveGroupFunction · 0.95
TestClientSyncGroupFunction · 0.95

Calls

no outgoing calls

Tested by 2

TestClientLeaveGroupFunction · 0.76
TestClientSyncGroupFunction · 0.76