instancerunner

Documentation

Index

• type InstanceRunner
  • func New(store instance.InstanceStore, instance instance.Instance, ...) *InstanceRunner
  • func (ir *InstanceRunner) Destroy(ctx context.Context) error
  • func (ir *InstanceRunner) Exec(ctx context.Context, cmd []string, timeout time.Duration) (*api.ExecResult, error)
  • func (ir *InstanceRunner) GetLog() []*api.LogEntry
  • func (s *InstanceRunner) Instance() instance.Instance
  • func (ir *InstanceRunner) Recover()
  • func (ir *InstanceRunner) Signal(ctx context.Context, signal string) error
  • func (ir *InstanceRunner) Start(ctx context.Context) error
  • func (s *InstanceRunner) Status() instance.InstanceStatus
  • func (ir *InstanceRunner) Stop(ctx context.Context, config *api.StopConfig) error
  • func (ir *InstanceRunner) SubscribeToLogs() ([]*api.LogEntry, *logging.LogSubscriber)
  • func (ir *InstanceRunner) WaitExit(ctx context.Context) WaitExitStatus
  • func (ir *InstanceRunner) WatchState(ctx context.Context) <-chan instance.State
• type WaitExitStatus
  • func (w *WaitExitStatus) Err() error
  • func (w *WaitExitStatus) ExitResult() instance.ExitResult
  • func (w *WaitExitStatus) IsValid() bool

Types

type InstanceRunner

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

func New

func New(
	store instance.InstanceStore,
	instance instance.Instance,
	ns instance.NetworkingService,
	vmBuilder instance.Builder,
) *InstanceRunner

func (*InstanceRunner) Destroy

func (ir *InstanceRunner) Destroy(ctx context.Context) error

func (*InstanceRunner) Exec

func (ir *InstanceRunner) Exec(ctx context.Context, cmd []string, timeout time.Duration) (*api.ExecResult, error)

func (*InstanceRunner) GetLog

func (ir *InstanceRunner) GetLog() []*api.LogEntry

func (*InstanceRunner) Instance

func (s *InstanceRunner) Instance() instance.Instance

func (*InstanceRunner) Recover

func (ir *InstanceRunner) Recover()

func (*InstanceRunner) Signal

func (ir *InstanceRunner) Signal(ctx context.Context, signal string) error

func (*InstanceRunner) Start

func (ir *InstanceRunner) Start(ctx context.Context) error

func (*InstanceRunner) Status

func (s *InstanceRunner) Status() instance.InstanceStatus

func (*InstanceRunner) Stop

func (ir *InstanceRunner) Stop(ctx context.Context, config *api.StopConfig) error

func (*InstanceRunner) SubscribeToLogs

func (ir *InstanceRunner) SubscribeToLogs() ([]*api.LogEntry, *logging.LogSubscriber)

func (*InstanceRunner) WaitExit

func (ir *InstanceRunner) WaitExit(ctx context.Context) WaitExitStatus

func (*InstanceRunner) WatchState

func (ir *InstanceRunner) WatchState(ctx context.Context) <-chan instance.State

type WaitExitStatus

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

func (*WaitExitStatus) Err

func (w *WaitExitStatus) Err() error

func (*WaitExitStatus) ExitResult

func (w *WaitExitStatus) ExitResult() instance.ExitResult

func (*WaitExitStatus) IsValid

func (w *WaitExitStatus) IsValid() bool