store

Documentation

Index

• Constants
• func RedirectInstanceConfig(new, old string) error
• type CompatDaemon
• type DaemonRafsStore
  • func NewDaemonRafsStore(db *Database) (*DaemonRafsStore, error)
  • func (s *DaemonRafsStore) AddDaemon(d *daemon.Daemon) error
  • func (s *DaemonRafsStore) AddRafsInstance(r *rafs.Rafs) error
  • func (s *DaemonRafsStore) CleanupDaemons(ctx context.Context) error
  • func (s *DaemonRafsStore) DeleteDaemon(id string) error
  • func (s *DaemonRafsStore) DeleteRafsInstance(snapshotID string) error
  • func (s *DaemonRafsStore) NextInstanceSeq() (uint64, error)
  • func (s *DaemonRafsStore) UpdateDaemon(d *daemon.Daemon) error
  • func (s *DaemonRafsStore) WalkDaemons(ctx context.Context, cb func(d *daemon.ConfigState) error) error
  • func (s *DaemonRafsStore) WalkRafsInstances(ctx context.Context, cb func(*rafs.Rafs) error) error
• type Database
  • func NewDatabase(rootDir string) (*Database, error)
  • func (db *Database) AddRafsInstance(_ context.Context, instance *rafs.Rafs) error
  • func (db *Database) CleanupDaemons(_ context.Context) error
  • func (db *Database) Close() error
  • func (db *Database) DeleteDaemon(_ context.Context, id string) error
  • func (db *Database) DeleteRafsInstance(_ context.Context, snapshotID string) error
  • func (db *Database) NextInstanceSeq() (uint64, error)
  • func (db *Database) SaveDaemon(_ context.Context, d *daemon.Daemon) error
  • func (db *Database) UpdateDaemon(_ context.Context, d *daemon.Daemon) error
  • func (db *Database) WalkCompatDaemons(_ context.Context, handler func(cd *CompatDaemon) error) error
  • func (db *Database) WalkDaemons(_ context.Context, cb func(info *daemon.ConfigState) error) error
  • func (db *Database) WalkRafsInstances(_ context.Context, cb func(r *rafs.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 DaemonRafsStore

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

func NewDaemonRafsStore

func NewDaemonRafsStore(db *Database) (*DaemonRafsStore, error)

func (*DaemonRafsStore) AddDaemon

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

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

func (*DaemonRafsStore) AddRafsInstance

func (s *DaemonRafsStore) AddRafsInstance(r *rafs.Rafs) error

func (*DaemonRafsStore) CleanupDaemons

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

func (*DaemonRafsStore) DeleteDaemon

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

func (*DaemonRafsStore) DeleteRafsInstance

func (s *DaemonRafsStore) DeleteRafsInstance(snapshotID string) error

func (*DaemonRafsStore) NextInstanceSeq

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

func (*DaemonRafsStore) UpdateDaemon

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

func (*DaemonRafsStore) WalkDaemons

func (s *DaemonRafsStore) WalkDaemons(ctx context.Context, cb func(d *daemon.ConfigState) error) error

func (*DaemonRafsStore) WalkRafsInstances

func (s *DaemonRafsStore) WalkRafsInstances(ctx context.Context, cb func(*rafs.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) AddRafsInstance

func (db *Database) AddRafsInstance(_ context.Context, instance *rafs.Rafs) error

func (*Database) CleanupDaemons

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

Cleanup deletes all daemon records

func (*Database) Close

func (db *Database) Close() error

func (*Database) DeleteDaemon

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

func (*Database) DeleteRafsInstance

func (db *Database) DeleteRafsInstance(_ context.Context, snapshotID string) error

func (*Database) NextInstanceSeq

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

func (*Database) SaveDaemon

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

func (*Database) UpdateDaemon

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

func (*Database) WalkCompatDaemons

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

func (*Database) WalkDaemons

func (db *Database) WalkDaemons(_ context.Context, cb func(info *daemon.ConfigState) error) error

func (*Database) WalkRafsInstances

func (db *Database) WalkRafsInstances(_ context.Context, cb func(r *rafs.Rafs) error) error

WalkDaemons iterates all daemon records and invoke callback on each