Method Pop

pkg/telemetry/exporter/task_queue.go:126–143

Pop pops the most recent task in the schedule, for which timestamp is in range [0, time.Now()], the value of the queue goes through the registered callback and determines which one should be called.

(ctx context.Context, consumerID string)

// Pop pops the most recent task in the schedule, for which timestamp is in range [0, time.Now()], the value of
// the queue goes through the registered callback and determines which one should be called.
func (q *RedisTaskQueue) Pop(ctx context.Context, consumerID string) error {
	return q.queue.Pop(
		ctx, consumerID, nil, func(p redis.Pipeliner, id string, t time.Time) error {
			v, ok := q.callbacks.Load(id)
			if !ok {
				return errCallbackNotRegistered.WithAttributes("id", id)
			}

			tt, err := v.(TaskCallback)(ctx)
			if err != nil {
				log.FromContext(ctx).WithError(err).WithField("id", id).Warn("Failed to execute task from queue")
				return q.Add(ctx, id, tt, false)
			}

			return q.Add(ctx, id, tt, false)
		},
	)
}