package store

import "github.com/containerd/nydus-snapshotter/pkg/store"

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

Source Files ¶

daemonstore.go database.go database_compat.go