PopTask returns a task that calls Pop with the provided consumerID.
(q TaskQueue, consumerID string)
| 32 | |
| 33 | // PopTask returns a task that calls Pop with the provided consumerID. |
| 34 | func PopTask(q TaskQueue, consumerID string) task.Func { |
| 35 | return func(ctx context.Context) error { |
| 36 | return q.Pop(ctx, consumerID) |
| 37 | } |
| 38 | } |
| 39 | |
| 40 | // OSTelemetryData returns the OS telemetry data which is attached to telemetry messages. |
| 41 | func OSTelemetryData() *models.OSTelemetry { |