queue

package
v1.15.0 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2024 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

Types

type Application 

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

func NewApplication 

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 

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

func NewConfig 

func NewConfig(config configcontract.Config) *Config

func (*Config) DefaultConnection 

func (r *Config) DefaultConnection() string

func (*Config) Driver 

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

func (*Config) Queue 

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

func (*Config) Redis 

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

type Debug 

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

func NewDebug 

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

func (*Debug) Fatal 

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

func (*Debug) Fatalf 

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

func (*Debug) Fatalln 

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

func (*Debug) Panic 

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

func (*Debug) Panicf 

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

func (*Debug) Panicln 

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

func (*Debug) Print 

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

func (*Debug) Printf 

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

func (*Debug) Println 

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

type Error 

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

func NewError 

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

func (*Error) Fatal 

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

func (*Error) Fatalf 

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

func (*Error) Fatalln 

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

func (*Error) Panic 

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

func (*Error) Panicf 

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

func (*Error) Panicln 

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

func (*Error) Print 

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

func (*Error) Printf 

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

func (*Error) Println 

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

type Fatal 

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

func NewFatal 

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

func (*Fatal) Fatal 

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

func (*Fatal) Fatalf 

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

func (*Fatal) Fatalln 

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

func (*Fatal) Panic 

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

func (*Fatal) Panicf 

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

func (*Fatal) Panicln 

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

func (*Fatal) Print 

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

func (*Fatal) Printf 

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

func (*Fatal) Println 

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

type Info 

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

func NewInfo 

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

func (*Info) Fatal 

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

func (*Info) Fatalf 

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

func (*Info) Fatalln 

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

func (*Info) Panic 

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

func (*Info) Panicf 

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

func (*Info) Panicln 

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

func (*Info) Print 

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

func (*Info) Printf 

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

func (*Info) Println 

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

type Machinery 

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

func NewMachinery 

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

func (*Machinery) Server 

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 

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

func NewChainTask 

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

func NewTask 

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

func (*Task) Delay 

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

func (*Task) Dispatch 

func (receiver *Task) Dispatch() error

func (*Task) DispatchSync 

func (receiver *Task) DispatchSync() error

func (*Task) OnConnection 

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

func (*Task) OnQueue 

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

type Warning 

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

func NewWarning 

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

func (*Warning) Fatal 

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

func (*Warning) Fatalf 

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

func (*Warning) Fatalln 

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

func (*Warning) Panic 

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

func (*Warning) Panicf 

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

func (*Warning) Panicln 

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

func (*Warning) Print 

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

func (*Warning) Printf 

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

func (*Warning) Println 

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

type Worker 

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

func NewWorker 

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

func (*Worker) Run 

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.