(_ context.Context, req *taskAPI.ExecProcessRequest)
| 75 | } |
| 76 | |
| 77 | func (s *mockTaskService) Exec(_ context.Context, req *taskAPI.ExecProcessRequest) (*types.Empty, error) { |
| 78 | reqCh, _ := s.execRequests.LoadOrStore(req.ID, make(chan *taskAPI.ExecProcessRequest, 128)) |
| 79 | reqCh.(chan *taskAPI.ExecProcessRequest) <- req |
| 80 | return nil, nil |
| 81 | } |
| 82 | |
| 83 | func (s *mockTaskService) PopExecRequests(id string) (reqs []*taskAPI.ExecProcessRequest) { |
| 84 | reqCh, _ := s.execRequests.Load(id) |