Documentation
¶
Index ¶
- func NewProcessManager(pool *Pool, machine domain.Machine) provider.AgentCLIProcessManager
- func ShellQuote(raw string) string
- type Client
- type DialConfig
- type Dialer
- type MonitorCollector
- func (c *MonitorCollector) CollectAgentEnvironment(ctx context.Context, machine domain.Machine) (domain.MachineAgentEnvironment, error)
- func (c *MonitorCollector) CollectFullAudit(ctx context.Context, machine domain.Machine) (domain.MachineFullAudit, error)
- func (c *MonitorCollector) CollectGPUResources(ctx context.Context, machine domain.Machine) (domain.MachineGPUResources, error)
- func (c *MonitorCollector) CollectReachability(ctx context.Context, machine domain.Machine) (domain.MachineReachability, error)
- func (c *MonitorCollector) CollectSystemResources(ctx context.Context, machine domain.Machine) (domain.MachineSystemResources, error)
- func (c *MonitorCollector) CollectWebsocketHealth(context.Context, domain.Machine) (domain.WebsocketMachineHealth, error)
- type Pool
- type PoolOption
- type ProcessManager
- type Session
- type Tester
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProcessManager ¶
func NewProcessManager(pool *Pool, machine domain.Machine) provider.AgentCLIProcessManager
func ShellQuote ¶
ShellQuote escapes a raw argument for POSIX shell evaluation.
Types ¶
type DialConfig ¶
type Dialer ¶
type Dialer interface {
DialContext(ctx context.Context, cfg DialConfig) (Client, error)
}
type MonitorCollector ¶
type MonitorCollector struct {
// contains filtered or unexported fields
}
func NewMonitorCollector ¶
func NewMonitorCollector(pool *Pool) *MonitorCollector
func (*MonitorCollector) CollectAgentEnvironment ¶
func (c *MonitorCollector) CollectAgentEnvironment(ctx context.Context, machine domain.Machine) (domain.MachineAgentEnvironment, error)
func (*MonitorCollector) CollectFullAudit ¶
func (c *MonitorCollector) CollectFullAudit(ctx context.Context, machine domain.Machine) (domain.MachineFullAudit, error)
func (*MonitorCollector) CollectGPUResources ¶
func (c *MonitorCollector) CollectGPUResources(ctx context.Context, machine domain.Machine) (domain.MachineGPUResources, error)
func (*MonitorCollector) CollectReachability ¶
func (c *MonitorCollector) CollectReachability(ctx context.Context, machine domain.Machine) (domain.MachineReachability, error)
func (*MonitorCollector) CollectSystemResources ¶
func (c *MonitorCollector) CollectSystemResources(ctx context.Context, machine domain.Machine) (domain.MachineSystemResources, error)
func (*MonitorCollector) CollectWebsocketHealth ¶ added in v0.6.0
func (c *MonitorCollector) CollectWebsocketHealth(context.Context, domain.Machine) (domain.WebsocketMachineHealth, error)
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
func NewPool ¶
func NewPool(openASEHomeDir string, opts ...PoolOption) *Pool
type PoolOption ¶
type PoolOption func(*Pool)
func WithDialer ¶
func WithDialer(dialer Dialer) PoolOption
func WithHostKeyCallback ¶
func WithHostKeyCallback(callback gossh.HostKeyCallback) PoolOption
func WithReadFile ¶
func WithReadFile(readFile func(string) ([]byte, error)) PoolOption
func WithTimeout ¶
func WithTimeout(timeout time.Duration) PoolOption
type ProcessManager ¶
type ProcessManager struct {
// contains filtered or unexported fields
}
func (*ProcessManager) Start ¶
func (m *ProcessManager) Start(ctx context.Context, spec provider.AgentCLIProcessSpec) (provider.AgentCLIProcess, error)
type Session ¶
type Session interface {
CombinedOutput(cmd string) ([]byte, error)
StdinPipe() (io.WriteCloser, error)
StdoutPipe() (io.Reader, error)
StderrPipe() (io.Reader, error)
Start(cmd string) error
StartPTY(cmd string, cols int, rows int) error
Resize(cols int, rows int) error
Signal(signal string) error
Wait() error
Close() error
}
Click to show internal directories.
Click to hide internal directories.