event

Documentation

Index

• Constants
• type Application
  • func NewApplication(queue queuecontract.Queue) *Application
  • func (app *Application) GetEvents() map[event.Event][]event.Listener
  • func (app *Application) Job(e event.Event, args []event.Arg) event.Task
  • func (app *Application) Register(events map[event.Event][]event.Listener)
• type ServiceProvider
  • func (receiver *ServiceProvider) Boot(app foundation.Application)
  • func (receiver *ServiceProvider) Register(app foundation.Application)
• type Task
  • func NewTask(queue queuecontract.Queue, args []event.Arg, event event.Event, ...) *Task
  • func (receiver *Task) Dispatch() error
• type TestCancelEvent
  • func (receiver *TestCancelEvent) Handle(args []event.Arg) ([]event.Arg, error)
• type TestEvent
  • func (receiver *TestEvent) Handle(args []event.Arg) ([]event.Arg, error)
• type TestEventHandleError
  • func (receiver *TestEventHandleError) Handle(args []event.Arg) ([]event.Arg, error)
• type TestEventNoRegister
  • func (receiver *TestEventNoRegister) Handle(args []event.Arg) ([]event.Arg, error)
• type TestListener
  • func (receiver *TestListener) Handle(args ...any) error
  • func (receiver *TestListener) Queue(args ...any) event.Queue
  • func (receiver *TestListener) Signature() string
• type TestListenerHandleError
  • func (receiver *TestListenerHandleError) Handle(args ...any) error
  • func (receiver *TestListenerHandleError) Queue(args ...any) event.Queue
  • func (receiver *TestListenerHandleError) Signature() string

Constants

const Binding = "goravel.event"

Types

type Application

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

func NewApplication

func NewApplication(queue queuecontract.Queue) *Application

func (*Application) GetEvents

func (app *Application) GetEvents() map[event.Event][]event.Listener

func (*Application) Job

func (app *Application) Job(e event.Event, args []event.Arg) event.Task

func (*Application) Register

func (app *Application) Register(events map[event.Event][]event.Listener)

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 NewTask

func NewTask(queue queuecontract.Queue, args []event.Arg, event event.Event, listeners []event.Listener) *Task

func (*Task) Dispatch

func (receiver *Task) Dispatch() error

type TestCancelEvent

type TestCancelEvent struct{}

func (*TestCancelEvent) Handle

func (receiver *TestCancelEvent) Handle(args []event.Arg) ([]event.Arg, error)

type TestEvent

type TestEvent struct{}

func (*TestEvent) Handle

func (receiver *TestEvent) Handle(args []event.Arg) ([]event.Arg, error)

type TestEventHandleError

type TestEventHandleError struct{}

func (*TestEventHandleError) Handle

func (receiver *TestEventHandleError) Handle(args []event.Arg) ([]event.Arg, error)

type TestEventNoRegister

type TestEventNoRegister struct{}

func (*TestEventNoRegister) Handle

func (receiver *TestEventNoRegister) Handle(args []event.Arg) ([]event.Arg, error)

type TestListener

type TestListener struct{}

func (*TestListener) Handle

func (receiver *TestListener) Handle(args ...any) error

func (*TestListener) Queue

func (receiver *TestListener) Queue(args ...any) event.Queue

func (*TestListener) Signature

func (receiver *TestListener) Signature() string

type TestListenerHandleError

type TestListenerHandleError struct{}

func (*TestListenerHandleError) Handle

func (receiver *TestListenerHandleError) Handle(args ...any) error

func (*TestListenerHandleError) Queue

func (receiver *TestListenerHandleError) Queue(args ...any) event.Queue

func (*TestListenerHandleError) Signature

func (receiver *TestListenerHandleError) Signature() string