Versions in this module Expand all Collapse all v0 v0.9.0 Jul 23, 2015 Changes in this version + var ErrInvalidObject = errors.New("pfs: invalid object") + var ErrIsDirectory = errors.New("pfs: is directory") + var ErrNoShards = errors.New("pfs: no shards") + var ErrOverallocated = errors.New("pfs: overallocated") + func NewShardHTTPHandler(shard Shard) http.Handler + func RunWorkload(t require.TestingT, url string, w traffic.Workload) + type Branch struct + ModTime time.Time + Name string + type Commit struct + ModTime time.Time + Name string + type File struct + File *os.File + ModTime time.Time + Name string + type Filesystem interface + BranchCreate func(name string, commit string) (Branch, error) + BranchGet func(name string) (Branch, error) + BranchList func() ([]Branch, error) + CommitCreate func(name string, branch string) (Commit, error) + CommitGet func(name string) (Commit, error) + CommitList func() ([]Commit, error) + FileCreate func(name string, content io.Reader, branch string) error + FileGet func(name string, commit string) (File, error) + FileGetAll func(name string, commit string) ([]File, error) + PipelineCreate func(name string, content io.Reader, branch string) error + PipelineFileGet func(pipelineName string, fileName string, commit string) (File, error) + PipelineFileGetAll func(pipelineName string, fileName string, commit string, shard string) ([]File, error) + PipelineWait func(name string, commit string) error + type Replica interface + From func() (string, error) + Pull func(from string, p btrfs.Pusher) error + Push func(diff io.Reader) error + type Shard interface + EnsureRepos func() error + FillRole func() + FindRole func() + func NewShard(url string, dataRepo string, pipelinePrefix string, shardNum uint64, ...) Shard