client

Documentation

Index

• type LogClient
  • func NewLogClient(address, socketPath string) *LogClient
  • func (l *LogClient) CloseChannel() error
  • func (l *LogClient) ReadProcessLogs(name string, offset int, follow bool, out io.StringWriter) (err error)
• type PcClient
  • func NewTcpClient(host string, port, logLength int) *PcClient
  • func NewUdsClient(sockPath string, 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) GetProcessesName() ([]string, 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

Types

type LogClient

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

func NewLogClient

func NewLogClient(address, socketPath string) *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(name string, offset int, follow bool, out io.StringWriter) (err error)

type PcClient

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

func NewTcpClient

func NewTcpClient(host string, port, logLength int) *PcClient

func NewUdsClient

func NewUdsClient(sockPath string, 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) GetProcessesName

func (p *PcClient) GetProcessesName() ([]string, 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