orchestrator

Documentation

Index

• type Orchestrator
  • func New(nc *nats.Conn, clusterState cluster.ClusterState, tlsConfig *tls.Config) *Orchestrator
  • func (o *Orchestrator) DestroyMachine(ctx context.Context, machine cluster.Machine, force bool) error
  • func (o *Orchestrator) DisableMachineGateway(ctx context.Context, machine cluster.Machine) error
  • func (o *Orchestrator) EnableMachineGateway(ctx context.Context, machine cluster.Machine) error
  • func (o *Orchestrator) GetMachineLogsRaw(ctx context.Context, machine cluster.Machine, follow bool) (io.ReadCloser, error)
  • func (m *Orchestrator) GetNode(ctx context.Context, id string) (api.Node, error)
  • func (m *Orchestrator) ListNodes(ctx context.Context) ([]api.Node, error)
  • func (m *Orchestrator) ListNodesInRegion(ctx context.Context, region string) ([]api.Node, error)
  • func (o *Orchestrator) MachineExec(ctx context.Context, machine cluster.Machine, execOpts *api.ExecOptions) (*api.ExecResult, error)
  • func (o *Orchestrator) PrepareAllocation(ctx context.Context, region string, allocationId string, ...) (nodeId string, err error)
  • func (o *Orchestrator) PutMachine(ctx context.Context, nodeId string, machine *cluster.Machine, ...) error
  • func (o *Orchestrator) StartMachineInstance(ctx context.Context, machine cluster.Machine) error
  • func (o *Orchestrator) StopMachineInstance(ctx context.Context, machine cluster.Machine, stopConfig *api.StopConfig) error
  • func (o *Orchestrator) WaitMachine(ctx context.Context, machine cluster.Machine, state api.MachineStatus, ...) error

Types

type Orchestrator

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

func New

func New(nc *nats.Conn, clusterState cluster.ClusterState, tlsConfig *tls.Config) *Orchestrator

func (*Orchestrator) DestroyMachine

func (o *Orchestrator) DestroyMachine(ctx context.Context, machine cluster.Machine, force bool) error

func (*Orchestrator) DisableMachineGateway

func (o *Orchestrator) DisableMachineGateway(ctx context.Context, machine cluster.Machine) error

func (*Orchestrator) EnableMachineGateway

func (o *Orchestrator) EnableMachineGateway(ctx context.Context, machine cluster.Machine) error

func (*Orchestrator) GetMachineLogsRaw

func (o *Orchestrator) GetMachineLogsRaw(ctx context.Context, machine cluster.Machine, follow bool) (io.ReadCloser, error)

func (*Orchestrator) GetNode

func (m *Orchestrator) GetNode(ctx context.Context, id string) (api.Node, error)

func (*Orchestrator) ListNodes

func (m *Orchestrator) ListNodes(ctx context.Context) ([]api.Node, error)

func (*Orchestrator) ListNodesInRegion

func (m *Orchestrator) ListNodesInRegion(ctx context.Context, region string) ([]api.Node, error)

func (*Orchestrator) MachineExec

func (o *Orchestrator) MachineExec(ctx context.Context, machine cluster.Machine, execOpts *api.ExecOptions) (*api.ExecResult, error)

func (*Orchestrator) PrepareAllocation

func (o *Orchestrator) PrepareAllocation(ctx context.Context, region string, allocationId string, resources api.Resources) (nodeId string, err error)

func (*Orchestrator) PutMachine

func (o *Orchestrator) PutMachine(ctx context.Context, nodeId string, machine *cluster.Machine, mv api.MachineVersion, start bool, enableGateway bool) error

func (*Orchestrator) StartMachineInstance

func (o *Orchestrator) StartMachineInstance(ctx context.Context, machine cluster.Machine) error

func (*Orchestrator) StopMachineInstance

func (o *Orchestrator) StopMachineInstance(ctx context.Context, machine cluster.Machine, stopConfig *api.StopConfig) error

func (*Orchestrator) WaitMachine

func (o *Orchestrator) WaitMachine(
	ctx context.Context,
	machine cluster.Machine,
	state api.MachineStatus,
	timeout uint,
) error