Versions in this module Expand all Collapse all v0 v0.32.0 Mar 4, 2024 Changes in this version + func DefaultTaskQConfig(name string, opts ...TasqOps) *taskq.QueueOptions + type CronJob struct + Handler CronJobHandler + Period time.Duration + type CronJobHandler func(ctx context.Context) error + type CronJobs map[string]CronJob + type Factory string + const FactoryEmpty + const FactoryMemory + const FactoryRedis + func (f Factory) IsEmpty() bool + func (f Factory) String() string + type TaskEngine interface + Close func(ctx context.Context) error + CronJobsInit func(cronJobsMap CronJobs) error + Factory func() Factory + GetTxnCtx func(ctx context.Context) context.Context + IsNewRelicEnabled func() bool + RegisterTask func(name string, handler interface{}) error + ResetCron func() + RunTask func(ctx context.Context, options *TaskRunOptions) error + Tasks func() map[string]*taskq.Task + func NewTaskManager(ctx context.Context, opts ...TaskManagerOptions) (TaskEngine, error) + type TaskManager struct + func (c *TaskManager) RegisterTask(name string, handler interface{}) (err error) + func (c *TaskManager) RunTask(ctx context.Context, options *TaskRunOptions) error + func (tm *TaskManager) Close(ctx context.Context) error + func (tm *TaskManager) CronJobsInit(cronJobsMap CronJobs) (err error) + func (tm *TaskManager) Factory() Factory + func (tm *TaskManager) GetTxnCtx(ctx context.Context) context.Context + func (tm *TaskManager) IsNewRelicEnabled() bool + func (tm *TaskManager) ResetCron() + func (tm *TaskManager) Tasks() map[string]*taskq.Task + type TaskManagerOptions func(c *options) + func WithLogger(customLogger *zerolog.Logger) TaskManagerOptions + func WithNewRelic() TaskManagerOptions + func WithTaskqConfig(config *taskq.QueueOptions) TaskManagerOptions + type TaskRunOptions struct + Arguments []interface{} + RunEveryPeriod time.Duration + TaskName string + type TasqOps func(*taskq.QueueOptions) + func WithRedis(addr string) TasqOps