taskqueue

type GetOptions struct {
	Count int64
}

type RedisTaskQueue struct {
	// contains filtered or unexported fields
}

type RedisTaskQueueOptions struct {
	QueueName          string
	InvisibleQueueName string
	QueueDataName      string
	VisibilityTimeout  time.Duration
	Client             *redis.Client
}

type TaskMessage struct {
	ID          string
	ScheduledAt time.Time
	Data        interface{}
	// contains filtered or unexported fields
}

type TaskQueue interface {
	Add(ctx context.Context, tasks []*TaskMessage) error
	Get(ctx context.Context, opts *GetOptions) (tasks []*TaskMessage, err error)
	Delete(ctx context.Context, task *TaskMessage) error
	Size(ctx context.Context) (int64, error)
}