queue

Documentation

Index

• Constants
• type Application
  • func NewApplication(config configcontract.Config) *Application
  • func (app *Application) Chain(jobs []queue.Jobs) queue.Task
  • func (app *Application) GetJobs() []queue.Job
  • func (app *Application) Job(job queue.Job, args []queue.Arg) queue.Task
  • func (app *Application) Register(jobs []queue.Job)
  • func (app *Application) Worker(args *queue.Args) queue.Worker
• type Config
  • func NewConfig(config configcontract.Config) *Config
  • func (r *Config) DefaultConnection() string
  • func (r *Config) Driver(connection string) string
  • func (r *Config) Queue(connection, queue string) string
  • func (r *Config) Redis(queueConnection string) (dsn string, database int, queue string)
• type Machinery
  • func NewMachinery(config *Config) *Machinery
  • func (m *Machinery) Server(connection string, queue string) (*machinery.Server, error)
• type ServiceProvider
  • func (receiver *ServiceProvider) Boot(app foundation.Application)
  • func (receiver *ServiceProvider) Register(app foundation.Application)
• type Task
  • func NewChainTask(config *Config, jobs []queue.Jobs) *Task
  • func NewTask(config *Config, job queue.Job, args []queue.Arg) *Task
  • func (receiver *Task) Delay(delay time.Time) queue.Task
  • func (receiver *Task) Dispatch() error
  • func (receiver *Task) DispatchSync() error
  • func (receiver *Task) OnConnection(connection string) queue.Task
  • func (receiver *Task) OnQueue(queue string) queue.Task
• type Worker
  • func NewWorker(config *Config, concurrent int, connection string, jobs []queue.Job, ...) *Worker
  • func (receiver *Worker) Run() error

Constants

const Binding = "goravel.queue"

const DriverRedis string = "redis"

const DriverSync string = "sync"

Types

type Application

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

func NewApplication

func NewApplication(config configcontract.Config) *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 Machinery

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

func NewMachinery

func NewMachinery(config *Config) *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, jobs []queue.Jobs) *Task

func NewTask

func NewTask(config *Config, 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 Worker

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

func NewWorker

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

func (*Worker) Run

func (receiver *Worker) Run() error