agent

Documentation

Index

• type Agent
  • func New(config Config, store Store, runtime *runtime.Runtime) (*Agent, error)
  • func (d *Agent) DestroyMachine(ctx context.Context, id string, force bool) error
  • func (d *Agent) DisableMachineGateway(ctx context.Context, id string) error
  • func (d *Agent) EnableMachineGateway(ctx context.Context, id string) error
  • func (d *Agent) GetMachineLogs(ctx context.Context, id string) ([]*api.LogEntry, error)
  • func (d *Agent) MachineExec(ctx context.Context, id string, cmd []string, timeout time.Duration) (*api.ExecResult, error)
  • func (a *Agent) PutMachine(ctx context.Context, opt cluster.PutMachineOptions) (*cluster.MachineInstance, error)
  • func (a *Agent) Start() error
  • func (d *Agent) StartMachine(ctx context.Context, id string) error
  • func (d *Agent) Stop(ctx context.Context) error
  • func (d *Agent) StopMachine(ctx context.Context, id string, opt *api.StopConfig) error
  • func (d *Agent) SubscribeToMachineLogs(ctx context.Context, id string) ([]*api.LogEntry, <-chan *api.LogEntry, error)
  • func (a *Agent) WaitForMachineStatus(ctx context.Context, id string, status api.MachineStatus, timeout uint) error
• type Config
• type Store

Types

type Agent

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

func New

func New(config Config, store Store, runtime *runtime.Runtime) (*Agent, error)

func (*Agent) DestroyMachine

func (d *Agent) DestroyMachine(ctx context.Context, id string, force bool) error

func (*Agent) DisableMachineGateway

func (d *Agent) DisableMachineGateway(ctx context.Context, id string) error

func (*Agent) EnableMachineGateway

func (d *Agent) EnableMachineGateway(ctx context.Context, id string) error

func (*Agent) GetMachineLogs

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

func (*Agent) MachineExec

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

func (*Agent) PutMachine

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

func (*Agent) Start

func (a *Agent) Start() error

func (*Agent) StartMachine

func (d *Agent) StartMachine(ctx context.Context, id string) error

func (*Agent) Stop

func (d *Agent) Stop(ctx context.Context) error

func (*Agent) StopMachine

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

func (*Agent) SubscribeToMachineLogs

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

func (*Agent) WaitForMachineStatus

func (a *Agent) WaitForMachineStatus(ctx context.Context, id string, status api.MachineStatus, timeout uint) error

type Config

type Config struct {
	Agent     *config.AgentConfig
	Nats      *config.NatsConfig
	Corrosion *config.CorrosionConfig
}

type Store

type Store interface {
	state.Store
	allocator.AllocationsStore
}