fs

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 13, 2022 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EnEmpty   = int8(0)
	EnPartial = int8(1) // Planning not to implemented
	EnRoLayer = int8(2)
	EnRwLayer = int8(3)
)
View Source 
const (
	DebugTrace = false
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ByAccessTime 

type ByAccessTime []*TraceItem

////////////////////////

func (ByAccessTime) Len 

func (b ByAccessTime) Len() int

func (ByAccessTime) Less 

func (b ByAccessTime) Less(i, j int) bool

func (ByAccessTime) Swap 

func (b ByAccessTime) Swap(i, j int)

type ByAccessTimeOptimized 

type ByAccessTimeOptimized []*OptimizedTraceItem

////////////////////////

func (ByAccessTimeOptimized) Len 

func (bo ByAccessTimeOptimized) Len() int

func (ByAccessTimeOptimized) Less 

func (bo ByAccessTimeOptimized) Less(i, j int) bool

func (ByAccessTimeOptimized) Swap 

func (bo ByAccessTimeOptimized) Swap(i, j int)

type Entry 

type Entry struct {
	*util.TraceableEntry

	State int8
	// contains filtered or unexported fields
}

--------------------------------------------------------------------------------------- Entry

func (*Entry) AddChild 

func (en *Entry) AddChild(base string, entry TocEntry)

func (*Entry) GetEntry 

func (en *Entry) GetEntry() *Entry

func (*Entry) GetInterface 

func (en *Entry) GetInterface() TocEntry

func (*Entry) String 

func (en *Entry) String() string

type FsEntry 

type FsEntry struct {
	Entry

	StateMu sync.Mutex
	// contains filtered or unexported fields
}

--------------------------------------------------------------------------------------- FsEntry

func NewFsEntry 

func NewFsEntry(fi *FsInstance, t *TemplateEntry) *FsEntry

func (*FsEntry) AtomicGetFileState 

func (fe *FsEntry) AtomicGetFileState() int8

func (*FsEntry) AtomicGetRealPath 

func (fe *FsEntry) AtomicGetRealPath() string

AtomicGetRealPath returns the absolute path in the real file system be aware that this method will lock StateMu

func (*FsEntry) AtomicSetFileState 

func (fe *FsEntry) AtomicSetFileState(from, to int8) bool

func (*FsEntry) Children 

func (fe *FsEntry) Children() *map[string]TocEntry

func (*FsEntry) GetAttrFromEntry 

func (fe *FsEntry) GetAttrFromEntry(out *fuse.Attr) syscall.Errno

GetAttrFromEntry converts stargz's TOCEntry to go-fuse's Attr. From estargz

func (*FsEntry) GetAttrFromFs 

func (fe *FsEntry) GetAttrFromFs(st *syscall.Stat_t) syscall.Errno

func (*FsEntry) GetChildren 

func (fe *FsEntry) GetChildren() *map[string]TocEntry

func (*FsEntry) GetFileMode 

func (fe *FsEntry) GetFileMode() uint32

func (*FsEntry) GetParent 

func (fe *FsEntry) GetParent() *FsEntry

func (*FsEntry) GetRoLayerPath 

func (fe *FsEntry) GetRoLayerPath() string

GetRoLayerPath returns the absolute path to the RO layer in the real file system this method will NOT lock StateMu

func (*FsEntry) GetRwLayerPath 

func (fe *FsEntry) GetRwLayerPath() string

GetRwLayerPath returns the absolute path to the RW layer in the real file system this method will NOT lock StateMu

func (*FsEntry) GetStableAttr 

func (fe *FsEntry) GetStableAttr() *fuseFs.StableAttr

func (*FsEntry) IsRoot 

func (fe *FsEntry) IsRoot() bool

func (*FsEntry) LookUp 

func (fe *FsEntry) LookUp(base string) (*FsEntry, bool)

func (*FsEntry) Promote 

func (fe *FsEntry) Promote() syscall.Errno

func (*FsEntry) RemoveChild 

func (fe *FsEntry) RemoveChild(baseName string)

type FsInstance 

type FsInstance struct {
	Root *FsEntry
	// contains filtered or unexported fields
}

FsInstance should be created using

func (*FsInstance) GetImageName 

func (fi *FsInstance) GetImageName() string

func (*FsInstance) GetImageTag 

func (fi *FsInstance) GetImageTag() string

func (*FsInstance) GetMountPoint 

func (fi *FsInstance) GetMountPoint() string

func (*FsInstance) GetRwLayerHash 

func (fi *FsInstance) GetRwLayerHash() digest.Digest

func (*FsInstance) GetRwLayerPath 

func (fi *FsInstance) GetRwLayerPath() string

func (*FsInstance) GetRwTraceableBlobDigest 

func (fi *FsInstance) GetRwTraceableBlobDigest() util.TraceableBlobDigest

func (*FsInstance) GetServer 

func (fi *FsInstance) GetServer() *fuse.Server

func (*FsInstance) NewFuseServer 

func (fi *FsInstance) NewFuseServer(dir string, options *fs.Options, debug bool) (*fuse.Server, error)

func (*FsInstance) SetOptimizerOn 

func (fi *FsInstance) SetOptimizerOn(optimizeGroup string) (err error)

func (*FsInstance) Teardown 

func (fi *FsInstance) Teardown() error

Teardown unmounts the file system and close the logging file if there is one writing

type LandmarkEntry 

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

func (*LandmarkEntry) AddChild 

func (le *LandmarkEntry) AddChild(base string, entry TocEntry)

func (*LandmarkEntry) GetEntry 

func (le *LandmarkEntry) GetEntry() *Entry

func (*LandmarkEntry) GetInterface 

func (le *LandmarkEntry) GetInterface() TocEntry

func (*LandmarkEntry) String 

func (le *LandmarkEntry) String() string

type LayerMeta 

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

func NewLayerMeta 

func NewLayerMeta(absPath string, writable, complete bool) *LayerMeta

func (*LayerMeta) AtomicIsComplete 

func (ls *LayerMeta) AtomicIsComplete() bool

func (*LayerMeta) AtomicSetCompleted 

func (ls *LayerMeta) AtomicSetCompleted() error

func (*LayerMeta) GetAbsPath 

func (ls *LayerMeta) GetAbsPath() string

func (*LayerMeta) IsWritable 

func (ls *LayerMeta) IsWritable() bool

func (*LayerMeta) String 

func (ls *LayerMeta) String() string

func (*LayerMeta) ToByte 

func (ls *LayerMeta) ToByte() []byte

type LayerStore 

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

func NewLayerStore 

func NewLayerStore(ctx context.Context, db *bolt.DB, workDir string) (*LayerStore, error)

func (*LayerStore) FindLayer 

func (s *LayerStore) FindLayer(digest util.TraceableBlobDigest) (*LayerMeta, error)

func (*LayerStore) GetWorkDir 

func (s *LayerStore) GetWorkDir() string

func (*LayerStore) RegisterLayer 

func (s *LayerStore) RegisterLayer(digest util.TraceableBlobDigest, writable, complete bool) (*LayerMeta, error)

func (*LayerStore) RegisterLayerWithAbsolutePath 

func (s *LayerStore) RegisterLayerWithAbsolutePath(digest util.TraceableBlobDigest, lay *LayerMeta) (*LayerMeta, error)

func (*LayerStore) RegisterLayerWithPath 

func (s *LayerStore) RegisterLayerWithPath(digest util.TraceableBlobDigest, lay *LayerMeta) (*LayerMeta, error)

func (*LayerStore) RegisterLayerWithPrefix 

func (s *LayerStore) RegisterLayerWithPrefix(prefix string, count int, digest util.TraceableBlobDigest, writable, complete bool) (*LayerMeta, error)

func (*LayerStore) RemoveLayer 

func (s *LayerStore) RemoveLayer(digest util.TraceableBlobDigest, removeFile bool) error

type OptimizedGroup 

type OptimizedGroup struct {
	History []*OptimizedTraceItem `json:"h"`
	Images  []*util.ImageRef      `json:"i"`
}

type OptimizedTraceItem 

type OptimizedTraceItem struct {
	TraceItem
	Rank        int `json:"r"`
	SourceImage int `json:"s"`
}

OptimizedTraceItem with ranking

func (OptimizedTraceItem) Key 

func (oti OptimizedTraceItem) Key() string

type Receiver 

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

func NewReceiver 

func NewReceiver(ctx context.Context, layerStore *LayerStore, reader io.Reader, headerOffset int64, prefix string, cb func()) (*Receiver, error)

NewReceiver reads image from reader and save it to layerStore

- ctx: context - layerStore: stores the layers - reader: image reader - tocOffset: size of the TOC in reader - prefix: to store the layers in one single folder (snapshot id)

func NewReceiverFromFile 

func NewReceiverFromFile(ctx context.Context, layerStore *LayerStore, filename string, headerOffset int64) (*Receiver, error)

func (*Receiver) ExtractFiles 

func (r *Receiver) ExtractFiles()

func (*Receiver) GetLayerMounts 

func (r *Receiver) GetLayerMounts() []mount.Mount

func (*Receiver) NewFsInstance 

func (r *Receiver) NewFsInstance(imageName, imageTag, snapshotId string, optimize bool, optimizeGroup string) (*FsInstance, error)

/////////////////////////////////////////////////////////////// NewFsInstance creates new file system instance, - imageName, imageTag should be available in ImageReader. imageLookupMap - snapshotId is the absolute path will be created to hold the rw layer and the mounting point. - checkpoint is the starting point for the image reader - optimize determines whether the file system should collect access traces for optimization

type StarlightFsNode 

type StarlightFsNode struct {
	//I is a pointer to fs.Inode
	fs.Inode

	// Ent is a pointer to delta.FsEntry via delta.TocEntry interface
	Ent *FsEntry
}

func (*StarlightFsNode) Create 

func (n *StarlightFsNode) Create(ctx context.Context, name string, flags uint32, mode uint32, out *fuse.EntryOut) (*fs.Inode, fs.FileHandle, uint32, syscall.Errno)

func (*StarlightFsNode) FileReadyWait 

func (n *StarlightFsNode) FileReadyWait()

func (*StarlightFsNode) Fsync 

func (n *StarlightFsNode) Fsync(ctx context.Context, f fs.FileHandle, flags uint32) syscall.Errno

func (*StarlightFsNode) Getattr 

func (n *StarlightFsNode) Getattr(ctx context.Context, fh fs.FileHandle, out *fuse.AttrOut) syscall.Errno

func (*StarlightFsNode) Getxattr 

func (n *StarlightFsNode) Getxattr(ctx context.Context, attr string, dest []byte) (uint32, syscall.Errno)
func (n *StarlightFsNode) Link(ctx context.Context, target fs.InodeEmbedder, name string, out *fuse.EntryOut) (node *fs.Inode, errno syscall.Errno)

func (*StarlightFsNode) Listxattr 

func (n *StarlightFsNode) Listxattr(ctx context.Context, dest []byte) (uint32, syscall.Errno)

func (*StarlightFsNode) Lookup 

func (n *StarlightFsNode) Lookup(ctx context.Context, name string, out *fuse.EntryOut) (*fs.Inode, syscall.Errno)

func (*StarlightFsNode) Mkdir 

func (n *StarlightFsNode) Mkdir(ctx context.Context, name string, mode uint32, out *fuse.EntryOut) (*fs.Inode, syscall.Errno)

func (*StarlightFsNode) Mknod 

func (n *StarlightFsNode) Mknod(ctx context.Context, name string, mode, rdev uint32, out *fuse.EntryOut) (*fs.Inode, syscall.Errno)

func (*StarlightFsNode) Open 

func (n *StarlightFsNode) Open(ctx context.Context, flags uint32) (fs.FileHandle, uint32, syscall.Errno)

func (*StarlightFsNode) Readdir 

func (n *StarlightFsNode) Readdir(ctx context.Context) (fs.DirStream, syscall.Errno)
func (n *StarlightFsNode) Readlink(ctx context.Context) ([]byte, syscall.Errno)

func (*StarlightFsNode) Removexattr 

func (n *StarlightFsNode) Removexattr(ctx context.Context, attr string) syscall.Errno

func (*StarlightFsNode) Rename 

func (n *StarlightFsNode) Rename(ctx context.Context, name string, newParent fs.InodeEmbedder, newName string, flags uint32) syscall.Errno

func (*StarlightFsNode) Rmdir 

func (n *StarlightFsNode) Rmdir(ctx context.Context, name string) syscall.Errno

func (*StarlightFsNode) Setattr 

func (n *StarlightFsNode) Setattr(ctx context.Context, fh fs.FileHandle, in *fuse.SetAttrIn, out *fuse.AttrOut) syscall.Errno

func (*StarlightFsNode) Setxattr 

func (n *StarlightFsNode) Setxattr(ctx context.Context, attr string, data []byte, flags uint32) syscall.Errno

func (*StarlightFsNode) Statfs 

func (n *StarlightFsNode) Statfs(ctx context.Context, out *fuse.StatfsOut) syscall.Errno
func (n *StarlightFsNode) Symlink(ctx context.Context, target, name string, out *fuse.EntryOut) (*fs.Inode, syscall.Errno)
func (n *StarlightFsNode) Unlink(ctx context.Context, name string) syscall.Errno

type TemplateEntry 

type TemplateEntry struct {
	Entry
}

--------------------------------------------------------------------------------------- TemplateEntry

func (*TemplateEntry) DeepCopy 

func (t *TemplateEntry) DeepCopy(fi *FsInstance) *FsEntry

type TocEntry 

type TocEntry interface {
	GetInterface() TocEntry
	GetEntry() *Entry

	AddChild(base string, entry TocEntry)

	String() string
}

--------------------------------------------------------------------------------------- TocEntry interface supports RootEntry and Entry

type TraceCollection 

type TraceCollection struct {
	Groups []*OptimizedGroup
	// contains filtered or unexported fields
}

func NewTraceCollection 

func NewTraceCollection(ctx context.Context, p string) (*TraceCollection, error)

func NewTraceCollectionFromBuffer 

func NewTraceCollectionFromBuffer(buf []byte) (*TraceCollection, error)

func (TraceCollection) ToJSONBuffer 

func (tc TraceCollection) ToJSONBuffer() []byte

type TraceItem 

type TraceItem struct {
	FileName string        `json:"f"`
	Access   time.Duration `json:"a"`
	Wait     time.Duration `json:"w"`
}

////////////////////////

type Tracer 

type Tracer struct {
	// label could be the name of the application or the workload.
	// Different workload might have
	OptimizeGroup string        `json:"group"`
	Image         util.ImageRef `json:"image"`
	StartTime     time.Time     `json:"start"`

	Seq []*TraceItem `json:"seq"`
	// contains filtered or unexported fields
}

////////////////////////

func NewTracer 

func NewTracer(optimizeGroup, imageName, imageTag string) (*Tracer, error)

////////////////////////

func (*Tracer) Close 

func (t *Tracer) Close() error

func (*Tracer) Log 

func (t *Tracer) Log(fileName string, accessTime, completeTime time.Time)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.