controlmsg

Documentation

Index

• Constants
• type ControlMsg
• type ControlMsgPipe
  • func NewControlMsgPipe() *ControlMsgPipe
  • func (p *ControlMsgPipe) CloseControlMsgPipe()
  • func (p *ControlMsgPipe) ReadCmdNoBlock() (*ControlMsg, bool)
  • func (p *ControlMsgPipe) ReadEchoNoBlock() (*ControlMsg, bool)
  • func (t *ControlMsgPipe) SysControlEntry(serviceName string, msg *ControlMsg) (int, int)
  • func (p *ControlMsgPipe) WriteCmdNoBlock(msg *ControlMsg) bool
  • func (p *ControlMsgPipe) WriteEchoNoBlock(msg *ControlMsg) bool

Constants

const (
	ControlMsgUnknown = iota
	ControlMsgPause
	ControlMsgResume
	ControlMsgExit
	ControlMsgTick
	ControlMsgDegrade
	ControlMsgMax
)

const (
	ProcessStatOK = iota
	ProcessStatIgnore
	ProcessStatPanic
	ProcessPipeFull
	ProcessPipeReceiverLost
	ProcessStatUnknown
)

const (
	NextActionBreak = iota
	NextActionContinue
	NextActionReturn
)

Types

type ControlMsg

type ControlMsg struct {
	MsgType int
	Payload interface{}
}

type ControlMsgPipe

type ControlMsgPipe struct {
	Cmd  chan *ControlMsg
	Echo chan *ControlMsg
}

func NewControlMsgPipe

func NewControlMsgPipe() *ControlMsgPipe

func (*ControlMsgPipe) CloseControlMsgPipe

func (p *ControlMsgPipe) CloseControlMsgPipe()

func (*ControlMsgPipe) ReadCmdNoBlock

func (p *ControlMsgPipe) ReadCmdNoBlock() (*ControlMsg, bool)

func (*ControlMsgPipe) ReadEchoNoBlock

func (p *ControlMsgPipe) ReadEchoNoBlock() (*ControlMsg, bool)

func (*ControlMsgPipe) SysControlEntry

func (t *ControlMsgPipe) SysControlEntry(serviceName string, msg *ControlMsg) (int, int)

func (*ControlMsgPipe) WriteCmdNoBlock

func (p *ControlMsgPipe) WriteCmdNoBlock(msg *ControlMsg) bool

func (*ControlMsgPipe) WriteEchoNoBlock

func (p *ControlMsgPipe) WriteEchoNoBlock(msg *ControlMsg) bool