store

Documentation

Index

• Constants
• func RedirectInstanceConfig(new, old string) error
• type CompatDaemon
• type DaemonStore
  • func NewDaemonStore(db *Database) (*DaemonStore, error)
  • func (s *DaemonStore) AddDaemon(d *daemon.Daemon) error
  • func (s *DaemonStore) AddInstance(r *daemon.Rafs) error
  • func (s *DaemonStore) CleanupDaemons(ctx context.Context) error
  • func (s *DaemonStore) DeleteDaemon(id string) error
  • func (s *DaemonStore) DeleteInstance(snapshotID string) error
  • func (s *DaemonStore) NextInstanceSeq() (uint64, error)
  • func (s *DaemonStore) UpdateDaemon(d *daemon.Daemon) error
  • func (s *DaemonStore) WalkDaemons(ctx context.Context, cb func(d *daemon.States) error) error
  • func (s *DaemonStore) WalkInstances(ctx context.Context, cb func(*daemon.Rafs) error) error
• type Database
  • func NewDatabase(rootDir string) (*Database, error)
  • func (db *Database) AddInstance(ctx context.Context, instance *daemon.Rafs) error
  • func (db *Database) CleanupDaemons(ctx context.Context) error
  • func (db *Database) Close() error
  • func (db *Database) DeleteDaemon(ctx context.Context, id string) error
  • func (db *Database) DeleteInstance(ctx context.Context, snapshotID string) error
  • func (db *Database) NextInstanceSeq() (uint64, error)
  • func (db *Database) SaveDaemon(ctx context.Context, d *daemon.Daemon) error
  • func (db *Database) UpdateDaemon(ctx context.Context, d *daemon.Daemon) error
  • func (db *Database) WalkCompatDaemons(ctx context.Context, handler func(cd *CompatDaemon) error) error
  • func (db *Database) WalkDaemons(ctx context.Context, cb func(info *daemon.States) error) error
  • func (db *Database) WalkInstances(ctx context.Context, cb func(r *daemon.Rafs) error) error

Constants

const SharedNydusDaemonID = "shared_daemon"

Functions

func RedirectInstanceConfig

func RedirectInstanceConfig(new, old string) error

Snapshotter v0.3.0 and lower store nydusd and rafs instance configurations in the different folders.

Types

type CompatDaemon

type CompatDaemon struct {
	ID               string
	SnapshotID       string
	ConfigDir        string
	SocketDir        string
	LogDir           string
	LogLevel         string
	LogToStdout      bool
	SnapshotDir      string
	Pid              int
	ImageID          string
	FsDriver         string
	APISock          *string
	RootMountPoint   *string
	CustomMountPoint *string
}

type DaemonStore

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

func NewDaemonStore

func NewDaemonStore(db *Database) (*DaemonStore, error)

func (*DaemonStore) AddDaemon

func (s *DaemonStore) AddDaemon(d *daemon.Daemon) error

If the daemon is inserted to DB before, return error ErrAlreadyExisted.

func (*DaemonStore) AddInstance

func (s *DaemonStore) AddInstance(r *daemon.Rafs) error

func (*DaemonStore) CleanupDaemons

func (s *DaemonStore) CleanupDaemons(ctx context.Context) error

func (*DaemonStore) DeleteDaemon

func (s *DaemonStore) DeleteDaemon(id string) error

func (*DaemonStore) DeleteInstance

func (s *DaemonStore) DeleteInstance(snapshotID string) error

func (*DaemonStore) NextInstanceSeq

func (s *DaemonStore) NextInstanceSeq() (uint64, error)

func (*DaemonStore) UpdateDaemon

func (s *DaemonStore) UpdateDaemon(d *daemon.Daemon) error

func (*DaemonStore) WalkDaemons

func (s *DaemonStore) WalkDaemons(ctx context.Context, cb func(d *daemon.States) error) error

func (*DaemonStore) WalkInstances

func (s *DaemonStore) WalkInstances(ctx context.Context, cb func(*daemon.Rafs) error) error

type Database

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

Database keeps infos that need to survive among snapshotter restart

func NewDatabase

func NewDatabase(rootDir string) (*Database, error)

NewDatabase creates a new or open existing database file

func (*Database) AddInstance

func (db *Database) AddInstance(ctx context.Context, instance *daemon.Rafs) error

func (*Database) CleanupDaemons

func (db *Database) CleanupDaemons(ctx context.Context) error

Cleanup deletes all daemon records

func (*Database) Close

func (db *Database) Close() error

func (*Database) DeleteDaemon

func (db *Database) DeleteDaemon(ctx context.Context, id string) error

func (*Database) DeleteInstance

func (db *Database) DeleteInstance(ctx context.Context, snapshotID string) error

func (*Database) NextInstanceSeq

func (db *Database) NextInstanceSeq() (uint64, error)

func (*Database) SaveDaemon

func (db *Database) SaveDaemon(ctx context.Context, d *daemon.Daemon) error

func (*Database) UpdateDaemon

func (db *Database) UpdateDaemon(ctx context.Context, d *daemon.Daemon) error

func (*Database) WalkCompatDaemons

func (db *Database) WalkCompatDaemons(ctx context.Context, handler func(cd *CompatDaemon) error) error

func (*Database) WalkDaemons

func (db *Database) WalkDaemons(ctx context.Context, cb func(info *daemon.States) error) error

func (*Database) WalkInstances

func (db *Database) WalkInstances(ctx context.Context, cb func(r *daemon.Rafs) error) error

WalkDaemons iterates all daemon records and invoke callback on each