api

Documentation

Index

• func RPCToProcessList(obj *rpc.ProcessListResponse) map[string]*Process
• type LogStream
  • func NewLogStream(stream rpc.ProcessManagerService_ProcessLogClient) *LogStream
  • func (s *LogStream) Recv() (string, error)
• type Process
  • func RPCToProcess(obj *rpc.ProcessResponse) *Process
• type ProcessStatus
  • func RPCToProcessStatus(obj *rpc.ProcessStatus) ProcessStatus
• type ProcessStream
  • func NewProcessStream(stream rpc.ProcessManagerService_ProcessWatchClient) *ProcessStream
  • func (s *ProcessStream) Recv() (*Process, error)

Functions

func RPCToProcessList

func RPCToProcessList(obj *rpc.ProcessListResponse) map[string]*Process

Types

type LogStream

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

func NewLogStream

func NewLogStream(stream rpc.ProcessManagerService_ProcessLogClient) *LogStream

func (*LogStream) Recv

func (s *LogStream) Recv() (string, error)

type Process

type Process struct {
	Name      string   `json:"name"`
	Binary    string   `json:"binary"`
	Args      []string `json:"args"`
	PortCount int32    `json:"portCount"`
	PortArgs  []string `json:"portArgs"`

	ProcessStatus ProcessStatus `json:"processStatus"`

	Deleted bool `json:"deleted"`
}

func RPCToProcess

func RPCToProcess(obj *rpc.ProcessResponse) *Process

type ProcessStatus

type ProcessStatus struct {
	State     string `json:"state"`
	ErrorMsg  string `json:"errorMsg"`
	PortStart int32  `json:"portStart"`
	PortEnd   int32  `json:"portEnd"`
}

func RPCToProcessStatus

func RPCToProcessStatus(obj *rpc.ProcessStatus) ProcessStatus

type ProcessStream

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

func NewProcessStream

func NewProcessStream(stream rpc.ProcessManagerService_ProcessWatchClient) *ProcessStream

func (*ProcessStream) Recv

func (s *ProcessStream) Recv() (*Process, error)