drive

Mar 29, 2017

Changes in this version

+ func ValidateRepoName(name string) error

+ type CommitEvent struct

+ Err error

+ Value *pfs.CommitInfo

+ type CommitStream interface

+ Close func()

+ Stream func() <-chan CommitEvent

type Driver

+ func NewLocalDriver(blockAddress string, etcdPrefix string) (Driver, error)

+ BuildCommit func(ctx context.Context, parent *pfs.Commit, branch string, ...) (*pfs.Commit, error)

+ DeleteBranch func(ctx context.Context, repo *pfs.Repo, name string) error

+ GlobFile func(ctx context.Context, commit *pfs.Commit, pattern string) ([]*pfs.FileInfo, error)

+ SetBranch func(ctx context.Context, commit *pfs.Commit, name string) error

+ SubscribeCommit func(ctx context.Context, repo *pfs.Repo, branch string, from *pfs.Commit) (CommitStream, error)

Oct 31, 2016

Changes in this version

+ type ListFileMode int

+ const ListFileFAST

+ const ListFileNORMAL

+ const ListFileRECURSE

Sep 23, 2016

Changes in this version

type Driver

+ ArchiveAll func() error

+ ArchiveCommit func(commit []*pfs.Commit) error

+ FlushCommit func(fromCommits []*pfs.Commit, toRepos []*pfs.Repo) ([]*pfs.CommitInfo, error)

+ ForkCommit func(parent *pfs.Commit, branch string, provenance []*pfs.Commit) (*pfs.Commit, error)

+ ReplayCommit func(fromCommits []*pfs.Commit, toBranch string) ([]*pfs.Commit, error)

+ SquashCommit func(fromCommits []*pfs.Commit, toCommit *pfs.Commit) error

Jul 7, 2016

Changes in this version

+ func IsPermissionError(err error) bool

Jun 28, 2016

Changes in this version

+ func MatchProvenance(want []*pfs.Commit, have []*pfs.Commit) bool

+ type Driver interface

+ AddShard func(shard uint64) error

+ CreateRepo func(repo *pfs.Repo, created *google_protobuf.Timestamp, provenance []*pfs.Repo, ...) error

+ DeleteAll func(shards map[uint64]bool) error

+ DeleteCommit func(commit *pfs.Commit, shards map[uint64]bool) error

+ DeleteFile func(file *pfs.File, shard uint64, unsafe bool, handle string) error

+ DeleteRepo func(repo *pfs.Repo, shards map[uint64]bool) error

+ DeleteShard func(shard uint64) error

+ Dump func()

+ FinishCommit func(commit *pfs.Commit, finished *google_protobuf.Timestamp, cancel bool, ...) error

+ GetFile func(file *pfs.File, filterShard *pfs.Shard, offset int64, size int64, ...) (io.ReadCloser, error)

+ InspectCommit func(commit *pfs.Commit, shards map[uint64]bool) (*pfs.CommitInfo, error)

+ InspectFile func(file *pfs.File, filterShard *pfs.Shard, from *pfs.Commit, shard uint64, ...) (*pfs.FileInfo, error)

+ InspectRepo func(repo *pfs.Repo, shards map[uint64]bool) (*pfs.RepoInfo, error)

+ ListBranch func(repo *pfs.Repo, shards map[uint64]bool) ([]*pfs.CommitInfo, error)

+ ListCommit func(repo []*pfs.Repo, commitType pfs.CommitType, fromCommit []*pfs.Commit, ...) ([]*pfs.CommitInfo, error)

+ ListFile func(file *pfs.File, filterShard *pfs.Shard, from *pfs.Commit, shard uint64, ...) ([]*pfs.FileInfo, error)

+ ListRepo func(provenance []*pfs.Repo, shards map[uint64]bool) ([]*pfs.RepoInfo, error)

+ MakeDirectory func(file *pfs.File, shard uint64) error

+ PutFile func(file *pfs.File, handle string, delimiter pfs.Delimiter, shard uint64, ...) error

+ StartCommit func(repo *pfs.Repo, commitID string, parentID string, branch string, ...) error

+ func NewDriver(blockAddress string) (Driver, error)