instance

Documentation

Index

• Constants
• type Manager
  • func NewInstanceManager(state state.InstanceState, runtime runtimes.Runtime, ...) *Manager
  • func (m *Manager) Destroy(ctx context.Context, force bool) error
  • func (m *Manager) Exec(ctx context.Context, cmd []string, timeout time.Duration) (*runtimes.ExecResult, error)
  • func (m *Manager) GetLog() []*core.LogEntry
  • func (m *Manager) Instance() core.Instance
  • func (m *Manager) Prepare() error
  • func (m *Manager) Recover()
  • func (m *Manager) Start(ctx context.Context) error
  • func (m *Manager) Status() core.InstanceStatus
  • func (m *Manager) Stop(ctx context.Context, signal string, timeout time.Duration) error
  • func (m *Manager) SubscribeToLogs() logging.LogSubscriber
  • func (m *Manager) Wait(ctx context.Context) error

Constants

const MAX_RETRIES = 3

Types

type Manager

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

func NewInstanceManager

func NewInstanceManager(state state.InstanceState, runtime runtimes.Runtime, reservation structs.Reservation) *Manager

func (*Manager) Destroy

func (m *Manager) Destroy(ctx context.Context, force bool) error

func (*Manager) Exec

func (m *Manager) Exec(ctx context.Context, cmd []string, timeout time.Duration) (*runtimes.ExecResult, error)

func (*Manager) GetLog

func (m *Manager) GetLog() []*core.LogEntry

func (*Manager) Instance

func (m *Manager) Instance() core.Instance

func (*Manager) Prepare

func (m *Manager) Prepare() error

func (*Manager) Recover

func (m *Manager) Recover()

func (*Manager) Start

func (m *Manager) Start(ctx context.Context) error

func (*Manager) Status

func (m *Manager) Status() core.InstanceStatus

func (*Manager) Stop

func (m *Manager) Stop(ctx context.Context, signal string, timeout time.Duration) error

func (*Manager) SubscribeToLogs

func (m *Manager) SubscribeToLogs() logging.LogSubscriber

func (*Manager) Wait

func (m *Manager) Wait(ctx context.Context) error