Method Add

pkg/redis/redis.go:659–664

Add adds a task s to the queue with a timestamp startAt.

(ctx context.Context, r redis.Cmdable, s string, startAt time.Time, replace bool)

// Add adds a task s to the queue with a timestamp startAt.
func (q *TaskQueue) Add(ctx context.Context, r redis.Cmdable, s string, startAt time.Time, replace bool) error {
	if r == nil {
		r = q.Redis
	}
	return addTask(ctx, r, q.Key, q.MaxLen, s, startAt, replace)
}

// Dispatch dispatches the tasks of the queue. It will continue to run until the context is done.
// consumerID is used to identify the consumer and should be unique for all concurrent calls to Dispatch.