events

Documentation

Index

• Constants
• func EmitEvent(event Event)
• func RegisterEventListener(eventListenerName string, events []string, listener *EventListener)
• type BaseEvent
  • func (be *BaseEvent) GetSerial() uint64
  • func (be *BaseEvent) GetType() string
• type Event
• type EventListener
  • func NewEventListener(pool string, server string, stdin io.Reader, stdout io.Writer, buffer_size int) *EventListener
  • func UnregisterEventListener(eventListenerName string) *EventListener
  • func (el *EventListener) HandleEvent(event Event)
• type EventListenerManager
  • func NewEventListenerManager() *EventListenerManager
  • func (em *EventListenerManager) EmitEvent(event Event)
• type EventPoolSerial
  • func NewEventPoolSerial() *EventPoolSerial
• type ProcCommEvent
  • func NewProcCommEvent(eventType string, procName string, groupName string, pid int, data string) *ProcCommEvent
  • func (p *ProcCommEvent) GetBody() string
• type ProcCommEventCapture
  • func NewProcCommEventCapture(reader io.Reader, captureMaxBytes int, stdType string, procName string, ...) *ProcCommEventCapture
  • func (pec *ProcCommEventCapture) SetPid(pid int)
• type ProcessGroupEvent
  • func CreateProcessGroupAddedEvent(group_name string) *ProcessGroupEvent
  • func CreateProcessGroupRemovedEvent(group_name string) *ProcessGroupEvent
  • func (pe *ProcessGroupEvent) GetBody() string
• type ProcessLogEvent
  • func CreateProcessLogStderrEvent(process_name string, group_name string, pid int, data string) *ProcessLogEvent
  • func CreateProcessLogStdoutEvent(process_name string, group_name string, pid int, data string) *ProcessLogEvent
  • func (pe *ProcessLogEvent) GetBody() string
• type ProcessStateEvent
  • func CreateProcessBackoffEvent(process string, group string, from_state string, tries int) *ProcessStateEvent
  • func CreateProcessExitedEvent(process string, group string, from_state string, expected int, pid int) *ProcessStateEvent
  • func CreateProcessFatalEvent(process string, group string, from_state string) *ProcessStateEvent
  • func CreateProcessRunningEvent(process string, group string, from_state string, pid int) *ProcessStateEvent
  • func CreateProcessStartingEvent(process string, group string, from_state string, tries int) *ProcessStateEvent
  • func CreateProcessStoppedEvent(process string, group string, from_state string, pid int) *ProcessStateEvent
  • func CreateProcessStoppingEvent(process string, group string, from_state string, pid int) *ProcessStateEvent
  • func CreateProcessUnknownEvent(process string, group string, from_state string) *ProcessStateEvent
  • func (pse *ProcessStateEvent) GetBody() string
• type RemoteCommunicationEvent
  • func NewRemoteCommunicationEvent(typ string, data string) *RemoteCommunicationEvent
  • func (r *RemoteCommunicationEvent) GetBody() string
• type SupervisorStateChangeEvent
  • func CreateSupervisorStateChangeRunning() *SupervisorStateChangeEvent
  • func (s *SupervisorStateChangeEvent) GetBody() string
• type TickEvent
  • func NewTickEvent(tickType string, when int64) *TickEvent
  • func (te *TickEvent) GetBody() string

Constants

const (
	EVENT_SYS_VERSION     = "3.0"
	PROC_COMMON_BEGIN_STR = "<!--XSUPERVISOR:BEGIN-->"
	PROC_COMMON_END_STR   = "<!--XSUPERVISOR:END-->"
)

Functions

func EmitEvent

func EmitEvent(event Event)

func RegisterEventListener

func RegisterEventListener(eventListenerName string,
	events []string,
	listener *EventListener)

Types

type BaseEvent

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

func (*BaseEvent) GetSerial

func (be *BaseEvent) GetSerial() uint64

func (*BaseEvent) GetType

func (be *BaseEvent) GetType() string

type Event

type Event interface {
	GetSerial() uint64
	GetType() string
	GetBody() string
}

type EventListener

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

func NewEventListener

func NewEventListener(pool string,
	server string,
	stdin io.Reader,
	stdout io.Writer,
	buffer_size int) *EventListener

func UnregisterEventListener

func UnregisterEventListener(eventListenerName string) *EventListener

func (*EventListener) HandleEvent

func (el *EventListener) HandleEvent(event Event)

type EventListenerManager

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

func NewEventListenerManager

func NewEventListenerManager() *EventListenerManager

func (*EventListenerManager) EmitEvent

func (em *EventListenerManager) EmitEvent(event Event)

type EventPoolSerial

type EventPoolSerial struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEventPoolSerial

func NewEventPoolSerial() *EventPoolSerial

type ProcCommEvent

type ProcCommEvent struct {
	BaseEvent
	// contains filtered or unexported fields
}

func NewProcCommEvent

func NewProcCommEvent(eventType string,
	procName string,
	groupName string,
	pid int,
	data string) *ProcCommEvent

func (*ProcCommEvent) GetBody

func (p *ProcCommEvent) GetBody() string

type ProcCommEventCapture

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

func NewProcCommEventCapture

func NewProcCommEventCapture(reader io.Reader,
	captureMaxBytes int,
	stdType string,
	procName string,
	groupName string) *ProcCommEventCapture

func (*ProcCommEventCapture) SetPid

func (pec *ProcCommEventCapture) SetPid(pid int)

type ProcessGroupEvent

type ProcessGroupEvent struct {
	BaseEvent
	// contains filtered or unexported fields
}

func CreateProcessGroupAddedEvent

func CreateProcessGroupAddedEvent(group_name string) *ProcessGroupEvent

func CreateProcessGroupRemovedEvent

func CreateProcessGroupRemovedEvent(group_name string) *ProcessGroupEvent

func (*ProcessGroupEvent) GetBody

func (pe *ProcessGroupEvent) GetBody() string

type ProcessLogEvent

type ProcessLogEvent struct {
	BaseEvent
	// contains filtered or unexported fields
}

func CreateProcessLogStderrEvent

func CreateProcessLogStderrEvent(process_name string,
	group_name string,
	pid int,
	data string) *ProcessLogEvent

func CreateProcessLogStdoutEvent

func CreateProcessLogStdoutEvent(process_name string,
	group_name string,
	pid int,
	data string) *ProcessLogEvent

func (*ProcessLogEvent) GetBody

func (pe *ProcessLogEvent) GetBody() string

type ProcessStateEvent

type ProcessStateEvent struct {
	BaseEvent
	// contains filtered or unexported fields
}

func CreateProcessBackoffEvent

func CreateProcessBackoffEvent(process string,
	group string,
	from_state string,
	tries int) *ProcessStateEvent

func CreateProcessExitedEvent

func CreateProcessExitedEvent(process string,
	group string,
	from_state string,
	expected int,
	pid int) *ProcessStateEvent

func CreateProcessFatalEvent

func CreateProcessFatalEvent(process string,
	group string,
	from_state string) *ProcessStateEvent

func CreateProcessRunningEvent

func CreateProcessRunningEvent(process string,
	group string,
	from_state string,
	pid int) *ProcessStateEvent

func CreateProcessStartingEvent

func CreateProcessStartingEvent(process string,
	group string,
	from_state string,
	tries int) *ProcessStateEvent

func CreateProcessStoppedEvent

func CreateProcessStoppedEvent(process string,
	group string,
	from_state string,
	pid int) *ProcessStateEvent

func CreateProcessStoppingEvent

func CreateProcessStoppingEvent(process string,
	group string,
	from_state string,
	pid int) *ProcessStateEvent

func CreateProcessUnknownEvent

func CreateProcessUnknownEvent(process string,
	group string,
	from_state string) *ProcessStateEvent

func (*ProcessStateEvent) GetBody

func (pse *ProcessStateEvent) GetBody() string

type RemoteCommunicationEvent

type RemoteCommunicationEvent struct {
	BaseEvent
	// contains filtered or unexported fields
}

func NewRemoteCommunicationEvent

func NewRemoteCommunicationEvent(typ string, data string) *RemoteCommunicationEvent

func (*RemoteCommunicationEvent) GetBody

func (r *RemoteCommunicationEvent) GetBody() string

type SupervisorStateChangeEvent

type SupervisorStateChangeEvent struct {
	BaseEvent
}

func CreateSupervisorStateChangeRunning

func CreateSupervisorStateChangeRunning() *SupervisorStateChangeEvent

func (*SupervisorStateChangeEvent) GetBody

func (s *SupervisorStateChangeEvent) GetBody() string

type TickEvent

type TickEvent struct {
	BaseEvent
	// contains filtered or unexported fields
}

func NewTickEvent

func NewTickEvent(tickType string, when int64) *TickEvent

func (*TickEvent) GetBody

func (te *TickEvent) GetBody() string