client

Documentation

Index

• func GetProcessInfo(address string, port int, name string) (*types.ProcessConfig, error)
• func GetProcessPorts(address string, port int, name string) (*types.ProcessPorts, error)
• func GetProcessState(address string, port int, name string) (*types.ProcessState, error)
• func GetProcessesName(address string, port int) ([]string, error)
• func GetProcessesState(address string, port int) (*types.ProcessesState, error)
• func RestartProcess(address string, port int, name string) error
• func ScaleProcess(address string, port int, name string, scale int) error
• func StartProcess(address string, port int, name string) error
• func StopProcess(address string, port int, name string) error
• func StopProcesses(address string, port int, names []string) ([]string, error)
• type LogClient
  • func NewLogClient() *LogClient
  • func (l *LogClient) CloseChannel() error
  • func (l *LogClient) ReadProcessLogs(address string, port int, name string, offset int, follow bool, ...) (err error)
• type PcClient
  • func NewClient(address string, port, logLength int) *PcClient
  • func (p *PcClient) ErrorForSecs() int
  • func (p *PcClient) GetHostName() (string, error)
  • func (p *PcClient) GetLexicographicProcessNames() ([]string, error)
  • func (p *PcClient) GetLogLength() int
  • func (p *PcClient) GetLogsAndSubscribe(name string, observer pclog.LogObserver) error
  • func (p *PcClient) GetProcessInfo(name string) (*types.ProcessConfig, error)
  • func (p *PcClient) GetProcessLog(name string, offsetFromEnd, limit int) ([]string, error)
  • func (p *PcClient) GetProcessPorts(name string) (*types.ProcessPorts, error)
  • func (p *PcClient) GetProcessState(name string) (*types.ProcessState, error)
  • func (p *PcClient) GetProcessesState() (*types.ProcessesState, error)
  • func (p *PcClient) GetProjectState(withMemory bool) (*types.ProjectState, error)
  • func (p *PcClient) IsAlive() error
  • func (p *PcClient) IsRemote() bool
  • func (p *PcClient) RestartProcess(name string) error
  • func (p *PcClient) ScaleProcess(name string, scale int) error
  • func (p *PcClient) ShutDownProject() error
  • func (p *PcClient) StartProcess(name string) error
  • func (p *PcClient) StopProcess(name string) error
  • func (p *PcClient) StopProcesses(names []string) ([]string, error)
  • func (p *PcClient) UnSubscribeLogger(name string, observer pclog.LogObserver) error

Functions

func GetProcessInfo

func GetProcessInfo(address string, port int, name string) (*types.ProcessConfig, error)

func GetProcessPorts

func GetProcessPorts(address string, port int, name string) (*types.ProcessPorts, error)

func GetProcessState

func GetProcessState(address string, port int, name string) (*types.ProcessState, error)

func GetProcessesName

func GetProcessesName(address string, port int) ([]string, error)

func GetProcessesState

func GetProcessesState(address string, port int) (*types.ProcessesState, error)

func RestartProcess

func RestartProcess(address string, port int, name string) error

func ScaleProcess

func ScaleProcess(address string, port int, name string, scale int) error

func StartProcess

func StartProcess(address string, port int, name string) error

func StopProcess

func StopProcess(address string, port int, name string) error

func StopProcesses

func StopProcesses(address string, port int, names []string) ([]string, error)

Types

type LogClient

type LogClient struct {
	Format string
	// contains filtered or unexported fields
}

func NewLogClient

func NewLogClient() *LogClient

func (*LogClient) CloseChannel

func (l *LogClient) CloseChannel() error

CloseChannel Cleanly close the connection by sending a close message and then waiting (with timeout) for the server to close the connection.

func (*LogClient) ReadProcessLogs

func (l *LogClient) ReadProcessLogs(address string, port int, name string, offset int, follow bool, out io.StringWriter) (err error)

type PcClient

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

func NewClient

func NewClient(address string, port, logLength int) *PcClient

func (*PcClient) ErrorForSecs

func (p *PcClient) ErrorForSecs() int

func (*PcClient) GetHostName

func (p *PcClient) GetHostName() (string, error)

func (*PcClient) GetLexicographicProcessNames

func (p *PcClient) GetLexicographicProcessNames() ([]string, error)

func (*PcClient) GetLogLength

func (p *PcClient) GetLogLength() int

func (*PcClient) GetLogsAndSubscribe

func (p *PcClient) GetLogsAndSubscribe(name string, observer pclog.LogObserver) error

func (*PcClient) GetProcessInfo

func (p *PcClient) GetProcessInfo(name string) (*types.ProcessConfig, error)

func (*PcClient) GetProcessLog

func (p *PcClient) GetProcessLog(name string, offsetFromEnd, limit int) ([]string, error)

func (*PcClient) GetProcessPorts

func (p *PcClient) GetProcessPorts(name string) (*types.ProcessPorts, error)

func (*PcClient) GetProcessState

func (p *PcClient) GetProcessState(name string) (*types.ProcessState, error)

func (*PcClient) GetProcessesState

func (p *PcClient) GetProcessesState() (*types.ProcessesState, error)

func (*PcClient) GetProjectState

func (p *PcClient) GetProjectState(withMemory bool) (*types.ProjectState, error)

func (*PcClient) IsAlive

func (p *PcClient) IsAlive() error

func (*PcClient) IsRemote

func (p *PcClient) IsRemote() bool

func (*PcClient) RestartProcess

func (p *PcClient) RestartProcess(name string) error

func (*PcClient) ScaleProcess

func (p *PcClient) ScaleProcess(name string, scale int) error

func (*PcClient) ShutDownProject

func (p *PcClient) ShutDownProject() error

func (*PcClient) StartProcess

func (p *PcClient) StartProcess(name string) error

func (*PcClient) StopProcess

func (p *PcClient) StopProcess(name string) error

func (*PcClient) StopProcesses

func (p *PcClient) StopProcesses(names []string) ([]string, error)

func (*PcClient) UnSubscribeLogger

func (p *PcClient) UnSubscribeLogger(name string, observer pclog.LogObserver) error