()
| 576 | } |
| 577 | |
| 578 | func newFakeOrderedStore() *fakeOrderedStore { |
| 579 | return &fakeOrderedStore{ |
| 580 | // buffer the channels so that we can queue up lots of responses to |
| 581 | // occur nearly simultaneously |
| 582 | jobs: make(chan database.ProvisionerJob, 100), |
| 583 | errors: make(chan error, 100), |
| 584 | inflight: make(map[uuid.UUID]bool), |
| 585 | } |
| 586 | } |
| 587 | |
| 588 | func (s *fakeOrderedStore) AcquireProvisionerJob( |
| 589 | _ context.Context, params database.AcquireProvisionerJobParams, |
no outgoing calls
no test coverage detected