events

Documentation

Index

• func Bus() (*eventsBus, string)
• func NewEvent(t fmt.Stringer, plugin string, message string) *event
• type Event
• type EventBus
• type EventType
  • func (et EventType) String() string

Functions

func Bus

func Bus() (*eventsBus, string)

func NewEvent

func NewEvent(t fmt.Stringer, plugin string, message string) *event

NewEvent initializes new event

Types

type Event

type Event interface {
	Type() fmt.Stringer
	Plugin() string
	Message() string
}

type EventBus

type EventBus interface {
	SubscribeAll(subID string, ch chan<- Event) error
	SubscribeP(subID string, pattern string, ch chan<- Event) error
	Unsubscribe(subID string)
	UnsubscribeP(subID, pattern string)
	Len() uint
	Send(ev Event)
}

type EventType

type EventType uint32

const (
	// EventWorkerConstruct thrown when new worker is spawned.
	EventWorkerConstruct EventType = iota
	// EventWorkerDestruct thrown after worker destruction.
	EventWorkerDestruct
	// EventSupervisorError triggered when supervisor can not complete work.
	EventSupervisorError
	// EventWorkerProcessExit triggered on process wait exit
	EventWorkerProcessExit
	// EventNoFreeWorkers triggered when there are no free workers in the stack and timeout for worker allocate elapsed
	EventNoFreeWorkers
	// EventMaxMemory caused when worker consumes more memory than allowed.
	EventMaxMemory
	// EventTTL thrown when worker is removed due TTL being reached. TTL defines maximum time worker is allowed to live (seconds)
	EventTTL
	// EventIdleTTL triggered when worker spends too much time at rest.
	EventIdleTTL
	// EventExecTTL triggered when worker spends too much time doing the task (max_execution_time).
	EventExecTTL
	// EventPoolRestart triggered when pool restart is needed
	EventPoolRestart
	// EventWorkerError triggered after WorkerProcess. Except payload to be error.
	EventWorkerError
	// EventWorkerLog triggered on every write to WorkerProcess StdErr pipe (batched). Except payload to be []byte string.
	EventWorkerLog
	// EventWorkerStderr is the worker standard error output
	EventWorkerStderr
	// EventWorkerWaitExit is the worker exit event
	EventWorkerWaitExit
)

func (EventType) String

func (et EventType) String() string