queue

Documentation

Index

• type Job
• type Nop
  • func (n *Nop) Enqueue(ctx context.Context, job Job) error
• type Queue

Types

type Job

type Job struct {
	Key     string
	Payload any
	RunAt   time.Time
}

Job represents a scheduled unit of work (e.g., send notification later).

type Nop

type Nop struct{}

Nop queue swallows jobs (used for tests or disabled scheduling).

func (*Nop) Enqueue

func (n *Nop) Enqueue(ctx context.Context, job Job) error

type Queue

type Queue interface {
	Enqueue(ctx context.Context, job Job) error
}

Queue represents the go-job compatible enqueue interface required by the dispatcher.