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

Method findCoordinator

consumergroup.go:557–557  ·  view source on GitHub ↗
(findCoordinatorRequestV0)

Source from the content-addressed store, hash-verified

555type coordinator interface {
556 io.Closer
557 findCoordinator(findCoordinatorRequestV0) (findCoordinatorResponseV0, error)
558 joinGroup(joinGroupRequest) (joinGroupResponse, error)
559 syncGroup(syncGroupRequestV0) (syncGroupResponseV0, error)
560 leaveGroup(leaveGroupRequestV0) (leaveGroupResponseV0, error)

Callers 4

waitForCoordinatorFunction · 0.65
testConnFindCoordinatorFunction · 0.65
findCoordinatorMethod · 0.65
coordinatorMethod · 0.65

Implementers 2

mockCoordinatorconsumergroup_test.go
timeoutCoordinatorconsumergroup.go

Calls

no outgoing calls

Tested by 2

waitForCoordinatorFunction · 0.52
testConnFindCoordinatorFunction · 0.52