Method Add

pkg/telemetry/exporter/task_queue.go:108–110

Add telemetry task's identifier at time startAt.

(ctx context.Context, id string, startAt time.Time, replace bool)

// Add telemetry task's identifier at time startAt.
func (q *RedisTaskQueue) Add(ctx context.Context, id string, startAt time.Time, replace bool) error {
	return q.queue.Add(ctx, nil, id, startAt, replace)
}

// RegisterCallback registers a callback that is called when a task is popped.
// All callbacks should be registered before the dispatch of the tasks in the queue, otherwise they are proned to fail