command

Documentation

Index

• Constants
• type AgentExec
• type Dispatch
  • func MakeDispatch(inc chan *agent_protocol.AgentMessage, outc chan *agent_protocol.AgentMessage) *Dispatch
  • func (cd *Dispatch) Run()
• type ExecManager
  • func MakeExecManager(outc chan *agent_protocol.AgentMessage) *ExecManager

Constants

const (
	ATTACHED = iota
	DETACHED = iota
	EXITED   = iota
	DRAINED  = iota
)

Types

type AgentExec

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

type Dispatch

type Dispatch struct {
	Inc           chan *agent_protocol.AgentMessage
	Outc          chan *agent_protocol.AgentMessage
	SimpleFuncMap map[string]func(proto.Message) proto.Message
	StreamFuncMap map[string]func(proto.Message, string, int64)
	ExMan         *ExecManager
	// contains filtered or unexported fields
}

func MakeDispatch

func MakeDispatch(inc chan *agent_protocol.AgentMessage, outc chan *agent_protocol.AgentMessage) *Dispatch

func (*Dispatch) Run

func (cd *Dispatch) Run()

type ExecManager

type ExecManager struct {
	Execs map[int64]*AgentExec
	Outc  chan *agent_protocol.AgentMessage
	Lock  *sync.Mutex
	// contains filtered or unexported fields
}

func MakeExecManager

func MakeExecManager(outc chan *agent_protocol.AgentMessage) *ExecManager