queue

package
v1.15.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 31, 2024 License: MIT Imports: 18 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	DriverSync  string = "sync"
	DriverRedis string = "redis"
)
View Source 
const Binding = "goravel.queue"

Variables

This section is empty.

Functions

This section is empty.

Types

type Application 

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

func NewApplication added in v1.7.2 

func NewApplication(config configcontract.Config, log log.Log) *Application

func (*Application) Chain 

func (app *Application) Chain(jobs []queue.Jobs) queue.Task

func (*Application) GetJobs 

func (app *Application) GetJobs() []queue.Job

func (*Application) Job 

func (app *Application) Job(job queue.Job, args []queue.Arg) queue.Task

func (*Application) Register 

func (app *Application) Register(jobs []queue.Job)

func (*Application) Worker 

func (app *Application) Worker(args ...queue.Args) queue.Worker

type Config added in v1.12.0 

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

func NewConfig added in v1.12.0 

func NewConfig(config configcontract.Config) *Config

func (*Config) DefaultConnection added in v1.12.0 

func (r *Config) DefaultConnection() string

func (*Config) Driver added in v1.12.0 

func (r *Config) Driver(connection string) string

func (*Config) Queue added in v1.12.0 

func (r *Config) Queue(connection, queue string) string

func (*Config) Redis added in v1.12.0 

func (r *Config) Redis(queueConnection string) (dsn string, database int, queue string)

type Debug added in v1.13.8 

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

func NewDebug added in v1.13.8 

func NewDebug(debug bool, log log.Log) *Debug

func (*Debug) Fatal added in v1.13.8 

func (r *Debug) Fatal(args ...any)

func (*Debug) Fatalf added in v1.13.8 

func (r *Debug) Fatalf(format string, args ...any)

func (*Debug) Fatalln added in v1.13.8 

func (r *Debug) Fatalln(args ...any)

func (*Debug) Panic added in v1.13.8 

func (r *Debug) Panic(args ...any)

func (*Debug) Panicf added in v1.13.8 

func (r *Debug) Panicf(format string, args ...any)

func (*Debug) Panicln added in v1.13.8 

func (r *Debug) Panicln(args ...any)

func (*Debug) Print added in v1.13.8 

func (r *Debug) Print(args ...any)

func (*Debug) Printf added in v1.13.8 

func (r *Debug) Printf(format string, args ...any)

func (*Debug) Println added in v1.13.8 

func (r *Debug) Println(args ...any)

type Error added in v1.13.8 

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

func NewError added in v1.13.8 

func NewError(debug bool, log log.Log) *Error

func (*Error) Fatal added in v1.13.8 

func (r *Error) Fatal(args ...any)

func (*Error) Fatalf added in v1.13.8 

func (r *Error) Fatalf(format string, args ...any)

func (*Error) Fatalln added in v1.13.8 

func (r *Error) Fatalln(args ...any)

func (*Error) Panic added in v1.13.8 

func (r *Error) Panic(args ...any)

func (*Error) Panicf added in v1.13.8 

func (r *Error) Panicf(format string, args ...any)

func (*Error) Panicln added in v1.13.8 

func (r *Error) Panicln(args ...any)

func (*Error) Print added in v1.13.8 

func (r *Error) Print(args ...any)

func (*Error) Printf added in v1.13.8 

func (r *Error) Printf(format string, args ...any)

func (*Error) Println added in v1.13.8 

func (r *Error) Println(args ...any)

type Fatal added in v1.13.8 

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

func NewFatal added in v1.13.8 

func NewFatal(debug bool, log log.Log) *Fatal

func (*Fatal) Fatal added in v1.13.8 

func (r *Fatal) Fatal(args ...any)

func (*Fatal) Fatalf added in v1.13.8 

func (r *Fatal) Fatalf(format string, args ...any)

func (*Fatal) Fatalln added in v1.13.8 

func (r *Fatal) Fatalln(args ...any)

func (*Fatal) Panic added in v1.13.8 

func (r *Fatal) Panic(args ...any)

func (*Fatal) Panicf added in v1.13.8 

func (r *Fatal) Panicf(format string, args ...any)

func (*Fatal) Panicln added in v1.13.8 

func (r *Fatal) Panicln(args ...any)

func (*Fatal) Print added in v1.13.8 

func (r *Fatal) Print(args ...any)

func (*Fatal) Printf added in v1.13.8 

func (r *Fatal) Printf(format string, args ...any)

func (*Fatal) Println added in v1.13.8 

func (r *Fatal) Println(args ...any)

type Info added in v1.13.8 

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

func NewInfo added in v1.13.8 

func NewInfo(debug bool, log log.Log) *Info

func (*Info) Fatal added in v1.13.8 

func (r *Info) Fatal(args ...any)

func (*Info) Fatalf added in v1.13.8 

func (r *Info) Fatalf(format string, args ...any)

func (*Info) Fatalln added in v1.13.8 

func (r *Info) Fatalln(args ...any)

func (*Info) Panic added in v1.13.8 

func (r *Info) Panic(args ...any)

func (*Info) Panicf added in v1.13.8 

func (r *Info) Panicf(format string, args ...any)

func (*Info) Panicln added in v1.13.8 

func (r *Info) Panicln(args ...any)

func (*Info) Print added in v1.13.8 

func (r *Info) Print(args ...any)

func (*Info) Printf added in v1.13.8 

func (r *Info) Printf(format string, args ...any)

func (*Info) Println added in v1.13.8 

func (r *Info) Println(args ...any)

type Machinery added in v1.12.0 

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

func NewMachinery added in v1.12.0 

func NewMachinery(config *Config, log logcontract.Log) *Machinery

func (*Machinery) Server added in v1.12.0 

func (m *Machinery) Server(connection string, queue string) (*machinery.Server, error)

type ServiceProvider 

type ServiceProvider struct {
}

func (*ServiceProvider) Boot 

func (receiver *ServiceProvider) Boot(app foundation.Application)

func (*ServiceProvider) Register 

func (receiver *ServiceProvider) Register(app foundation.Application)

type Task added in v1.12.0 

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

func NewChainTask added in v1.12.0 

func NewChainTask(config *Config, log log.Log, jobs []queue.Jobs) *Task

func NewTask added in v1.12.0 

func NewTask(config *Config, log log.Log, job queue.Job, args []queue.Arg) *Task

func (*Task) Delay added in v1.12.0 

func (receiver *Task) Delay(delay time.Time) queue.Task

func (*Task) Dispatch added in v1.12.0 

func (receiver *Task) Dispatch() error

func (*Task) DispatchSync added in v1.12.0 

func (receiver *Task) DispatchSync() error

func (*Task) OnConnection added in v1.12.0 

func (receiver *Task) OnConnection(connection string) queue.Task

func (*Task) OnQueue added in v1.12.0 

func (receiver *Task) OnQueue(queue string) queue.Task

type Warning added in v1.13.8 

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

func NewWarning added in v1.13.8 

func NewWarning(debug bool, log log.Log) *Warning

func (*Warning) Fatal added in v1.13.8 

func (r *Warning) Fatal(args ...any)

func (*Warning) Fatalf added in v1.13.8 

func (r *Warning) Fatalf(format string, args ...any)

func (*Warning) Fatalln added in v1.13.8 

func (r *Warning) Fatalln(args ...any)

func (*Warning) Panic added in v1.13.8 

func (r *Warning) Panic(args ...any)

func (*Warning) Panicf added in v1.13.8 

func (r *Warning) Panicf(format string, args ...any)

func (*Warning) Panicln added in v1.13.8 

func (r *Warning) Panicln(args ...any)

func (*Warning) Print added in v1.13.8 

func (r *Warning) Print(args ...any)

func (*Warning) Printf added in v1.13.8 

func (r *Warning) Printf(format string, args ...any)

func (*Warning) Println added in v1.13.8 

func (r *Warning) Println(args ...any)

type Worker added in v1.12.0 

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

func NewWorker added in v1.12.0 

func NewWorker(config *Config, log log.Log, concurrent int, connection string, jobs []queue.Job, queue string) *Worker

func (*Worker) Run added in v1.12.0 

func (receiver *Worker) Run() error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.