(t *testing.T, ps pubsub.Pubsub, pt database.ProvisionerType, tags provisionerdserver.Tags)
| 550 | } |
| 551 | |
| 552 | func postJob(t *testing.T, ps pubsub.Pubsub, pt database.ProvisionerType, tags provisionerdserver.Tags) { |
| 553 | t.Helper() |
| 554 | msg, err := json.Marshal(provisionerjobs.JobPosting{ |
| 555 | ProvisionerType: pt, |
| 556 | Tags: tags, |
| 557 | }) |
| 558 | require.NoError(t, err) |
| 559 | err = ps.Publish(provisionerjobs.EventJobPosted, msg) |
| 560 | require.NoError(t, err) |
| 561 | } |
| 562 | |
| 563 | // fakeOrderedStore is a fake store that lets tests send AcquireProvisionerJob |
| 564 | // results in order over a channel, and tests for overlapped calls. |
no test coverage detected