meq

README

meq

Documentation

Index

• type DB
  • func NewAsynqDB(logger ezutil.Logger, opts asynq.RedisConnOpt) DB
• type TaskQueue
  • func NewTaskQueue[T task.Message](logger ezutil.Logger, db DB) TaskQueue[T]

Types

type DB

type DB interface {
	Ping() error
	Shutdown() error
}

func NewAsynqDB

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

type TaskQueue

type TaskQueue[T task.Message] interface {
	Enqueue(ctx context.Context, source string, message T) error
	GetAllPending(ctx context.Context) ([]task.Task[T], error)
	DeleteAll(ctx context.Context) error
	GetOldest(ctx context.Context) (task.Task[T], string, error)
	Delete(ctx context.Context, id string) error
}

func NewTaskQueue

func NewTaskQueue[T task.Message](logger ezutil.Logger, db DB) TaskQueue[T]