Method Init

pkg/redis/redis.go:641–643

Init initializes the task queue. It must be called at least once before using the queue.

(ctx context.Context)

// Init initializes the task queue.
// It must be called at least once before using the queue.
func (q *TaskQueue) Init(ctx context.Context) error {
	return initTaskGroup(ctx, q.Redis, q.Group, q.Key)
}

// Close closes the TaskQueue.
func (q *TaskQueue) Close(ctx context.Context) error {