| 14 | var _ coordinator = mockCoordinator{} |
| 15 | |
| 16 | type mockCoordinator struct { |
| 17 | closeFunc func() error |
| 18 | findCoordinatorFunc func(findCoordinatorRequestV0) (findCoordinatorResponseV0, error) |
| 19 | joinGroupFunc func(joinGroupRequest) (joinGroupResponse, error) |
| 20 | syncGroupFunc func(syncGroupRequestV0) (syncGroupResponseV0, error) |
| 21 | leaveGroupFunc func(leaveGroupRequestV0) (leaveGroupResponseV0, error) |
| 22 | heartbeatFunc func(heartbeatRequestV0) (heartbeatResponseV0, error) |
| 23 | offsetFetchFunc func(offsetFetchRequestV1) (offsetFetchResponseV1, error) |
| 24 | offsetCommitFunc func(offsetCommitRequestV2) (offsetCommitResponseV2, error) |
| 25 | readPartitionsFunc func(...string) ([]Partition, error) |
| 26 | } |
| 27 | |
| 28 | func (c mockCoordinator) Close() error { |
| 29 | if c.closeFunc != nil { |
nothing calls this directly
no outgoing calls
no test coverage detected