Function DispatchTask

pkg/telemetry/exporter/utils.go:27–31

DispatchTask returns a task that calls Dispatch with the provided consumerID.

(q TaskQueue, consumerID string)

// DispatchTask returns a task that calls Dispatch with the provided consumerID.
func DispatchTask(q TaskQueue, consumerID string) task.Func {
	return func(ctx context.Context) error {
		return q.Dispatch(ctx, consumerID)
	}
}

// PopTask returns a task that calls Pop with the provided consumerID.
func PopTask(q TaskQueue, consumerID string) task.Func {