btrfs

package

v0.7.1 Latest Latest Go to latest Published: May 22, 2015 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pachyderm/pfs

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func BasePath(name string) string
func Branch(repo, commit, branch string) error
func Commit(repo, commit, branch string) error
func Commits(repo, from string, order int, cont func(CommitInfo) error) error
func CopyFile(name string, r io.Reader) (int64, error)
func Create(name string) (*os.File, error)
func CreateAll(name string) (*os.File, error)
func CreateFromReader(name string, r io.Reader) (int64, error)
func Ensure(repo string) error
func EnsureReplica(repo string) error
func FileExists(name string) (bool, error)
func FilePath(name string) string
func FindNew(repo, from, to string) ([]string, error)
func GetFrom(repo string) (string, error)
func GetMeta(name, key string) string
func Hold(repo, commit string) (string, error)
func Init(repo string) error
func InitReplica(repo string) error
func IsReadOnly(volume string) (bool, error)
func LazyWalk(name string, f func(string) error) error
func Link(oldname, newname string) error
func Log(repo, from string, order int, cont func(io.Reader) error) error
func Lstat(name string) (os.FileInfo, error)
func Mkdir(name string) error
func MkdirAll(name string) error
func Open(name string) (*os.File, error)
func OpenFd(name string, mode int, perm uint32) (int, error)
func OpenFile(name string, flag int, perm os.FileMode) (*os.File, error)
func Pull(repo, from string, cb Pusher) error
func RandSeq(n int) string
func ReadDir(name string) ([]os.FileInfo, error)
func ReadFile(name string) ([]byte, error)
func Readlink(name string) (string, error)
func Recv(repo string, data io.Reader) error
func Release(name string)
func Remove(name string) error
func RemoveAll(name string) error
func Rename(oldname, newname string) error
func Send(repo, commit string, cont func(io.Reader) error) error
func SetMeta(branch, key, value string) error
func SetReadOnly(volume string) error
func Snapshot(volume string, dest string, readonly bool) error
func Stat(name string) (os.FileInfo, error)
func SubvolumeCreate(name string) error
func SubvolumeDelete(name string) error
func SubvolumeDeleteAll(name string) error
func Symlink(oldname, newname string) error
func Sync() error
func TrimFilePath(name string) string
func UnsetReadOnly(volume string) error
func WaitForFile(name string) error
func WriteFile(name string, data []byte) error
type CommitInfo
type LocalReplica
- func NewLocalReplica(repo string) *LocalReplica
- func (r LocalReplica) Pull(from string, cb Pusher) error
- func (r LocalReplica) Push(diff io.Reader) error
type Puller
type Pusher
type Replica
type S3Replica
- func NewS3Replica(uri string) *S3Replica
- func (r *S3Replica) Pull(from string, target Pusher) error
- func (r *S3Replica) Push(diff io.Reader) error

Constants ¶

View Source

const (
	Desc = iota
	Asc  = iota
)

Constants used for passing to log

Variables ¶

View Source

var Complete = errors.New("Complete")

Functions ¶

func BasePath ¶

func BasePath(name string) string

func Branch ¶

func Branch(repo, commit, branch string) error

func Commit ¶

func Commit(repo, commit, branch string) error

Commit creates a new commit for a branch.

func Commits ¶

func Commits(repo, from string, order int, cont func(CommitInfo) error) error

Commits is a wrapper around `Log` which parses the output in to a convenient struct

func CopyFile ¶ added in v0.7.1

func CopyFile(name string, r io.Reader) (int64, error)

func Create ¶

func Create(name string) (*os.File, error)

func CreateAll ¶

func CreateAll(name string) (*os.File, error)

func CreateFromReader ¶

func CreateFromReader(name string, r io.Reader) (int64, error)

func Ensure ¶

func Ensure(repo string) error

Ensure is like Init but won't error if the repo is already present. It will error if the repo is not present and we fail to make it.

func EnsureReplica ¶ added in v0.7.1

func EnsureReplica(repo string) error

func FileExists ¶

func FileExists(name string) (bool, error)

func FilePath ¶

func FilePath(name string) string

func FindNew ¶

func FindNew(repo, from, to string) ([]string, error)

FindNew returns an array of filenames that were created between `from` and `to`

func GetFrom ¶ added in v0.7.1

func GetFrom(repo string) (string, error)

GetFrom returns the commit that this repo should pass to Pull to get itself up to date.

func GetMeta ¶ added in v0.7.1

func GetMeta(name, key string) string

GetMeta gets metadata from a commit.

func Hold ¶

func Hold(repo, commit string) (string, error)

Hold creates a temporary snapshot of a commit that no one else knows about. It's your responsibility to release the snapshot with Release

func Init ¶

func Init(repo string) error

Init initializes an empty repo.

func InitReplica ¶ added in v0.7.1

func InitReplica(repo string) error

func IsReadOnly ¶ added in v0.7.1

func IsReadOnly(volume string) (bool, error)

func LazyWalk ¶

func LazyWalk(name string, f func(string) error) error

func Link ¶

func Link(oldname, newname string) error

func Log ¶

func Log(repo, from string, order int, cont func(io.Reader) error) error

Log returns all of the commits the repo which have generation >= from.

func Lstat ¶ added in v0.7.1

func Lstat(name string) (os.FileInfo, error)

func Mkdir ¶

func Mkdir(name string) error

func MkdirAll ¶

func MkdirAll(name string) error

TODO(rw,jd): check into atomicity/race conditions with multiple callers

func Open ¶

func Open(name string) (*os.File, error)

func OpenFd ¶ added in v0.7.1

func OpenFd(name string, mode int, perm uint32) (int, error)

func OpenFile ¶

func OpenFile(name string, flag int, perm os.FileMode) (*os.File, error)

func Pull ¶

func Pull(repo, from string, cb Pusher) error

func RandSeq ¶

func RandSeq(n int) string

Generates a random sequence of letters. Useful for making filesystems that won't interfere with each other. This should be factored out to another file.

func ReadDir ¶

func ReadDir(name string) ([]os.FileInfo, error)

func ReadFile ¶ added in v0.7.1

func ReadFile(name string) ([]byte, error)

func Readlink ¶

func Readlink(name string) (string, error)

func Recv ¶

func Recv(repo string, data io.Reader) error

func Release ¶

func Release(name string)

Release releases commit snapshots held by Hold.

func Remove ¶

func Remove(name string) error

func RemoveAll ¶ added in v0.7.1

func RemoveAll(name string) error

func Rename ¶

func Rename(oldname, newname string) error

func Send ¶

func Send(repo, commit string, cont func(io.Reader) error) error

func SetMeta ¶ added in v0.7.1

func SetMeta(branch, key, value string) error

SetMeta sets metadata for a branch.

func SetReadOnly ¶

func SetReadOnly(volume string) error

func Snapshot ¶

func Snapshot(volume string, dest string, readonly bool) error

func Stat ¶ added in v0.7.1

func Stat(name string) (os.FileInfo, error)

func SubvolumeCreate ¶

func SubvolumeCreate(name string) error

func SubvolumeDelete ¶

func SubvolumeDelete(name string) error

func SubvolumeDeleteAll ¶ added in v0.7.1

func SubvolumeDeleteAll(name string) error

func Symlink ¶

func Symlink(oldname, newname string) error

func Sync ¶

func Sync() error

func TrimFilePath ¶

func TrimFilePath(name string) string

func UnsetReadOnly ¶

func UnsetReadOnly(volume string) error

func WaitForFile ¶ added in v0.7.1

func WaitForFile(name string) error

func WriteFile ¶

func WriteFile(name string, data []byte) error

Types ¶

type CommitInfo ¶

type CommitInfo struct {
	Path string
	// contains filtered or unexported fields
}

type LocalReplica ¶ added in v0.7.1

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

A LocalReplica implements the CommitBrancher interface and replicates the commits to a local repo. It expects `repo` to already exist

func NewLocalReplica ¶ added in v0.7.1

func NewLocalReplica(repo string) *LocalReplica

func (LocalReplica) Pull ¶ added in v0.7.1

func (r LocalReplica) Pull(from string, cb Pusher) error

func (LocalReplica) Push ¶ added in v0.7.1

func (r LocalReplica) Push(diff io.Reader) error

type Puller ¶ added in v0.7.1

type Puller interface {
	// Pull pulls data from a replica and applies it to the target,
	// `from` is used to pickup where you left-off, passing `from=""` will start from the beginning
	// Pull returns the value that should be passed next as `from`
	Pull(from string, target Pusher) error
}

type Pusher ¶ added in v0.7.1

type Pusher interface {
	Push(diff io.Reader) error
}

type Replica ¶ added in v0.7.1

type Replica interface {
	Pusher
	Puller
}

type S3Replica ¶ added in v0.7.1

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

func NewS3Replica ¶ added in v0.7.1

func NewS3Replica(uri string) *S3Replica

func (*S3Replica) Pull ¶ added in v0.7.1

func (r *S3Replica) Pull(from string, target Pusher) error

func (*S3Replica) Push ¶ added in v0.7.1

func (r *S3Replica) Push(diff io.Reader) error

Source Files ¶

View all Source files

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