queue

Documentation

Index

• type Arg
• type Args
• type Job
• type Jobs
• type Queue
• type Task
• type Worker

Types

type Arg

type Arg struct {
	Type  string
	Value any
}

type Args

type Args struct {
	// Specify connection
	Connection string
	// Specify queue
	Queue string
	// Concurrent num
	Concurrent int
}

type Job

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

type Jobs

type Jobs struct {
	Job  Job
	Args []Arg
}

type Queue

type Queue interface {
	Worker(args *Args) Worker
	// Register Register jobs
	Register(jobs []Job)
	// GetJobs Get all jobs
	GetJobs() []Job
	// Job Add a job to queue
	Job(job Job, args []Arg) Task
	// Chain Creates a chain of jobs to be processed one by one, passing
	Chain(jobs []Jobs) Task
}

type Task

type Task interface {
	Dispatch() error
	DispatchSync() error
	Delay(time time.Time) Task
	OnConnection(connection string) Task
	OnQueue(queue string) Task
}

type Worker

type Worker interface {
	Run() error
}