(ctx context.Context, t testing.TB)
| 1400 | } |
| 1401 | |
| 1402 | func newFakeCoordinatorClient(ctx context.Context, t testing.TB) *fakeCoordinatorClient { |
| 1403 | return &fakeCoordinatorClient{ |
| 1404 | ctx: ctx, |
| 1405 | t: t, |
| 1406 | reqs: make(chan *coordReqCall), |
| 1407 | resps: make(chan *coordRespCall), |
| 1408 | close: make(chan chan<- error), |
| 1409 | } |
| 1410 | } |
| 1411 | |
| 1412 | type coordReqCall struct { |
| 1413 | req *proto.CoordinateRequest |
no outgoing calls
no test coverage detected