casfuse

type API interface {
	Type(inode Inode) cas.FileMode
	// Check if the path has been modified locally and not committed to the store
	Dirty(inode Inode) (bool, error)
	// DirList get a directory listing hash
	DirList(ctx context.Context, inode Inode) (hash.Hash, error)
	// Loaded check if the content at the path has been loaded locally
	Loaded(inode Inode) (bool, error)
	// Excluded check if the path is excluded from parent's hash calculation
	Excluded(inode Inode) (bool, error)
	// SetExcluded sets the excluded attribute
	SetExcluded(inode Inode, val bool) error
	// Hash if dirty the contents are stored to the store with a new hash value
	Hash(ctx context.Context, inode Inode) (hash.Hash, error)
	// SetHash set the hash of the path, only valid if the path is not yet loaded.
	SetHash(inode Inode, hash hash.Hash) error
	// HashStat get the hash,mode, and size of the path
	HashStat(ctx context.Context, inode Inode) (*fs.HashStat, error)
	// HashSet get the hash,size of a file at the given path.
	HashSize(ctx context.Context, inode Inode) (hash.Hash, int64, error)
	// SetHashSize set the hash,size for a file at the given path, only valid if the path
	// is not yet loaded.
	SetHashSize(inode Inode, hash hash.Hash, size int64) error
	// SetDeepTree set the deep tree hash for the given directory path, only valid if
	// the path is not yet loaded.  After setting the deep tree hash all children
	// nodes can answer Stat() call without accessing the backend.
	SetDeepTree(inode Inode, hash hash.Hash) error
	// Debug get the debug attribute of the path.
	Debug(inode Inode) (bool, error)
	// SetDebug set dynamic debug for the given path
	SetDebug(inode Inode, val bool) error

	// Create control directory under path
	CreateControl(ctx context.Context, inode Inode, directory string) error
	// Create a non-cas ramfs type directory under the input path
	CreateRamfs(ctx context.Context, inode Inode, directory string) error
	// Create GIT project under given path
	CreateGit(ctx context.Context, inode Inode, directory, head string) error
	// Create GIT objects only under the given path
	CreateGitObjects(ctx context.Context, inode Inode, directory string) error
	// Status of FS
	Status() (*fs.Status, error)
}

type ContextValue struct {
	Pid uint32
}

type Dcache interface {
	Add(d Dentry) error
	Create(dir Dentry, name string) Dentry
	Lookup(dir Dentry, name string) Dentry
	Remove(d Dentry)
	Rename(oldEntry, newEntry Dentry)
	Path(d Dentry) string
	NotifyChange(d Dentry)
	RegisterWatch(DcacheWatch)
}

type DcacheWatch interface {
	Change(Dentry)
}

type Dentry interface {
	Name() string
	Parent() Dentry
	Path() string
	Instantiate(inode Inode)
	IsHashed() bool
	Inode() Inode
	Get()
	Put()
	Ext() any
	SetExt(any)
	Dcache() Dcache
}

type DentryState uint32

type Dir interface {
	Inode

	Entries(ctx context.Context) (map[string]Inode, error)
	Lookup(ctx context.Context, dentry Dentry) (Inode, error)
	Mkdir(ctx context.Context, dentry Dentry, perm cas.FileMode) (Inode, error)
	Remove(ctx context.Context, dentry Dentry) error
	CreateTmpFile(ctx context.Context, dentry Dentry, mode cas.FileMode) (Inode, error)
	CreateFile(ctx context.Context, dentry Dentry, mode cas.FileMode) (Inode, error)
	Symlink(ctx context.Context, dentry Dentry, target string) (Inode, error)
	Rename(ctx context.Context, oldDentry Dentry, newDirInode Inode, newDentry Dentry) error
	Mknod(ctx context.Context, dentry Dentry, mode cas.FileMode, rDev int) (Inode, error)
	Link(ctx context.Context, source Dentry, dentry Dentry) (Inode, error)
}

type ExtType int

type FS interface {
	Ready() bool
	SetReady(bool)

	Root() Dentry
	SetRoot(node Inode) error
	// Try to remove hasher here
	Hasher() hash.Hasher
	GetExt(key ExtType) interface{}
	RegisterExt(key ExtType, any interface{})
	Dcache() Dcache
}

type Fifo interface {
	Inode
}

type File interface {
	Inode
	SetAttr(ctx context.Context, dentry Dentry, size *int64, atime, mtime *time.Time, mode *cas.FileMode)
	Open(ctx context.Context, dentry Dentry, truncate, readOnly bool) error
	Close() error
	Fsync(ctx context.Context) error
	ReadAt(p []byte, off int64) (int, error)
	WriteAt(p []byte, off int64) (int, error)
	Release(ctx context.Context) error
	Flush(ctx context.Context) error
	Fallocate(ctx context.Context, mode int, offset, len int64) error
	Lseek(ctx context.Context, offset int64, whence uint32) (int64, error)
	Poll(ctx context.Context) (bool, bool)
}

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

type Inode interface {
	Mode() cas.FileMode
	Attr(ctx context.Context, dentry Dentry) *NodeAttr
	Ino() uint64
	Size() int64

	CanCache() bool

	FS() FS
}

type NodeAttr struct {
	Ino       uint64
	Size      int64
	Blocks    uint64
	Ctime     time.Time
	Atime     time.Time
	Mtime     time.Time
	Mode      cas.FileMode
	Nlinks    uint32
	Uid       uint32
	Gid       uint32
	Rdev      uint32
	BlockSize uint32
}

type Socket interface {
	Inode
}

type SymLink interface {
	Inode

	Target(ctx context.Context, dentry Dentry) (string, error)
	SetTarget(ctx context.Context, target string)
}