lcnode

package
v1.34.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	SnapScanTypeOnlyFile        int = 1
	SnapScanTypeOnlyDirAndDepth int = 2
)
View Source
const (
	ModuleName = "lcNode"
)

Default of configuration value

Variables

This section is empty.

Functions

This section is empty.

Types

type LcNode

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

func NewServer

func NewServer() *LcNode

func (*LcNode) Shutdown

func (l *LcNode) Shutdown()

func (*LcNode) Start

func (l *LcNode) Start(cfg *config.Config) (err error)

func (*LcNode) Sync

func (l *LcNode) Sync()

type LcScanner

type LcScanner struct {
	ID     string
	Volume string
	// contains filtered or unexported fields
}

func NewS3Scanner

func NewS3Scanner(adminTask *proto.AdminTask, l *LcNode) (*LcScanner, error)

func (*LcScanner) DoneScanning

func (s *LcScanner) DoneScanning() bool

func (*LcScanner) FindPrefixInode

func (s *LcScanner) FindPrefixInode() (inode uint64, prefixDirs []string, err error)

func (*LcScanner) Start

func (s *LcScanner) Start() (err error)

func (*LcScanner) Stop

func (s *LcScanner) Stop()

type MetaWrapper

type MetaWrapper interface {
	ReadDirLimitForSnapShotClean(parentID uint64, from string, limit uint64, verSeq uint64, isDir bool) ([]proto.Dentry, error)
	Delete_Ver_ll(parentID uint64, name string, isDir bool, verSeq uint64, fullPath string) (*proto.InodeInfo, error)
	Lookup_ll(parentID uint64, name string) (inode uint64, mode uint32, err error)
	BatchInodeGet(inodes []uint64) []*proto.InodeInfo
	DeleteWithCond_ll(parentID, cond uint64, name string, isDir bool, fullPath string) (inode *proto.InodeInfo, err error)
	Evict(inode uint64, fullPath string) error
	ReadDirLimit_ll(parentID uint64, from string, limit uint64) ([]proto.Dentry, error)
	Close() error
}

type SnapshotScanner

type SnapshotScanner struct {
	ID     string
	Volume string
	// contains filtered or unexported fields
}

func NewSnapshotScanner

func NewSnapshotScanner(adminTask *proto.AdminTask, l *LcNode) (*SnapshotScanner, error)

func (*SnapshotScanner) DoneScanning

func (s *SnapshotScanner) DoneScanning() bool

func (*SnapshotScanner) Start

func (s *SnapshotScanner) Start()

func (*SnapshotScanner) Stop

func (s *SnapshotScanner) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL