()
| 63 | } |
| 64 | |
| 65 | func newTestServer() *testServer { |
| 66 | return &testServer{ |
| 67 | checkinCh: make(chan checkinRecord, 16), |
| 68 | spiteReqCh: make(chan *clientpb.SpiteRequest, 16), |
| 69 | spiteRespCh: make(chan *clientpb.SpiteResponse, 64), |
| 70 | jobCtrlCh: make(chan *clientpb.JobCtrl, 16), |
| 71 | jobStatusCh: make(chan *clientpb.JobStatus, 16), |
| 72 | jobStreamDisconnectCh: make(chan struct{}), |
| 73 | } |
| 74 | } |
| 75 | |
| 76 | // -- Unary RPCs -------------------------------------------------------------- |
| 77 |