queue

type Consumer func(name string, args map[string]any) Result

type Option func(*Queue)

type PreProcessor func(*Task) error

type Queue struct {
	// contains filtered or unexported fields
}

type Result struct {
	Status string
	Error  error
	Delay  time.Duration
}

type Storage interface {

	// GetTasks retrieves a batch of Tasks from the Storage provider
	GetTasks() ([]Task, error)

	// SaveTask saves a Task to the Storage provider
	SaveTask(task Task) error

	// DeleteTask removes a Task from the Storage provider
	DeleteTask(taskID string) error

	// DeleteTaskBySignature removes a Task from the Storage provider using its signature
	DeleteTaskBySignature(signature string) error

	// LogFailure writes a Task to the error log
	LogFailure(task Task) error
}

type Task struct {
	TaskID      string    `bson:"taskId"`              // Unique identfier for this task
	LockID      string    `bson:"lockId,omitempty"`    // Unique identifier for the worker that is currently processing this task
	Name        string    `bson:"name"`                // Name of the task (used to identify the handler function)
	Arguments   mapof.Any `bson:"arguments"`           // Data required to execute this task (marshalled as a map)
	CreateDate  int64     `bson:"createDate"`          // Unix epoch seconds when this task was created
	StartDate   int64     `bson:"startDate"`           // Unix epoch seconds when this task is scheduled to execute
	TimeoutDate int64     `bson:"timeoutDate"`         // Unix epoch seconds when this task will "time out" and can be reclaimed by another process
	Priority    int       `bson:"priority"`            // Priority of the handler, determines the order that tasks are executed in.
	Signature   string    `bson:"signature,omitempty"` // Signature of the task.  If a signature is present, then no other tasks will be allowed with this signature.
	RetryCount  int       `bson:"retryCount"`          // Number of times that this task has already been retried
	RetryMax    int       `bson:"retryMax"`            // Maximum number of times that this task can be retried
	Error       string    `bson:"error,omitempty"`     // Error (if any) from the last execution
	AsyncDelay  int       `bson:"-"`                   // If non-zero, then the `Publish` method will execute in a separate goroutine, and will sleep for this many miliseconds before publishing the Task.
}

type TaskOption func(*Task)