scanner

Documentation

Index

• func MakeRegularInode(stat *wsyscall.Stat_t) *filesystem.RegularInode
• func MakeSpecialInode(stat *wsyscall.Stat_t) *filesystem.SpecialInode
• func MakeSymlinkInode(stat *wsyscall.Stat_t) *filesystem.SymlinkInode
• func NewCpuLimitedHasher(cpuLimiter *cpulimiter.CpuLimiter, hasher Hasher) cpuLimitedHasher
• type FileSystem
  • func ScanFileSystem(rootDirectoryName string, fsScanContext *fsrateio.ReaderContext, ...) (*FileSystem, error)
  • func ScanFileSystemWithParams(params Params) (*FileSystem, error)
  • func (fs *FileSystem) GetObject(hashVal hash.Hash) (uint64, io.ReadCloser, error)
• type Hasher
  • func GetSimpleHasher(ignoreShortReads bool) Hasher
• type Params

Functions

func MakeRegularInode

func MakeRegularInode(stat *wsyscall.Stat_t) *filesystem.RegularInode

func MakeSpecialInode

func MakeSpecialInode(stat *wsyscall.Stat_t) *filesystem.SpecialInode

func MakeSymlinkInode

func MakeSymlinkInode(stat *wsyscall.Stat_t) *filesystem.SymlinkInode

func NewCpuLimitedHasher

func NewCpuLimitedHasher(cpuLimiter *cpulimiter.CpuLimiter,
	hasher Hasher) cpuLimitedHasher

Types

type FileSystem

type FileSystem struct {
	filesystem.FileSystem
	// contains filtered or unexported fields
}

func ScanFileSystem

func ScanFileSystem(rootDirectoryName string,
	fsScanContext *fsrateio.ReaderContext, scanFilter *filter.Filter,
	checkScanDisableRequest func() bool, hasher Hasher, oldFS *FileSystem) (
	*FileSystem, error)

func ScanFileSystemWithParams

func ScanFileSystemWithParams(params Params) (*FileSystem, error)

func (*FileSystem) GetObject

func (fs *FileSystem) GetObject(hashVal hash.Hash) (
	uint64, io.ReadCloser, error)

type Hasher

type Hasher interface {
	Hash(reader io.Reader, length uint64) (hash.Hash, error)
}

func GetSimpleHasher

func GetSimpleHasher(ignoreShortReads bool) Hasher

type Params

type Params struct {
	FsScanContext           *fsrateio.ReaderContext
	RootDirectoryName       string
	Runner                  concurrent.MeasuringRunner
	ScanFilter              *filter.Filter
	CheckScanDisableRequest func() bool
	Hasher                  Hasher
	OldFS                   *FileSystem
}