pfs

Apr 19, 2018

Changes in this version

+ var CommitState_name = map[int32]string

+ var CommitState_value = map[string]int32

type CommitInfo

+ ReadyProvenance int64

+ func (m *CommitInfo) GetReadyProvenance() int64

+ type CommitState int32

+ const CommitState_FINISHED

+ const CommitState_READY

+ const CommitState_STARTED

+ func (CommitState) EnumDescriptor() ([]byte, []int)

+ func (x CommitState) String() string

type InspectCommitRequest

+ BlockState CommitState

+ func (m *InspectCommitRequest) GetBlockState() CommitState

type SubscribeCommitRequest

+ State CommitState

+ func (m *SubscribeCommitRequest) GetState() CommitState

Mar 27, 2018

Changes in this version

type APIClient

+ CreateBranch func(ctx context.Context, in *CreateBranchRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ InspectBranch func(ctx context.Context, in *InspectBranchRequest, opts ...grpc.CallOption) (*BranchInfo, error)

type APIServer

+ CreateBranch func(context.Context, *CreateBranchRequest) (*google_protobuf.Empty, error)

+ InspectBranch func(context.Context, *InspectBranchRequest) (*BranchInfo, error)

type Branch

+ Repo *Repo

+ func (m *Branch) GetRepo() *Repo

+ func (m *Branch) Marshal() (dAtA []byte, err error)

+ func (m *Branch) MarshalTo(dAtA []byte) (int, error)

+ func (m *Branch) Size() (n int)

+ func (m *Branch) Unmarshal(dAtA []byte) error

type BranchInfo

+ Branch *Branch

+ DirectProvenance []*Branch

+ Provenance []*Branch

+ Subvenance []*Branch

+ func (m *BranchInfo) GetBranch() *Branch

+ func (m *BranchInfo) GetDirectProvenance() []*Branch

+ func (m *BranchInfo) GetProvenance() []*Branch

+ func (m *BranchInfo) GetSubvenance() []*Branch

type CommitInfo

+ BranchProvenance []*Branch

+ ChildCommits []*Commit

+ Subvenance []*CommitRange

+ func (m *CommitInfo) GetBranchProvenance() []*Branch

+ func (m *CommitInfo) GetChildCommits() []*Commit

+ func (m *CommitInfo) GetSubvenance() []*CommitRange

+ type CommitRange struct

+ Lower *Commit

+ Upper *Commit

+ func (*CommitRange) Descriptor() ([]byte, []int)

+ func (*CommitRange) ProtoMessage()

+ func (m *CommitRange) GetLower() *Commit

+ func (m *CommitRange) GetUpper() *Commit

+ func (m *CommitRange) Marshal() (dAtA []byte, err error)

+ func (m *CommitRange) MarshalTo(dAtA []byte) (int, error)

+ func (m *CommitRange) Reset()

+ func (m *CommitRange) Size() (n int)

+ func (m *CommitRange) String() string

+ func (m *CommitRange) Unmarshal(dAtA []byte) error

+ type CreateBranchRequest struct

+ Branch *Branch

+ Head *Commit

+ Provenance []*Branch

+ SBranch string

+ func (*CreateBranchRequest) Descriptor() ([]byte, []int)

+ func (*CreateBranchRequest) ProtoMessage()

+ func (m *CreateBranchRequest) GetBranch() *Branch

+ func (m *CreateBranchRequest) GetHead() *Commit

+ func (m *CreateBranchRequest) GetProvenance() []*Branch

+ func (m *CreateBranchRequest) GetSBranch() string

+ func (m *CreateBranchRequest) Marshal() (dAtA []byte, err error)

+ func (m *CreateBranchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CreateBranchRequest) Reset()

+ func (m *CreateBranchRequest) Size() (n int)

+ func (m *CreateBranchRequest) String() string

+ func (m *CreateBranchRequest) Unmarshal(dAtA []byte) error

type DeleteBranchRequest

+ Force bool

+ func (m *DeleteBranchRequest) GetForce() bool

type FinishCommitRequest

+ Empty bool

+ Tree *Object

+ func (m *FinishCommitRequest) GetEmpty() bool

+ func (m *FinishCommitRequest) GetTree() *Object

+ type InspectBranchRequest struct

+ Branch *Branch

+ func (*InspectBranchRequest) Descriptor() ([]byte, []int)

+ func (*InspectBranchRequest) ProtoMessage()

+ func (m *InspectBranchRequest) GetBranch() *Branch

+ func (m *InspectBranchRequest) Marshal() (dAtA []byte, err error)

+ func (m *InspectBranchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InspectBranchRequest) Reset()

+ func (m *InspectBranchRequest) Size() (n int)

+ func (m *InspectBranchRequest) String() string

+ func (m *InspectBranchRequest) Unmarshal(dAtA []byte) error

type InspectCommitRequest

+ Block bool

+ func (m *InspectCommitRequest) GetBlock() bool

type RepoInfo

+ Branches []*Branch

+ func (m *RepoInfo) GetBranches() []*Branch

Feb 27, 2018

Changes in this version

type BuildCommitRequest

+ ID string

+ func (m *BuildCommitRequest) GetID() string

Jan 11, 2018

Changes in this version

type PutFileRecords

+ Tombstone bool

+ func (m *PutFileRecords) GetTombstone() bool

Dec 11, 2017

Changes in this version

type CommitInfo

+ Description string

+ func (m *CommitInfo) GetDescription() string

type FinishCommitRequest

+ Description string

+ func (m *FinishCommitRequest) GetDescription() string

type StartCommitRequest

+ Description string

+ func (m *StartCommitRequest) GetDescription() string

Nov 15, 2017

Changes in this version

type APIClient

+ ListCommitStream func(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (API_ListCommitStreamClient, error)

type APIServer

+ ListCommitStream func(*ListCommitRequest, API_ListCommitStreamServer) error

+ type API_ListCommitStreamClient interface

+ Recv func() (*CommitInfo, error)

+ type API_ListCommitStreamServer interface

+ Send func(*CommitInfo) error

Oct 18, 2017

Changes in this version

type APIClient

+ GlobFileStream func(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (API_GlobFileStreamClient, error)

+ ListFileStream func(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (API_ListFileStreamClient, error)

type APIServer

+ GlobFileStream func(*GlobFileRequest, API_GlobFileStreamServer) error

+ ListFileStream func(*ListFileRequest, API_ListFileStreamServer) error

+ type API_GlobFileStreamClient interface

+ Recv func() (*FileInfo, error)

+ type API_GlobFileStreamServer interface

+ Send func(*FileInfo) error

+ type API_ListFileStreamClient interface

+ Recv func() (*FileInfo, error)

+ type API_ListFileStreamServer interface

+ Send func(*FileInfo) error

Oct 4, 2017

Changes in this version

+ var ChunkSize = int64(16 * 1024 * 1024)

+ func EncodeHash(bytes []byte) string

+ func NewHash() hash.Hash

type APIClient

+ CopyFile func(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

type APIServer

+ CopyFile func(context.Context, *CopyFileRequest) (*google_protobuf.Empty, error)

+ type CopyFileRequest struct

+ Dst *File

+ Overwrite bool

+ Src *File

+ func (*CopyFileRequest) Descriptor() ([]byte, []int)

+ func (*CopyFileRequest) ProtoMessage()

+ func (m *CopyFileRequest) GetDst() *File

+ func (m *CopyFileRequest) GetOverwrite() bool

+ func (m *CopyFileRequest) GetSrc() *File

+ func (m *CopyFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *CopyFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CopyFileRequest) Reset()

+ func (m *CopyFileRequest) Size() (n int)

+ func (m *CopyFileRequest) String() string

+ func (m *CopyFileRequest) Unmarshal(dAtA []byte) error

type GetObjectsRequest

+ TotalSize uint64

+ func (m *GetObjectsRequest) GetTotalSize() uint64

type ListFileRequest

+ Full bool

+ func (m *ListFileRequest) GetFull() bool

+ type ListRepoResponse struct

+ RepoInfo []*RepoInfo

+ func (*ListRepoResponse) Descriptor() ([]byte, []int)

+ func (*ListRepoResponse) ProtoMessage()

+ func (m *ListRepoResponse) GetRepoInfo() []*RepoInfo

+ func (m *ListRepoResponse) Marshal() (dAtA []byte, err error)

+ func (m *ListRepoResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListRepoResponse) Reset()

+ func (m *ListRepoResponse) Size() (n int)

+ func (m *ListRepoResponse) String() string

+ func (m *ListRepoResponse) Unmarshal(dAtA []byte) error

type ObjectAPIClient

+ PutObjectSplit func(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectSplitClient, error)

type ObjectAPIServer

+ PutObjectSplit func(ObjectAPI_PutObjectSplitServer) error

+ type ObjectAPI_PutObjectSplitClient interface

+ CloseAndRecv func() (*Objects, error)

+ Send func(*PutObjectRequest) error

+ type ObjectAPI_PutObjectSplitServer interface

+ Recv func() (*PutObjectRequest, error)

+ SendAndClose func(*Objects) error

+ type Objects struct

+ Objects []*Object

+ func (*Objects) Descriptor() ([]byte, []int)

+ func (*Objects) ProtoMessage()

+ func (m *Objects) GetObjects() []*Object

+ func (m *Objects) Marshal() (dAtA []byte, err error)

+ func (m *Objects) MarshalTo(dAtA []byte) (int, error)

+ func (m *Objects) Reset()

+ func (m *Objects) Size() (n int)

+ func (m *Objects) String() string

+ func (m *Objects) Unmarshal(dAtA []byte) error

+ type OverwriteIndex struct

+ Index int64

+ func (*OverwriteIndex) Descriptor() ([]byte, []int)

+ func (*OverwriteIndex) ProtoMessage()

+ func (m *OverwriteIndex) GetIndex() int64

+ func (m *OverwriteIndex) Marshal() (dAtA []byte, err error)

+ func (m *OverwriteIndex) MarshalTo(dAtA []byte) (int, error)

+ func (m *OverwriteIndex) Reset()

+ func (m *OverwriteIndex) Size() (n int)

+ func (m *OverwriteIndex) String() string

+ func (m *OverwriteIndex) Unmarshal(dAtA []byte) error

+ type PutFileRecord struct

+ ObjectHash string

+ OverwriteIndex *OverwriteIndex

+ SizeBytes int64

+ func (*PutFileRecord) Descriptor() ([]byte, []int)

+ func (*PutFileRecord) ProtoMessage()

+ func (m *PutFileRecord) GetObjectHash() string

+ func (m *PutFileRecord) GetOverwriteIndex() *OverwriteIndex

+ func (m *PutFileRecord) GetSizeBytes() int64

+ func (m *PutFileRecord) Marshal() (dAtA []byte, err error)

+ func (m *PutFileRecord) MarshalTo(dAtA []byte) (int, error)

+ func (m *PutFileRecord) Reset()

+ func (m *PutFileRecord) Size() (n int)

+ func (m *PutFileRecord) String() string

+ func (m *PutFileRecord) Unmarshal(dAtA []byte) error

+ type PutFileRecords struct

+ Records []*PutFileRecord

+ Split bool

+ func (*PutFileRecords) Descriptor() ([]byte, []int)

+ func (*PutFileRecords) ProtoMessage()

+ func (m *PutFileRecords) GetRecords() []*PutFileRecord

+ func (m *PutFileRecords) GetSplit() bool

+ func (m *PutFileRecords) Marshal() (dAtA []byte, err error)

+ func (m *PutFileRecords) MarshalTo(dAtA []byte) (int, error)

+ func (m *PutFileRecords) Reset()

+ func (m *PutFileRecords) Size() (n int)

+ func (m *PutFileRecords) String() string

+ func (m *PutFileRecords) Unmarshal(dAtA []byte) error

type PutFileRequest

+ OverwriteIndex *OverwriteIndex

+ func (m *PutFileRequest) GetOverwriteIndex() *OverwriteIndex

+ type RepoAuthInfo struct

+ AccessLevel auth.Scope

+ func (*RepoAuthInfo) Descriptor() ([]byte, []int)

+ func (*RepoAuthInfo) ProtoMessage()

+ func (m *RepoAuthInfo) GetAccessLevel() auth.Scope

+ func (m *RepoAuthInfo) Marshal() (dAtA []byte, err error)

+ func (m *RepoAuthInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *RepoAuthInfo) Reset()

+ func (m *RepoAuthInfo) Size() (n int)

+ func (m *RepoAuthInfo) String() string

+ func (m *RepoAuthInfo) Unmarshal(dAtA []byte) error

type RepoInfo

+ AuthInfo *RepoAuthInfo

+ func (m *RepoInfo) GetAuthInfo() *RepoAuthInfo

Aug 17, 2017

Changes in this version

type ListRepoRequest

+ IncludeAuth bool

+ func (m *ListRepoRequest) GetIncludeAuth() bool

type PutFileRequest

+ Overwrite bool

+ func (m *PutFileRequest) GetOverwrite() bool

type RepoInfos

+ Scopes []auth.Scope

+ func (m *RepoInfos) GetScopes() []auth.Scope

Aug 5, 2017

Changes in this version

type DiffFileRequest

+ Shallow bool

+ func (m *DiffFileRequest) GetShallow() bool

Jul 7, 2017

Changes in this version

+ var ErrIntOverflowPfs = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPfs = fmt.Errorf("proto: negative length found during unmarshaling")

type Block

+ func (m *Block) Marshal() (dAtA []byte, err error)

+ func (m *Block) MarshalTo(dAtA []byte) (int, error)

+ func (m *Block) Size() (n int)

+ func (m *Block) Unmarshal(dAtA []byte) error

type BlockRef

+ func (m *BlockRef) Marshal() (dAtA []byte, err error)

+ func (m *BlockRef) MarshalTo(dAtA []byte) (int, error)

+ func (m *BlockRef) Size() (n int)

+ func (m *BlockRef) Unmarshal(dAtA []byte) error

+ type BranchInfo struct

+ Head *Commit

+ Name string

+ func (*BranchInfo) Descriptor() ([]byte, []int)

+ func (*BranchInfo) ProtoMessage()

+ func (m *BranchInfo) GetHead() *Commit

+ func (m *BranchInfo) GetName() string

+ func (m *BranchInfo) Marshal() (dAtA []byte, err error)

+ func (m *BranchInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *BranchInfo) Reset()

+ func (m *BranchInfo) Size() (n int)

+ func (m *BranchInfo) String() string

+ func (m *BranchInfo) Unmarshal(dAtA []byte) error

+ type BranchInfos struct

+ BranchInfo []*BranchInfo

+ func (*BranchInfos) Descriptor() ([]byte, []int)

+ func (*BranchInfos) ProtoMessage()

+ func (m *BranchInfos) GetBranchInfo() []*BranchInfo

+ func (m *BranchInfos) Marshal() (dAtA []byte, err error)

+ func (m *BranchInfos) MarshalTo(dAtA []byte) (int, error)

+ func (m *BranchInfos) Reset()

+ func (m *BranchInfos) Size() (n int)

+ func (m *BranchInfos) String() string

+ func (m *BranchInfos) Unmarshal(dAtA []byte) error

type BuildCommitRequest

+ func (m *BuildCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *BuildCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *BuildCommitRequest) Size() (n int)

+ func (m *BuildCommitRequest) Unmarshal(dAtA []byte) error

type ByteRange

+ func (m *ByteRange) Marshal() (dAtA []byte, err error)

+ func (m *ByteRange) MarshalTo(dAtA []byte) (int, error)

+ func (m *ByteRange) Size() (n int)

+ func (m *ByteRange) Unmarshal(dAtA []byte) error

type CheckObjectRequest

+ func (m *CheckObjectRequest) Marshal() (dAtA []byte, err error)

+ func (m *CheckObjectRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CheckObjectRequest) Size() (n int)

+ func (m *CheckObjectRequest) Unmarshal(dAtA []byte) error

type CheckObjectResponse

+ func (m *CheckObjectResponse) Marshal() (dAtA []byte, err error)

+ func (m *CheckObjectResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CheckObjectResponse) Size() (n int)

+ func (m *CheckObjectResponse) Unmarshal(dAtA []byte) error

type Commit

+ func (m *Commit) Marshal() (dAtA []byte, err error)

+ func (m *Commit) MarshalTo(dAtA []byte) (int, error)

+ func (m *Commit) Size() (n int)

+ func (m *Commit) Unmarshal(dAtA []byte) error

type CommitInfo

+ func (m *CommitInfo) Marshal() (dAtA []byte, err error)

+ func (m *CommitInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *CommitInfo) Size() (n int)

+ func (m *CommitInfo) Unmarshal(dAtA []byte) error

type CommitInfos

+ func (m *CommitInfos) Marshal() (dAtA []byte, err error)

+ func (m *CommitInfos) MarshalTo(dAtA []byte) (int, error)

+ func (m *CommitInfos) Size() (n int)

+ func (m *CommitInfos) Unmarshal(dAtA []byte) error

type Commits

+ func (m *Commits) Marshal() (dAtA []byte, err error)

+ func (m *Commits) MarshalTo(dAtA []byte) (int, error)

+ func (m *Commits) Size() (n int)

+ func (m *Commits) Unmarshal(dAtA []byte) error

type CreateRepoRequest

+ Update bool

+ func (m *CreateRepoRequest) GetUpdate() bool

+ func (m *CreateRepoRequest) Marshal() (dAtA []byte, err error)

+ func (m *CreateRepoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CreateRepoRequest) Size() (n int)

+ func (m *CreateRepoRequest) Unmarshal(dAtA []byte) error

type DeleteBranchRequest

+ func (m *DeleteBranchRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteBranchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteBranchRequest) Size() (n int)

+ func (m *DeleteBranchRequest) Unmarshal(dAtA []byte) error

type DeleteCommitRequest

+ func (m *DeleteCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteCommitRequest) Size() (n int)

+ func (m *DeleteCommitRequest) Unmarshal(dAtA []byte) error

type DeleteFileRequest

+ func (m *DeleteFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteFileRequest) Size() (n int)

+ func (m *DeleteFileRequest) Unmarshal(dAtA []byte) error

type DeleteObjectsRequest

+ func (m *DeleteObjectsRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteObjectsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteObjectsRequest) Size() (n int)

+ func (m *DeleteObjectsRequest) Unmarshal(dAtA []byte) error

type DeleteObjectsResponse

+ func (m *DeleteObjectsResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeleteObjectsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteObjectsResponse) Size() (n int)

+ func (m *DeleteObjectsResponse) Unmarshal(dAtA []byte) error

type DeleteRepoRequest

+ func (m *DeleteRepoRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteRepoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteRepoRequest) Size() (n int)

+ func (m *DeleteRepoRequest) Unmarshal(dAtA []byte) error

type DeleteTagsRequest

+ func (m *DeleteTagsRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeleteTagsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteTagsRequest) Size() (n int)

+ func (m *DeleteTagsRequest) Unmarshal(dAtA []byte) error

type DeleteTagsResponse

+ func (m *DeleteTagsResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeleteTagsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteTagsResponse) Size() (n int)

+ func (m *DeleteTagsResponse) Unmarshal(dAtA []byte) error

type DiffFileRequest

+ func (m *DiffFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *DiffFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DiffFileRequest) Size() (n int)

+ func (m *DiffFileRequest) Unmarshal(dAtA []byte) error

type DiffFileResponse

+ func (m *DiffFileResponse) Marshal() (dAtA []byte, err error)

+ func (m *DiffFileResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DiffFileResponse) Size() (n int)

+ func (m *DiffFileResponse) Unmarshal(dAtA []byte) error

type File

+ func (m *File) Marshal() (dAtA []byte, err error)

+ func (m *File) MarshalTo(dAtA []byte) (int, error)

+ func (m *File) Size() (n int)

+ func (m *File) Unmarshal(dAtA []byte) error

type FileInfo

+ func (m *FileInfo) Marshal() (dAtA []byte, err error)

+ func (m *FileInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *FileInfo) Size() (n int)

+ func (m *FileInfo) Unmarshal(dAtA []byte) error

type FileInfos

+ func (m *FileInfos) Marshal() (dAtA []byte, err error)

+ func (m *FileInfos) MarshalTo(dAtA []byte) (int, error)

+ func (m *FileInfos) Size() (n int)

+ func (m *FileInfos) Unmarshal(dAtA []byte) error

type FinishCommitRequest

+ func (m *FinishCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *FinishCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FinishCommitRequest) Size() (n int)

+ func (m *FinishCommitRequest) Unmarshal(dAtA []byte) error

type FlushCommitRequest

+ func (m *FlushCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *FlushCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FlushCommitRequest) Size() (n int)

+ func (m *FlushCommitRequest) Unmarshal(dAtA []byte) error

type GetFileRequest

+ func (m *GetFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetFileRequest) Size() (n int)

+ func (m *GetFileRequest) Unmarshal(dAtA []byte) error

type GetObjectsRequest

+ func (m *GetObjectsRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetObjectsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetObjectsRequest) Size() (n int)

+ func (m *GetObjectsRequest) Unmarshal(dAtA []byte) error

type GlobFileRequest

+ func (m *GlobFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *GlobFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GlobFileRequest) Size() (n int)

+ func (m *GlobFileRequest) Unmarshal(dAtA []byte) error

type InspectCommitRequest

+ func (m *InspectCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *InspectCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InspectCommitRequest) Size() (n int)

+ func (m *InspectCommitRequest) Unmarshal(dAtA []byte) error

type InspectFileRequest

+ func (m *InspectFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *InspectFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InspectFileRequest) Size() (n int)

+ func (m *InspectFileRequest) Unmarshal(dAtA []byte) error

type InspectRepoRequest

+ func (m *InspectRepoRequest) Marshal() (dAtA []byte, err error)

+ func (m *InspectRepoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InspectRepoRequest) Size() (n int)

+ func (m *InspectRepoRequest) Unmarshal(dAtA []byte) error

type ListBranchRequest

+ func (m *ListBranchRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListBranchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListBranchRequest) Size() (n int)

+ func (m *ListBranchRequest) Unmarshal(dAtA []byte) error

type ListCommitRequest

+ func (m *ListCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListCommitRequest) Size() (n int)

+ func (m *ListCommitRequest) Unmarshal(dAtA []byte) error

type ListFileRequest

+ func (m *ListFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListFileRequest) Size() (n int)

+ func (m *ListFileRequest) Unmarshal(dAtA []byte) error

type ListObjectsRequest

+ func (m *ListObjectsRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListObjectsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListObjectsRequest) Size() (n int)

+ func (m *ListObjectsRequest) Unmarshal(dAtA []byte) error

type ListRepoRequest

+ func (m *ListRepoRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListRepoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListRepoRequest) Size() (n int)

+ func (m *ListRepoRequest) Unmarshal(dAtA []byte) error

type ListTagsRequest

+ func (m *ListTagsRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListTagsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListTagsRequest) Size() (n int)

+ func (m *ListTagsRequest) Unmarshal(dAtA []byte) error

type ListTagsResponse

+ func (m *ListTagsResponse) Marshal() (dAtA []byte, err error)

+ func (m *ListTagsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListTagsResponse) Size() (n int)

+ func (m *ListTagsResponse) Unmarshal(dAtA []byte) error

type Object

+ func (m *Object) Marshal() (dAtA []byte, err error)

+ func (m *Object) MarshalTo(dAtA []byte) (int, error)

+ func (m *Object) Size() (n int)

+ func (m *Object) Unmarshal(dAtA []byte) error

type ObjectIndex

+ func (m *ObjectIndex) Marshal() (dAtA []byte, err error)

+ func (m *ObjectIndex) MarshalTo(dAtA []byte) (int, error)

+ func (m *ObjectIndex) Size() (n int)

+ func (m *ObjectIndex) Unmarshal(dAtA []byte) error

type ObjectInfo

+ func (m *ObjectInfo) Marshal() (dAtA []byte, err error)

+ func (m *ObjectInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ObjectInfo) Size() (n int)

+ func (m *ObjectInfo) Unmarshal(dAtA []byte) error

type PutFileRequest

+ func (m *PutFileRequest) Marshal() (dAtA []byte, err error)

+ func (m *PutFileRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PutFileRequest) Size() (n int)

+ func (m *PutFileRequest) Unmarshal(dAtA []byte) error

type PutObjectRequest

+ func (m *PutObjectRequest) Marshal() (dAtA []byte, err error)

+ func (m *PutObjectRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PutObjectRequest) Size() (n int)

+ func (m *PutObjectRequest) Unmarshal(dAtA []byte) error

type Repo

+ func (m *Repo) Marshal() (dAtA []byte, err error)

+ func (m *Repo) MarshalTo(dAtA []byte) (int, error)

+ func (m *Repo) Size() (n int)

+ func (m *Repo) Unmarshal(dAtA []byte) error

type RepoInfo

+ func (m *RepoInfo) Marshal() (dAtA []byte, err error)

+ func (m *RepoInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *RepoInfo) Size() (n int)

+ func (m *RepoInfo) Unmarshal(dAtA []byte) error

type RepoInfos

+ func (m *RepoInfos) Marshal() (dAtA []byte, err error)

+ func (m *RepoInfos) MarshalTo(dAtA []byte) (int, error)

+ func (m *RepoInfos) Size() (n int)

+ func (m *RepoInfos) Unmarshal(dAtA []byte) error

type SetBranchRequest

+ func (m *SetBranchRequest) Marshal() (dAtA []byte, err error)

+ func (m *SetBranchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetBranchRequest) Size() (n int)

+ func (m *SetBranchRequest) Unmarshal(dAtA []byte) error

type StartCommitRequest

+ func (m *StartCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *StartCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *StartCommitRequest) Size() (n int)

+ func (m *StartCommitRequest) Unmarshal(dAtA []byte) error

type SubscribeCommitRequest

+ func (m *SubscribeCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *SubscribeCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubscribeCommitRequest) Size() (n int)

+ func (m *SubscribeCommitRequest) Unmarshal(dAtA []byte) error

type Tag

+ func (m *Tag) Marshal() (dAtA []byte, err error)

+ func (m *Tag) MarshalTo(dAtA []byte) (int, error)

+ func (m *Tag) Size() (n int)

+ func (m *Tag) Unmarshal(dAtA []byte) error

type TagObjectRequest

+ func (m *TagObjectRequest) Marshal() (dAtA []byte, err error)

+ func (m *TagObjectRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *TagObjectRequest) Size() (n int)

+ func (m *TagObjectRequest) Unmarshal(dAtA []byte) error

Jun 14, 2017

Changes in this version

type APIClient

+ DiffFile func(ctx context.Context, in *DiffFileRequest, opts ...grpc.CallOption) (*DiffFileResponse, error)

type APIServer

+ DiffFile func(context.Context, *DiffFileRequest) (*DiffFileResponse, error)

type DeleteRepoRequest

+ All bool

+ func (m *DeleteRepoRequest) GetAll() bool

+ type DiffFileRequest struct

+ NewFile *File

+ OldFile *File

+ func (*DiffFileRequest) Descriptor() ([]byte, []int)

+ func (*DiffFileRequest) ProtoMessage()

+ func (m *DiffFileRequest) GetNewFile() *File

+ func (m *DiffFileRequest) GetOldFile() *File

+ func (m *DiffFileRequest) Reset()

+ func (m *DiffFileRequest) String() string

+ type DiffFileResponse struct

+ NewFiles []*FileInfo

+ OldFiles []*FileInfo

+ func (*DiffFileResponse) Descriptor() ([]byte, []int)

+ func (*DiffFileResponse) ProtoMessage()

+ func (m *DiffFileResponse) GetNewFiles() []*FileInfo

+ func (m *DiffFileResponse) GetOldFiles() []*FileInfo

+ func (m *DiffFileResponse) Reset()

+ func (m *DiffFileResponse) String() string

Jun 1, 2017

Changes in this version

+ type CheckObjectRequest struct

+ Object *Object

+ func (*CheckObjectRequest) Descriptor() ([]byte, []int)

+ func (*CheckObjectRequest) ProtoMessage()

+ func (m *CheckObjectRequest) GetObject() *Object

+ func (m *CheckObjectRequest) Reset()

+ func (m *CheckObjectRequest) String() string

+ type CheckObjectResponse struct

+ Exists bool

+ func (*CheckObjectResponse) Descriptor() ([]byte, []int)

+ func (*CheckObjectResponse) ProtoMessage()

+ func (m *CheckObjectResponse) GetExists() bool

+ func (m *CheckObjectResponse) Reset()

+ func (m *CheckObjectResponse) String() string

type CreateRepoRequest

+ Description string

+ func (m *CreateRepoRequest) GetDescription() string

+ type DeleteObjectsRequest struct

+ Objects []*Object

+ func (*DeleteObjectsRequest) Descriptor() ([]byte, []int)

+ func (*DeleteObjectsRequest) ProtoMessage()

+ func (m *DeleteObjectsRequest) GetObjects() []*Object

+ func (m *DeleteObjectsRequest) Reset()

+ func (m *DeleteObjectsRequest) String() string

+ type DeleteObjectsResponse struct

+ func (*DeleteObjectsResponse) Descriptor() ([]byte, []int)

+ func (*DeleteObjectsResponse) ProtoMessage()

+ func (m *DeleteObjectsResponse) Reset()

+ func (m *DeleteObjectsResponse) String() string

+ type DeleteTagsRequest struct

+ Tags []string

+ func (*DeleteTagsRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTagsRequest) ProtoMessage()

+ func (m *DeleteTagsRequest) GetTags() []string

+ func (m *DeleteTagsRequest) Reset()

+ func (m *DeleteTagsRequest) String() string

+ type DeleteTagsResponse struct

+ func (*DeleteTagsResponse) Descriptor() ([]byte, []int)

+ func (*DeleteTagsResponse) ProtoMessage()

+ func (m *DeleteTagsResponse) Reset()

+ func (m *DeleteTagsResponse) String() string

+ type ListObjectsRequest struct

+ func (*ListObjectsRequest) Descriptor() ([]byte, []int)

+ func (*ListObjectsRequest) ProtoMessage()

+ func (m *ListObjectsRequest) Reset()

+ func (m *ListObjectsRequest) String() string

+ type ListTagsRequest struct

+ IncludeObject bool

+ Prefix string

+ func (*ListTagsRequest) Descriptor() ([]byte, []int)

+ func (*ListTagsRequest) ProtoMessage()

+ func (m *ListTagsRequest) GetIncludeObject() bool

+ func (m *ListTagsRequest) GetPrefix() string

+ func (m *ListTagsRequest) Reset()

+ func (m *ListTagsRequest) String() string

+ type ListTagsResponse struct

+ Object *Object

+ Tag string

+ func (*ListTagsResponse) Descriptor() ([]byte, []int)

+ func (*ListTagsResponse) ProtoMessage()

+ func (m *ListTagsResponse) GetObject() *Object

+ func (m *ListTagsResponse) GetTag() string

+ func (m *ListTagsResponse) Reset()

+ func (m *ListTagsResponse) String() string

type ObjectAPIClient

+ CheckObject func(ctx context.Context, in *CheckObjectRequest, opts ...grpc.CallOption) (*CheckObjectResponse, error)

+ DeleteObjects func(ctx context.Context, in *DeleteObjectsRequest, opts ...grpc.CallOption) (*DeleteObjectsResponse, error)

+ DeleteTags func(ctx context.Context, in *DeleteTagsRequest, opts ...grpc.CallOption) (*DeleteTagsResponse, error)

+ ListObjects func(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_ListObjectsClient, error)

+ ListTags func(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (ObjectAPI_ListTagsClient, error)

type ObjectAPIServer

+ CheckObject func(context.Context, *CheckObjectRequest) (*CheckObjectResponse, error)

+ DeleteObjects func(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)

+ DeleteTags func(context.Context, *DeleteTagsRequest) (*DeleteTagsResponse, error)

+ ListObjects func(*ListObjectsRequest, ObjectAPI_ListObjectsServer) error

+ ListTags func(*ListTagsRequest, ObjectAPI_ListTagsServer) error

+ type ObjectAPI_ListObjectsClient interface

+ Recv func() (*Object, error)

+ type ObjectAPI_ListObjectsServer interface

+ Send func(*Object) error

+ type ObjectAPI_ListTagsClient interface

+ Recv func() (*ListTagsResponse, error)

+ type ObjectAPI_ListTagsServer interface

+ Send func(*ListTagsResponse) error

type RepoInfo

+ Description string

+ func (m *RepoInfo) GetDescription() string

May 5, 2017

Changes in this version

type FileInfo

+ Objects []*Object

+ func (m *FileInfo) GetObjects() []*Object

Mar 29, 2017

Changes in this version

type APIClient

+ BuildCommit func(ctx context.Context, in *BuildCommitRequest, opts ...grpc.CallOption) (*Commit, error)

+ DeleteBranch func(ctx context.Context, in *DeleteBranchRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ GlobFile func(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (*FileInfos, error)

+ SetBranch func(ctx context.Context, in *SetBranchRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ SubscribeCommit func(ctx context.Context, in *SubscribeCommitRequest, opts ...grpc.CallOption) (API_SubscribeCommitClient, error)

type APIServer

+ BuildCommit func(context.Context, *BuildCommitRequest) (*Commit, error)

+ DeleteBranch func(context.Context, *DeleteBranchRequest) (*google_protobuf.Empty, error)

+ GlobFile func(context.Context, *GlobFileRequest) (*FileInfos, error)

+ SetBranch func(context.Context, *SetBranchRequest) (*google_protobuf.Empty, error)

+ SubscribeCommit func(*SubscribeCommitRequest, API_SubscribeCommitServer) error

+ type API_FlushCommitClient interface

+ Recv func() (*CommitInfo, error)

+ type API_FlushCommitServer interface

+ Send func(*CommitInfo) error

+ type API_SubscribeCommitClient interface

+ Recv func() (*CommitInfo, error)

+ type API_SubscribeCommitServer interface

+ Send func(*CommitInfo) error

+ type Branch struct

+ Head *Commit

+ Name string

+ func (*Branch) Descriptor() ([]byte, []int)

+ func (*Branch) ProtoMessage()

+ func (m *Branch) GetHead() *Commit

+ func (m *Branch) GetName() string

+ func (m *Branch) Reset()

+ func (m *Branch) String() string

+ type BuildCommitRequest struct

+ Branch string

+ Parent *Commit

+ Provenance []*Commit

+ Tree *Object

+ func (*BuildCommitRequest) Descriptor() ([]byte, []int)

+ func (*BuildCommitRequest) ProtoMessage()

+ func (m *BuildCommitRequest) GetBranch() string

+ func (m *BuildCommitRequest) GetParent() *Commit

+ func (m *BuildCommitRequest) GetProvenance() []*Commit

+ func (m *BuildCommitRequest) GetTree() *Object

+ func (m *BuildCommitRequest) Reset()

+ func (m *BuildCommitRequest) String() string

type Commit

+ func (c *Commit) FullID() string

type CommitInfo

+ Tree *Object

+ func (m *CommitInfo) GetTree() *Object

+ type DeleteBranchRequest struct

+ Branch string

+ Repo *Repo

+ func (*DeleteBranchRequest) Descriptor() ([]byte, []int)

+ func (*DeleteBranchRequest) ProtoMessage()

+ func (m *DeleteBranchRequest) GetBranch() string

+ func (m *DeleteBranchRequest) GetRepo() *Repo

+ func (m *DeleteBranchRequest) Reset()

+ func (m *DeleteBranchRequest) String() string

type FileInfo

+ Hash []byte

+ func (m *FileInfo) GetHash() []byte

type FileType

+ const FileType_DIR

+ const FileType_FILE

+ const FileType_RESERVED

type FlushCommitRequest

+ Commits []*Commit

+ ToRepos []*Repo

+ func (m *FlushCommitRequest) GetCommits() []*Commit

+ func (m *FlushCommitRequest) GetToRepos() []*Repo

+ type GetObjectsRequest struct

+ Objects []*Object

+ OffsetBytes uint64

+ SizeBytes uint64

+ func (*GetObjectsRequest) Descriptor() ([]byte, []int)

+ func (*GetObjectsRequest) ProtoMessage()

+ func (m *GetObjectsRequest) GetObjects() []*Object

+ func (m *GetObjectsRequest) GetOffsetBytes() uint64

+ func (m *GetObjectsRequest) GetSizeBytes() uint64

+ func (m *GetObjectsRequest) Reset()

+ func (m *GetObjectsRequest) String() string

+ type GlobFileRequest struct

+ Commit *Commit

+ Pattern string

+ func (*GlobFileRequest) Descriptor() ([]byte, []int)

+ func (*GlobFileRequest) ProtoMessage()

+ func (m *GlobFileRequest) GetCommit() *Commit

+ func (m *GlobFileRequest) GetPattern() string

+ func (m *GlobFileRequest) Reset()

+ func (m *GlobFileRequest) String() string

type ListCommitRequest

+ From *Commit

+ Number uint64

+ To *Commit

+ func (m *ListCommitRequest) GetFrom() *Commit

+ func (m *ListCommitRequest) GetNumber() uint64

+ func (m *ListCommitRequest) GetTo() *Commit

type ObjectAPIClient

+ GetObjects func(ctx context.Context, in *GetObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_GetObjectsClient, error)

type ObjectAPIServer

+ GetObjects func(*GetObjectsRequest, ObjectAPI_GetObjectsServer) error

+ type ObjectAPI_GetObjectsClient interface

+ Recv func() (*google_protobuf2.BytesValue, error)

+ type ObjectAPI_GetObjectsServer interface

+ Send func(*google_protobuf2.BytesValue) error

type PutFileRequest

+ TargetFileBytes int64

+ TargetFileDatums int64

+ func (m *PutFileRequest) GetTargetFileBytes() int64

+ func (m *PutFileRequest) GetTargetFileDatums() int64

+ type SetBranchRequest struct

+ Branch string

+ Commit *Commit

+ func (*SetBranchRequest) Descriptor() ([]byte, []int)

+ func (*SetBranchRequest) ProtoMessage()

+ func (m *SetBranchRequest) GetBranch() string

+ func (m *SetBranchRequest) GetCommit() *Commit

+ func (m *SetBranchRequest) Reset()

+ func (m *SetBranchRequest) String() string

type StartCommitRequest

+ func (m *StartCommitRequest) GetBranch() string

+ type SubscribeCommitRequest struct

+ Branch string

+ From *Commit

+ Repo *Repo

+ func (*SubscribeCommitRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeCommitRequest) ProtoMessage()

+ func (m *SubscribeCommitRequest) GetBranch() string

+ func (m *SubscribeCommitRequest) GetFrom() *Commit

+ func (m *SubscribeCommitRequest) GetRepo() *Repo

+ func (m *SubscribeCommitRequest) Reset()

+ func (m *SubscribeCommitRequest) String() string

Feb 27, 2017

Changes in this version

+ func RegisterObjectAPIServer(s *grpc.Server, srv ObjectAPIServer)

+ type Object struct

+ Hash string

+ func (*Object) Descriptor() ([]byte, []int)

+ func (*Object) ProtoMessage()

+ func (m *Object) GetHash() string

+ func (m *Object) Reset()

+ func (m *Object) String() string

+ type ObjectAPIClient interface

+ Compact func(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ GetObject func(ctx context.Context, in *Object, opts ...grpc.CallOption) (ObjectAPI_GetObjectClient, error)

+ GetTag func(ctx context.Context, in *Tag, opts ...grpc.CallOption) (ObjectAPI_GetTagClient, error)

+ InspectObject func(ctx context.Context, in *Object, opts ...grpc.CallOption) (*ObjectInfo, error)

+ InspectTag func(ctx context.Context, in *Tag, opts ...grpc.CallOption) (*ObjectInfo, error)

+ PutObject func(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectClient, error)

+ TagObject func(ctx context.Context, in *TagObjectRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ func NewObjectAPIClient(cc *grpc.ClientConn) ObjectAPIClient

+ type ObjectAPIServer interface

+ Compact func(context.Context, *google_protobuf1.Empty) (*google_protobuf1.Empty, error)

+ GetObject func(*Object, ObjectAPI_GetObjectServer) error

+ GetTag func(*Tag, ObjectAPI_GetTagServer) error

+ InspectObject func(context.Context, *Object) (*ObjectInfo, error)

+ InspectTag func(context.Context, *Tag) (*ObjectInfo, error)

+ PutObject func(ObjectAPI_PutObjectServer) error

+ TagObject func(context.Context, *TagObjectRequest) (*google_protobuf1.Empty, error)

+ type ObjectAPI_GetObjectClient interface

+ Recv func() (*google_protobuf3.BytesValue, error)

+ type ObjectAPI_GetObjectServer interface

+ Send func(*google_protobuf3.BytesValue) error

+ type ObjectAPI_GetTagClient interface

+ Recv func() (*google_protobuf3.BytesValue, error)

+ type ObjectAPI_GetTagServer interface

+ Send func(*google_protobuf3.BytesValue) error

+ type ObjectAPI_PutObjectClient interface

+ CloseAndRecv func() (*Object, error)

+ Send func(*PutObjectRequest) error

+ type ObjectAPI_PutObjectServer interface

+ Recv func() (*PutObjectRequest, error)

+ SendAndClose func(*Object) error

+ type ObjectIndex struct

+ Objects map[string]*BlockRef

+ Tags map[string]*Object

+ func (*ObjectIndex) Descriptor() ([]byte, []int)

+ func (*ObjectIndex) ProtoMessage()

+ func (m *ObjectIndex) GetObjects() map[string]*BlockRef

+ func (m *ObjectIndex) GetTags() map[string]*Object

+ func (m *ObjectIndex) Reset()

+ func (m *ObjectIndex) String() string

+ type ObjectInfo struct

+ BlockRef *BlockRef

+ Object *Object

+ func (*ObjectInfo) Descriptor() ([]byte, []int)

+ func (*ObjectInfo) ProtoMessage()

+ func (m *ObjectInfo) GetBlockRef() *BlockRef

+ func (m *ObjectInfo) GetObject() *Object

+ func (m *ObjectInfo) Reset()

+ func (m *ObjectInfo) String() string

+ type PutObjectRequest struct

+ Tags []*Tag

+ Value []byte

+ func (*PutObjectRequest) Descriptor() ([]byte, []int)

+ func (*PutObjectRequest) ProtoMessage()

+ func (m *PutObjectRequest) GetTags() []*Tag

+ func (m *PutObjectRequest) GetValue() []byte

+ func (m *PutObjectRequest) Reset()

+ func (m *PutObjectRequest) String() string

+ type Tag struct

+ Name string

+ func (*Tag) Descriptor() ([]byte, []int)

+ func (*Tag) ProtoMessage()

+ func (m *Tag) GetName() string

+ func (m *Tag) Reset()

+ func (m *Tag) String() string

+ type TagObjectRequest struct

+ Object *Object

+ Tags []*Tag

+ func (*TagObjectRequest) Descriptor() ([]byte, []int)

+ func (*TagObjectRequest) ProtoMessage()

+ func (m *TagObjectRequest) GetObject() *Object

+ func (m *TagObjectRequest) GetTags() []*Tag

+ func (m *TagObjectRequest) Reset()

+ func (m *TagObjectRequest) String() string

Feb 9, 2017

Changes in this version

type Append

+ func (m *Append) GetDelete() bool

+ func (m *Append) GetFileType() FileType

type Block

+ func (m *Block) GetHash() string

type BlockInfo

+ func (m *BlockInfo) GetSizeBytes() uint64

type Branches

+ func (m *Branches) GetBranches() []string

type ByteRange

+ func (m *ByteRange) GetLower() uint64

+ func (m *ByteRange) GetUpper() uint64

type Commit

+ func (m *Commit) GetID() string

type CommitInfo

+ func (m *CommitInfo) GetArchived() bool

+ func (m *CommitInfo) GetBranch() string

+ func (m *CommitInfo) GetCancelled() bool

+ func (m *CommitInfo) GetCommitType() CommitType

+ func (m *CommitInfo) GetSizeBytes() uint64

type DeleteRepoRequest

+ func (m *DeleteRepoRequest) GetForce() bool

type DiffMethod

+ func (m *DiffMethod) GetFullFile() bool

type File

+ func (m *File) GetPath() string

type FileInfo

+ func (m *FileInfo) GetFileType() FileType

+ func (m *FileInfo) GetSizeBytes() uint64

type FinishCommitRequest

+ func (m *FinishCommitRequest) GetCancel() bool

type ForkCommitRequest

+ func (m *ForkCommitRequest) GetBranch() string

type GetBlockRequest

+ func (m *GetBlockRequest) GetOffsetBytes() uint64

+ func (m *GetBlockRequest) GetSizeBytes() uint64

type GetFileRequest

+ func (m *GetFileRequest) GetOffsetBytes() int64

+ func (m *GetFileRequest) GetSizeBytes() int64

type ListBranchRequest

+ func (m *ListBranchRequest) GetStatus() CommitStatus

type ListCommitRequest

+ func (m *ListCommitRequest) GetBlock() bool

+ func (m *ListCommitRequest) GetCommitType() CommitType

+ func (m *ListCommitRequest) GetStatus() CommitStatus

type ListFileRequest

+ func (m *ListFileRequest) GetMode() ListFileMode

type PutBlockRequest

+ func (m *PutBlockRequest) GetDelimiter() Delimiter

+ func (m *PutBlockRequest) GetValue() []byte

type PutFileRequest

+ func (m *PutFileRequest) GetDelimiter() Delimiter

+ func (m *PutFileRequest) GetFileType() FileType

+ func (m *PutFileRequest) GetRecursive() bool

+ func (m *PutFileRequest) GetUrl() string

+ func (m *PutFileRequest) GetValue() []byte

type ReplayCommitRequest

+ func (m *ReplayCommitRequest) GetToBranch() string

type Repo

+ func (m *Repo) GetName() string

type RepoInfo

+ func (m *RepoInfo) GetSizeBytes() uint64

type Shard

+ func (m *Shard) GetBlockModulus() uint64

+ func (m *Shard) GetBlockNumber() uint64

+ func (m *Shard) GetFileModulus() uint64

+ func (m *Shard) GetFileNumber() uint64

Nov 23, 2016

Changes in this version

type ListCommitRequest

+ Exclude []*Commit

+ Include []*Commit

+ func (m *ListCommitRequest) GetExclude() []*Commit

+ func (m *ListCommitRequest) GetInclude() []*Commit

type PutFileRequest

+ Recursive bool

Oct 31, 2016

Changes in this version

+ var ListFileMode_name = map[int32]string

+ var ListFileMode_value = map[string]int32

+ type ListFileMode int32

+ const ListFileMode_ListFile_FAST

+ const ListFileMode_ListFile_NORMAL

+ const ListFileMode_ListFile_RECURSE

+ func (ListFileMode) EnumDescriptor() ([]byte, []int)

+ func (x ListFileMode) String() string

type ListFileRequest

+ Mode ListFileMode

Sep 23, 2016

Changes in this version

+ var CommitStatus_name = map[int32]string

+ var CommitStatus_value = map[string]int32

type APIClient

+ ArchiveAll func(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ ArchiveCommit func(ctx context.Context, in *ArchiveCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ ForkCommit func(ctx context.Context, in *ForkCommitRequest, opts ...grpc.CallOption) (*Commit, error)

+ ReplayCommit func(ctx context.Context, in *ReplayCommitRequest, opts ...grpc.CallOption) (*Commits, error)

+ SquashCommit func(ctx context.Context, in *SquashCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

type APIServer

+ ArchiveAll func(context.Context, *google_protobuf1.Empty) (*google_protobuf1.Empty, error)

+ ArchiveCommit func(context.Context, *ArchiveCommitRequest) (*google_protobuf1.Empty, error)

+ ForkCommit func(context.Context, *ForkCommitRequest) (*Commit, error)

+ ReplayCommit func(context.Context, *ReplayCommitRequest) (*Commits, error)

+ SquashCommit func(context.Context, *SquashCommitRequest) (*google_protobuf1.Empty, error)

+ type ArchiveCommitRequest struct

+ Commits []*Commit

+ func (*ArchiveCommitRequest) Descriptor() ([]byte, []int)

+ func (*ArchiveCommitRequest) ProtoMessage()

+ func (m *ArchiveCommitRequest) GetCommits() []*Commit

+ func (m *ArchiveCommitRequest) Reset()

+ func (m *ArchiveCommitRequest) String() string

+ type Branches struct

+ Branches []string

+ func (*Branches) Descriptor() ([]byte, []int)

+ func (*Branches) ProtoMessage()

+ func (m *Branches) Reset()

+ func (m *Branches) String() string

type CommitInfo

+ Archived bool

+ type CommitStatus int32

+ const CommitStatus_ALL

+ const CommitStatus_ARCHIVED

+ const CommitStatus_CANCELLED

+ const CommitStatus_NORMAL

+ func (CommitStatus) EnumDescriptor() ([]byte, []int)

+ func (x CommitStatus) String() string

+ type Commits struct

+ Commit []*Commit

+ func (*Commits) Descriptor() ([]byte, []int)

+ func (*Commits) ProtoMessage()

+ func (m *Commits) GetCommit() []*Commit

+ func (m *Commits) Reset()

+ func (m *Commits) String() string

type DiffInfo

+ Archived bool

+ type DiffMethod struct

+ FromCommit *Commit

+ FullFile bool

+ func (*DiffMethod) Descriptor() ([]byte, []int)

+ func (*DiffMethod) ProtoMessage()

+ func (m *DiffMethod) GetFromCommit() *Commit

+ func (m *DiffMethod) Reset()

+ func (m *DiffMethod) String() string

+ type ForkCommitRequest struct

+ Branch string

+ Parent *Commit

+ Provenance []*Commit

+ func (*ForkCommitRequest) Descriptor() ([]byte, []int)

+ func (*ForkCommitRequest) ProtoMessage()

+ func (m *ForkCommitRequest) GetParent() *Commit

+ func (m *ForkCommitRequest) GetProvenance() []*Commit

+ func (m *ForkCommitRequest) Reset()

+ func (m *ForkCommitRequest) String() string

type GetFileRequest

+ DiffMethod *DiffMethod

+ func (m *GetFileRequest) GetDiffMethod() *DiffMethod

type InspectFileRequest

+ DiffMethod *DiffMethod

+ func (m *InspectFileRequest) GetDiffMethod() *DiffMethod

type ListBranchRequest

+ Status CommitStatus

type ListCommitRequest

+ FromCommits []*Commit

+ Status CommitStatus

+ func (m *ListCommitRequest) GetFromCommits() []*Commit

type ListFileRequest

+ DiffMethod *DiffMethod

+ func (m *ListFileRequest) GetDiffMethod() *DiffMethod

type PutFileRequest

+ Url string

+ type ReplayCommitRequest struct

+ FromCommits []*Commit

+ ToBranch string

+ func (*ReplayCommitRequest) Descriptor() ([]byte, []int)

+ func (*ReplayCommitRequest) ProtoMessage()

+ func (m *ReplayCommitRequest) GetFromCommits() []*Commit

+ func (m *ReplayCommitRequest) Reset()

+ func (m *ReplayCommitRequest) String() string

+ type SquashCommitRequest struct

+ FromCommits []*Commit

+ ToCommit *Commit

+ func (*SquashCommitRequest) Descriptor() ([]byte, []int)

+ func (*SquashCommitRequest) ProtoMessage()

+ func (m *SquashCommitRequest) GetFromCommits() []*Commit

+ func (m *SquashCommitRequest) GetToCommit() *Commit

+ func (m *SquashCommitRequest) Reset()

+ func (m *SquashCommitRequest) String() string

type StartCommitRequest

+ Parent *Commit

+ func (m *StartCommitRequest) GetParent() *Commit

Jul 7, 2016

Changes in this version

type DeleteRepoRequest

+ Force bool

Apr 20, 2016

Changes in this version

+ func CancelCommit(apiClient APIClient, repoName string, commitID string) error

Apr 15, 2016

Changes in this version

+ func PutFileWriter(apiClient APIClient, repoName string, commitID string, path string) (io.WriteCloser, error)

Apr 11, 2016

Changes in this version

+ func CreateRepo(apiClient APIClient, repoName string) error

+ func DeleteBlock(apiClient BlockAPIClient, block *Block) error

+ func DeleteCommit(apiClient APIClient, repoName string, commitID string) error

+ func DeleteFile(apiClient APIClient, repoName string, commitID string, path string) error

+ func DeleteRepo(apiClient APIClient, repoName string) error

+ func FinishCommit(apiClient APIClient, repoName string, commitID string) error

+ func GetBlock(apiClient BlockAPIClient, hash string, offsetBytes uint64, sizeBytes uint64) (io.Reader, error)

+ func GetFile(apiClient APIClient, repoName string, commitID string, path string, ...) error

+ func MakeDirectory(apiClient APIClient, repoName string, commitID string, path string) (retErr error)

+ func PutFile(apiClient APIClient, repoName string, commitID string, path string, ...) (_ int, retErr error)

+ func RegisterAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

type Block

+ func NewBlock(hash string) *Block

type BlockInfo

+ func InspectBlock(apiClient BlockAPIClient, hash string) (*BlockInfo, error)

+ func ListBlock(apiClient BlockAPIClient) ([]*BlockInfo, error)

type BlockRefs

+ func PutBlock(apiClient BlockAPIClient, reader io.Reader) (*BlockRefs, error)

type Commit

+ func NewCommit(repoName string, commitID string) *Commit

+ func StartCommit(apiClient APIClient, repoName string, parentCommit string, branch string) (*Commit, error)

type CommitInfo

+ func InspectCommit(apiClient APIClient, repoName string, commitID string) (*CommitInfo, error)

+ func ListBranch(apiClient APIClient, repoName string) ([]*CommitInfo, error)

+ func ListCommit(apiClient APIClient, repoNames []string, fromCommitIDs []string, block bool) ([]*CommitInfo, error)

type Diff

+ func NewDiff(repoName string, commitID string, shard uint64) *Diff

type File

+ func NewFile(repoName string, commitID string, path string) *File

type FileInfo

+ Perm uint32

+ func InspectFile(apiClient APIClient, repoName string, commitID string, path string, ...) (*FileInfo, error)

+ func ListFile(apiClient APIClient, repoName string, commitID string, path string, ...) ([]*FileInfo, error)

type PutFileRequest

+ OffsetBytes int64

type Repo

+ func NewRepo(repoName string) *Repo

type RepoInfo

+ func InspectRepo(apiClient APIClient, repoName string) (*RepoInfo, error)

+ func ListRepo(apiClient APIClient) ([]*RepoInfo, error)

Jun 28, 2016

Changes in this version

+ var CommitType_name = map[int32]string

+ var CommitType_value = map[string]int32

+ var Delimiter_name = map[int32]string

+ var Delimiter_value = map[string]int32

+ var FileType_name = map[int32]string

+ var FileType_value = map[string]int32

+ func RegisterAPIServer(s *grpc.Server, srv APIServer)

+ func RegisterBlockAPIServer(s *grpc.Server, srv BlockAPIServer)

+ func RegisterInternalAPIServer(s *grpc.Server, srv InternalAPIServer)

+ type APIClient interface

+ CreateRepo func(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteAll func(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteCommit func(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteFile func(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteRepo func(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ FinishCommit func(ctx context.Context, in *FinishCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ FlushCommit func(ctx context.Context, in *FlushCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)

+ GetFile func(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (API_GetFileClient, error)

+ InspectCommit func(ctx context.Context, in *InspectCommitRequest, opts ...grpc.CallOption) (*CommitInfo, error)

+ InspectFile func(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error)

+ InspectRepo func(ctx context.Context, in *InspectRepoRequest, opts ...grpc.CallOption) (*RepoInfo, error)

+ ListBranch func(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*CommitInfos, error)

+ ListCommit func(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)

+ ListFile func(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*FileInfos, error)

+ ListRepo func(ctx context.Context, in *ListRepoRequest, opts ...grpc.CallOption) (*RepoInfos, error)

+ PutFile func(ctx context.Context, opts ...grpc.CallOption) (API_PutFileClient, error)

+ StartCommit func(ctx context.Context, in *StartCommitRequest, opts ...grpc.CallOption) (*Commit, error)

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

+ CreateRepo func(context.Context, *CreateRepoRequest) (*google_protobuf1.Empty, error)

+ DeleteAll func(context.Context, *google_protobuf1.Empty) (*google_protobuf1.Empty, error)

+ DeleteCommit func(context.Context, *DeleteCommitRequest) (*google_protobuf1.Empty, error)

+ DeleteFile func(context.Context, *DeleteFileRequest) (*google_protobuf1.Empty, error)

+ DeleteRepo func(context.Context, *DeleteRepoRequest) (*google_protobuf1.Empty, error)

+ FinishCommit func(context.Context, *FinishCommitRequest) (*google_protobuf1.Empty, error)

+ FlushCommit func(context.Context, *FlushCommitRequest) (*CommitInfos, error)

+ GetFile func(*GetFileRequest, API_GetFileServer) error

+ InspectCommit func(context.Context, *InspectCommitRequest) (*CommitInfo, error)

+ InspectFile func(context.Context, *InspectFileRequest) (*FileInfo, error)

+ InspectRepo func(context.Context, *InspectRepoRequest) (*RepoInfo, error)

+ ListBranch func(context.Context, *ListBranchRequest) (*CommitInfos, error)

+ ListCommit func(context.Context, *ListCommitRequest) (*CommitInfos, error)

+ ListFile func(context.Context, *ListFileRequest) (*FileInfos, error)

+ ListRepo func(context.Context, *ListRepoRequest) (*RepoInfos, error)

+ PutFile func(API_PutFileServer) error

+ StartCommit func(context.Context, *StartCommitRequest) (*Commit, error)

+ type API_GetFileClient interface

+ Recv func() (*google_protobuf3.BytesValue, error)

+ type API_GetFileServer interface

+ Send func(*google_protobuf3.BytesValue) error

+ type API_PutFileClient interface

+ CloseAndRecv func() (*google_protobuf1.Empty, error)

+ Send func(*PutFileRequest) error

+ type API_PutFileServer interface

+ Recv func() (*PutFileRequest, error)

+ SendAndClose func(*google_protobuf1.Empty) error

+ type Append struct

+ BlockRefs []*BlockRef

+ Children map[string]bool

+ Delete bool

+ FileType FileType

+ HandleDeletes map[string]bool

+ Handles map[string]*BlockRefs

+ LastRef *Commit

+ func (*Append) Descriptor() ([]byte, []int)

+ func (*Append) ProtoMessage()

+ func (m *Append) GetBlockRefs() []*BlockRef

+ func (m *Append) GetChildren() map[string]bool

+ func (m *Append) GetHandleDeletes() map[string]bool

+ func (m *Append) GetHandles() map[string]*BlockRefs

+ func (m *Append) GetLastRef() *Commit

+ func (m *Append) Reset()

+ func (m *Append) String() string

+ type Block struct

+ Hash string

+ func (*Block) Descriptor() ([]byte, []int)

+ func (*Block) ProtoMessage()

+ func (m *Block) Reset()

+ func (m *Block) String() string

+ type BlockAPIClient interface

+ CreateDiff func(ctx context.Context, in *DiffInfo, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteBlock func(ctx context.Context, in *DeleteBlockRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteDiff func(ctx context.Context, in *DeleteDiffRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ GetBlock func(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (BlockAPI_GetBlockClient, error)

+ InspectBlock func(ctx context.Context, in *InspectBlockRequest, opts ...grpc.CallOption) (*BlockInfo, error)

+ InspectDiff func(ctx context.Context, in *InspectDiffRequest, opts ...grpc.CallOption) (*DiffInfo, error)

+ ListBlock func(ctx context.Context, in *ListBlockRequest, opts ...grpc.CallOption) (*BlockInfos, error)

+ ListDiff func(ctx context.Context, in *ListDiffRequest, opts ...grpc.CallOption) (BlockAPI_ListDiffClient, error)

+ PutBlock func(ctx context.Context, opts ...grpc.CallOption) (BlockAPI_PutBlockClient, error)

+ func NewBlockAPIClient(cc *grpc.ClientConn) BlockAPIClient

+ type BlockAPIServer interface

+ CreateDiff func(context.Context, *DiffInfo) (*google_protobuf1.Empty, error)

+ DeleteBlock func(context.Context, *DeleteBlockRequest) (*google_protobuf1.Empty, error)

+ DeleteDiff func(context.Context, *DeleteDiffRequest) (*google_protobuf1.Empty, error)

+ GetBlock func(*GetBlockRequest, BlockAPI_GetBlockServer) error

+ InspectBlock func(context.Context, *InspectBlockRequest) (*BlockInfo, error)

+ InspectDiff func(context.Context, *InspectDiffRequest) (*DiffInfo, error)

+ ListBlock func(context.Context, *ListBlockRequest) (*BlockInfos, error)

+ ListDiff func(*ListDiffRequest, BlockAPI_ListDiffServer) error

+ PutBlock func(BlockAPI_PutBlockServer) error

+ type BlockAPI_GetBlockClient interface

+ Recv func() (*google_protobuf3.BytesValue, error)

+ type BlockAPI_GetBlockServer interface

+ Send func(*google_protobuf3.BytesValue) error

+ type BlockAPI_ListDiffClient interface

+ Recv func() (*DiffInfo, error)

+ type BlockAPI_ListDiffServer interface

+ Send func(*DiffInfo) error

+ type BlockAPI_PutBlockClient interface

+ CloseAndRecv func() (*BlockRefs, error)

+ Send func(*PutBlockRequest) error

+ type BlockAPI_PutBlockServer interface

+ Recv func() (*PutBlockRequest, error)

+ SendAndClose func(*BlockRefs) error

+ type BlockInfo struct

+ Block *Block

+ Created *google_protobuf2.Timestamp

+ SizeBytes uint64

+ func (*BlockInfo) Descriptor() ([]byte, []int)

+ func (*BlockInfo) ProtoMessage()

+ func (m *BlockInfo) GetBlock() *Block

+ func (m *BlockInfo) GetCreated() *google_protobuf2.Timestamp

+ func (m *BlockInfo) Reset()

+ func (m *BlockInfo) String() string

+ type BlockInfos struct

+ BlockInfo []*BlockInfo

+ func (*BlockInfos) Descriptor() ([]byte, []int)

+ func (*BlockInfos) ProtoMessage()

+ func (m *BlockInfos) GetBlockInfo() []*BlockInfo

+ func (m *BlockInfos) Reset()

+ func (m *BlockInfos) String() string

+ type BlockRef struct

+ Block *Block

+ Range *ByteRange

+ func (*BlockRef) Descriptor() ([]byte, []int)

+ func (*BlockRef) ProtoMessage()

+ func (m *BlockRef) GetBlock() *Block

+ func (m *BlockRef) GetRange() *ByteRange

+ func (m *BlockRef) Reset()

+ func (m *BlockRef) String() string

+ type BlockRefs struct

+ BlockRef []*BlockRef

+ func (*BlockRefs) Descriptor() ([]byte, []int)

+ func (*BlockRefs) ProtoMessage()

+ func (m *BlockRefs) GetBlockRef() []*BlockRef

+ func (m *BlockRefs) Reset()

+ func (m *BlockRefs) String() string

+ type ByteRange struct

+ Lower uint64

+ Upper uint64

+ func (*ByteRange) Descriptor() ([]byte, []int)

+ func (*ByteRange) ProtoMessage()

+ func (m *ByteRange) Reset()

+ func (m *ByteRange) String() string

+ type Commit struct

+ ID string

+ Repo *Repo

+ func (*Commit) Descriptor() ([]byte, []int)

+ func (*Commit) ProtoMessage()

+ func (m *Commit) GetRepo() *Repo

+ func (m *Commit) Reset()

+ func (m *Commit) String() string

+ type CommitInfo struct

+ Branch string

+ Cancelled bool

+ Commit *Commit

+ CommitType CommitType

+ Finished *google_protobuf2.Timestamp

+ ParentCommit *Commit

+ Provenance []*Commit

+ SizeBytes uint64

+ Started *google_protobuf2.Timestamp

+ func (*CommitInfo) Descriptor() ([]byte, []int)

+ func (*CommitInfo) ProtoMessage()

+ func (m *CommitInfo) GetCommit() *Commit

+ func (m *CommitInfo) GetFinished() *google_protobuf2.Timestamp

+ func (m *CommitInfo) GetParentCommit() *Commit

+ func (m *CommitInfo) GetProvenance() []*Commit

+ func (m *CommitInfo) GetStarted() *google_protobuf2.Timestamp

+ func (m *CommitInfo) Reset()

+ func (m *CommitInfo) String() string

+ type CommitInfos struct

+ CommitInfo []*CommitInfo

+ func (*CommitInfos) Descriptor() ([]byte, []int)

+ func (*CommitInfos) ProtoMessage()

+ func (m *CommitInfos) GetCommitInfo() []*CommitInfo

+ func (m *CommitInfos) Reset()

+ func (m *CommitInfos) String() string

+ type CommitType int32

+ const CommitType_COMMIT_TYPE_NONE

+ const CommitType_COMMIT_TYPE_READ

+ const CommitType_COMMIT_TYPE_WRITE

+ func (CommitType) EnumDescriptor() ([]byte, []int)

+ func (x CommitType) String() string

+ type CreateRepoRequest struct

+ Created *google_protobuf2.Timestamp

+ Provenance []*Repo

+ Repo *Repo

+ func (*CreateRepoRequest) Descriptor() ([]byte, []int)

+ func (*CreateRepoRequest) ProtoMessage()

+ func (m *CreateRepoRequest) GetCreated() *google_protobuf2.Timestamp

+ func (m *CreateRepoRequest) GetProvenance() []*Repo

+ func (m *CreateRepoRequest) GetRepo() *Repo

+ func (m *CreateRepoRequest) Reset()

+ func (m *CreateRepoRequest) String() string

+ type DeleteBlockRequest struct

+ Block *Block

+ func (*DeleteBlockRequest) Descriptor() ([]byte, []int)

+ func (*DeleteBlockRequest) ProtoMessage()

+ func (m *DeleteBlockRequest) GetBlock() *Block

+ func (m *DeleteBlockRequest) Reset()

+ func (m *DeleteBlockRequest) String() string

+ type DeleteCommitRequest struct

+ Commit *Commit

+ func (*DeleteCommitRequest) Descriptor() ([]byte, []int)

+ func (*DeleteCommitRequest) ProtoMessage()

+ func (m *DeleteCommitRequest) GetCommit() *Commit

+ func (m *DeleteCommitRequest) Reset()

+ func (m *DeleteCommitRequest) String() string

+ type DeleteDiffRequest struct

+ Diff *Diff

+ func (*DeleteDiffRequest) Descriptor() ([]byte, []int)

+ func (*DeleteDiffRequest) ProtoMessage()

+ func (m *DeleteDiffRequest) GetDiff() *Diff

+ func (m *DeleteDiffRequest) Reset()

+ func (m *DeleteDiffRequest) String() string

+ type DeleteFileRequest struct

+ File *File

+ Handle string

+ Unsafe bool

+ func (*DeleteFileRequest) Descriptor() ([]byte, []int)

+ func (*DeleteFileRequest) ProtoMessage()

+ func (m *DeleteFileRequest) GetFile() *File

+ func (m *DeleteFileRequest) Reset()

+ func (m *DeleteFileRequest) String() string

+ type DeleteRepoRequest struct

+ Repo *Repo

+ func (*DeleteRepoRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRepoRequest) ProtoMessage()

+ func (m *DeleteRepoRequest) GetRepo() *Repo

+ func (m *DeleteRepoRequest) Reset()

+ func (m *DeleteRepoRequest) String() string

+ type Delimiter int32

+ const Delimiter_JSON

+ const Delimiter_LINE

+ const Delimiter_NONE

+ func (Delimiter) EnumDescriptor() ([]byte, []int)

+ func (x Delimiter) String() string

+ type Diff struct

+ Commit *Commit

+ Shard uint64

+ func (*Diff) Descriptor() ([]byte, []int)

+ func (*Diff) ProtoMessage()

+ func (m *Diff) GetCommit() *Commit

+ func (m *Diff) Reset()

+ func (m *Diff) String() string

+ type DiffInfo struct

+ Appends map[string]*Append

+ Branch string

+ Cancelled bool

+ Diff *Diff

+ Finished *google_protobuf2.Timestamp

+ ParentCommit *Commit

+ Provenance []*Commit

+ SizeBytes uint64

+ Started *google_protobuf2.Timestamp

+ func (*DiffInfo) Descriptor() ([]byte, []int)

+ func (*DiffInfo) ProtoMessage()

+ func (m *DiffInfo) GetAppends() map[string]*Append

+ func (m *DiffInfo) GetDiff() *Diff

+ func (m *DiffInfo) GetFinished() *google_protobuf2.Timestamp

+ func (m *DiffInfo) GetParentCommit() *Commit

+ func (m *DiffInfo) GetProvenance() []*Commit

+ func (m *DiffInfo) GetStarted() *google_protobuf2.Timestamp

+ func (m *DiffInfo) Reset()

+ func (m *DiffInfo) String() string

+ type File struct

+ Commit *Commit

+ Path string

+ func (*File) Descriptor() ([]byte, []int)

+ func (*File) ProtoMessage()

+ func (m *File) GetCommit() *Commit

+ func (m *File) Reset()

+ func (m *File) String() string

+ type FileInfo struct

+ Children []*File

+ CommitModified *Commit

+ File *File

+ FileType FileType

+ Modified *google_protobuf2.Timestamp

+ SizeBytes uint64

+ func (*FileInfo) Descriptor() ([]byte, []int)

+ func (*FileInfo) ProtoMessage()

+ func (m *FileInfo) GetChildren() []*File

+ func (m *FileInfo) GetCommitModified() *Commit

+ func (m *FileInfo) GetFile() *File

+ func (m *FileInfo) GetModified() *google_protobuf2.Timestamp

+ func (m *FileInfo) Reset()

+ func (m *FileInfo) String() string

+ type FileInfos struct

+ FileInfo []*FileInfo

+ func (*FileInfos) Descriptor() ([]byte, []int)

+ func (*FileInfos) ProtoMessage()

+ func (m *FileInfos) GetFileInfo() []*FileInfo

+ func (m *FileInfos) Reset()

+ func (m *FileInfos) String() string

+ type FileType int32

+ const FileType_FILE_TYPE_DIR

+ const FileType_FILE_TYPE_NONE

+ const FileType_FILE_TYPE_REGULAR

+ func (FileType) EnumDescriptor() ([]byte, []int)

+ func (x FileType) String() string

+ type FinishCommitRequest struct

+ Cancel bool

+ Commit *Commit

+ Finished *google_protobuf2.Timestamp

+ func (*FinishCommitRequest) Descriptor() ([]byte, []int)

+ func (*FinishCommitRequest) ProtoMessage()

+ func (m *FinishCommitRequest) GetCommit() *Commit

+ func (m *FinishCommitRequest) GetFinished() *google_protobuf2.Timestamp

+ func (m *FinishCommitRequest) Reset()

+ func (m *FinishCommitRequest) String() string

+ type FlushCommitRequest struct

+ Commit []*Commit

+ ToRepo []*Repo

+ func (*FlushCommitRequest) Descriptor() ([]byte, []int)

+ func (*FlushCommitRequest) ProtoMessage()

+ func (m *FlushCommitRequest) GetCommit() []*Commit

+ func (m *FlushCommitRequest) GetToRepo() []*Repo

+ func (m *FlushCommitRequest) Reset()

+ func (m *FlushCommitRequest) String() string

+ type GetBlockRequest struct

+ Block *Block

+ OffsetBytes uint64

+ SizeBytes uint64

+ func (*GetBlockRequest) Descriptor() ([]byte, []int)

+ func (*GetBlockRequest) ProtoMessage()

+ func (m *GetBlockRequest) GetBlock() *Block

+ func (m *GetBlockRequest) Reset()

+ func (m *GetBlockRequest) String() string

+ type GetFileRequest struct

+ File *File

+ FromCommit *Commit

+ Handle string

+ OffsetBytes int64

+ Shard *Shard

+ SizeBytes int64

+ Unsafe bool

+ func (*GetFileRequest) Descriptor() ([]byte, []int)

+ func (*GetFileRequest) ProtoMessage()

+ func (m *GetFileRequest) GetFile() *File

+ func (m *GetFileRequest) GetFromCommit() *Commit

+ func (m *GetFileRequest) GetShard() *Shard

+ func (m *GetFileRequest) Reset()

+ func (m *GetFileRequest) String() string

+ type InspectBlockRequest struct

+ Block *Block

+ func (*InspectBlockRequest) Descriptor() ([]byte, []int)

+ func (*InspectBlockRequest) ProtoMessage()

+ func (m *InspectBlockRequest) GetBlock() *Block

+ func (m *InspectBlockRequest) Reset()

+ func (m *InspectBlockRequest) String() string

+ type InspectCommitRequest struct

+ Commit *Commit

+ func (*InspectCommitRequest) Descriptor() ([]byte, []int)

+ func (*InspectCommitRequest) ProtoMessage()

+ func (m *InspectCommitRequest) GetCommit() *Commit

+ func (m *InspectCommitRequest) Reset()

+ func (m *InspectCommitRequest) String() string

+ type InspectDiffRequest struct

+ Diff *Diff

+ func (*InspectDiffRequest) Descriptor() ([]byte, []int)

+ func (*InspectDiffRequest) ProtoMessage()

+ func (m *InspectDiffRequest) GetDiff() *Diff

+ func (m *InspectDiffRequest) Reset()

+ func (m *InspectDiffRequest) String() string

+ type InspectFileRequest struct

+ File *File

+ FromCommit *Commit

+ Handle string

+ Shard *Shard

+ Unsafe bool

+ func (*InspectFileRequest) Descriptor() ([]byte, []int)

+ func (*InspectFileRequest) ProtoMessage()

+ func (m *InspectFileRequest) GetFile() *File

+ func (m *InspectFileRequest) GetFromCommit() *Commit

+ func (m *InspectFileRequest) GetShard() *Shard

+ func (m *InspectFileRequest) Reset()

+ func (m *InspectFileRequest) String() string

+ type InspectRepoRequest struct

+ Repo *Repo

+ func (*InspectRepoRequest) Descriptor() ([]byte, []int)

+ func (*InspectRepoRequest) ProtoMessage()

+ func (m *InspectRepoRequest) GetRepo() *Repo

+ func (m *InspectRepoRequest) Reset()

+ func (m *InspectRepoRequest) String() string

+ type InternalAPIClient interface

+ CreateRepo func(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteAll func(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteCommit func(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteFile func(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ DeleteRepo func(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ FinishCommit func(ctx context.Context, in *FinishCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ FlushCommit func(ctx context.Context, in *FlushCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)

+ GetFile func(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (InternalAPI_GetFileClient, error)

+ InspectCommit func(ctx context.Context, in *InspectCommitRequest, opts ...grpc.CallOption) (*CommitInfo, error)

+ InspectFile func(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error)

+ InspectRepo func(ctx context.Context, in *InspectRepoRequest, opts ...grpc.CallOption) (*RepoInfo, error)

+ ListBranch func(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*CommitInfos, error)

+ ListCommit func(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)

+ ListFile func(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*FileInfos, error)

+ ListRepo func(ctx context.Context, in *ListRepoRequest, opts ...grpc.CallOption) (*RepoInfos, error)

+ PutFile func(ctx context.Context, opts ...grpc.CallOption) (InternalAPI_PutFileClient, error)

+ StartCommit func(ctx context.Context, in *StartCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)

+ func NewInternalAPIClient(cc *grpc.ClientConn) InternalAPIClient

+ type InternalAPIServer interface

+ CreateRepo func(context.Context, *CreateRepoRequest) (*google_protobuf1.Empty, error)

+ DeleteAll func(context.Context, *google_protobuf1.Empty) (*google_protobuf1.Empty, error)

+ DeleteCommit func(context.Context, *DeleteCommitRequest) (*google_protobuf1.Empty, error)

+ DeleteFile func(context.Context, *DeleteFileRequest) (*google_protobuf1.Empty, error)

+ DeleteRepo func(context.Context, *DeleteRepoRequest) (*google_protobuf1.Empty, error)

+ FinishCommit func(context.Context, *FinishCommitRequest) (*google_protobuf1.Empty, error)

+ FlushCommit func(context.Context, *FlushCommitRequest) (*CommitInfos, error)

+ GetFile func(*GetFileRequest, InternalAPI_GetFileServer) error

+ InspectCommit func(context.Context, *InspectCommitRequest) (*CommitInfo, error)

+ InspectFile func(context.Context, *InspectFileRequest) (*FileInfo, error)

+ InspectRepo func(context.Context, *InspectRepoRequest) (*RepoInfo, error)

+ ListBranch func(context.Context, *ListBranchRequest) (*CommitInfos, error)

+ ListCommit func(context.Context, *ListCommitRequest) (*CommitInfos, error)

+ ListFile func(context.Context, *ListFileRequest) (*FileInfos, error)

+ ListRepo func(context.Context, *ListRepoRequest) (*RepoInfos, error)

+ PutFile func(InternalAPI_PutFileServer) error

+ StartCommit func(context.Context, *StartCommitRequest) (*google_protobuf1.Empty, error)

+ type InternalAPI_GetFileClient interface

+ Recv func() (*google_protobuf3.BytesValue, error)

+ type InternalAPI_GetFileServer interface

+ Send func(*google_protobuf3.BytesValue) error

+ type InternalAPI_PutFileClient interface

+ CloseAndRecv func() (*google_protobuf1.Empty, error)

+ Send func(*PutFileRequest) error

+ type InternalAPI_PutFileServer interface

+ Recv func() (*PutFileRequest, error)

+ SendAndClose func(*google_protobuf1.Empty) error

+ type ListBlockRequest struct

+ func (*ListBlockRequest) Descriptor() ([]byte, []int)

+ func (*ListBlockRequest) ProtoMessage()

+ func (m *ListBlockRequest) Reset()

+ func (m *ListBlockRequest) String() string

+ type ListBranchRequest struct

+ Repo *Repo

+ func (*ListBranchRequest) Descriptor() ([]byte, []int)

+ func (*ListBranchRequest) ProtoMessage()

+ func (m *ListBranchRequest) GetRepo() *Repo

+ func (m *ListBranchRequest) Reset()

+ func (m *ListBranchRequest) String() string

+ type ListCommitRequest struct

+ All bool

+ Block bool

+ CommitType CommitType

+ FromCommit []*Commit

+ Provenance []*Commit

+ Repo []*Repo

+ func (*ListCommitRequest) Descriptor() ([]byte, []int)

+ func (*ListCommitRequest) ProtoMessage()

+ func (m *ListCommitRequest) GetFromCommit() []*Commit

+ func (m *ListCommitRequest) GetProvenance() []*Commit

+ func (m *ListCommitRequest) GetRepo() []*Repo

+ func (m *ListCommitRequest) Reset()

+ func (m *ListCommitRequest) String() string

+ type ListDiffRequest struct

+ Shard uint64

+ func (*ListDiffRequest) Descriptor() ([]byte, []int)

+ func (*ListDiffRequest) ProtoMessage()

+ func (m *ListDiffRequest) Reset()

+ func (m *ListDiffRequest) String() string

+ type ListFileRequest struct

+ File *File

+ FromCommit *Commit

+ Handle string

+ Recurse bool

+ Shard *Shard

+ Unsafe bool

+ func (*ListFileRequest) Descriptor() ([]byte, []int)

+ func (*ListFileRequest) ProtoMessage()

+ func (m *ListFileRequest) GetFile() *File

+ func (m *ListFileRequest) GetFromCommit() *Commit

+ func (m *ListFileRequest) GetShard() *Shard

+ func (m *ListFileRequest) Reset()

+ func (m *ListFileRequest) String() string

+ type ListRepoRequest struct

+ Provenance []*Repo

+ func (*ListRepoRequest) Descriptor() ([]byte, []int)

+ func (*ListRepoRequest) ProtoMessage()

+ func (m *ListRepoRequest) GetProvenance() []*Repo

+ func (m *ListRepoRequest) Reset()

+ func (m *ListRepoRequest) String() string

+ type PutBlockRequest struct

+ Delimiter Delimiter

+ Value []byte

+ func (*PutBlockRequest) Descriptor() ([]byte, []int)

+ func (*PutBlockRequest) ProtoMessage()

+ func (m *PutBlockRequest) Reset()

+ func (m *PutBlockRequest) String() string

+ type PutFileRequest struct

+ Delimiter Delimiter

+ File *File

+ FileType FileType

+ Handle string

+ Value []byte

+ func (*PutFileRequest) Descriptor() ([]byte, []int)

+ func (*PutFileRequest) ProtoMessage()

+ func (m *PutFileRequest) GetFile() *File

+ func (m *PutFileRequest) Reset()

+ func (m *PutFileRequest) String() string

+ type Repo struct

+ Name string

+ func (*Repo) Descriptor() ([]byte, []int)

+ func (*Repo) ProtoMessage()

+ func (m *Repo) Reset()

+ func (m *Repo) String() string

+ type RepoInfo struct

+ Created *google_protobuf2.Timestamp

+ Provenance []*Repo

+ Repo *Repo

+ SizeBytes uint64

+ func (*RepoInfo) Descriptor() ([]byte, []int)

+ func (*RepoInfo) ProtoMessage()

+ func (m *RepoInfo) GetCreated() *google_protobuf2.Timestamp

+ func (m *RepoInfo) GetProvenance() []*Repo

+ func (m *RepoInfo) GetRepo() *Repo

+ func (m *RepoInfo) Reset()

+ func (m *RepoInfo) String() string

+ type RepoInfos struct

+ RepoInfo []*RepoInfo

+ func (*RepoInfos) Descriptor() ([]byte, []int)

+ func (*RepoInfos) ProtoMessage()

+ func (m *RepoInfos) GetRepoInfo() []*RepoInfo

+ func (m *RepoInfos) Reset()

+ func (m *RepoInfos) String() string

+ type Shard struct

+ BlockModulus uint64

+ BlockNumber uint64

+ FileModulus uint64

+ FileNumber uint64

+ func (*Shard) Descriptor() ([]byte, []int)

+ func (*Shard) ProtoMessage()

+ func (m *Shard) Reset()

+ func (m *Shard) String() string

+ type StartCommitRequest struct

+ Branch string

+ ID string

+ ParentID string

+ Provenance []*Commit

+ Repo *Repo

+ Started *google_protobuf2.Timestamp

+ func (*StartCommitRequest) Descriptor() ([]byte, []int)

+ func (*StartCommitRequest) ProtoMessage()

+ func (m *StartCommitRequest) GetProvenance() []*Commit

+ func (m *StartCommitRequest) GetRepo() *Repo

+ func (m *StartCommitRequest) GetStarted() *google_protobuf2.Timestamp

+ func (m *StartCommitRequest) Reset()

+ func (m *StartCommitRequest) String() string