listener

Documentation

Index

• Constants
• Variables
• func GetSupervisor() supervisor.Supervisor
• type Header
• type Listener
  • func (l *Listener) Run() error
• type ProcessCommunication
• type ProcessLog
• type ProcessLogHandler
• type ProcessState
• type ProcessStateHandler
• type ProcessStateHandlerFunc
• type RemoteCommunication
• type RemoteCommunicationHandler
• type Result
  • func (r Result) String() string
• type SupervisorStateChangeHandler
• type Tick
• type TickHandler

Constants

const (
	ProcessStatePrefix          = "PROCESS_STATE"
	RemoteCommunicationPrefix   = "REMOTE_COMMUNICATION"
	ProcessLogPrefix            = "PROCESS_LOG"
	SupervisorStateChangePrefix = "SUPERVISOR_STATE_CHANGE"
	TickPrefix                  = "TICK"
)

Variables

var (
	SupervisorProcessName = os.Getenv("SUPERVISOR_PROCESS_NAME")
	SupervisorGroupName   = os.Getenv("SUPERVISOR_GROUP_NAME")
	SupervisorURL         = os.Getenv("SUPERVISOR_SERVER_URL")
	SupervisorEnabled     = os.Getenv("SUPERVISOR_ENABLED")
)

Functions

func GetSupervisor

func GetSupervisor() supervisor.Supervisor

Types

type Header

type Header struct {
	Version    string `mapstructure:"ver"`
	Server     string
	Serial     int
	Pool       string
	PoolSerial int
	EventName  string
	Len        int
}

type Listener

type Listener struct {
	ProcessStateHandler
	RemoteCommunicationHandler
}

func (*Listener) Run

func (l *Listener) Run() error

type ProcessCommunication

type ProcessCommunication struct {
}

type ProcessLog

type ProcessLog struct {
	ProcessName string
	GroupName   string
	Pid         int
	Data        string
}

type ProcessLogHandler

type ProcessLogHandler interface {
}

type ProcessState

type ProcessState struct {
	ProcessName string
	GroupName   string
	FromState   string `mapstructure:"from_state"`
	Pid         int
	Expected    bool
	Tries       int
}

type ProcessStateHandler

type ProcessStateHandler interface {
	// contains filtered or unexported methods
}

type ProcessStateHandlerFunc

type ProcessStateHandlerFunc func(Header, ProcessState) Result

type RemoteCommunication

type RemoteCommunication struct {
}

type RemoteCommunicationHandler

type RemoteCommunicationHandler interface {
	// contains filtered or unexported methods
}

type Result

type Result string

const (
	RESULT_FAIL Result = "FAIL"
	RESULT_OK   Result = "OK"
)

func (Result) String

func (r Result) String() string

type SupervisorStateChangeHandler

type SupervisorStateChangeHandler interface {
}

type Tick

type Tick struct {
	When int
}

type TickHandler

type TickHandler interface {
}