nydus

Documentation

Index

• Constants
• func NewFileSystem(ctx context.Context, opt ...NewFSOpt) (fspkg.FileSystem, error)
• type BlobManager
  • func NewBlobManager(blobDir string) *BlobManager
  • func (b *BlobManager) GetBlobDir() string
  • func (b *BlobManager) Remove(id string, async bool) error
  • func (b *BlobManager) Run(ctx context.Context) error
• type ImageMode
• type NewFSOpt
  • func WithCacheManager(cm *cache.Manager) NewFSOpt
  • func WithDaemonBackend(daemonBackend string) NewFSOpt
  • func WithDaemonConfig(cfg config.DaemonConfig) NewFSOpt
  • func WithDaemonMode(daemonMode string) NewFSOpt
  • func WithImageMode(cfg config.DaemonConfig) NewFSOpt
  • func WithLogDir(dir string) NewFSOpt
  • func WithLogLevel(logLevel string) NewFSOpt
  • func WithLogToStdout(logToStdout bool) NewFSOpt
  • func WithMeta(root string) NewFSOpt
  • func WithNydusdBinaryPath(p string, daemonMode string) NewFSOpt
  • func WithNydusdThreadNum(nydusdThreadNum int) NewFSOpt
  • func WithProcessManager(pm *process.Manager) NewFSOpt
  • func WithVPCRegistry(vpcRegistry bool) NewFSOpt
  • func WithVerifier(verifier *signature.Verifier) NewFSOpt
• type Resolver
  • func NewResolver() *Resolver
  • func (r *Resolver) Resolve(ref, digest string, labels map[string]string) (io.ReadCloser, error)

Constants

const BootstrapFile = "image/image.boot"

const ChunkInfoOffset = 1024 + 128 + 24

const LayerAnnotationNydusBlobIDs = "containerd.io/snapshot/nydus-blob-ids"

TODO: Move snapshotter needed all image annotations to nydus-snapshotter.

const LegacyBootstrapFile = "image.boot"

const MaxSuperBlockSize = 8 * 1024

RafsV6 layout: 1k + SuperBlock(128) + SuperBlockExtener(256) RafsV5 layout: 8K superblock So we only need to read the MaxSuperBlockSize size to include both v5 and v6 superblocks

const RafsV6Magic = 0xE0F5E1E2

const RafsV6SuppeOffset = 1024

Functions

func NewFileSystem

func NewFileSystem(ctx context.Context, opt ...NewFSOpt) (fspkg.FileSystem, error)

NewFileSystem initialize Filesystem instance

Types

type BlobManager

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

func NewBlobManager

func NewBlobManager(blobDir string) *BlobManager

func (*BlobManager) GetBlobDir

func (b *BlobManager) GetBlobDir() string

func (*BlobManager) Remove

func (b *BlobManager) Remove(id string, async bool) error

func (*BlobManager) Run

func (b *BlobManager) Run(ctx context.Context) error

type ImageMode

type ImageMode int

const (
	OnDemand ImageMode = iota
	PreLoad
)

type NewFSOpt

type NewFSOpt func(d *filesystem) error

func WithCacheManager

func WithCacheManager(cm *cache.Manager) NewFSOpt

func WithDaemonBackend

func WithDaemonBackend(daemonBackend string) NewFSOpt

func WithDaemonConfig

func WithDaemonConfig(cfg config.DaemonConfig) NewFSOpt

func WithDaemonMode

func WithDaemonMode(daemonMode string) NewFSOpt

func WithImageMode

func WithImageMode(cfg config.DaemonConfig) NewFSOpt

func WithLogDir

func WithLogDir(dir string) NewFSOpt

func WithLogLevel

func WithLogLevel(logLevel string) NewFSOpt

func WithLogToStdout

func WithLogToStdout(logToStdout bool) NewFSOpt

func WithMeta

func WithMeta(root string) NewFSOpt

func WithNydusdBinaryPath

func WithNydusdBinaryPath(p string, daemonMode string) NewFSOpt

func WithNydusdThreadNum

func WithNydusdThreadNum(nydusdThreadNum int) NewFSOpt

func WithProcessManager

func WithProcessManager(pm *process.Manager) NewFSOpt

func WithVPCRegistry

func WithVPCRegistry(vpcRegistry bool) NewFSOpt

func WithVerifier

func WithVerifier(verifier *signature.Verifier) NewFSOpt

type Resolver

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

func NewResolver

func NewResolver() *Resolver

func (*Resolver) Resolve

func (r *Resolver) Resolve(ref, digest string, labels map[string]string) (io.ReadCloser, error)