agentclient

Documentation

Index

• type AgentClient
  • func NewAgentClient(c *http.Client, baseUrl string) *AgentClient
  • func (a *AgentClient) DestroyMachine(ctx context.Context, id string, force bool) error
  • func (a *AgentClient) GetMachineLogs(ctx context.Context, id string) ([]*api.LogEntry, error)
  • func (a *AgentClient) GetMachineLogsRaw(ctx context.Context, id string, follow bool) (io.ReadCloser, error)
  • func (a *AgentClient) MachineExec(ctx context.Context, id string, cmd []string, timeout time.Duration) (*api.ExecResult, error)
  • func (a *AgentClient) PutMachine(ctx context.Context, opt cluster.PutMachineOptions) (*cluster.MachineInstance, error)
  • func (a *AgentClient) StartMachine(ctx context.Context, id string) error
  • func (a *AgentClient) StopMachine(ctx context.Context, id string, opt *api.StopConfig) error
  • func (a *AgentClient) SubscribeToMachineLogs(ctx context.Context, id string) ([]*api.LogEntry, <-chan *api.LogEntry, error)

Types

type AgentClient

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

func NewAgentClient

func NewAgentClient(c *http.Client, baseUrl string) *AgentClient

func (*AgentClient) DestroyMachine

func (a *AgentClient) DestroyMachine(ctx context.Context, id string, force bool) error

func (*AgentClient) GetMachineLogs

func (a *AgentClient) GetMachineLogs(ctx context.Context, id string) ([]*api.LogEntry, error)

func (*AgentClient) GetMachineLogsRaw

func (a *AgentClient) GetMachineLogsRaw(ctx context.Context, id string, follow bool) (io.ReadCloser, error)

func (*AgentClient) MachineExec

func (a *AgentClient) MachineExec(ctx context.Context, id string, cmd []string, timeout time.Duration) (*api.ExecResult, error)

func (*AgentClient) PutMachine

func (a *AgentClient) PutMachine(ctx context.Context, opt cluster.PutMachineOptions) (*cluster.MachineInstance, error)

func (*AgentClient) StartMachine

func (a *AgentClient) StartMachine(ctx context.Context, id string) error

func (*AgentClient) StopMachine

func (a *AgentClient) StopMachine(ctx context.Context, id string, opt *api.StopConfig) error

func (*AgentClient) SubscribeToMachineLogs

func (a *AgentClient) SubscribeToMachineLogs(ctx context.Context, id string) ([]*api.LogEntry, <-chan *api.LogEntry, error)