gobi

type BackoffOptions struct {
	Strategy string `json:"strategy"`
	Delay    int64  `json:"delay"`
}

type Job interface {
	Save() (string, error)
	ID() string
	DecrementRetries()
	AddError(err error)
	GetDelay() int64
	ToData() (string, error)
	SetID(string)
}

type JobData struct {
	Data    interface{} `json:"data"`
	Options JobOptions  `json:"options"`
	Status  string      `json:"status"`
}

type JobOptions struct {
	Timestamp   int64          `json:"timestamp"`
	Delay       int64          `json:"delay"`
	Timeout     int64          `json:"timeout"`
	Retries     int64          `json:"retries"`
	Backoff     BackoffOptions `json:"backoff"`
	StackTraces []string       `json:"stacktraces"`
}

type Queue interface {
	Name() string
	CreateJob(data interface{}, options JobOptions) Job
	ToKey(string) string
	Process(int, func(Job) (interface{}, error))

	RunScriptForName(name string, keys []string, args ...interface{}) (interface{}, error)
	NewJobFromId(string) (Job, error)
}

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

type QueueOptions struct {
	QueuePrefix     string
	RemoveOnFailure bool
	RemoveOnSuccess bool
}