Versions in this module Expand all Collapse all v0 v0.6.3 Apr 7, 2019 v0.6.2 Apr 7, 2019 Changes in this version + const EVENT_SYS_VERSION + const PROC_COMMON_BEGIN_STR + const PROC_COMMON_END_STR + func EmitEvent(event Event) + func RegisterEventListener(eventListenerName string, events []string, listener *EventListener) + type BaseEvent struct + func (be *BaseEvent) GetSerial() uint64 + func (be *BaseEvent) GetType() string + type Event interface + GetBody func() string + GetSerial func() uint64 + GetType func() string + type EventListener struct + 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 struct + func NewEventListenerManager() *EventListenerManager + func (em *EventListenerManager) EmitEvent(event Event) + type EventPoolSerial struct + func NewEventPoolSerial() *EventPoolSerial + type ProcCommEvent struct + func NewProcCommEvent(eventType string, procName string, groupName string, pid int, data string) *ProcCommEvent + func (p *ProcCommEvent) GetBody() string + type ProcCommEventCapture struct + func NewProcCommEventCapture(reader io.Reader, captureMaxBytes int, stdType string, procName string, ...) *ProcCommEventCapture + func (pec *ProcCommEventCapture) SetPid(pid int) + type ProcessGroupEvent struct + func CreateProcessGroupAddedEvent(group_name string) *ProcessGroupEvent + func CreateProcessGroupRemovedEvent(group_name string) *ProcessGroupEvent + func (pe *ProcessGroupEvent) GetBody() string + type ProcessLogEvent struct + 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 struct + 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 struct + func NewRemoteCommunicationEvent(typ string, data string) *RemoteCommunicationEvent + func (r *RemoteCommunicationEvent) GetBody() string + type SupervisorStateChangeEvent struct + func CreateSupervisorStateChangeRunning() *SupervisorStateChangeEvent + func (s *SupervisorStateChangeEvent) GetBody() string + type TickEvent struct + func NewTickEvent(tickType string, when int64) *TickEvent + func (te *TickEvent) GetBody() string
Go to main page