(req findCoordinatorRequestV0)
| 582 | } |
| 583 | |
| 584 | func (t *timeoutCoordinator) findCoordinator(req findCoordinatorRequestV0) (findCoordinatorResponseV0, error) { |
| 585 | if err := t.conn.SetDeadline(time.Now().Add(t.timeout)); err != nil { |
| 586 | return findCoordinatorResponseV0{}, err |
| 587 | } |
| 588 | return t.conn.findCoordinator(req) |
| 589 | } |
| 590 | |
| 591 | func (t *timeoutCoordinator) joinGroup(req joinGroupRequest) (joinGroupResponse, error) { |
| 592 | // in the case of join group, the consumer group coordinator may wait up |
nothing calls this directly
no test coverage detected