client

package

v0.50.0 Latest Latest Go to latest Published: Jun 10, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/f1bonacc1/process-compose

Links

Open Source Insights

Documentation ¶

Index ¶

func GetProcessInfo(address string, port int, name string) (*types.ProcessConfig, 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 RestartProcesses(address string, port int, name string) error
func StartProcesses(address string, port int, name string) error
func StopProcesses(address string, port int, name 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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetProcessInfo ¶ added in v0.50.0

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

func GetProcessState ¶ added in v0.50.0

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

func GetProcessesName ¶

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

func GetProcessesState ¶ added in v0.50.0

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

func RestartProcesses ¶

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

func StartProcesses ¶

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

func StopProcesses ¶

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

Types ¶

type LogClient ¶ added in v0.50.0

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

func NewLogClient ¶ added in v0.50.0

func NewLogClient() *LogClient

func (*LogClient) CloseChannel ¶ added in v0.50.0

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 ¶ added in v0.50.0

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

type PcClient ¶ added in v0.50.0

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

func NewClient ¶ added in v0.50.0

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

func (*PcClient) ErrorForSecs ¶ added in v0.50.0

func (p *PcClient) ErrorForSecs() int

func (*PcClient) GetHostName ¶ added in v0.50.0

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

func (*PcClient) GetLexicographicProcessNames ¶ added in v0.50.0

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

func (*PcClient) GetLogLength ¶ added in v0.50.0

func (p *PcClient) GetLogLength() int

func (*PcClient) GetLogsAndSubscribe ¶ added in v0.50.0

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

func (*PcClient) GetProcessInfo ¶ added in v0.50.0

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

func (*PcClient) GetProcessLog ¶ added in v0.50.0

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

func (*PcClient) GetProcessState ¶ added in v0.50.0

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

func (*PcClient) GetProcessesState ¶ added in v0.50.0

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

func (*PcClient) IsAlive ¶ added in v0.50.0

func (p *PcClient) IsAlive() error

func (*PcClient) IsRemote ¶ added in v0.50.0

func (p *PcClient) IsRemote() bool

func (*PcClient) RestartProcess ¶ added in v0.50.0

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

func (*PcClient) ShutDownProject ¶ added in v0.50.0

func (p *PcClient) ShutDownProject()

func (*PcClient) StartProcess ¶ added in v0.50.0

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

func (*PcClient) StopProcess ¶ added in v0.50.0

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

func (*PcClient) UnSubscribeLogger ¶ added in v0.50.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL