events

Documentation

Index

• func NewEvent(t fmt.Stringer, plugin string, message string) *event
• type Bus
  • func NewEventBus() (*Bus, string)
  • func (eb *Bus) Len() uint
  • func (eb *Bus) Send(ev Event)
  • func (eb *Bus) SubscribeAll(subID string, ch chan<- Event) error
  • func (eb *Bus) SubscribeP(subID string, pattern string, ch chan<- Event) error
  • func (eb *Bus) Unsubscribe(subID string)
  • func (eb *Bus) UnsubscribeP(subID, pattern string)
• type Event
• type EventBus
• type EventType
  • func (et EventType) String() string

Functions

func NewEvent

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

NewEvent initializes new event

Types

type Bus

type Bus struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewEventBus

func NewEventBus() (*Bus, string)

func (*Bus) Len

func (eb *Bus) Len() uint

func (*Bus) Send

func (eb *Bus) Send(ev Event)

Send sends event to the events bus

func (*Bus) SubscribeAll

func (eb *Bus) SubscribeAll(subID string, ch chan<- Event) error

SubscribeAll for all RR events returns subscriptionID

func (*Bus) SubscribeP

func (eb *Bus) SubscribeP(subID string, pattern string, ch chan<- Event) error

SubscribeP pattern like "pluginName.EventType"

func (*Bus) Unsubscribe

func (eb *Bus) Unsubscribe(subID string)

func (*Bus) UnsubscribeP

func (eb *Bus) UnsubscribeP(subID, pattern string)

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
	// 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
	// EventWorkerError triggered after WorkerProcess. Except payload to be error.
	EventWorkerError
	// EventWorkerStderr is the worker standard error output
	EventWorkerStderr
	// EventWorkerWaitExit is the worker exit event
	EventWorkerWaitExit
	// EventWorkerStopped triggered when worker gracefully stopped
	EventWorkerStopped
)

func (EventType) String

func (et EventType) String() string