(ctx context.Context, job database.ProvisionerJob, err error)
| 609 | } |
| 610 | |
| 611 | func (s *fakeOrderedStore) sendCtx(ctx context.Context, job database.ProvisionerJob, err error) error { |
| 612 | select { |
| 613 | case <-ctx.Done(): |
| 614 | return ctx.Err() |
| 615 | case s.jobs <- job: |
| 616 | // OK |
| 617 | } |
| 618 | select { |
| 619 | case <-ctx.Done(): |
| 620 | return ctx.Err() |
| 621 | case s.errors <- err: |
| 622 | // OK |
| 623 | } |
| 624 | return nil |
| 625 | } |
| 626 | |
| 627 | // fakeTaggedStore is a test store that allows tests to specify which jobs are |
| 628 | // available, and returns them to callers with the appropriate provisioner type |
no test coverage detected