process

Documentation

Index

• type Manager
  • func NewManager(opt Opt) (*Manager, error)
  • func (m *Manager) CleanUpDaemonResource(d *daemon.Daemon)
  • func (m *Manager) DeleteBySnapshotID(id string) (*daemon.Daemon, error)
  • func (m *Manager) DeleteDaemon(daemon *daemon.Daemon)
  • func (m *Manager) DestroyBySnapshotID(id string) error
  • func (m *Manager) DestroyDaemon(d *daemon.Daemon) error
  • func (m *Manager) GetByID(id string) (*daemon.Daemon, error)
  • func (m *Manager) GetBySnapshotID(id string) (*daemon.Daemon, error)
  • func (m *Manager) IsPrefetchDaemon() bool
  • func (m *Manager) IsSharedDaemon() bool
  • func (m *Manager) ListDaemons() []*daemon.Daemon
  • func (m *Manager) NewDaemon(daemon *daemon.Daemon) error
  • func (m *Manager) Reconnect(ctx context.Context) error
  • func (m *Manager) StartDaemon(d *daemon.Daemon) error
• type Opt
• type Store

Types

type Manager

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

func NewManager

func NewManager(opt Opt) (*Manager, error)

func (*Manager) CleanUpDaemonResource

func (m *Manager) CleanUpDaemonResource(d *daemon.Daemon)

func (*Manager) DeleteBySnapshotID

func (m *Manager) DeleteBySnapshotID(id string) (*daemon.Daemon, error)

func (*Manager) DeleteDaemon

func (m *Manager) DeleteDaemon(daemon *daemon.Daemon)

func (*Manager) DestroyBySnapshotID

func (m *Manager) DestroyBySnapshotID(id string) error

func (*Manager) DestroyDaemon

func (m *Manager) DestroyDaemon(d *daemon.Daemon) error

FIXME: should handle the inconsistent status caused by any step in the function that returns an error.

func (*Manager) GetByID

func (m *Manager) GetByID(id string) (*daemon.Daemon, error)

func (*Manager) GetBySnapshotID

func (m *Manager) GetBySnapshotID(id string) (*daemon.Daemon, error)

func (*Manager) IsPrefetchDaemon

func (m *Manager) IsPrefetchDaemon() bool

func (*Manager) IsSharedDaemon

func (m *Manager) IsSharedDaemon() bool

func (*Manager) ListDaemons

func (m *Manager) ListDaemons() []*daemon.Daemon

func (*Manager) NewDaemon

func (m *Manager) NewDaemon(daemon *daemon.Daemon) error

func (*Manager) Reconnect

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

Reconnect already running daemons，and rebuild daemons management structs.

func (*Manager) StartDaemon

func (m *Manager) StartDaemon(d *daemon.Daemon) error

type Opt

type Opt struct {
	NydusdBinaryPath string
	Database         *store.Database
	DaemonMode       string
}

type Store

type Store interface {
	Get(id string) (*daemon.Daemon, error)
	GetBySnapshot(snapshotID string) (*daemon.Daemon, error)
	Add(*daemon.Daemon) error
	Update(d *daemon.Daemon) error
	Delete(*daemon.Daemon) error
	List() []*daemon.Daemon
	Size() int
	WalkDaemons(ctx context.Context, cb func(*daemon.Daemon) error) error
	CleanupDaemons(ctx context.Context) error
}