internal

Documentation

Index

• type AsynqDB
  • func NewAsynqDB(logger ezutil.Logger, opts asynq.RedisConnOpt) *AsynqDB
  • func (d *AsynqDB) Ping() error
  • func (d *AsynqDB) Shutdown() error
• type AsynqTaskQueue
  • func NewAsynqTaskQueue[T task.Message](logger ezutil.Logger, db *AsynqDB) *AsynqTaskQueue[T]
  • func (tq *AsynqTaskQueue[T]) Delete(ctx context.Context, id string) error
  • func (tq *AsynqTaskQueue[T]) DeleteAll(ctx context.Context) error
  • func (tq *AsynqTaskQueue[T]) Enqueue(ctx context.Context, source string, message T) error
  • func (tq *AsynqTaskQueue[T]) GetAllPending(ctx context.Context) ([]task.Task[T], error)
  • func (tq *AsynqTaskQueue[T]) GetOldest(ctx context.Context) (task.Task[T], string, error)

Types

type AsynqDB

type AsynqDB struct {
	Client    *asynq.Client
	Inspector *asynq.Inspector
}

func NewAsynqDB

func NewAsynqDB(logger ezutil.Logger, opts asynq.RedisConnOpt) *AsynqDB

func (*AsynqDB) Ping

func (d *AsynqDB) Ping() error

func (*AsynqDB) Shutdown

func (d *AsynqDB) Shutdown() error

type AsynqTaskQueue

type AsynqTaskQueue[T task.Message] struct {
	// contains filtered or unexported fields
}

func NewAsynqTaskQueue

func NewAsynqTaskQueue[T task.Message](logger ezutil.Logger, db *AsynqDB) *AsynqTaskQueue[T]

func (*AsynqTaskQueue[T]) Delete

func (tq *AsynqTaskQueue[T]) Delete(ctx context.Context, id string) error

func (*AsynqTaskQueue[T]) DeleteAll

func (tq *AsynqTaskQueue[T]) DeleteAll(ctx context.Context) error

func (*AsynqTaskQueue[T]) Enqueue

func (tq *AsynqTaskQueue[T]) Enqueue(ctx context.Context, source string, message T) error

func (*AsynqTaskQueue[T]) GetAllPending

func (tq *AsynqTaskQueue[T]) GetAllPending(ctx context.Context) ([]task.Task[T], error)

func (*AsynqTaskQueue[T]) GetOldest

func (tq *AsynqTaskQueue[T]) GetOldest(ctx context.Context) (task.Task[T], string, error)