tarfs

Documentation

Index

• Constants
• type Manager
  • func NewManager(insecure, checkTarfsHint bool, cacheDirPath, nydusImagePath string, ...) *Manager
  • func (t *Manager) CheckTarfsHintAnnotation(ctx context.Context, ref string, manifestDigest digest.Digest) (bool, error)
  • func (t *Manager) DetachLayer(snapshotID string) error
  • func (t *Manager) ExportBlockData(s storage.Snapshot, perLayer bool, labels map[string]string, ...) ([]string, error)
  • func (t *Manager) GetConcurrentLimiter(ref string) *semaphore.Weighted
  • func (t *Manager) ImageDiskFilePath(blobID string) string
  • func (t *Manager) LayerDiskFilePath(blobID string) string
  • func (t *Manager) MergeLayers(s storage.Snapshot, storageLocater func(string) string) error
  • func (t *Manager) MountTarErofs(snapshotID string, s *storage.Snapshot, labels map[string]string, ...) error
  • func (t *Manager) PrepareLayer(snapshotID, ref string, manifestDigest, layerDigest digest.Digest, ...) error
  • func (t *Manager) UmountTarErofs(snapshotID string) error

Constants

const (
	TarfsStatusInit    = 0
	TarfsStatusPrepare = 1
	TarfsStatusReady   = 2
	TarfsStatusFailed  = 3
)

const (
	MaxManifestConfigSize   = 0x100000
	TarfsLayerBootstrapName = "layer.boot"
	TarfsImageBootstrapName = "image.boot"
	TarfsLayerDiskName      = "layer.disk"
	TarfsImageDiskName      = "image.disk"
)

Types

type Manager

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

func NewManager

func NewManager(insecure, checkTarfsHint bool, cacheDirPath, nydusImagePath string, maxConcurrentProcess int64) *Manager

func (*Manager) CheckTarfsHintAnnotation

func (t *Manager) CheckTarfsHintAnnotation(ctx context.Context, ref string, manifestDigest digest.Digest) (bool, error)

func (*Manager) DetachLayer

func (t *Manager) DetachLayer(snapshotID string) error

func (*Manager) ExportBlockData

func (t *Manager) ExportBlockData(s storage.Snapshot, perLayer bool, labels map[string]string, storageLocater func(string) string) ([]string, error)

func (*Manager) GetConcurrentLimiter

func (t *Manager) GetConcurrentLimiter(ref string) *semaphore.Weighted

func (*Manager) ImageDiskFilePath

func (t *Manager) ImageDiskFilePath(blobID string) string

func (*Manager) LayerDiskFilePath

func (t *Manager) LayerDiskFilePath(blobID string) string

func (*Manager) MergeLayers

func (t *Manager) MergeLayers(s storage.Snapshot, storageLocater func(string) string) error

func (*Manager) MountTarErofs

func (t *Manager) MountTarErofs(snapshotID string, s *storage.Snapshot, labels map[string]string, rafs *rafs.Rafs) error

func (*Manager) PrepareLayer

func (t *Manager) PrepareLayer(snapshotID, ref string, manifestDigest, layerDigest digest.Digest, upperDirPath string) error

func (*Manager) UmountTarErofs

func (t *Manager) UmountTarErofs(snapshotID string) error