queue

Documentation

Index

• type Driver
• type Job
  • func (j *Job) GetModel() Queueable
  • func (j *Job) Release(delay time.Duration)
  • func (j *Job) SetModel(model Queueable)
• type JobInterface
• type Queue
• type Queueable

Types

type Driver

type Driver interface {
	Open(options map[string]any) (Queue, error)
}

type Job

type Job struct {
	JobInterface
	// contains filtered or unexported fields
}

func (*Job) GetModel

func (j *Job) GetModel() Queueable

func (*Job) Release

func (j *Job) Release(delay time.Duration)

func (*Job) SetModel

func (j *Job) SetModel(model Queueable)

type JobInterface

type JobInterface interface {
	SetModel(Queueable)
	GetModel() Queueable
	GetDelay() time.Duration
	GetMaxAttempts() int
	GetRetryDelay() time.Duration
	Handle() error
	Failed(error)
}

type Queue

type Queue interface {
	Empty() bool
	Count() int64
	Enqueue(JobInterface)
	Dequeue() JobInterface
	Remove(JobInterface)
	Ack(JobInterface)
	Release(JobInterface, time.Duration)
}

type Queueable

type Queueable interface {
	GetID() string
	GetQueue() string
	GetPayload() JobInterface
	GetAttempts() int
}