pfs

Documentation

Index

• func BlockInShard(shard *pfs.Shard, file *pfs.File, block *pfs.Block) bool
• func ByteRangeSize(byteRange *pfs.ByteRange) uint64
• func FileInShard(shard *pfs.Shard, file *pfs.File) bool
• func ReduceCommitInfos(commitInfos []*pfs.CommitInfo) []*pfs.CommitInfo
• func ReduceFileInfos(fileInfos []*pfs.FileInfo) []*pfs.FileInfo
• func ReduceRepoInfos(repoInfos []*pfs.RepoInfo) []*pfs.RepoInfo
• type ErrCommitExists
  • func (e ErrCommitExists) Error() string
• type ErrCommitFinished
  • func (e ErrCommitFinished) Error() string
• type ErrCommitNotFound
  • func (e ErrCommitNotFound) Error() string
• type ErrFileNotFound
  • func (e ErrFileNotFound) Error() string
• type ErrParentCommitNotFound
  • func (e ErrParentCommitNotFound) Error() string
• type ErrRepoExists
  • func (e ErrRepoExists) Error() string
• type ErrRepoNotFound
  • func (e ErrRepoNotFound) Error() string
• type Hasher
  • func NewHasher(fileModulus uint64, blockModulus uint64) *Hasher
  • func (s *Hasher) HashBlock(file *pfs.File, block *pfs.Block) uint64
  • func (s *Hasher) HashFile(file *pfs.File) uint64

Functions

func BlockInShard

func BlockInShard(shard *pfs.Shard, file *pfs.File, block *pfs.Block) bool

BlockInShard returns true if the block is in the given shard.

func ByteRangeSize

func ByteRangeSize(byteRange *pfs.ByteRange) uint64

ByteRangeSize returns byteRange.Upper - byteRange.Lower.

func FileInShard

func FileInShard(shard *pfs.Shard, file *pfs.File) bool

FileInShard checks if a given file belongs in a given shard, using only the file's top-level path. That is, for a path like foo/bar/buzz, FileInShard only considers foo

func ReduceCommitInfos

func ReduceCommitInfos(commitInfos []*pfs.CommitInfo) []*pfs.CommitInfo

ReduceCommitInfos combines commit info for each commit id, resolving writes and adding byte-sizes together as appropriate.

func ReduceFileInfos

func ReduceFileInfos(fileInfos []*pfs.FileInfo) []*pfs.FileInfo

ReduceFileInfos combines file info for each file path, taking the latest modification time for each path and combining their children.

func ReduceRepoInfos

func ReduceRepoInfos(repoInfos []*pfs.RepoInfo) []*pfs.RepoInfo

ReduceRepoInfos combines repo info for each named repo, adding byte-sizes together as appropriate.

Types

type ErrCommitExists

type ErrCommitExists struct {
	Commit *pfs.Commit
}

ErrCommitExists represents an error where the commit already exists.

func (ErrCommitExists) Error

func (e ErrCommitExists) Error() string

type ErrCommitFinished

type ErrCommitFinished struct {
	Commit *pfs.Commit
}

ErrCommitFinished represents an error where the commit has been finished.

func (ErrCommitFinished) Error

func (e ErrCommitFinished) Error() string

type ErrCommitNotFound

type ErrCommitNotFound struct {
	Commit *pfs.Commit
}

ErrCommitNotFound represents a commit-not-found error.

func (ErrCommitNotFound) Error

func (e ErrCommitNotFound) Error() string

type ErrFileNotFound

type ErrFileNotFound struct {
	File *pfs.File
}

ErrFileNotFound represents a file-not-found error.

func (ErrFileNotFound) Error

func (e ErrFileNotFound) Error() string

type ErrParentCommitNotFound

type ErrParentCommitNotFound struct {
	Commit *pfs.Commit
}

ErrParentCommitNotFound represents a parent-commit-not-found error.

func (ErrParentCommitNotFound) Error

func (e ErrParentCommitNotFound) Error() string

type ErrRepoExists

type ErrRepoExists struct {
	Repo *pfs.Repo
}

ErrRepoExists represents a repo-exists error.

func (ErrRepoExists) Error

func (e ErrRepoExists) Error() string

type ErrRepoNotFound

type ErrRepoNotFound struct {
	Repo *pfs.Repo
}

ErrRepoNotFound represents a repo-not-found error.

func (ErrRepoNotFound) Error

func (e ErrRepoNotFound) Error() string

type Hasher

type Hasher struct {
	FileModulus  uint64
	BlockModulus uint64
}

A Hasher represents a file/block hasher.

func NewHasher

func NewHasher(fileModulus uint64, blockModulus uint64) *Hasher

NewHasher creates a Hasher.

func (*Hasher) HashBlock

func (s *Hasher) HashBlock(file *pfs.File, block *pfs.Block) uint64

HashBlock computes and returns a hash of a block.

func (*Hasher) HashFile

func (s *Hasher) HashFile(file *pfs.File) uint64

HashFile computes and returns a hash of a file.