Method Pop

pkg/redis/redis.go:680–686

Pop calls f on the most recent task in the queue, for which timestamp is in range [0, time.Now()], if such is available, otherwise it blocks until it is or context is done. Pipeline is executed even if f returns an error. consumerID is used to identify the consumer and should be unique for all concu

(ctx context.Context, consumerID string, r redis.Cmdable, f func(redis.Pipeliner, string, time.Time) error)

// Pipeline is executed even if f returns an error.
// consumerID is used to identify the consumer and should be unique for all concurrent calls to Pop.
func (q *TaskQueue) Pop(ctx context.Context, consumerID string, r redis.Cmdable, f func(redis.Pipeliner, string, time.Time) error) error {
	q.consumerIDs.LoadOrStore(consumerID, struct{}{})
	if r == nil {
		r = q.Redis
	}
	return popTask(ctx, r, q.Group, consumerID, f, q.Key, q.StreamBlockLimit)
}

var deduplicateProtosScript = redis.NewScript(`local exp = table.remove(ARGV, 1)
local limit = tonumber(table.remove(ARGV, 1))