queue

Documentation

Index

• type Job
• type JobItem
• type JobWithErrHandle
• type Queue
  • func New(bufferSize int) *Queue
  • func (r *Queue) Bulk(jobs []JobItem) error
  • func (r *Queue) IsFull() bool
  • func (r *Queue) Later(delay uint, job Job, args []any) error
  • func (r *Queue) Len() int
  • func (r *Queue) Push(job Job, args []any) error
  • func (r *Queue) Run(ctx context.Context)

Types

type Job

type Job interface {
	Handle(args ...any) error
}

type JobItem

type JobItem struct {
	Job   Job
	Args  []any
	Delay uint
}

type JobWithErrHandle

type JobWithErrHandle interface {
	Job
	ErrHandle(err error)
}

type Queue

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

func New

func New(bufferSize int) *Queue

func (*Queue) Bulk

func (r *Queue) Bulk(jobs []JobItem) error

func (*Queue) IsFull

func (r *Queue) IsFull() bool

func (*Queue) Later

func (r *Queue) Later(delay uint, job Job, args []any) error

func (*Queue) Len

func (r *Queue) Len() int

func (*Queue) Push

func (r *Queue) Push(job Job, args []any) error

func (*Queue) Run

func (r *Queue) Run(ctx context.Context)