work

Documentation

Index

• Constants
• Variables
• func AsynqConfig(cfg Config, log *zap.Logger) asynq.Config
• func DecodeTask(task *asynq.Task, out any) error
• func IsDuplicateTaskErr(err error) bool
• func NewAsynqScheduler(redisOpt asynq.RedisClientOpt, log *zap.Logger) *asynq.Scheduler
• func NewServeMux(meterProvider *sdkmetric.MeterProvider, ...) *asynq.ServeMux
• func NewTask(typename string, payload any, opts ...asynq.Option) (*asynq.Task, error)
• func RegisterScheduledTasks(sch *asynq.Scheduler, tasks ...SchedulerFunc) error
• type Config
• type Queue
  • func NewQueue(r asynq.RedisConnOpt, meterProvider *sdkmetric.MeterProvider, ...) Queue
• type SchedulerFunc

Constants

const MeterName = "github.com/ianunruh/go-backend-app/internal/work"

const TracerName = "github.com/ianunruh/go-backend-app/internal/work"

Variables

var (
	CriticalQueue = asynq.Queue("critical")
	HighQueue     = asynq.Queue("high")
	LowQueue      = asynq.Queue("low")
)

Functions

func AsynqConfig

func AsynqConfig(cfg Config, log *zap.Logger) asynq.Config

func DecodeTask

func DecodeTask(task *asynq.Task, out any) error

func IsDuplicateTaskErr

func IsDuplicateTaskErr(err error) bool

func NewAsynqScheduler

func NewAsynqScheduler(redisOpt asynq.RedisClientOpt, log *zap.Logger) *asynq.Scheduler

func NewServeMux

func NewServeMux(
	meterProvider *sdkmetric.MeterProvider,
	tracerProvider *sdktrace.TracerProvider,
	log *zap.Logger,
) *asynq.ServeMux

func NewTask

func NewTask(typename string, payload any, opts ...asynq.Option) (*asynq.Task, error)

func RegisterScheduledTasks

func RegisterScheduledTasks(sch *asynq.Scheduler, tasks ...SchedulerFunc) error

Types

type Config

type Config struct {
	Concurrency int `env:"CONCURRENCY" envDefault:"10"`
}

type Queue

type Queue interface {
	Enqueue(ctx context.Context, task *asynq.Task, opts ...asynq.Option) (*asynq.TaskInfo, error)
	Close() error
}

func NewQueue

func NewQueue(r asynq.RedisConnOpt, meterProvider *sdkmetric.MeterProvider, tracerProvider *sdktrace.TracerProvider, log *zap.Logger) Queue

type SchedulerFunc

type SchedulerFunc func(sch *asynq.Scheduler) error