taskqueue

Sep 29, 2025

Changes in this version

type RedisTaskQueue

+ func (q *RedisTaskQueue) Schedule(ctx context.Context, task *TaskMessage) error

type TaskQueue

+ Schedule func(ctx context.Context, task *TaskMessage) error

Jul 30, 2025

Changes in this version

+ type MessageData struct

+ Attempt int

+ EndpointId string

+ Event string

+ EventID string

type RedisTaskQueue

+ func (q *RedisTaskQueue) Stats() map[string]interface{}

type TaskQueue

+ Stats func() map[string]interface{}

Nov 20, 2024

Changes in this version

+ type GetOptions struct

+ Count int64

+ type RedisTaskQueue struct

+ func NewRedisQueue(opts RedisTaskQueueOptions, logger *zap.SugaredLogger, ...) *RedisTaskQueue

+ func (q *RedisTaskQueue) Add(ctx context.Context, tasks []*TaskMessage) error

+ func (q *RedisTaskQueue) Delete(ctx context.Context, task *TaskMessage) error

+ func (q *RedisTaskQueue) Get(ctx context.Context, opts *GetOptions) ([]*TaskMessage, error)

+ func (q *RedisTaskQueue) Size(ctx context.Context) (int64, error)

+ type RedisTaskQueueOptions struct

+ Client *redis.Client

+ InvisibleQueueName string

+ QueueDataName string

+ QueueName string

+ VisibilityTimeout time.Duration

+ type TaskMessage struct

+ Data interface{}

+ ID string

+ ScheduledAt time.Time

+ func (t *TaskMessage) MarshalData() ([]byte, error)

+ func (t *TaskMessage) String() string

+ func (t *TaskMessage) UnmarshalData(v interface{}) error

+ type TaskQueue interface

+ Add func(ctx context.Context, tasks []*TaskMessage) error

+ Delete func(ctx context.Context, task *TaskMessage) error

+ Get func(ctx context.Context, opts *GetOptions) (tasks []*TaskMessage, err error)

+ Size func(ctx context.Context) (int64, error)