worker

Nov 13, 2024

Changes in this version

type Cronjob

+ Unique bool

+ type CronjobOption func(c *Cronjob)

Oct 28, 2024

Changes in this version

+ var ErrClientStartFailed = errors.New("failed to start the worker client")

+ var ErrCronSpecInvalid = errors.New("cron specification is invalid")

+ var ErrHandleCronFailed = errors.New("failed to handle cron")

+ var ErrServerStartFailed = errors.New("failed to start the worker server")

+ var ErrSubmitFailed = errors.New("failed to submit the payload")

+ var ErrTaskPatternInvalid = errors.New("task pattern is invalid")

+ type Client interface

+ Close func() error

+ Submit func(ctx context.Context, pattern TaskPattern, payload []byte) error

+ SubmitToBatch func(ctx context.Context, pattern TaskPattern, payload []byte) error

+ type CronHandler func(ctx context.Context) error

+ type CronSpec string

+ func (cs CronSpec) MustValidate()

+ func (cs CronSpec) String() string

+ func (cs CronSpec) Validate() bool

+ type Cronjob struct

+ Handler CronHandler

+ Identifier string

+ Spec CronSpec

+ type Server interface

+ HandleCron func(spec CronSpec, cronFunc CronHandler)

+ HandleTask func(pattern TaskPattern, cb TaskHandler, opts ...TaskOption)

+ Shutdown func()

+ Start func() error

+ type Task struct

+ Handler TaskHandler

+ Pattern TaskPattern

+ type TaskHandler func(ctx context.Context, payload []byte) error

+ type TaskOption func(t *Task)

+ type TaskPattern string

+ func (tp TaskPattern) MustValidate()

+ func (tp TaskPattern) Queue() string

+ func (tp TaskPattern) String() string

+ func (tp TaskPattern) Validate() bool