runtime

Documentation

Index

• type Runtime
  • func New(config *config.RuntimeConfig, registries registry.RegistriesConfig, ...) (*Runtime, error)
  • func (r *Runtime) CreateDisk(id string, sizeMB uint64) (*disks.Disk, error)
  • func (r *Runtime) CreateInstance(ctx context.Context, opt instance.InstanceOptions) (*instance.Instance, error)
  • func (r *Runtime) DeleteImage(ctx context.Context, ref string) error
  • func (r *Runtime) DestroyDisk(id string) error
  • func (r *Runtime) DestroyInstance(ctx context.Context, id string) error
  • func (r *Runtime) GetDisk(id string) (*disks.Disk, error)
  • func (r *Runtime) GetInstance(id string) (*instance.Instance, error)
  • func (r *Runtime) GetInstanceLogs(id string) ([]*api.LogEntry, error)
  • func (r *Runtime) InstanceExec(ctx context.Context, id string, cmd []string, timeout time.Duration) (*api.ExecResult, error)
  • func (r *Runtime) ListDisks() ([]disks.Disk, error)
  • func (r *Runtime) ListImages(ctx context.Context) ([]daemon.Image, error)
  • func (r *Runtime) ListInstances() []instance.Instance
  • func (r *Runtime) PruneImages(ctx context.Context) error
  • func (r *Runtime) PullImage(ctx context.Context, opt daemon.ImagePullOptions) (*daemon.Image, error)
  • func (r *Runtime) Start() error
  • func (r *Runtime) StartInstance(ctx context.Context, id string) error
  • func (r *Runtime) StopInstance(ctx context.Context, id string, opt *api.StopConfig) error
  • func (r *Runtime) SubscribeToInstanceLogs(ctx context.Context, id string) ([]*api.LogEntry, <-chan *api.LogEntry, error)
  • func (r *Runtime) WatchInstanceState(ctx context.Context, id string) (<-chan instance.State, error)
• type State
  • func NewState() *State
  • func (s *State) AddInstance(id string, manager *instancerunner.InstanceRunner)
  • func (s *State) Delete(id string)
  • func (s *State) GetInstance(id string) (*instancerunner.InstanceRunner, error)
  • func (s *State) List() []instance.Instance
  • func (s *State) ReleaseId(id string)
  • func (s *State) ReserveId(id string) bool
• type Store

Types

type Runtime

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

func New

func New(config *config.RuntimeConfig, registries registry.RegistriesConfig, store Store) (*Runtime, error)

func (*Runtime) CreateDisk

func (r *Runtime) CreateDisk(id string, sizeMB uint64) (*disks.Disk, error)

func (*Runtime) CreateInstance

func (r *Runtime) CreateInstance(ctx context.Context, opt instance.InstanceOptions) (*instance.Instance, error)

func (*Runtime) DeleteImage

func (r *Runtime) DeleteImage(ctx context.Context, ref string) error

func (*Runtime) DestroyDisk

func (r *Runtime) DestroyDisk(id string) error

func (*Runtime) DestroyInstance

func (r *Runtime) DestroyInstance(ctx context.Context, id string) error

func (*Runtime) GetDisk

func (r *Runtime) GetDisk(id string) (*disks.Disk, error)

func (*Runtime) GetInstance

func (r *Runtime) GetInstance(id string) (*instance.Instance, error)

func (*Runtime) GetInstanceLogs

func (r *Runtime) GetInstanceLogs(id string) ([]*api.LogEntry, error)

func (*Runtime) InstanceExec

func (r *Runtime) InstanceExec(ctx context.Context, id string, cmd []string, timeout time.Duration) (*api.ExecResult, error)

func (*Runtime) ListDisks

func (r *Runtime) ListDisks() ([]disks.Disk, error)

func (*Runtime) ListImages

func (r *Runtime) ListImages(ctx context.Context) ([]daemon.Image, error)

func (*Runtime) ListInstances

func (r *Runtime) ListInstances() []instance.Instance

func (*Runtime) PruneImages

func (r *Runtime) PruneImages(ctx context.Context) error

func (*Runtime) PullImage

func (r *Runtime) PullImage(ctx context.Context, opt daemon.ImagePullOptions) (*daemon.Image, error)

func (*Runtime) Start

func (r *Runtime) Start() error

func (*Runtime) StartInstance

func (r *Runtime) StartInstance(ctx context.Context, id string) error

func (*Runtime) StopInstance

func (r *Runtime) StopInstance(ctx context.Context, id string, opt *api.StopConfig) error

func (*Runtime) SubscribeToInstanceLogs

func (r *Runtime) SubscribeToInstanceLogs(ctx context.Context, id string) ([]*api.LogEntry, <-chan *api.LogEntry, error)

func (*Runtime) WatchInstanceState

func (r *Runtime) WatchInstanceState(ctx context.Context, id string) (<-chan instance.State, error)

type State

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

func NewState

func NewState() *State

func (*State) AddInstance

func (s *State) AddInstance(id string, manager *instancerunner.InstanceRunner)

func (*State) Delete

func (s *State) Delete(id string)

func (*State) GetInstance

func (s *State) GetInstance(id string) (*instancerunner.InstanceRunner, error)

func (*State) List

func (s *State) List() []instance.Instance

func (*State) ReleaseId

func (s *State) ReleaseId(id string)

func (*State) ReserveId

func (s *State) ReserveId(id string) bool

type Store

type Store interface {
	instance.InstanceStore
	disks.Store
}