Versions in this module Expand all Collapse all v0 v0.3.1 Nov 28, 2016 v0.3.0 Nov 27, 2016 Changes in this version + const KeySize + var ChunkBufferSize = 8 * 1024 * 1024 + var ErrAlreadyPushed = fmt.Errorf("chunk is already pushed to the remote") + var FetchOp = Op("fetch") + var IndexBucket = []byte("index") + var IndexOp = Op("index") + var PushOp = Op("push") + var RemoteBranchSuffix = "bits-remote" + var RemoteChunk = []byte + var StageOp = Op("stage") + type Chunk []byte + type Conf struct + AWSAccessKeyID string + AWSS3BucketName string + AWSSecretAccessKey string + DeduplicationScope uint64 + func DefaultConf() *Conf + func (conf *Conf) OverwriteFromGit(repo *Repository) (err error) + type K [KeySize]byte + type KeyOp struct + CopyN int64 + K K + Op Op + Skipped bool + type Op string + type Remote interface + ChunkReader func(k K) (rc io.ReadCloser, err error) + ChunkWriter func(k K) (wc io.WriteCloser, err error) + ListChunks func(w io.Writer) (err error) + type Repository struct + KeyProgressFn func(KeyOp, float64) + func NewRepository(dir string, output io.Writer) (repo *Repository, err error) + func (repo *Repository) Combine(r io.Reader, w io.Writer) (err error) + func (repo *Repository) Fetch(r io.Reader, w io.Writer) (err error) + func (repo *Repository) ForEach(r io.Reader, fn func(K) error) error + func (repo *Repository) Git(ctx context.Context, in io.Reader, out io.Writer, args ...string) (err error) + func (repo *Repository) Install(w io.Writer, conf *Conf) (err error) + func (repo *Repository) LocalStore() (db *bolt.DB, err error) + func (repo *Repository) Path(k K, mkdir bool) (p string, err error) + func (repo *Repository) Pull(ref string, w io.Writer) (err error) + func (repo *Repository) Push(store *bolt.DB, r io.Reader, remoteName string) (err error) + func (repo *Repository) Scan(left, right string, w io.Writer) (err error) + func (repo *Repository) ScanEach(r io.Reader, w io.Writer) (err error) + func (repo *Repository) Split(r io.Reader, w io.Writer) (err error) + type S3Remote struct + func NewS3Remote(repo *Repository, remote, bucket, accessKey, secretKey string) (s3 *S3Remote, err error) + func (s *S3Remote) ChunkReader(k K) (rc io.ReadCloser, err error) + func (s *S3Remote) ChunkWriter(k K) (wc io.WriteCloser, err error) + func (s *S3Remote) ListChunks(w io.Writer) (err error) + func (s3 *S3Remote) Name() string
Go to main page