queue

Nov 18, 2024

Changes in this version

+ const ResultStatusError

+ const ResultStatusFailure

+ const ResultStatusIgnored

+ const ResultStatusSuccess

type QueueOption

+ func WithRunImmediatePriority(runImmediatePriority int) QueueOption

+ type Result struct

+ Error error

+ Status string

+ func Error(err error) Result

+ func Failure(err error) Result

+ func Ignored() Result

+ func Success() Result

+ func (result Result) IsSuccessful() bool

+ func (result Result) NotSuccessful() bool

Oct 11, 2024

Changes in this version

type QueueOption

+ func WithDefaultPriority(defaultPriority int) QueueOption

+ func WithDefaultRetryMax(defaultRetryMax int) QueueOption

Oct 11, 2024

Changes in this version

+ type Consumer func(name string, args map[string]any) (bool, error)

+ type Queue struct

+ func New(options ...QueueOption) Queue

+ func (q *Queue) Publish(task Task) error

+ func (q *Queue) Schedule(task Task, delay time.Duration) error

+ func (queue *Queue) Stop()

+ type QueueOption func(*Queue)

+ func WithBufferSize(bufferSize int) QueueOption

+ func WithConsumers(consumers ...Consumer) QueueOption

+ func WithPollStorage(pollStorage bool) QueueOption

+ func WithStorage(storage Storage) QueueOption

+ func WithWorkerCount(workerCount int) QueueOption

+ type Storage interface

+ DeleteTask func(taskID string) error

+ GetTasks func() ([]Task, error)

+ LogFailure func(task Task) error

+ SaveTask func(task Task) error

+ type Task struct

+ Arguments mapof.Any

+ CreateDate int64

+ Error error

+ LockID string

+ Name string

+ Priority int

+ RetryCount int

+ RetryMax int

+ StartDate int64

+ TaskID string

+ TimeoutDate int64

+ func NewTask(name string, arguments map[string]any, options ...TaskOption) Task

+ func (task *Task) Delay(delay time.Duration)

+ type TaskOption func(*Task)

+ func WithDelayHours(delayHours int) TaskOption

+ func WithDelayMinutes(delayMinutes int) TaskOption

+ func WithDelaySeconds(delaySeconds int) TaskOption

+ func WithPriority(priority int) TaskOption

+ func WithRetryMax(retryMax int) TaskOption