Documentation ¶
Index ¶
- Variables
- func EncodeHash(bytes []byte) string
- func NewHash() hash.Hash
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- func RegisterObjectAPIServer(s *grpc.Server, srv ObjectAPIServer)
- type APIClient
- type APIServer
- type API_FlushCommitClient
- type API_FlushCommitServer
- type API_GetFileClient
- type API_GetFileServer
- type API_GlobFileStreamClient
- type API_GlobFileStreamServer
- type API_ListCommitStreamClient
- type API_ListCommitStreamServer
- type API_ListFileStreamClient
- type API_ListFileStreamServer
- type API_PutFileClient
- type API_PutFileServer
- type API_SubscribeCommitClient
- type API_SubscribeCommitServer
- type Block
- func (*Block) Descriptor() ([]byte, []int)
- func (m *Block) GetHash() string
- func (m *Block) Marshal() (dAtA []byte, err error)
- func (m *Block) MarshalTo(dAtA []byte) (int, error)
- func (*Block) ProtoMessage()
- func (m *Block) Reset()
- func (m *Block) Size() (n int)
- func (m *Block) String() string
- func (m *Block) Unmarshal(dAtA []byte) error
- func (m *Block) XXX_DiscardUnknown()
- func (m *Block) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Block) XXX_Merge(src proto.Message)
- func (m *Block) XXX_Size() int
- func (m *Block) XXX_Unmarshal(b []byte) error
- type BlockRef
- func (*BlockRef) Descriptor() ([]byte, []int)
- func (m *BlockRef) GetBlock() *Block
- func (m *BlockRef) GetRange() *ByteRange
- func (m *BlockRef) Marshal() (dAtA []byte, err error)
- func (m *BlockRef) MarshalTo(dAtA []byte) (int, error)
- func (*BlockRef) ProtoMessage()
- func (m *BlockRef) Reset()
- func (m *BlockRef) Size() (n int)
- func (m *BlockRef) String() string
- func (m *BlockRef) Unmarshal(dAtA []byte) error
- func (m *BlockRef) XXX_DiscardUnknown()
- func (m *BlockRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BlockRef) XXX_Merge(src proto.Message)
- func (m *BlockRef) XXX_Size() int
- func (m *BlockRef) XXX_Unmarshal(b []byte) error
- type Branch
- func (*Branch) Descriptor() ([]byte, []int)
- func (m *Branch) GetName() string
- func (m *Branch) GetRepo() *Repo
- func (m *Branch) Marshal() (dAtA []byte, err error)
- func (m *Branch) MarshalTo(dAtA []byte) (int, error)
- func (*Branch) ProtoMessage()
- func (m *Branch) Reset()
- func (m *Branch) Size() (n int)
- func (m *Branch) String() string
- func (m *Branch) Unmarshal(dAtA []byte) error
- func (m *Branch) XXX_DiscardUnknown()
- func (m *Branch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Branch) XXX_Merge(src proto.Message)
- func (m *Branch) XXX_Size() int
- func (m *Branch) XXX_Unmarshal(b []byte) error
- type BranchInfo
- func (*BranchInfo) Descriptor() ([]byte, []int)
- func (m *BranchInfo) GetBranch() *Branch
- func (m *BranchInfo) GetDirectProvenance() []*Branch
- func (m *BranchInfo) GetHead() *Commit
- func (m *BranchInfo) GetName() string
- func (m *BranchInfo) GetProvenance() []*Branch
- func (m *BranchInfo) GetSubvenance() []*Branch
- func (m *BranchInfo) Marshal() (dAtA []byte, err error)
- func (m *BranchInfo) MarshalTo(dAtA []byte) (int, error)
- func (*BranchInfo) ProtoMessage()
- func (m *BranchInfo) Reset()
- func (m *BranchInfo) Size() (n int)
- func (m *BranchInfo) String() string
- func (m *BranchInfo) Unmarshal(dAtA []byte) error
- func (m *BranchInfo) XXX_DiscardUnknown()
- func (m *BranchInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BranchInfo) XXX_Merge(src proto.Message)
- func (m *BranchInfo) XXX_Size() int
- func (m *BranchInfo) XXX_Unmarshal(b []byte) error
- type BranchInfos
- func (*BranchInfos) Descriptor() ([]byte, []int)
- func (m *BranchInfos) GetBranchInfo() []*BranchInfo
- func (m *BranchInfos) Marshal() (dAtA []byte, err error)
- func (m *BranchInfos) MarshalTo(dAtA []byte) (int, error)
- func (*BranchInfos) ProtoMessage()
- func (m *BranchInfos) Reset()
- func (m *BranchInfos) Size() (n int)
- func (m *BranchInfos) String() string
- func (m *BranchInfos) Unmarshal(dAtA []byte) error
- func (m *BranchInfos) XXX_DiscardUnknown()
- func (m *BranchInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BranchInfos) XXX_Merge(src proto.Message)
- func (m *BranchInfos) XXX_Size() int
- func (m *BranchInfos) XXX_Unmarshal(b []byte) error
- type BuildCommitRequest
- func (*BuildCommitRequest) Descriptor() ([]byte, []int)
- func (m *BuildCommitRequest) GetBranch() string
- func (m *BuildCommitRequest) GetID() string
- func (m *BuildCommitRequest) GetParent() *Commit
- func (m *BuildCommitRequest) GetProvenance() []*Commit
- func (m *BuildCommitRequest) GetTree() *Object
- func (m *BuildCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *BuildCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BuildCommitRequest) ProtoMessage()
- func (m *BuildCommitRequest) Reset()
- func (m *BuildCommitRequest) Size() (n int)
- func (m *BuildCommitRequest) String() string
- func (m *BuildCommitRequest) Unmarshal(dAtA []byte) error
- func (m *BuildCommitRequest) XXX_DiscardUnknown()
- func (m *BuildCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BuildCommitRequest) XXX_Merge(src proto.Message)
- func (m *BuildCommitRequest) XXX_Size() int
- func (m *BuildCommitRequest) XXX_Unmarshal(b []byte) error
- type ByteRange
- func (*ByteRange) Descriptor() ([]byte, []int)
- func (m *ByteRange) GetLower() uint64
- func (m *ByteRange) GetUpper() uint64
- func (m *ByteRange) Marshal() (dAtA []byte, err error)
- func (m *ByteRange) MarshalTo(dAtA []byte) (int, error)
- func (*ByteRange) ProtoMessage()
- func (m *ByteRange) Reset()
- func (m *ByteRange) Size() (n int)
- func (m *ByteRange) String() string
- func (m *ByteRange) Unmarshal(dAtA []byte) error
- func (m *ByteRange) XXX_DiscardUnknown()
- func (m *ByteRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ByteRange) XXX_Merge(src proto.Message)
- func (m *ByteRange) XXX_Size() int
- func (m *ByteRange) XXX_Unmarshal(b []byte) error
- type CheckObjectRequest
- func (*CheckObjectRequest) Descriptor() ([]byte, []int)
- func (m *CheckObjectRequest) GetObject() *Object
- func (m *CheckObjectRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckObjectRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CheckObjectRequest) ProtoMessage()
- func (m *CheckObjectRequest) Reset()
- func (m *CheckObjectRequest) Size() (n int)
- func (m *CheckObjectRequest) String() string
- func (m *CheckObjectRequest) Unmarshal(dAtA []byte) error
- func (m *CheckObjectRequest) XXX_DiscardUnknown()
- func (m *CheckObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckObjectRequest) XXX_Merge(src proto.Message)
- func (m *CheckObjectRequest) XXX_Size() int
- func (m *CheckObjectRequest) XXX_Unmarshal(b []byte) error
- type CheckObjectResponse
- func (*CheckObjectResponse) Descriptor() ([]byte, []int)
- func (m *CheckObjectResponse) GetExists() bool
- func (m *CheckObjectResponse) Marshal() (dAtA []byte, err error)
- func (m *CheckObjectResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CheckObjectResponse) ProtoMessage()
- func (m *CheckObjectResponse) Reset()
- func (m *CheckObjectResponse) Size() (n int)
- func (m *CheckObjectResponse) String() string
- func (m *CheckObjectResponse) Unmarshal(dAtA []byte) error
- func (m *CheckObjectResponse) XXX_DiscardUnknown()
- func (m *CheckObjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckObjectResponse) XXX_Merge(src proto.Message)
- func (m *CheckObjectResponse) XXX_Size() int
- func (m *CheckObjectResponse) XXX_Unmarshal(b []byte) error
- type Commit
- func (*Commit) Descriptor() ([]byte, []int)
- func (c *Commit) FullID() string
- func (m *Commit) GetID() string
- func (m *Commit) GetRepo() *Repo
- func (m *Commit) Marshal() (dAtA []byte, err error)
- func (m *Commit) MarshalTo(dAtA []byte) (int, error)
- func (*Commit) ProtoMessage()
- func (m *Commit) Reset()
- func (m *Commit) Size() (n int)
- func (m *Commit) String() string
- func (m *Commit) Unmarshal(dAtA []byte) error
- func (m *Commit) XXX_DiscardUnknown()
- func (m *Commit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Commit) XXX_Merge(src proto.Message)
- func (m *Commit) XXX_Size() int
- func (m *Commit) XXX_Unmarshal(b []byte) error
- type CommitInfo
- func (*CommitInfo) Descriptor() ([]byte, []int)
- func (m *CommitInfo) GetBranchProvenance() []*Branch
- func (m *CommitInfo) GetChildCommits() []*Commit
- func (m *CommitInfo) GetCommit() *Commit
- func (m *CommitInfo) GetDescription() string
- func (m *CommitInfo) GetFinished() *types.Timestamp
- func (m *CommitInfo) GetParentCommit() *Commit
- func (m *CommitInfo) GetProvenance() []*Commit
- func (m *CommitInfo) GetReadyProvenance() int64
- func (m *CommitInfo) GetSizeBytes() uint64
- func (m *CommitInfo) GetStarted() *types.Timestamp
- func (m *CommitInfo) GetSubvenance() []*CommitRange
- func (m *CommitInfo) GetTree() *Object
- func (m *CommitInfo) Marshal() (dAtA []byte, err error)
- func (m *CommitInfo) MarshalTo(dAtA []byte) (int, error)
- func (*CommitInfo) ProtoMessage()
- func (m *CommitInfo) Reset()
- func (m *CommitInfo) Size() (n int)
- func (m *CommitInfo) String() string
- func (m *CommitInfo) Unmarshal(dAtA []byte) error
- func (m *CommitInfo) XXX_DiscardUnknown()
- func (m *CommitInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommitInfo) XXX_Merge(src proto.Message)
- func (m *CommitInfo) XXX_Size() int
- func (m *CommitInfo) XXX_Unmarshal(b []byte) error
- type CommitInfos
- func (*CommitInfos) Descriptor() ([]byte, []int)
- func (m *CommitInfos) GetCommitInfo() []*CommitInfo
- func (m *CommitInfos) Marshal() (dAtA []byte, err error)
- func (m *CommitInfos) MarshalTo(dAtA []byte) (int, error)
- func (*CommitInfos) ProtoMessage()
- func (m *CommitInfos) Reset()
- func (m *CommitInfos) Size() (n int)
- func (m *CommitInfos) String() string
- func (m *CommitInfos) Unmarshal(dAtA []byte) error
- func (m *CommitInfos) XXX_DiscardUnknown()
- func (m *CommitInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommitInfos) XXX_Merge(src proto.Message)
- func (m *CommitInfos) XXX_Size() int
- func (m *CommitInfos) XXX_Unmarshal(b []byte) error
- type CommitRange
- func (*CommitRange) Descriptor() ([]byte, []int)
- 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 (*CommitRange) ProtoMessage()
- func (m *CommitRange) Reset()
- func (m *CommitRange) Size() (n int)
- func (m *CommitRange) String() string
- func (m *CommitRange) Unmarshal(dAtA []byte) error
- func (m *CommitRange) XXX_DiscardUnknown()
- func (m *CommitRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommitRange) XXX_Merge(src proto.Message)
- func (m *CommitRange) XXX_Size() int
- func (m *CommitRange) XXX_Unmarshal(b []byte) error
- type CommitState
- type CopyFileRequest
- func (*CopyFileRequest) Descriptor() ([]byte, []int)
- 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 (*CopyFileRequest) ProtoMessage()
- func (m *CopyFileRequest) Reset()
- func (m *CopyFileRequest) Size() (n int)
- func (m *CopyFileRequest) String() string
- func (m *CopyFileRequest) Unmarshal(dAtA []byte) error
- func (m *CopyFileRequest) XXX_DiscardUnknown()
- func (m *CopyFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CopyFileRequest) XXX_Merge(src proto.Message)
- func (m *CopyFileRequest) XXX_Size() int
- func (m *CopyFileRequest) XXX_Unmarshal(b []byte) error
- type CreateBranchRequest
- func (*CreateBranchRequest) Descriptor() ([]byte, []int)
- 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 (*CreateBranchRequest) ProtoMessage()
- func (m *CreateBranchRequest) Reset()
- func (m *CreateBranchRequest) Size() (n int)
- func (m *CreateBranchRequest) String() string
- func (m *CreateBranchRequest) Unmarshal(dAtA []byte) error
- func (m *CreateBranchRequest) XXX_DiscardUnknown()
- func (m *CreateBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateBranchRequest) XXX_Merge(src proto.Message)
- func (m *CreateBranchRequest) XXX_Size() int
- func (m *CreateBranchRequest) XXX_Unmarshal(b []byte) error
- type CreateRepoRequest
- func (*CreateRepoRequest) Descriptor() ([]byte, []int)
- func (m *CreateRepoRequest) GetDescription() string
- func (m *CreateRepoRequest) GetRepo() *Repo
- func (m *CreateRepoRequest) GetUpdate() bool
- func (m *CreateRepoRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateRepoRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CreateRepoRequest) ProtoMessage()
- func (m *CreateRepoRequest) Reset()
- func (m *CreateRepoRequest) Size() (n int)
- func (m *CreateRepoRequest) String() string
- func (m *CreateRepoRequest) Unmarshal(dAtA []byte) error
- func (m *CreateRepoRequest) XXX_DiscardUnknown()
- func (m *CreateRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRepoRequest) XXX_Merge(src proto.Message)
- func (m *CreateRepoRequest) XXX_Size() int
- func (m *CreateRepoRequest) XXX_Unmarshal(b []byte) error
- type DeleteBranchRequest
- func (*DeleteBranchRequest) Descriptor() ([]byte, []int)
- func (m *DeleteBranchRequest) GetBranch() *Branch
- func (m *DeleteBranchRequest) GetForce() bool
- func (m *DeleteBranchRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteBranchRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteBranchRequest) ProtoMessage()
- func (m *DeleteBranchRequest) Reset()
- func (m *DeleteBranchRequest) Size() (n int)
- func (m *DeleteBranchRequest) String() string
- func (m *DeleteBranchRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteBranchRequest) XXX_DiscardUnknown()
- func (m *DeleteBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteBranchRequest) XXX_Merge(src proto.Message)
- func (m *DeleteBranchRequest) XXX_Size() int
- func (m *DeleteBranchRequest) XXX_Unmarshal(b []byte) error
- type DeleteCommitRequest
- func (*DeleteCommitRequest) Descriptor() ([]byte, []int)
- func (m *DeleteCommitRequest) GetCommit() *Commit
- func (m *DeleteCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteCommitRequest) ProtoMessage()
- func (m *DeleteCommitRequest) Reset()
- func (m *DeleteCommitRequest) Size() (n int)
- func (m *DeleteCommitRequest) String() string
- func (m *DeleteCommitRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteCommitRequest) XXX_DiscardUnknown()
- func (m *DeleteCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteCommitRequest) XXX_Merge(src proto.Message)
- func (m *DeleteCommitRequest) XXX_Size() int
- func (m *DeleteCommitRequest) XXX_Unmarshal(b []byte) error
- type DeleteFileRequest
- func (*DeleteFileRequest) Descriptor() ([]byte, []int)
- func (m *DeleteFileRequest) GetFile() *File
- func (m *DeleteFileRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteFileRequest) ProtoMessage()
- func (m *DeleteFileRequest) Reset()
- func (m *DeleteFileRequest) Size() (n int)
- func (m *DeleteFileRequest) String() string
- func (m *DeleteFileRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteFileRequest) XXX_DiscardUnknown()
- func (m *DeleteFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteFileRequest) XXX_Merge(src proto.Message)
- func (m *DeleteFileRequest) XXX_Size() int
- func (m *DeleteFileRequest) XXX_Unmarshal(b []byte) error
- type DeleteObjectsRequest
- func (*DeleteObjectsRequest) Descriptor() ([]byte, []int)
- func (m *DeleteObjectsRequest) GetObjects() []*Object
- func (m *DeleteObjectsRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteObjectsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteObjectsRequest) ProtoMessage()
- func (m *DeleteObjectsRequest) Reset()
- func (m *DeleteObjectsRequest) Size() (n int)
- func (m *DeleteObjectsRequest) String() string
- func (m *DeleteObjectsRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteObjectsRequest) XXX_DiscardUnknown()
- func (m *DeleteObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteObjectsRequest) XXX_Merge(src proto.Message)
- func (m *DeleteObjectsRequest) XXX_Size() int
- func (m *DeleteObjectsRequest) XXX_Unmarshal(b []byte) error
- type DeleteObjectsResponse
- func (*DeleteObjectsResponse) Descriptor() ([]byte, []int)
- func (m *DeleteObjectsResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteObjectsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteObjectsResponse) ProtoMessage()
- func (m *DeleteObjectsResponse) Reset()
- func (m *DeleteObjectsResponse) Size() (n int)
- func (m *DeleteObjectsResponse) String() string
- func (m *DeleteObjectsResponse) Unmarshal(dAtA []byte) error
- func (m *DeleteObjectsResponse) XXX_DiscardUnknown()
- func (m *DeleteObjectsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteObjectsResponse) XXX_Merge(src proto.Message)
- func (m *DeleteObjectsResponse) XXX_Size() int
- func (m *DeleteObjectsResponse) XXX_Unmarshal(b []byte) error
- type DeleteRepoRequest
- func (*DeleteRepoRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRepoRequest) GetAll() bool
- func (m *DeleteRepoRequest) GetForce() bool
- func (m *DeleteRepoRequest) GetRepo() *Repo
- func (m *DeleteRepoRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteRepoRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteRepoRequest) ProtoMessage()
- func (m *DeleteRepoRequest) Reset()
- func (m *DeleteRepoRequest) Size() (n int)
- func (m *DeleteRepoRequest) String() string
- func (m *DeleteRepoRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteRepoRequest) XXX_DiscardUnknown()
- func (m *DeleteRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRepoRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRepoRequest) XXX_Size() int
- func (m *DeleteRepoRequest) XXX_Unmarshal(b []byte) error
- type DeleteTagsRequest
- func (*DeleteTagsRequest) Descriptor() ([]byte, []int)
- func (m *DeleteTagsRequest) GetTags() []*Tag
- func (m *DeleteTagsRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteTagsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteTagsRequest) ProtoMessage()
- func (m *DeleteTagsRequest) Reset()
- func (m *DeleteTagsRequest) Size() (n int)
- func (m *DeleteTagsRequest) String() string
- func (m *DeleteTagsRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteTagsRequest) XXX_DiscardUnknown()
- func (m *DeleteTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteTagsRequest) XXX_Merge(src proto.Message)
- func (m *DeleteTagsRequest) XXX_Size() int
- func (m *DeleteTagsRequest) XXX_Unmarshal(b []byte) error
- type DeleteTagsResponse
- func (*DeleteTagsResponse) Descriptor() ([]byte, []int)
- func (m *DeleteTagsResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteTagsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteTagsResponse) ProtoMessage()
- func (m *DeleteTagsResponse) Reset()
- func (m *DeleteTagsResponse) Size() (n int)
- func (m *DeleteTagsResponse) String() string
- func (m *DeleteTagsResponse) Unmarshal(dAtA []byte) error
- func (m *DeleteTagsResponse) XXX_DiscardUnknown()
- func (m *DeleteTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteTagsResponse) XXX_Merge(src proto.Message)
- func (m *DeleteTagsResponse) XXX_Size() int
- func (m *DeleteTagsResponse) XXX_Unmarshal(b []byte) error
- type Delimiter
- type DiffFileRequest
- func (*DiffFileRequest) Descriptor() ([]byte, []int)
- func (m *DiffFileRequest) GetNewFile() *File
- func (m *DiffFileRequest) GetOldFile() *File
- func (m *DiffFileRequest) GetShallow() bool
- func (m *DiffFileRequest) Marshal() (dAtA []byte, err error)
- func (m *DiffFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DiffFileRequest) ProtoMessage()
- func (m *DiffFileRequest) Reset()
- func (m *DiffFileRequest) Size() (n int)
- func (m *DiffFileRequest) String() string
- func (m *DiffFileRequest) Unmarshal(dAtA []byte) error
- func (m *DiffFileRequest) XXX_DiscardUnknown()
- func (m *DiffFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiffFileRequest) XXX_Merge(src proto.Message)
- func (m *DiffFileRequest) XXX_Size() int
- func (m *DiffFileRequest) XXX_Unmarshal(b []byte) error
- type DiffFileResponse
- func (*DiffFileResponse) Descriptor() ([]byte, []int)
- func (m *DiffFileResponse) GetNewFiles() []*FileInfo
- func (m *DiffFileResponse) GetOldFiles() []*FileInfo
- func (m *DiffFileResponse) Marshal() (dAtA []byte, err error)
- func (m *DiffFileResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DiffFileResponse) ProtoMessage()
- func (m *DiffFileResponse) Reset()
- func (m *DiffFileResponse) Size() (n int)
- func (m *DiffFileResponse) String() string
- func (m *DiffFileResponse) Unmarshal(dAtA []byte) error
- func (m *DiffFileResponse) XXX_DiscardUnknown()
- func (m *DiffFileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiffFileResponse) XXX_Merge(src proto.Message)
- func (m *DiffFileResponse) XXX_Size() int
- func (m *DiffFileResponse) XXX_Unmarshal(b []byte) error
- type File
- func (*File) Descriptor() ([]byte, []int)
- func (m *File) GetCommit() *Commit
- func (m *File) GetPath() string
- func (m *File) Marshal() (dAtA []byte, err error)
- func (m *File) MarshalTo(dAtA []byte) (int, error)
- func (*File) ProtoMessage()
- func (m *File) Reset()
- func (m *File) Size() (n int)
- func (m *File) String() string
- func (m *File) Unmarshal(dAtA []byte) error
- func (m *File) XXX_DiscardUnknown()
- func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *File) XXX_Merge(src proto.Message)
- func (m *File) XXX_Size() int
- func (m *File) XXX_Unmarshal(b []byte) error
- type FileInfo
- func (*FileInfo) Descriptor() ([]byte, []int)
- func (m *FileInfo) GetChildren() []string
- func (m *FileInfo) GetFile() *File
- func (m *FileInfo) GetFileType() FileType
- func (m *FileInfo) GetHash() []byte
- func (m *FileInfo) GetObjects() []*Object
- func (m *FileInfo) GetSizeBytes() uint64
- func (m *FileInfo) Marshal() (dAtA []byte, err error)
- func (m *FileInfo) MarshalTo(dAtA []byte) (int, error)
- func (*FileInfo) ProtoMessage()
- func (m *FileInfo) Reset()
- func (m *FileInfo) Size() (n int)
- func (m *FileInfo) String() string
- func (m *FileInfo) Unmarshal(dAtA []byte) error
- func (m *FileInfo) XXX_DiscardUnknown()
- func (m *FileInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FileInfo) XXX_Merge(src proto.Message)
- func (m *FileInfo) XXX_Size() int
- func (m *FileInfo) XXX_Unmarshal(b []byte) error
- type FileInfos
- func (*FileInfos) Descriptor() ([]byte, []int)
- func (m *FileInfos) GetFileInfo() []*FileInfo
- func (m *FileInfos) Marshal() (dAtA []byte, err error)
- func (m *FileInfos) MarshalTo(dAtA []byte) (int, error)
- func (*FileInfos) ProtoMessage()
- func (m *FileInfos) Reset()
- func (m *FileInfos) Size() (n int)
- func (m *FileInfos) String() string
- func (m *FileInfos) Unmarshal(dAtA []byte) error
- func (m *FileInfos) XXX_DiscardUnknown()
- func (m *FileInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FileInfos) XXX_Merge(src proto.Message)
- func (m *FileInfos) XXX_Size() int
- func (m *FileInfos) XXX_Unmarshal(b []byte) error
- type FileType
- type FinishCommitRequest
- func (*FinishCommitRequest) Descriptor() ([]byte, []int)
- func (m *FinishCommitRequest) GetCommit() *Commit
- func (m *FinishCommitRequest) GetDescription() string
- func (m *FinishCommitRequest) GetEmpty() bool
- func (m *FinishCommitRequest) GetTree() *Object
- func (m *FinishCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *FinishCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*FinishCommitRequest) ProtoMessage()
- func (m *FinishCommitRequest) Reset()
- func (m *FinishCommitRequest) Size() (n int)
- func (m *FinishCommitRequest) String() string
- func (m *FinishCommitRequest) Unmarshal(dAtA []byte) error
- func (m *FinishCommitRequest) XXX_DiscardUnknown()
- func (m *FinishCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FinishCommitRequest) XXX_Merge(src proto.Message)
- func (m *FinishCommitRequest) XXX_Size() int
- func (m *FinishCommitRequest) XXX_Unmarshal(b []byte) error
- type FlushCommitRequest
- func (*FlushCommitRequest) Descriptor() ([]byte, []int)
- func (m *FlushCommitRequest) GetCommits() []*Commit
- func (m *FlushCommitRequest) GetToRepos() []*Repo
- func (m *FlushCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *FlushCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*FlushCommitRequest) ProtoMessage()
- func (m *FlushCommitRequest) Reset()
- func (m *FlushCommitRequest) Size() (n int)
- func (m *FlushCommitRequest) String() string
- func (m *FlushCommitRequest) Unmarshal(dAtA []byte) error
- func (m *FlushCommitRequest) XXX_DiscardUnknown()
- func (m *FlushCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FlushCommitRequest) XXX_Merge(src proto.Message)
- func (m *FlushCommitRequest) XXX_Size() int
- func (m *FlushCommitRequest) XXX_Unmarshal(b []byte) error
- type GetFileRequest
- func (*GetFileRequest) Descriptor() ([]byte, []int)
- func (m *GetFileRequest) GetFile() *File
- func (m *GetFileRequest) GetOffsetBytes() int64
- func (m *GetFileRequest) GetSizeBytes() int64
- func (m *GetFileRequest) Marshal() (dAtA []byte, err error)
- func (m *GetFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetFileRequest) ProtoMessage()
- func (m *GetFileRequest) Reset()
- func (m *GetFileRequest) Size() (n int)
- func (m *GetFileRequest) String() string
- func (m *GetFileRequest) Unmarshal(dAtA []byte) error
- func (m *GetFileRequest) XXX_DiscardUnknown()
- func (m *GetFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetFileRequest) XXX_Merge(src proto.Message)
- func (m *GetFileRequest) XXX_Size() int
- func (m *GetFileRequest) XXX_Unmarshal(b []byte) error
- type GetObjectsRequest
- func (*GetObjectsRequest) Descriptor() ([]byte, []int)
- func (m *GetObjectsRequest) GetObjects() []*Object
- func (m *GetObjectsRequest) GetOffsetBytes() uint64
- func (m *GetObjectsRequest) GetSizeBytes() uint64
- func (m *GetObjectsRequest) GetTotalSize() uint64
- func (m *GetObjectsRequest) Marshal() (dAtA []byte, err error)
- func (m *GetObjectsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetObjectsRequest) ProtoMessage()
- func (m *GetObjectsRequest) Reset()
- func (m *GetObjectsRequest) Size() (n int)
- func (m *GetObjectsRequest) String() string
- func (m *GetObjectsRequest) Unmarshal(dAtA []byte) error
- func (m *GetObjectsRequest) XXX_DiscardUnknown()
- func (m *GetObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetObjectsRequest) XXX_Merge(src proto.Message)
- func (m *GetObjectsRequest) XXX_Size() int
- func (m *GetObjectsRequest) XXX_Unmarshal(b []byte) error
- type GlobFileRequest
- func (*GlobFileRequest) Descriptor() ([]byte, []int)
- func (m *GlobFileRequest) GetCommit() *Commit
- func (m *GlobFileRequest) GetPattern() string
- func (m *GlobFileRequest) Marshal() (dAtA []byte, err error)
- func (m *GlobFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GlobFileRequest) ProtoMessage()
- func (m *GlobFileRequest) Reset()
- func (m *GlobFileRequest) Size() (n int)
- func (m *GlobFileRequest) String() string
- func (m *GlobFileRequest) Unmarshal(dAtA []byte) error
- func (m *GlobFileRequest) XXX_DiscardUnknown()
- func (m *GlobFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GlobFileRequest) XXX_Merge(src proto.Message)
- func (m *GlobFileRequest) XXX_Size() int
- func (m *GlobFileRequest) XXX_Unmarshal(b []byte) error
- type InspectBranchRequest
- func (*InspectBranchRequest) Descriptor() ([]byte, []int)
- func (m *InspectBranchRequest) GetBranch() *Branch
- func (m *InspectBranchRequest) Marshal() (dAtA []byte, err error)
- func (m *InspectBranchRequest) MarshalTo(dAtA []byte) (int, error)
- func (*InspectBranchRequest) ProtoMessage()
- func (m *InspectBranchRequest) Reset()
- func (m *InspectBranchRequest) Size() (n int)
- func (m *InspectBranchRequest) String() string
- func (m *InspectBranchRequest) Unmarshal(dAtA []byte) error
- func (m *InspectBranchRequest) XXX_DiscardUnknown()
- func (m *InspectBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectBranchRequest) XXX_Merge(src proto.Message)
- func (m *InspectBranchRequest) XXX_Size() int
- func (m *InspectBranchRequest) XXX_Unmarshal(b []byte) error
- type InspectCommitRequest
- func (*InspectCommitRequest) Descriptor() ([]byte, []int)
- func (m *InspectCommitRequest) GetBlockState() CommitState
- func (m *InspectCommitRequest) GetCommit() *Commit
- func (m *InspectCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *InspectCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*InspectCommitRequest) ProtoMessage()
- func (m *InspectCommitRequest) Reset()
- func (m *InspectCommitRequest) Size() (n int)
- func (m *InspectCommitRequest) String() string
- func (m *InspectCommitRequest) Unmarshal(dAtA []byte) error
- func (m *InspectCommitRequest) XXX_DiscardUnknown()
- func (m *InspectCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectCommitRequest) XXX_Merge(src proto.Message)
- func (m *InspectCommitRequest) XXX_Size() int
- func (m *InspectCommitRequest) XXX_Unmarshal(b []byte) error
- type InspectFileRequest
- func (*InspectFileRequest) Descriptor() ([]byte, []int)
- func (m *InspectFileRequest) GetFile() *File
- func (m *InspectFileRequest) Marshal() (dAtA []byte, err error)
- func (m *InspectFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*InspectFileRequest) ProtoMessage()
- func (m *InspectFileRequest) Reset()
- func (m *InspectFileRequest) Size() (n int)
- func (m *InspectFileRequest) String() string
- func (m *InspectFileRequest) Unmarshal(dAtA []byte) error
- func (m *InspectFileRequest) XXX_DiscardUnknown()
- func (m *InspectFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectFileRequest) XXX_Merge(src proto.Message)
- func (m *InspectFileRequest) XXX_Size() int
- func (m *InspectFileRequest) XXX_Unmarshal(b []byte) error
- type InspectRepoRequest
- func (*InspectRepoRequest) Descriptor() ([]byte, []int)
- func (m *InspectRepoRequest) GetRepo() *Repo
- func (m *InspectRepoRequest) Marshal() (dAtA []byte, err error)
- func (m *InspectRepoRequest) MarshalTo(dAtA []byte) (int, error)
- func (*InspectRepoRequest) ProtoMessage()
- func (m *InspectRepoRequest) Reset()
- func (m *InspectRepoRequest) Size() (n int)
- func (m *InspectRepoRequest) String() string
- func (m *InspectRepoRequest) Unmarshal(dAtA []byte) error
- func (m *InspectRepoRequest) XXX_DiscardUnknown()
- func (m *InspectRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectRepoRequest) XXX_Merge(src proto.Message)
- func (m *InspectRepoRequest) XXX_Size() int
- func (m *InspectRepoRequest) XXX_Unmarshal(b []byte) error
- type ListBranchRequest
- func (*ListBranchRequest) Descriptor() ([]byte, []int)
- func (m *ListBranchRequest) GetRepo() *Repo
- func (m *ListBranchRequest) Marshal() (dAtA []byte, err error)
- func (m *ListBranchRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListBranchRequest) ProtoMessage()
- func (m *ListBranchRequest) Reset()
- func (m *ListBranchRequest) Size() (n int)
- func (m *ListBranchRequest) String() string
- func (m *ListBranchRequest) Unmarshal(dAtA []byte) error
- func (m *ListBranchRequest) XXX_DiscardUnknown()
- func (m *ListBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListBranchRequest) XXX_Merge(src proto.Message)
- func (m *ListBranchRequest) XXX_Size() int
- func (m *ListBranchRequest) XXX_Unmarshal(b []byte) error
- type ListCommitRequest
- func (*ListCommitRequest) Descriptor() ([]byte, []int)
- func (m *ListCommitRequest) GetFrom() *Commit
- func (m *ListCommitRequest) GetNumber() uint64
- func (m *ListCommitRequest) GetRepo() *Repo
- func (m *ListCommitRequest) GetTo() *Commit
- func (m *ListCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *ListCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListCommitRequest) ProtoMessage()
- func (m *ListCommitRequest) Reset()
- func (m *ListCommitRequest) Size() (n int)
- func (m *ListCommitRequest) String() string
- func (m *ListCommitRequest) Unmarshal(dAtA []byte) error
- func (m *ListCommitRequest) XXX_DiscardUnknown()
- func (m *ListCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListCommitRequest) XXX_Merge(src proto.Message)
- func (m *ListCommitRequest) XXX_Size() int
- func (m *ListCommitRequest) XXX_Unmarshal(b []byte) error
- type ListFileRequest
- func (*ListFileRequest) Descriptor() ([]byte, []int)
- func (m *ListFileRequest) GetFile() *File
- func (m *ListFileRequest) GetFull() bool
- func (m *ListFileRequest) Marshal() (dAtA []byte, err error)
- func (m *ListFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListFileRequest) ProtoMessage()
- func (m *ListFileRequest) Reset()
- func (m *ListFileRequest) Size() (n int)
- func (m *ListFileRequest) String() string
- func (m *ListFileRequest) Unmarshal(dAtA []byte) error
- func (m *ListFileRequest) XXX_DiscardUnknown()
- func (m *ListFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListFileRequest) XXX_Merge(src proto.Message)
- func (m *ListFileRequest) XXX_Size() int
- func (m *ListFileRequest) XXX_Unmarshal(b []byte) error
- type ListObjectsRequest
- func (*ListObjectsRequest) Descriptor() ([]byte, []int)
- func (m *ListObjectsRequest) Marshal() (dAtA []byte, err error)
- func (m *ListObjectsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListObjectsRequest) ProtoMessage()
- func (m *ListObjectsRequest) Reset()
- func (m *ListObjectsRequest) Size() (n int)
- func (m *ListObjectsRequest) String() string
- func (m *ListObjectsRequest) Unmarshal(dAtA []byte) error
- func (m *ListObjectsRequest) XXX_DiscardUnknown()
- func (m *ListObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListObjectsRequest) XXX_Merge(src proto.Message)
- func (m *ListObjectsRequest) XXX_Size() int
- func (m *ListObjectsRequest) XXX_Unmarshal(b []byte) error
- type ListRepoRequest
- func (*ListRepoRequest) Descriptor() ([]byte, []int)
- func (m *ListRepoRequest) Marshal() (dAtA []byte, err error)
- func (m *ListRepoRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListRepoRequest) ProtoMessage()
- func (m *ListRepoRequest) Reset()
- func (m *ListRepoRequest) Size() (n int)
- func (m *ListRepoRequest) String() string
- func (m *ListRepoRequest) Unmarshal(dAtA []byte) error
- func (m *ListRepoRequest) XXX_DiscardUnknown()
- func (m *ListRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRepoRequest) XXX_Merge(src proto.Message)
- func (m *ListRepoRequest) XXX_Size() int
- func (m *ListRepoRequest) XXX_Unmarshal(b []byte) error
- type ListRepoResponse
- func (*ListRepoResponse) Descriptor() ([]byte, []int)
- func (m *ListRepoResponse) GetRepoInfo() []*RepoInfo
- func (m *ListRepoResponse) Marshal() (dAtA []byte, err error)
- func (m *ListRepoResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ListRepoResponse) ProtoMessage()
- func (m *ListRepoResponse) Reset()
- func (m *ListRepoResponse) Size() (n int)
- func (m *ListRepoResponse) String() string
- func (m *ListRepoResponse) Unmarshal(dAtA []byte) error
- func (m *ListRepoResponse) XXX_DiscardUnknown()
- func (m *ListRepoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRepoResponse) XXX_Merge(src proto.Message)
- func (m *ListRepoResponse) XXX_Size() int
- func (m *ListRepoResponse) XXX_Unmarshal(b []byte) error
- type ListTagsRequest
- func (*ListTagsRequest) Descriptor() ([]byte, []int)
- func (m *ListTagsRequest) GetIncludeObject() bool
- func (m *ListTagsRequest) GetPrefix() string
- func (m *ListTagsRequest) Marshal() (dAtA []byte, err error)
- func (m *ListTagsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListTagsRequest) ProtoMessage()
- func (m *ListTagsRequest) Reset()
- func (m *ListTagsRequest) Size() (n int)
- func (m *ListTagsRequest) String() string
- func (m *ListTagsRequest) Unmarshal(dAtA []byte) error
- func (m *ListTagsRequest) XXX_DiscardUnknown()
- func (m *ListTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListTagsRequest) XXX_Merge(src proto.Message)
- func (m *ListTagsRequest) XXX_Size() int
- func (m *ListTagsRequest) XXX_Unmarshal(b []byte) error
- type ListTagsResponse
- func (*ListTagsResponse) Descriptor() ([]byte, []int)
- func (m *ListTagsResponse) GetObject() *Object
- func (m *ListTagsResponse) GetTag() *Tag
- func (m *ListTagsResponse) Marshal() (dAtA []byte, err error)
- func (m *ListTagsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ListTagsResponse) ProtoMessage()
- func (m *ListTagsResponse) Reset()
- func (m *ListTagsResponse) Size() (n int)
- func (m *ListTagsResponse) String() string
- func (m *ListTagsResponse) Unmarshal(dAtA []byte) error
- func (m *ListTagsResponse) XXX_DiscardUnknown()
- func (m *ListTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListTagsResponse) XXX_Merge(src proto.Message)
- func (m *ListTagsResponse) XXX_Size() int
- func (m *ListTagsResponse) XXX_Unmarshal(b []byte) error
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)
- func (m *Metadata) GetValue() []byte
- func (m *Metadata) Marshal() (dAtA []byte, err error)
- func (m *Metadata) MarshalTo(dAtA []byte) (int, error)
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) Size() (n int)
- func (m *Metadata) String() string
- func (m *Metadata) Unmarshal(dAtA []byte) error
- func (m *Metadata) XXX_DiscardUnknown()
- func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metadata) XXX_Merge(src proto.Message)
- func (m *Metadata) XXX_Size() int
- func (m *Metadata) XXX_Unmarshal(b []byte) error
- type Object
- func (*Object) Descriptor() ([]byte, []int)
- func (m *Object) GetHash() string
- func (m *Object) Marshal() (dAtA []byte, err error)
- func (m *Object) MarshalTo(dAtA []byte) (int, error)
- func (*Object) ProtoMessage()
- func (m *Object) Reset()
- func (m *Object) Size() (n int)
- func (m *Object) String() string
- func (m *Object) Unmarshal(dAtA []byte) error
- func (m *Object) XXX_DiscardUnknown()
- func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Object) XXX_Merge(src proto.Message)
- func (m *Object) XXX_Size() int
- func (m *Object) XXX_Unmarshal(b []byte) error
- type ObjectAPIClient
- type ObjectAPIServer
- type ObjectAPI_GetObjectClient
- type ObjectAPI_GetObjectServer
- type ObjectAPI_GetObjectsClient
- type ObjectAPI_GetObjectsServer
- type ObjectAPI_GetTagClient
- type ObjectAPI_GetTagServer
- type ObjectAPI_ListObjectsClient
- type ObjectAPI_ListObjectsServer
- type ObjectAPI_ListTagsClient
- type ObjectAPI_ListTagsServer
- type ObjectAPI_PutObjectClient
- type ObjectAPI_PutObjectServer
- type ObjectAPI_PutObjectSplitClient
- type ObjectAPI_PutObjectSplitServer
- type ObjectIndex
- func (*ObjectIndex) Descriptor() ([]byte, []int)
- func (m *ObjectIndex) GetObjects() map[string]*BlockRef
- func (m *ObjectIndex) GetTags() map[string]*Object
- func (m *ObjectIndex) Marshal() (dAtA []byte, err error)
- func (m *ObjectIndex) MarshalTo(dAtA []byte) (int, error)
- func (*ObjectIndex) ProtoMessage()
- func (m *ObjectIndex) Reset()
- func (m *ObjectIndex) Size() (n int)
- func (m *ObjectIndex) String() string
- func (m *ObjectIndex) Unmarshal(dAtA []byte) error
- func (m *ObjectIndex) XXX_DiscardUnknown()
- func (m *ObjectIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectIndex) XXX_Merge(src proto.Message)
- func (m *ObjectIndex) XXX_Size() int
- func (m *ObjectIndex) XXX_Unmarshal(b []byte) error
- type ObjectInfo
- func (*ObjectInfo) Descriptor() ([]byte, []int)
- func (m *ObjectInfo) GetBlockRef() *BlockRef
- func (m *ObjectInfo) GetObject() *Object
- func (m *ObjectInfo) Marshal() (dAtA []byte, err error)
- func (m *ObjectInfo) MarshalTo(dAtA []byte) (int, error)
- func (*ObjectInfo) ProtoMessage()
- func (m *ObjectInfo) Reset()
- func (m *ObjectInfo) Size() (n int)
- func (m *ObjectInfo) String() string
- func (m *ObjectInfo) Unmarshal(dAtA []byte) error
- func (m *ObjectInfo) XXX_DiscardUnknown()
- func (m *ObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectInfo) XXX_Merge(src proto.Message)
- func (m *ObjectInfo) XXX_Size() int
- func (m *ObjectInfo) XXX_Unmarshal(b []byte) error
- type Objects
- func (*Objects) Descriptor() ([]byte, []int)
- func (m *Objects) GetObjects() []*Object
- func (m *Objects) Marshal() (dAtA []byte, err error)
- func (m *Objects) MarshalTo(dAtA []byte) (int, error)
- func (*Objects) ProtoMessage()
- func (m *Objects) Reset()
- func (m *Objects) Size() (n int)
- func (m *Objects) String() string
- func (m *Objects) Unmarshal(dAtA []byte) error
- func (m *Objects) XXX_DiscardUnknown()
- func (m *Objects) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Objects) XXX_Merge(src proto.Message)
- func (m *Objects) XXX_Size() int
- func (m *Objects) XXX_Unmarshal(b []byte) error
- type OverwriteIndex
- func (*OverwriteIndex) Descriptor() ([]byte, []int)
- func (m *OverwriteIndex) GetIndex() int64
- func (m *OverwriteIndex) Marshal() (dAtA []byte, err error)
- func (m *OverwriteIndex) MarshalTo(dAtA []byte) (int, error)
- func (*OverwriteIndex) ProtoMessage()
- func (m *OverwriteIndex) Reset()
- func (m *OverwriteIndex) Size() (n int)
- func (m *OverwriteIndex) String() string
- func (m *OverwriteIndex) Unmarshal(dAtA []byte) error
- func (m *OverwriteIndex) XXX_DiscardUnknown()
- func (m *OverwriteIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OverwriteIndex) XXX_Merge(src proto.Message)
- func (m *OverwriteIndex) XXX_Size() int
- func (m *OverwriteIndex) XXX_Unmarshal(b []byte) error
- type PutFileRecord
- func (*PutFileRecord) Descriptor() ([]byte, []int)
- 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 (*PutFileRecord) ProtoMessage()
- func (m *PutFileRecord) Reset()
- func (m *PutFileRecord) Size() (n int)
- func (m *PutFileRecord) String() string
- func (m *PutFileRecord) Unmarshal(dAtA []byte) error
- func (m *PutFileRecord) XXX_DiscardUnknown()
- func (m *PutFileRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutFileRecord) XXX_Merge(src proto.Message)
- func (m *PutFileRecord) XXX_Size() int
- func (m *PutFileRecord) XXX_Unmarshal(b []byte) error
- type PutFileRecords
- func (*PutFileRecords) Descriptor() ([]byte, []int)
- func (m *PutFileRecords) GetFooter() *PutFileRecord
- func (m *PutFileRecords) GetHeader() *PutFileRecord
- func (m *PutFileRecords) GetRecords() []*PutFileRecord
- func (m *PutFileRecords) GetSplit() bool
- func (m *PutFileRecords) GetTombstone() bool
- func (m *PutFileRecords) Marshal() (dAtA []byte, err error)
- func (m *PutFileRecords) MarshalTo(dAtA []byte) (int, error)
- func (*PutFileRecords) ProtoMessage()
- func (m *PutFileRecords) Reset()
- func (m *PutFileRecords) Size() (n int)
- func (m *PutFileRecords) String() string
- func (m *PutFileRecords) Unmarshal(dAtA []byte) error
- func (m *PutFileRecords) XXX_DiscardUnknown()
- func (m *PutFileRecords) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutFileRecords) XXX_Merge(src proto.Message)
- func (m *PutFileRecords) XXX_Size() int
- func (m *PutFileRecords) XXX_Unmarshal(b []byte) error
- type PutFileRequest
- func (*PutFileRequest) Descriptor() ([]byte, []int)
- func (m *PutFileRequest) GetDelimiter() Delimiter
- func (m *PutFileRequest) GetFile() *File
- func (m *PutFileRequest) GetFooter() *Metadata
- func (m *PutFileRequest) GetHeader() *Metadata
- func (m *PutFileRequest) GetOverwriteIndex() *OverwriteIndex
- func (m *PutFileRequest) GetRecursive() bool
- func (m *PutFileRequest) GetTargetFileBytes() int64
- func (m *PutFileRequest) GetTargetFileDatums() int64
- func (m *PutFileRequest) GetUrl() string
- func (m *PutFileRequest) GetValue() []byte
- func (m *PutFileRequest) Marshal() (dAtA []byte, err error)
- func (m *PutFileRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PutFileRequest) ProtoMessage()
- func (m *PutFileRequest) Reset()
- func (m *PutFileRequest) Size() (n int)
- func (m *PutFileRequest) String() string
- func (m *PutFileRequest) Unmarshal(dAtA []byte) error
- func (m *PutFileRequest) XXX_DiscardUnknown()
- func (m *PutFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutFileRequest) XXX_Merge(src proto.Message)
- func (m *PutFileRequest) XXX_Size() int
- func (m *PutFileRequest) XXX_Unmarshal(b []byte) error
- type PutObjectRequest
- func (*PutObjectRequest) Descriptor() ([]byte, []int)
- func (m *PutObjectRequest) GetTags() []*Tag
- func (m *PutObjectRequest) GetValue() []byte
- func (m *PutObjectRequest) Marshal() (dAtA []byte, err error)
- func (m *PutObjectRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PutObjectRequest) ProtoMessage()
- func (m *PutObjectRequest) Reset()
- func (m *PutObjectRequest) Size() (n int)
- func (m *PutObjectRequest) String() string
- func (m *PutObjectRequest) Unmarshal(dAtA []byte) error
- func (m *PutObjectRequest) XXX_DiscardUnknown()
- func (m *PutObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutObjectRequest) XXX_Merge(src proto.Message)
- func (m *PutObjectRequest) XXX_Size() int
- func (m *PutObjectRequest) XXX_Unmarshal(b []byte) error
- type Repo
- func (*Repo) Descriptor() ([]byte, []int)
- func (m *Repo) GetName() string
- func (m *Repo) Marshal() (dAtA []byte, err error)
- func (m *Repo) MarshalTo(dAtA []byte) (int, error)
- func (*Repo) ProtoMessage()
- func (m *Repo) Reset()
- func (m *Repo) Size() (n int)
- func (m *Repo) String() string
- func (m *Repo) Unmarshal(dAtA []byte) error
- func (m *Repo) XXX_DiscardUnknown()
- func (m *Repo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Repo) XXX_Merge(src proto.Message)
- func (m *Repo) XXX_Size() int
- func (m *Repo) XXX_Unmarshal(b []byte) error
- type RepoAuthInfo
- func (*RepoAuthInfo) Descriptor() ([]byte, []int)
- func (m *RepoAuthInfo) GetAccessLevel() auth.Scope
- func (m *RepoAuthInfo) Marshal() (dAtA []byte, err error)
- func (m *RepoAuthInfo) MarshalTo(dAtA []byte) (int, error)
- func (*RepoAuthInfo) ProtoMessage()
- func (m *RepoAuthInfo) Reset()
- func (m *RepoAuthInfo) Size() (n int)
- func (m *RepoAuthInfo) String() string
- func (m *RepoAuthInfo) Unmarshal(dAtA []byte) error
- func (m *RepoAuthInfo) XXX_DiscardUnknown()
- func (m *RepoAuthInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepoAuthInfo) XXX_Merge(src proto.Message)
- func (m *RepoAuthInfo) XXX_Size() int
- func (m *RepoAuthInfo) XXX_Unmarshal(b []byte) error
- type RepoInfo
- func (*RepoInfo) Descriptor() ([]byte, []int)
- func (m *RepoInfo) GetAuthInfo() *RepoAuthInfo
- func (m *RepoInfo) GetBranches() []*Branch
- func (m *RepoInfo) GetCreated() *types.Timestamp
- func (m *RepoInfo) GetDescription() string
- func (m *RepoInfo) GetRepo() *Repo
- func (m *RepoInfo) GetSizeBytes() uint64
- func (m *RepoInfo) Marshal() (dAtA []byte, err error)
- func (m *RepoInfo) MarshalTo(dAtA []byte) (int, error)
- func (*RepoInfo) ProtoMessage()
- func (m *RepoInfo) Reset()
- func (m *RepoInfo) Size() (n int)
- func (m *RepoInfo) String() string
- func (m *RepoInfo) Unmarshal(dAtA []byte) error
- func (m *RepoInfo) XXX_DiscardUnknown()
- func (m *RepoInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepoInfo) XXX_Merge(src proto.Message)
- func (m *RepoInfo) XXX_Size() int
- func (m *RepoInfo) XXX_Unmarshal(b []byte) error
- type StartCommitRequest
- func (*StartCommitRequest) Descriptor() ([]byte, []int)
- func (m *StartCommitRequest) GetBranch() string
- func (m *StartCommitRequest) GetDescription() string
- func (m *StartCommitRequest) GetParent() *Commit
- func (m *StartCommitRequest) GetProvenance() []*Commit
- func (m *StartCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *StartCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*StartCommitRequest) ProtoMessage()
- func (m *StartCommitRequest) Reset()
- func (m *StartCommitRequest) Size() (n int)
- func (m *StartCommitRequest) String() string
- func (m *StartCommitRequest) Unmarshal(dAtA []byte) error
- func (m *StartCommitRequest) XXX_DiscardUnknown()
- func (m *StartCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartCommitRequest) XXX_Merge(src proto.Message)
- func (m *StartCommitRequest) XXX_Size() int
- func (m *StartCommitRequest) XXX_Unmarshal(b []byte) error
- type SubscribeCommitRequest
- func (*SubscribeCommitRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeCommitRequest) GetBranch() string
- func (m *SubscribeCommitRequest) GetFrom() *Commit
- func (m *SubscribeCommitRequest) GetRepo() *Repo
- func (m *SubscribeCommitRequest) GetState() CommitState
- func (m *SubscribeCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *SubscribeCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SubscribeCommitRequest) ProtoMessage()
- func (m *SubscribeCommitRequest) Reset()
- func (m *SubscribeCommitRequest) Size() (n int)
- func (m *SubscribeCommitRequest) String() string
- func (m *SubscribeCommitRequest) Unmarshal(dAtA []byte) error
- func (m *SubscribeCommitRequest) XXX_DiscardUnknown()
- func (m *SubscribeCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubscribeCommitRequest) XXX_Merge(src proto.Message)
- func (m *SubscribeCommitRequest) XXX_Size() int
- func (m *SubscribeCommitRequest) XXX_Unmarshal(b []byte) error
- type Tag
- func (*Tag) Descriptor() ([]byte, []int)
- func (m *Tag) GetName() string
- func (m *Tag) Marshal() (dAtA []byte, err error)
- func (m *Tag) MarshalTo(dAtA []byte) (int, error)
- func (*Tag) ProtoMessage()
- func (m *Tag) Reset()
- func (m *Tag) Size() (n int)
- func (m *Tag) String() string
- func (m *Tag) Unmarshal(dAtA []byte) error
- func (m *Tag) XXX_DiscardUnknown()
- func (m *Tag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Tag) XXX_Merge(src proto.Message)
- func (m *Tag) XXX_Size() int
- func (m *Tag) XXX_Unmarshal(b []byte) error
- type TagObjectRequest
- func (*TagObjectRequest) Descriptor() ([]byte, []int)
- func (m *TagObjectRequest) GetObject() *Object
- func (m *TagObjectRequest) GetTags() []*Tag
- func (m *TagObjectRequest) Marshal() (dAtA []byte, err error)
- func (m *TagObjectRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TagObjectRequest) ProtoMessage()
- func (m *TagObjectRequest) Reset()
- func (m *TagObjectRequest) Size() (n int)
- func (m *TagObjectRequest) String() string
- func (m *TagObjectRequest) Unmarshal(dAtA []byte) error
- func (m *TagObjectRequest) XXX_DiscardUnknown()
- func (m *TagObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TagObjectRequest) XXX_Merge(src proto.Message)
- func (m *TagObjectRequest) XXX_Size() int
- func (m *TagObjectRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthPfs = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPfs = fmt.Errorf("proto: integer overflow") )
var ( // ChunkSize is the size of file chunks when resumable upload is used ChunkSize = int64(512 * 1024 * 1024) // 512 MB )
var CommitState_name = map[int32]string{
0: "STARTED",
1: "READY",
2: "FINISHED",
}
var CommitState_value = map[string]int32{
"STARTED": 0,
"READY": 1,
"FINISHED": 2,
}
var Delimiter_name = map[int32]string{
0: "NONE",
1: "JSON",
2: "LINE",
3: "SQL",
}
var Delimiter_value = map[string]int32{
"NONE": 0,
"JSON": 1,
"LINE": 2,
"SQL": 3,
}
var FileType_name = map[int32]string{
0: "RESERVED",
1: "FILE",
2: "DIR",
}
var FileType_value = map[string]int32{
"RESERVED": 0,
"FILE": 1,
"DIR": 2,
}
Functions ¶
func EncodeHash ¶ added in v1.6.0
EncodeHash encodes a hash into a readable format.
func NewHash ¶ added in v1.6.0
NewHash returns a hash that PFS uses internally to compute checksums.
func RegisterAPIServer ¶
func RegisterObjectAPIServer ¶ added in v1.3.9
func RegisterObjectAPIServer(s *grpc.Server, srv ObjectAPIServer)
Types ¶
type APIClient ¶
type APIClient interface { // Repo rpcs // CreateRepo creates a new repo. // An error is returned if the repo already exists. CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*types.Empty, error) // InspectRepo returns info about a repo. InspectRepo(ctx context.Context, in *InspectRepoRequest, opts ...grpc.CallOption) (*RepoInfo, error) // ListRepo returns info about all repos. ListRepo(ctx context.Context, in *ListRepoRequest, opts ...grpc.CallOption) (*ListRepoResponse, error) // DeleteRepo deletes a repo. DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*types.Empty, error) // Commit rpcs // StartCommit creates a new write commit from a parent commit. StartCommit(ctx context.Context, in *StartCommitRequest, opts ...grpc.CallOption) (*Commit, error) // FinishCommit turns a write commit into a read commit. FinishCommit(ctx context.Context, in *FinishCommitRequest, opts ...grpc.CallOption) (*types.Empty, error) // InspectCommit returns the info about a commit. InspectCommit(ctx context.Context, in *InspectCommitRequest, opts ...grpc.CallOption) (*CommitInfo, error) // ListCommit returns info about all commits. This is deprecated in favor of // ListCommitStream. ListCommit(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error) // ListCommitStream is like ListCommit, but returns its results in a GRPC stream ListCommitStream(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (API_ListCommitStreamClient, error) // DeleteCommit deletes a commit. DeleteCommit(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*types.Empty, error) // FlushCommit waits for downstream commits to finish FlushCommit(ctx context.Context, in *FlushCommitRequest, opts ...grpc.CallOption) (API_FlushCommitClient, error) // SubscribeCommit subscribes for new commits on a given branch SubscribeCommit(ctx context.Context, in *SubscribeCommitRequest, opts ...grpc.CallOption) (API_SubscribeCommitClient, error) // BuildCommit builds a commit that's backed by the given tree BuildCommit(ctx context.Context, in *BuildCommitRequest, opts ...grpc.CallOption) (*Commit, error) // CreateBranch creates a new branch CreateBranch(ctx context.Context, in *CreateBranchRequest, opts ...grpc.CallOption) (*types.Empty, error) // InspectBranch returns info about a branch. InspectBranch(ctx context.Context, in *InspectBranchRequest, opts ...grpc.CallOption) (*BranchInfo, error) // ListBranch returns info about the heads of branches. ListBranch(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*BranchInfos, error) // DeleteBranch deletes a branch; note that the commits still exist. DeleteBranch(ctx context.Context, in *DeleteBranchRequest, opts ...grpc.CallOption) (*types.Empty, error) // File rpcs // PutFile writes the specified file to pfs. PutFile(ctx context.Context, opts ...grpc.CallOption) (API_PutFileClient, error) // CopyFile copies the contents of one file to another. CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (*types.Empty, error) // GetFile returns a byte stream of the contents of the file. GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (API_GetFileClient, error) // InspectFile returns info about a file. InspectFile(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error) // ListFile returns info about all files. This is deprecated in favor of // ListFileStream ListFile(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*FileInfos, error) // ListFileStream is a streaming version of ListFile // TODO(msteffen): When the dash has been updated to use ListFileStream, // replace ListFile with this RPC (https://github.com/pachyderm/dash/issues/201) ListFileStream(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (API_ListFileStreamClient, error) // GlobFile returns info about all files. This is deprecated in favor of // GlobFileStream GlobFile(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (*FileInfos, error) // GlobFileStream is a streaming version of GlobFile // TODO(msteffen): When the dash has been updated to use GlobFileStream, // replace GlobFile with this RPC (https://github.com/pachyderm/dash/issues/201) GlobFileStream(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (API_GlobFileStreamClient, error) // DiffFile returns the differences between 2 paths at 2 commits. DiffFile(ctx context.Context, in *DiffFileRequest, opts ...grpc.CallOption) (*DiffFileResponse, error) // DeleteFile deletes a file. DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*types.Empty, error) // DeleteAll deletes everything DeleteAll(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error) }
APIClient is the client API for API service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface { // Repo rpcs // CreateRepo creates a new repo. // An error is returned if the repo already exists. CreateRepo(context.Context, *CreateRepoRequest) (*types.Empty, error) // InspectRepo returns info about a repo. InspectRepo(context.Context, *InspectRepoRequest) (*RepoInfo, error) // ListRepo returns info about all repos. ListRepo(context.Context, *ListRepoRequest) (*ListRepoResponse, error) // DeleteRepo deletes a repo. DeleteRepo(context.Context, *DeleteRepoRequest) (*types.Empty, error) // Commit rpcs // StartCommit creates a new write commit from a parent commit. StartCommit(context.Context, *StartCommitRequest) (*Commit, error) // FinishCommit turns a write commit into a read commit. FinishCommit(context.Context, *FinishCommitRequest) (*types.Empty, error) // InspectCommit returns the info about a commit. InspectCommit(context.Context, *InspectCommitRequest) (*CommitInfo, error) // ListCommit returns info about all commits. This is deprecated in favor of // ListCommitStream. ListCommit(context.Context, *ListCommitRequest) (*CommitInfos, error) // ListCommitStream is like ListCommit, but returns its results in a GRPC stream ListCommitStream(*ListCommitRequest, API_ListCommitStreamServer) error // DeleteCommit deletes a commit. DeleteCommit(context.Context, *DeleteCommitRequest) (*types.Empty, error) // FlushCommit waits for downstream commits to finish FlushCommit(*FlushCommitRequest, API_FlushCommitServer) error // SubscribeCommit subscribes for new commits on a given branch SubscribeCommit(*SubscribeCommitRequest, API_SubscribeCommitServer) error // BuildCommit builds a commit that's backed by the given tree BuildCommit(context.Context, *BuildCommitRequest) (*Commit, error) // CreateBranch creates a new branch CreateBranch(context.Context, *CreateBranchRequest) (*types.Empty, error) // InspectBranch returns info about a branch. InspectBranch(context.Context, *InspectBranchRequest) (*BranchInfo, error) // ListBranch returns info about the heads of branches. ListBranch(context.Context, *ListBranchRequest) (*BranchInfos, error) // DeleteBranch deletes a branch; note that the commits still exist. DeleteBranch(context.Context, *DeleteBranchRequest) (*types.Empty, error) // File rpcs // PutFile writes the specified file to pfs. PutFile(API_PutFileServer) error // CopyFile copies the contents of one file to another. CopyFile(context.Context, *CopyFileRequest) (*types.Empty, error) // GetFile returns a byte stream of the contents of the file. GetFile(*GetFileRequest, API_GetFileServer) error // InspectFile returns info about a file. InspectFile(context.Context, *InspectFileRequest) (*FileInfo, error) // ListFile returns info about all files. This is deprecated in favor of // ListFileStream ListFile(context.Context, *ListFileRequest) (*FileInfos, error) // ListFileStream is a streaming version of ListFile // TODO(msteffen): When the dash has been updated to use ListFileStream, // replace ListFile with this RPC (https://github.com/pachyderm/dash/issues/201) ListFileStream(*ListFileRequest, API_ListFileStreamServer) error // GlobFile returns info about all files. This is deprecated in favor of // GlobFileStream GlobFile(context.Context, *GlobFileRequest) (*FileInfos, error) // GlobFileStream is a streaming version of GlobFile // TODO(msteffen): When the dash has been updated to use GlobFileStream, // replace GlobFile with this RPC (https://github.com/pachyderm/dash/issues/201) GlobFileStream(*GlobFileRequest, API_GlobFileStreamServer) error // DiffFile returns the differences between 2 paths at 2 commits. DiffFile(context.Context, *DiffFileRequest) (*DiffFileResponse, error) // DeleteFile deletes a file. DeleteFile(context.Context, *DeleteFileRequest) (*types.Empty, error) // DeleteAll deletes everything DeleteAll(context.Context, *types.Empty) (*types.Empty, error) }
APIServer is the server API for API service.
type API_FlushCommitClient ¶ added in v1.3.19
type API_FlushCommitClient interface { Recv() (*CommitInfo, error) grpc.ClientStream }
type API_FlushCommitServer ¶ added in v1.3.19
type API_FlushCommitServer interface { Send(*CommitInfo) error grpc.ServerStream }
type API_GetFileClient ¶
type API_GetFileClient interface { Recv() (*types.BytesValue, error) grpc.ClientStream }
type API_GetFileServer ¶
type API_GetFileServer interface { Send(*types.BytesValue) error grpc.ServerStream }
type API_GlobFileStreamClient ¶ added in v1.6.2
type API_GlobFileStreamClient interface { Recv() (*FileInfo, error) grpc.ClientStream }
type API_GlobFileStreamServer ¶ added in v1.6.2
type API_GlobFileStreamServer interface { Send(*FileInfo) error grpc.ServerStream }
type API_ListCommitStreamClient ¶ added in v1.6.4
type API_ListCommitStreamClient interface { Recv() (*CommitInfo, error) grpc.ClientStream }
type API_ListCommitStreamServer ¶ added in v1.6.4
type API_ListCommitStreamServer interface { Send(*CommitInfo) error grpc.ServerStream }
type API_ListFileStreamClient ¶ added in v1.6.2
type API_ListFileStreamClient interface { Recv() (*FileInfo, error) grpc.ClientStream }
type API_ListFileStreamServer ¶ added in v1.6.2
type API_ListFileStreamServer interface { Send(*FileInfo) error grpc.ServerStream }
type API_PutFileClient ¶
type API_PutFileClient interface { Send(*PutFileRequest) error CloseAndRecv() (*types.Empty, error) grpc.ClientStream }
type API_PutFileServer ¶
type API_PutFileServer interface { SendAndClose(*types.Empty) error Recv() (*PutFileRequest, error) grpc.ServerStream }
type API_SubscribeCommitClient ¶ added in v1.3.19
type API_SubscribeCommitClient interface { Recv() (*CommitInfo, error) grpc.ClientStream }
type API_SubscribeCommitServer ¶ added in v1.3.19
type API_SubscribeCommitServer interface { Send(*CommitInfo) error grpc.ServerStream }
type Block ¶
type Block struct { Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Block) Descriptor ¶
func (*Block) ProtoMessage ¶
func (*Block) ProtoMessage()
func (*Block) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Block) XXX_DiscardUnknown()
func (*Block) XXX_Marshal ¶ added in v1.7.12
func (*Block) XXX_Unmarshal ¶ added in v1.7.12
type BlockRef ¶
type BlockRef struct { Block *Block `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"` Range *ByteRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BlockRef) Descriptor ¶
func (*BlockRef) ProtoMessage ¶
func (*BlockRef) ProtoMessage()
func (*BlockRef) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *BlockRef) XXX_DiscardUnknown()
func (*BlockRef) XXX_Marshal ¶ added in v1.7.12
func (*BlockRef) XXX_Unmarshal ¶ added in v1.7.12
type Branch ¶ added in v1.3.19
type Branch struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Branch) Descriptor ¶ added in v1.3.19
func (*Branch) ProtoMessage ¶ added in v1.3.19
func (*Branch) ProtoMessage()
func (*Branch) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Branch) XXX_DiscardUnknown()
func (*Branch) XXX_Marshal ¶ added in v1.7.12
func (*Branch) XXX_Unmarshal ¶ added in v1.7.12
type BranchInfo ¶ added in v1.5.0
type BranchInfo struct { Branch *Branch `protobuf:"bytes,4,opt,name=branch,proto3" json:"branch,omitempty"` Head *Commit `protobuf:"bytes,2,opt,name=head,proto3" json:"head,omitempty"` Provenance []*Branch `protobuf:"bytes,3,rep,name=provenance,proto3" json:"provenance,omitempty"` Subvenance []*Branch `protobuf:"bytes,5,rep,name=subvenance,proto3" json:"subvenance,omitempty"` DirectProvenance []*Branch `protobuf:"bytes,6,rep,name=direct_provenance,json=directProvenance,proto3" json:"direct_provenance,omitempty"` // Deprecated field left for backward compatibility. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BranchInfo) Descriptor ¶ added in v1.5.0
func (*BranchInfo) Descriptor() ([]byte, []int)
func (*BranchInfo) GetBranch ¶ added in v1.7.0
func (m *BranchInfo) GetBranch() *Branch
func (*BranchInfo) GetDirectProvenance ¶ added in v1.7.0
func (m *BranchInfo) GetDirectProvenance() []*Branch
func (*BranchInfo) GetHead ¶ added in v1.5.0
func (m *BranchInfo) GetHead() *Commit
func (*BranchInfo) GetName ¶ added in v1.5.0
func (m *BranchInfo) GetName() string
func (*BranchInfo) GetProvenance ¶ added in v1.7.0
func (m *BranchInfo) GetProvenance() []*Branch
func (*BranchInfo) GetSubvenance ¶ added in v1.7.0
func (m *BranchInfo) GetSubvenance() []*Branch
func (*BranchInfo) Marshal ¶ added in v1.5.0
func (m *BranchInfo) Marshal() (dAtA []byte, err error)
func (*BranchInfo) MarshalTo ¶ added in v1.5.0
func (m *BranchInfo) MarshalTo(dAtA []byte) (int, error)
func (*BranchInfo) ProtoMessage ¶ added in v1.5.0
func (*BranchInfo) ProtoMessage()
func (*BranchInfo) Reset ¶ added in v1.5.0
func (m *BranchInfo) Reset()
func (*BranchInfo) Size ¶ added in v1.5.0
func (m *BranchInfo) Size() (n int)
func (*BranchInfo) String ¶ added in v1.5.0
func (m *BranchInfo) String() string
func (*BranchInfo) Unmarshal ¶ added in v1.5.0
func (m *BranchInfo) Unmarshal(dAtA []byte) error
func (*BranchInfo) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *BranchInfo) XXX_DiscardUnknown()
func (*BranchInfo) XXX_Marshal ¶ added in v1.7.12
func (m *BranchInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BranchInfo) XXX_Merge ¶ added in v1.7.12
func (m *BranchInfo) XXX_Merge(src proto.Message)
func (*BranchInfo) XXX_Size ¶ added in v1.7.12
func (m *BranchInfo) XXX_Size() int
func (*BranchInfo) XXX_Unmarshal ¶ added in v1.7.12
func (m *BranchInfo) XXX_Unmarshal(b []byte) error
type BranchInfos ¶ added in v1.5.0
type BranchInfos struct { BranchInfo []*BranchInfo `protobuf:"bytes,1,rep,name=branch_info,json=branchInfo,proto3" json:"branch_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BranchInfos) Descriptor ¶ added in v1.5.0
func (*BranchInfos) Descriptor() ([]byte, []int)
func (*BranchInfos) GetBranchInfo ¶ added in v1.5.0
func (m *BranchInfos) GetBranchInfo() []*BranchInfo
func (*BranchInfos) Marshal ¶ added in v1.5.0
func (m *BranchInfos) Marshal() (dAtA []byte, err error)
func (*BranchInfos) MarshalTo ¶ added in v1.5.0
func (m *BranchInfos) MarshalTo(dAtA []byte) (int, error)
func (*BranchInfos) ProtoMessage ¶ added in v1.5.0
func (*BranchInfos) ProtoMessage()
func (*BranchInfos) Reset ¶ added in v1.5.0
func (m *BranchInfos) Reset()
func (*BranchInfos) Size ¶ added in v1.5.0
func (m *BranchInfos) Size() (n int)
func (*BranchInfos) String ¶ added in v1.5.0
func (m *BranchInfos) String() string
func (*BranchInfos) Unmarshal ¶ added in v1.5.0
func (m *BranchInfos) Unmarshal(dAtA []byte) error
func (*BranchInfos) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *BranchInfos) XXX_DiscardUnknown()
func (*BranchInfos) XXX_Marshal ¶ added in v1.7.12
func (m *BranchInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BranchInfos) XXX_Merge ¶ added in v1.7.12
func (m *BranchInfos) XXX_Merge(src proto.Message)
func (*BranchInfos) XXX_Size ¶ added in v1.7.12
func (m *BranchInfos) XXX_Size() int
func (*BranchInfos) XXX_Unmarshal ¶ added in v1.7.12
func (m *BranchInfos) XXX_Unmarshal(b []byte) error
type BuildCommitRequest ¶ added in v1.3.19
type BuildCommitRequest struct { Parent *Commit `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` Branch string `protobuf:"bytes,4,opt,name=branch,proto3" json:"branch,omitempty"` Provenance []*Commit `protobuf:"bytes,2,rep,name=provenance,proto3" json:"provenance,omitempty"` Tree *Object `protobuf:"bytes,3,opt,name=tree,proto3" json:"tree,omitempty"` // ID sets the ID of the created commit. ID string `protobuf:"bytes,5,opt,name=ID,proto3" json:"ID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BuildCommitRequest) Descriptor ¶ added in v1.3.19
func (*BuildCommitRequest) Descriptor() ([]byte, []int)
func (*BuildCommitRequest) GetBranch ¶ added in v1.3.19
func (m *BuildCommitRequest) GetBranch() string
func (*BuildCommitRequest) GetID ¶ added in v1.6.9
func (m *BuildCommitRequest) GetID() string
func (*BuildCommitRequest) GetParent ¶ added in v1.3.19
func (m *BuildCommitRequest) GetParent() *Commit
func (*BuildCommitRequest) GetProvenance ¶ added in v1.3.19
func (m *BuildCommitRequest) GetProvenance() []*Commit
func (*BuildCommitRequest) GetTree ¶ added in v1.3.19
func (m *BuildCommitRequest) GetTree() *Object
func (*BuildCommitRequest) Marshal ¶ added in v1.5.0
func (m *BuildCommitRequest) Marshal() (dAtA []byte, err error)
func (*BuildCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *BuildCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*BuildCommitRequest) ProtoMessage ¶ added in v1.3.19
func (*BuildCommitRequest) ProtoMessage()
func (*BuildCommitRequest) Reset ¶ added in v1.3.19
func (m *BuildCommitRequest) Reset()
func (*BuildCommitRequest) Size ¶ added in v1.5.0
func (m *BuildCommitRequest) Size() (n int)
func (*BuildCommitRequest) String ¶ added in v1.3.19
func (m *BuildCommitRequest) String() string
func (*BuildCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *BuildCommitRequest) Unmarshal(dAtA []byte) error
func (*BuildCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *BuildCommitRequest) XXX_DiscardUnknown()
func (*BuildCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *BuildCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BuildCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *BuildCommitRequest) XXX_Merge(src proto.Message)
func (*BuildCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *BuildCommitRequest) XXX_Size() int
func (*BuildCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *BuildCommitRequest) XXX_Unmarshal(b []byte) error
type ByteRange ¶
type ByteRange struct { Lower uint64 `protobuf:"varint,1,opt,name=lower,proto3" json:"lower,omitempty"` Upper uint64 `protobuf:"varint,2,opt,name=upper,proto3" json:"upper,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ByteRange) Descriptor ¶
func (*ByteRange) ProtoMessage ¶
func (*ByteRange) ProtoMessage()
func (*ByteRange) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ByteRange) XXX_DiscardUnknown()
func (*ByteRange) XXX_Marshal ¶ added in v1.7.12
func (*ByteRange) XXX_Unmarshal ¶ added in v1.7.12
type CheckObjectRequest ¶ added in v1.4.7
type CheckObjectRequest struct { Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CheckObjectRequest) Descriptor ¶ added in v1.4.7
func (*CheckObjectRequest) Descriptor() ([]byte, []int)
func (*CheckObjectRequest) GetObject ¶ added in v1.4.7
func (m *CheckObjectRequest) GetObject() *Object
func (*CheckObjectRequest) Marshal ¶ added in v1.5.0
func (m *CheckObjectRequest) Marshal() (dAtA []byte, err error)
func (*CheckObjectRequest) MarshalTo ¶ added in v1.5.0
func (m *CheckObjectRequest) MarshalTo(dAtA []byte) (int, error)
func (*CheckObjectRequest) ProtoMessage ¶ added in v1.4.7
func (*CheckObjectRequest) ProtoMessage()
func (*CheckObjectRequest) Reset ¶ added in v1.4.7
func (m *CheckObjectRequest) Reset()
func (*CheckObjectRequest) Size ¶ added in v1.5.0
func (m *CheckObjectRequest) Size() (n int)
func (*CheckObjectRequest) String ¶ added in v1.4.7
func (m *CheckObjectRequest) String() string
func (*CheckObjectRequest) Unmarshal ¶ added in v1.5.0
func (m *CheckObjectRequest) Unmarshal(dAtA []byte) error
func (*CheckObjectRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CheckObjectRequest) XXX_DiscardUnknown()
func (*CheckObjectRequest) XXX_Marshal ¶ added in v1.7.12
func (m *CheckObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckObjectRequest) XXX_Merge ¶ added in v1.7.12
func (m *CheckObjectRequest) XXX_Merge(src proto.Message)
func (*CheckObjectRequest) XXX_Size ¶ added in v1.7.12
func (m *CheckObjectRequest) XXX_Size() int
func (*CheckObjectRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *CheckObjectRequest) XXX_Unmarshal(b []byte) error
type CheckObjectResponse ¶ added in v1.4.7
type CheckObjectResponse struct { Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CheckObjectResponse) Descriptor ¶ added in v1.4.7
func (*CheckObjectResponse) Descriptor() ([]byte, []int)
func (*CheckObjectResponse) GetExists ¶ added in v1.4.7
func (m *CheckObjectResponse) GetExists() bool
func (*CheckObjectResponse) Marshal ¶ added in v1.5.0
func (m *CheckObjectResponse) Marshal() (dAtA []byte, err error)
func (*CheckObjectResponse) MarshalTo ¶ added in v1.5.0
func (m *CheckObjectResponse) MarshalTo(dAtA []byte) (int, error)
func (*CheckObjectResponse) ProtoMessage ¶ added in v1.4.7
func (*CheckObjectResponse) ProtoMessage()
func (*CheckObjectResponse) Reset ¶ added in v1.4.7
func (m *CheckObjectResponse) Reset()
func (*CheckObjectResponse) Size ¶ added in v1.5.0
func (m *CheckObjectResponse) Size() (n int)
func (*CheckObjectResponse) String ¶ added in v1.4.7
func (m *CheckObjectResponse) String() string
func (*CheckObjectResponse) Unmarshal ¶ added in v1.5.0
func (m *CheckObjectResponse) Unmarshal(dAtA []byte) error
func (*CheckObjectResponse) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CheckObjectResponse) XXX_DiscardUnknown()
func (*CheckObjectResponse) XXX_Marshal ¶ added in v1.7.12
func (m *CheckObjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckObjectResponse) XXX_Merge ¶ added in v1.7.12
func (m *CheckObjectResponse) XXX_Merge(src proto.Message)
func (*CheckObjectResponse) XXX_Size ¶ added in v1.7.12
func (m *CheckObjectResponse) XXX_Size() int
func (*CheckObjectResponse) XXX_Unmarshal ¶ added in v1.7.12
func (m *CheckObjectResponse) XXX_Unmarshal(b []byte) error
type Commit ¶
type Commit struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` ID string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Commit is a reference to a commit (e.g. the collection of branches and the collection of currently-open commits in etcd are collections of Commit protos)
func (*Commit) Descriptor ¶
func (*Commit) ProtoMessage ¶
func (*Commit) ProtoMessage()
func (*Commit) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Commit) XXX_DiscardUnknown()
func (*Commit) XXX_Marshal ¶ added in v1.7.12
func (*Commit) XXX_Unmarshal ¶ added in v1.7.12
type CommitInfo ¶
type CommitInfo struct { Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` // description is a user-provided script describing this commit Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"` ParentCommit *Commit `protobuf:"bytes,2,opt,name=parent_commit,json=parentCommit,proto3" json:"parent_commit,omitempty"` ChildCommits []*Commit `protobuf:"bytes,11,rep,name=child_commits,json=childCommits,proto3" json:"child_commits,omitempty"` Started *types.Timestamp `protobuf:"bytes,3,opt,name=started,proto3" json:"started,omitempty"` Finished *types.Timestamp `protobuf:"bytes,4,opt,name=finished,proto3" json:"finished,omitempty"` SizeBytes uint64 `protobuf:"varint,5,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` // Commits on which this commit is provenant. provenance[i] is a commit in // branch_provenance[i] (a branch name, and one of the branches on which this // commit's branch is provenant) Provenance []*Commit `protobuf:"bytes,6,rep,name=provenance,proto3" json:"provenance,omitempty"` BranchProvenance []*Branch `protobuf:"bytes,10,rep,name=branch_provenance,json=branchProvenance,proto3" json:"branch_provenance,omitempty"` // ReadyProvenance is the number of provenant commits which have been // finished, if ReadyProvenance == len(Provenance) then the commit is ready // to be processed by pps. ReadyProvenance int64 `protobuf:"varint,12,opt,name=ready_provenance,json=readyProvenance,proto3" json:"ready_provenance,omitempty"` Subvenance []*CommitRange `protobuf:"bytes,9,rep,name=subvenance,proto3" json:"subvenance,omitempty"` // this is the block that stores the serialized form of a tree that // represents the entire file system hierarchy of the repo at this commit // If this is nil, then the commit is either open (in which case 'finished' // will also be nil) or is the output commit of a failed job (in which case // 'finished' will have a value -- the end time of the job) Tree *Object `protobuf:"bytes,7,opt,name=tree,proto3" json:"tree,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CommitInfo is the main data structure representing a commit in etcd
func (*CommitInfo) Descriptor ¶
func (*CommitInfo) Descriptor() ([]byte, []int)
func (*CommitInfo) GetBranchProvenance ¶ added in v1.7.0
func (m *CommitInfo) GetBranchProvenance() []*Branch
func (*CommitInfo) GetChildCommits ¶ added in v1.7.0
func (m *CommitInfo) GetChildCommits() []*Commit
func (*CommitInfo) GetCommit ¶
func (m *CommitInfo) GetCommit() *Commit
func (*CommitInfo) GetDescription ¶ added in v1.6.6
func (m *CommitInfo) GetDescription() string
func (*CommitInfo) GetFinished ¶
func (m *CommitInfo) GetFinished() *types.Timestamp
func (*CommitInfo) GetParentCommit ¶
func (m *CommitInfo) GetParentCommit() *Commit
func (*CommitInfo) GetProvenance ¶ added in v1.1.0
func (m *CommitInfo) GetProvenance() []*Commit
func (*CommitInfo) GetReadyProvenance ¶ added in v1.7.1
func (m *CommitInfo) GetReadyProvenance() int64
func (*CommitInfo) GetSizeBytes ¶ added in v1.3.5
func (m *CommitInfo) GetSizeBytes() uint64
func (*CommitInfo) GetStarted ¶
func (m *CommitInfo) GetStarted() *types.Timestamp
func (*CommitInfo) GetSubvenance ¶ added in v1.7.0
func (m *CommitInfo) GetSubvenance() []*CommitRange
func (*CommitInfo) GetTree ¶ added in v1.3.19
func (m *CommitInfo) GetTree() *Object
func (*CommitInfo) Marshal ¶ added in v1.5.0
func (m *CommitInfo) Marshal() (dAtA []byte, err error)
func (*CommitInfo) MarshalTo ¶ added in v1.5.0
func (m *CommitInfo) MarshalTo(dAtA []byte) (int, error)
func (*CommitInfo) ProtoMessage ¶
func (*CommitInfo) ProtoMessage()
func (*CommitInfo) Reset ¶
func (m *CommitInfo) Reset()
func (*CommitInfo) Size ¶ added in v1.5.0
func (m *CommitInfo) Size() (n int)
func (*CommitInfo) String ¶
func (m *CommitInfo) String() string
func (*CommitInfo) Unmarshal ¶ added in v1.5.0
func (m *CommitInfo) Unmarshal(dAtA []byte) error
func (*CommitInfo) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CommitInfo) XXX_DiscardUnknown()
func (*CommitInfo) XXX_Marshal ¶ added in v1.7.12
func (m *CommitInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitInfo) XXX_Merge ¶ added in v1.7.12
func (m *CommitInfo) XXX_Merge(src proto.Message)
func (*CommitInfo) XXX_Size ¶ added in v1.7.12
func (m *CommitInfo) XXX_Size() int
func (*CommitInfo) XXX_Unmarshal ¶ added in v1.7.12
func (m *CommitInfo) XXX_Unmarshal(b []byte) error
type CommitInfos ¶
type CommitInfos struct { CommitInfo []*CommitInfo `protobuf:"bytes,1,rep,name=commit_info,json=commitInfo,proto3" json:"commit_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CommitInfos) Descriptor ¶
func (*CommitInfos) Descriptor() ([]byte, []int)
func (*CommitInfos) GetCommitInfo ¶
func (m *CommitInfos) GetCommitInfo() []*CommitInfo
func (*CommitInfos) Marshal ¶ added in v1.5.0
func (m *CommitInfos) Marshal() (dAtA []byte, err error)
func (*CommitInfos) MarshalTo ¶ added in v1.5.0
func (m *CommitInfos) MarshalTo(dAtA []byte) (int, error)
func (*CommitInfos) ProtoMessage ¶
func (*CommitInfos) ProtoMessage()
func (*CommitInfos) Reset ¶
func (m *CommitInfos) Reset()
func (*CommitInfos) Size ¶ added in v1.5.0
func (m *CommitInfos) Size() (n int)
func (*CommitInfos) String ¶
func (m *CommitInfos) String() string
func (*CommitInfos) Unmarshal ¶ added in v1.5.0
func (m *CommitInfos) Unmarshal(dAtA []byte) error
func (*CommitInfos) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CommitInfos) XXX_DiscardUnknown()
func (*CommitInfos) XXX_Marshal ¶ added in v1.7.12
func (m *CommitInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitInfos) XXX_Merge ¶ added in v1.7.12
func (m *CommitInfos) XXX_Merge(src proto.Message)
func (*CommitInfos) XXX_Size ¶ added in v1.7.12
func (m *CommitInfos) XXX_Size() int
func (*CommitInfos) XXX_Unmarshal ¶ added in v1.7.12
func (m *CommitInfos) XXX_Unmarshal(b []byte) error
type CommitRange ¶ added in v1.7.0
type CommitRange struct { Lower *Commit `protobuf:"bytes,1,opt,name=lower,proto3" json:"lower,omitempty"` Upper *Commit `protobuf:"bytes,2,opt,name=upper,proto3" json:"upper,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CommitRange represents chain of commits with Lower being an ancestor of Upper or, in the case of a range of size 1, the same commit.
func (*CommitRange) Descriptor ¶ added in v1.7.0
func (*CommitRange) Descriptor() ([]byte, []int)
func (*CommitRange) GetLower ¶ added in v1.7.0
func (m *CommitRange) GetLower() *Commit
func (*CommitRange) GetUpper ¶ added in v1.7.0
func (m *CommitRange) GetUpper() *Commit
func (*CommitRange) Marshal ¶ added in v1.7.0
func (m *CommitRange) Marshal() (dAtA []byte, err error)
func (*CommitRange) MarshalTo ¶ added in v1.7.0
func (m *CommitRange) MarshalTo(dAtA []byte) (int, error)
func (*CommitRange) ProtoMessage ¶ added in v1.7.0
func (*CommitRange) ProtoMessage()
func (*CommitRange) Reset ¶ added in v1.7.0
func (m *CommitRange) Reset()
func (*CommitRange) Size ¶ added in v1.7.0
func (m *CommitRange) Size() (n int)
func (*CommitRange) String ¶ added in v1.7.0
func (m *CommitRange) String() string
func (*CommitRange) Unmarshal ¶ added in v1.7.0
func (m *CommitRange) Unmarshal(dAtA []byte) error
func (*CommitRange) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CommitRange) XXX_DiscardUnknown()
func (*CommitRange) XXX_Marshal ¶ added in v1.7.12
func (m *CommitRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitRange) XXX_Merge ¶ added in v1.7.12
func (m *CommitRange) XXX_Merge(src proto.Message)
func (*CommitRange) XXX_Size ¶ added in v1.7.12
func (m *CommitRange) XXX_Size() int
func (*CommitRange) XXX_Unmarshal ¶ added in v1.7.12
func (m *CommitRange) XXX_Unmarshal(b []byte) error
type CommitState ¶ added in v1.7.1
type CommitState int32
CommitState describes the states a commit can be in. The states are increasingly specific, i.e. a commit that is FINISHED also counts as STARTED.
const ( CommitState_STARTED CommitState = 0 CommitState_READY CommitState = 1 CommitState_FINISHED CommitState = 2 )
func (CommitState) EnumDescriptor ¶ added in v1.7.1
func (CommitState) EnumDescriptor() ([]byte, []int)
func (CommitState) String ¶ added in v1.7.1
func (x CommitState) String() string
type CopyFileRequest ¶ added in v1.6.0
type CopyFileRequest struct { Src *File `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"` Dst *File `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"` Overwrite bool `protobuf:"varint,3,opt,name=overwrite,proto3" json:"overwrite,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CopyFileRequest) Descriptor ¶ added in v1.6.0
func (*CopyFileRequest) Descriptor() ([]byte, []int)
func (*CopyFileRequest) GetDst ¶ added in v1.6.0
func (m *CopyFileRequest) GetDst() *File
func (*CopyFileRequest) GetOverwrite ¶ added in v1.6.0
func (m *CopyFileRequest) GetOverwrite() bool
func (*CopyFileRequest) GetSrc ¶ added in v1.6.0
func (m *CopyFileRequest) GetSrc() *File
func (*CopyFileRequest) Marshal ¶ added in v1.6.0
func (m *CopyFileRequest) Marshal() (dAtA []byte, err error)
func (*CopyFileRequest) MarshalTo ¶ added in v1.6.0
func (m *CopyFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*CopyFileRequest) ProtoMessage ¶ added in v1.6.0
func (*CopyFileRequest) ProtoMessage()
func (*CopyFileRequest) Reset ¶ added in v1.6.0
func (m *CopyFileRequest) Reset()
func (*CopyFileRequest) Size ¶ added in v1.6.0
func (m *CopyFileRequest) Size() (n int)
func (*CopyFileRequest) String ¶ added in v1.6.0
func (m *CopyFileRequest) String() string
func (*CopyFileRequest) Unmarshal ¶ added in v1.6.0
func (m *CopyFileRequest) Unmarshal(dAtA []byte) error
func (*CopyFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CopyFileRequest) XXX_DiscardUnknown()
func (*CopyFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *CopyFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CopyFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *CopyFileRequest) XXX_Merge(src proto.Message)
func (*CopyFileRequest) XXX_Size ¶ added in v1.7.12
func (m *CopyFileRequest) XXX_Size() int
func (*CopyFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *CopyFileRequest) XXX_Unmarshal(b []byte) error
type CreateBranchRequest ¶ added in v1.7.0
type CreateBranchRequest struct { Head *Commit `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"` // s_branch matches the field number and type of SetBranchRequest.Branch in // Pachyderm 1.6--so that operations (generated by pachyderm 1.6's // Admin.Export) can be deserialized by pachyderm 1.7 correctly SBranch string `protobuf:"bytes,2,opt,name=s_branch,json=sBranch,proto3" json:"s_branch,omitempty"` Branch *Branch `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"` Provenance []*Branch `protobuf:"bytes,4,rep,name=provenance,proto3" json:"provenance,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateBranchRequest) Descriptor ¶ added in v1.7.0
func (*CreateBranchRequest) Descriptor() ([]byte, []int)
func (*CreateBranchRequest) GetBranch ¶ added in v1.7.0
func (m *CreateBranchRequest) GetBranch() *Branch
func (*CreateBranchRequest) GetHead ¶ added in v1.7.0
func (m *CreateBranchRequest) GetHead() *Commit
func (*CreateBranchRequest) GetProvenance ¶ added in v1.7.0
func (m *CreateBranchRequest) GetProvenance() []*Branch
func (*CreateBranchRequest) GetSBranch ¶ added in v1.7.0
func (m *CreateBranchRequest) GetSBranch() string
func (*CreateBranchRequest) Marshal ¶ added in v1.7.0
func (m *CreateBranchRequest) Marshal() (dAtA []byte, err error)
func (*CreateBranchRequest) MarshalTo ¶ added in v1.7.0
func (m *CreateBranchRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateBranchRequest) ProtoMessage ¶ added in v1.7.0
func (*CreateBranchRequest) ProtoMessage()
func (*CreateBranchRequest) Reset ¶ added in v1.7.0
func (m *CreateBranchRequest) Reset()
func (*CreateBranchRequest) Size ¶ added in v1.7.0
func (m *CreateBranchRequest) Size() (n int)
func (*CreateBranchRequest) String ¶ added in v1.7.0
func (m *CreateBranchRequest) String() string
func (*CreateBranchRequest) Unmarshal ¶ added in v1.7.0
func (m *CreateBranchRequest) Unmarshal(dAtA []byte) error
func (*CreateBranchRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CreateBranchRequest) XXX_DiscardUnknown()
func (*CreateBranchRequest) XXX_Marshal ¶ added in v1.7.12
func (m *CreateBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateBranchRequest) XXX_Merge ¶ added in v1.7.12
func (m *CreateBranchRequest) XXX_Merge(src proto.Message)
func (*CreateBranchRequest) XXX_Size ¶ added in v1.7.12
func (m *CreateBranchRequest) XXX_Size() int
func (*CreateBranchRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *CreateBranchRequest) XXX_Unmarshal(b []byte) error
type CreateRepoRequest ¶
type CreateRepoRequest struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` Update bool `protobuf:"varint,4,opt,name=update,proto3" json:"update,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateRepoRequest) Descriptor ¶
func (*CreateRepoRequest) Descriptor() ([]byte, []int)
func (*CreateRepoRequest) GetDescription ¶ added in v1.4.7
func (m *CreateRepoRequest) GetDescription() string
func (*CreateRepoRequest) GetRepo ¶
func (m *CreateRepoRequest) GetRepo() *Repo
func (*CreateRepoRequest) GetUpdate ¶ added in v1.5.0
func (m *CreateRepoRequest) GetUpdate() bool
func (*CreateRepoRequest) Marshal ¶ added in v1.5.0
func (m *CreateRepoRequest) Marshal() (dAtA []byte, err error)
func (*CreateRepoRequest) MarshalTo ¶ added in v1.5.0
func (m *CreateRepoRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateRepoRequest) ProtoMessage ¶
func (*CreateRepoRequest) ProtoMessage()
func (*CreateRepoRequest) Reset ¶
func (m *CreateRepoRequest) Reset()
func (*CreateRepoRequest) Size ¶ added in v1.5.0
func (m *CreateRepoRequest) Size() (n int)
func (*CreateRepoRequest) String ¶
func (m *CreateRepoRequest) String() string
func (*CreateRepoRequest) Unmarshal ¶ added in v1.5.0
func (m *CreateRepoRequest) Unmarshal(dAtA []byte) error
func (*CreateRepoRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *CreateRepoRequest) XXX_DiscardUnknown()
func (*CreateRepoRequest) XXX_Marshal ¶ added in v1.7.12
func (m *CreateRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRepoRequest) XXX_Merge ¶ added in v1.7.12
func (m *CreateRepoRequest) XXX_Merge(src proto.Message)
func (*CreateRepoRequest) XXX_Size ¶ added in v1.7.12
func (m *CreateRepoRequest) XXX_Size() int
func (*CreateRepoRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *CreateRepoRequest) XXX_Unmarshal(b []byte) error
type DeleteBranchRequest ¶ added in v1.3.19
type DeleteBranchRequest struct { Branch *Branch `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"` Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteBranchRequest) Descriptor ¶ added in v1.3.19
func (*DeleteBranchRequest) Descriptor() ([]byte, []int)
func (*DeleteBranchRequest) GetBranch ¶ added in v1.3.19
func (m *DeleteBranchRequest) GetBranch() *Branch
func (*DeleteBranchRequest) GetForce ¶ added in v1.7.0
func (m *DeleteBranchRequest) GetForce() bool
func (*DeleteBranchRequest) Marshal ¶ added in v1.5.0
func (m *DeleteBranchRequest) Marshal() (dAtA []byte, err error)
func (*DeleteBranchRequest) MarshalTo ¶ added in v1.5.0
func (m *DeleteBranchRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteBranchRequest) ProtoMessage ¶ added in v1.3.19
func (*DeleteBranchRequest) ProtoMessage()
func (*DeleteBranchRequest) Reset ¶ added in v1.3.19
func (m *DeleteBranchRequest) Reset()
func (*DeleteBranchRequest) Size ¶ added in v1.5.0
func (m *DeleteBranchRequest) Size() (n int)
func (*DeleteBranchRequest) String ¶ added in v1.3.19
func (m *DeleteBranchRequest) String() string
func (*DeleteBranchRequest) Unmarshal ¶ added in v1.5.0
func (m *DeleteBranchRequest) Unmarshal(dAtA []byte) error
func (*DeleteBranchRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteBranchRequest) XXX_DiscardUnknown()
func (*DeleteBranchRequest) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteBranchRequest) XXX_Merge ¶ added in v1.7.12
func (m *DeleteBranchRequest) XXX_Merge(src proto.Message)
func (*DeleteBranchRequest) XXX_Size ¶ added in v1.7.12
func (m *DeleteBranchRequest) XXX_Size() int
func (*DeleteBranchRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteBranchRequest) XXX_Unmarshal(b []byte) error
type DeleteCommitRequest ¶
type DeleteCommitRequest struct { Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteCommitRequest) Descriptor ¶
func (*DeleteCommitRequest) Descriptor() ([]byte, []int)
func (*DeleteCommitRequest) GetCommit ¶
func (m *DeleteCommitRequest) GetCommit() *Commit
func (*DeleteCommitRequest) Marshal ¶ added in v1.5.0
func (m *DeleteCommitRequest) Marshal() (dAtA []byte, err error)
func (*DeleteCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *DeleteCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteCommitRequest) ProtoMessage ¶
func (*DeleteCommitRequest) ProtoMessage()
func (*DeleteCommitRequest) Reset ¶
func (m *DeleteCommitRequest) Reset()
func (*DeleteCommitRequest) Size ¶ added in v1.5.0
func (m *DeleteCommitRequest) Size() (n int)
func (*DeleteCommitRequest) String ¶
func (m *DeleteCommitRequest) String() string
func (*DeleteCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *DeleteCommitRequest) Unmarshal(dAtA []byte) error
func (*DeleteCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteCommitRequest) XXX_DiscardUnknown()
func (*DeleteCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *DeleteCommitRequest) XXX_Merge(src proto.Message)
func (*DeleteCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *DeleteCommitRequest) XXX_Size() int
func (*DeleteCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteCommitRequest) XXX_Unmarshal(b []byte) error
type DeleteFileRequest ¶
type DeleteFileRequest struct { File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteFileRequest) Descriptor ¶
func (*DeleteFileRequest) Descriptor() ([]byte, []int)
func (*DeleteFileRequest) GetFile ¶
func (m *DeleteFileRequest) GetFile() *File
func (*DeleteFileRequest) Marshal ¶ added in v1.5.0
func (m *DeleteFileRequest) Marshal() (dAtA []byte, err error)
func (*DeleteFileRequest) MarshalTo ¶ added in v1.5.0
func (m *DeleteFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteFileRequest) ProtoMessage ¶
func (*DeleteFileRequest) ProtoMessage()
func (*DeleteFileRequest) Reset ¶
func (m *DeleteFileRequest) Reset()
func (*DeleteFileRequest) Size ¶ added in v1.5.0
func (m *DeleteFileRequest) Size() (n int)
func (*DeleteFileRequest) String ¶
func (m *DeleteFileRequest) String() string
func (*DeleteFileRequest) Unmarshal ¶ added in v1.5.0
func (m *DeleteFileRequest) Unmarshal(dAtA []byte) error
func (*DeleteFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteFileRequest) XXX_DiscardUnknown()
func (*DeleteFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *DeleteFileRequest) XXX_Merge(src proto.Message)
func (*DeleteFileRequest) XXX_Size ¶ added in v1.7.12
func (m *DeleteFileRequest) XXX_Size() int
func (*DeleteFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteFileRequest) XXX_Unmarshal(b []byte) error
type DeleteObjectsRequest ¶ added in v1.4.7
type DeleteObjectsRequest struct { Objects []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteObjectsRequest) Descriptor ¶ added in v1.4.7
func (*DeleteObjectsRequest) Descriptor() ([]byte, []int)
func (*DeleteObjectsRequest) GetObjects ¶ added in v1.4.7
func (m *DeleteObjectsRequest) GetObjects() []*Object
func (*DeleteObjectsRequest) Marshal ¶ added in v1.5.0
func (m *DeleteObjectsRequest) Marshal() (dAtA []byte, err error)
func (*DeleteObjectsRequest) MarshalTo ¶ added in v1.5.0
func (m *DeleteObjectsRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteObjectsRequest) ProtoMessage ¶ added in v1.4.7
func (*DeleteObjectsRequest) ProtoMessage()
func (*DeleteObjectsRequest) Reset ¶ added in v1.4.7
func (m *DeleteObjectsRequest) Reset()
func (*DeleteObjectsRequest) Size ¶ added in v1.5.0
func (m *DeleteObjectsRequest) Size() (n int)
func (*DeleteObjectsRequest) String ¶ added in v1.4.7
func (m *DeleteObjectsRequest) String() string
func (*DeleteObjectsRequest) Unmarshal ¶ added in v1.5.0
func (m *DeleteObjectsRequest) Unmarshal(dAtA []byte) error
func (*DeleteObjectsRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteObjectsRequest) XXX_DiscardUnknown()
func (*DeleteObjectsRequest) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteObjectsRequest) XXX_Merge ¶ added in v1.7.12
func (m *DeleteObjectsRequest) XXX_Merge(src proto.Message)
func (*DeleteObjectsRequest) XXX_Size ¶ added in v1.7.12
func (m *DeleteObjectsRequest) XXX_Size() int
func (*DeleteObjectsRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteObjectsRequest) XXX_Unmarshal(b []byte) error
type DeleteObjectsResponse ¶ added in v1.4.7
type DeleteObjectsResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteObjectsResponse) Descriptor ¶ added in v1.4.7
func (*DeleteObjectsResponse) Descriptor() ([]byte, []int)
func (*DeleteObjectsResponse) Marshal ¶ added in v1.5.0
func (m *DeleteObjectsResponse) Marshal() (dAtA []byte, err error)
func (*DeleteObjectsResponse) MarshalTo ¶ added in v1.5.0
func (m *DeleteObjectsResponse) MarshalTo(dAtA []byte) (int, error)
func (*DeleteObjectsResponse) ProtoMessage ¶ added in v1.4.7
func (*DeleteObjectsResponse) ProtoMessage()
func (*DeleteObjectsResponse) Reset ¶ added in v1.4.7
func (m *DeleteObjectsResponse) Reset()
func (*DeleteObjectsResponse) Size ¶ added in v1.5.0
func (m *DeleteObjectsResponse) Size() (n int)
func (*DeleteObjectsResponse) String ¶ added in v1.4.7
func (m *DeleteObjectsResponse) String() string
func (*DeleteObjectsResponse) Unmarshal ¶ added in v1.5.0
func (m *DeleteObjectsResponse) Unmarshal(dAtA []byte) error
func (*DeleteObjectsResponse) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteObjectsResponse) XXX_DiscardUnknown()
func (*DeleteObjectsResponse) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteObjectsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteObjectsResponse) XXX_Merge ¶ added in v1.7.12
func (m *DeleteObjectsResponse) XXX_Merge(src proto.Message)
func (*DeleteObjectsResponse) XXX_Size ¶ added in v1.7.12
func (m *DeleteObjectsResponse) XXX_Size() int
func (*DeleteObjectsResponse) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteObjectsResponse) XXX_Unmarshal(b []byte) error
type DeleteRepoRequest ¶
type DeleteRepoRequest struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` All bool `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteRepoRequest) Descriptor ¶
func (*DeleteRepoRequest) Descriptor() ([]byte, []int)
func (*DeleteRepoRequest) GetAll ¶ added in v1.4.8
func (m *DeleteRepoRequest) GetAll() bool
func (*DeleteRepoRequest) GetForce ¶ added in v1.3.5
func (m *DeleteRepoRequest) GetForce() bool
func (*DeleteRepoRequest) GetRepo ¶
func (m *DeleteRepoRequest) GetRepo() *Repo
func (*DeleteRepoRequest) Marshal ¶ added in v1.5.0
func (m *DeleteRepoRequest) Marshal() (dAtA []byte, err error)
func (*DeleteRepoRequest) MarshalTo ¶ added in v1.5.0
func (m *DeleteRepoRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteRepoRequest) ProtoMessage ¶
func (*DeleteRepoRequest) ProtoMessage()
func (*DeleteRepoRequest) Reset ¶
func (m *DeleteRepoRequest) Reset()
func (*DeleteRepoRequest) Size ¶ added in v1.5.0
func (m *DeleteRepoRequest) Size() (n int)
func (*DeleteRepoRequest) String ¶
func (m *DeleteRepoRequest) String() string
func (*DeleteRepoRequest) Unmarshal ¶ added in v1.5.0
func (m *DeleteRepoRequest) Unmarshal(dAtA []byte) error
func (*DeleteRepoRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteRepoRequest) XXX_DiscardUnknown()
func (*DeleteRepoRequest) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRepoRequest) XXX_Merge ¶ added in v1.7.12
func (m *DeleteRepoRequest) XXX_Merge(src proto.Message)
func (*DeleteRepoRequest) XXX_Size ¶ added in v1.7.12
func (m *DeleteRepoRequest) XXX_Size() int
func (*DeleteRepoRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteRepoRequest) XXX_Unmarshal(b []byte) error
type DeleteTagsRequest ¶ added in v1.4.7
type DeleteTagsRequest struct { Tags []*Tag `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteTagsRequest) Descriptor ¶ added in v1.4.7
func (*DeleteTagsRequest) Descriptor() ([]byte, []int)
func (*DeleteTagsRequest) GetTags ¶ added in v1.4.7
func (m *DeleteTagsRequest) GetTags() []*Tag
func (*DeleteTagsRequest) Marshal ¶ added in v1.5.0
func (m *DeleteTagsRequest) Marshal() (dAtA []byte, err error)
func (*DeleteTagsRequest) MarshalTo ¶ added in v1.5.0
func (m *DeleteTagsRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteTagsRequest) ProtoMessage ¶ added in v1.4.7
func (*DeleteTagsRequest) ProtoMessage()
func (*DeleteTagsRequest) Reset ¶ added in v1.4.7
func (m *DeleteTagsRequest) Reset()
func (*DeleteTagsRequest) Size ¶ added in v1.5.0
func (m *DeleteTagsRequest) Size() (n int)
func (*DeleteTagsRequest) String ¶ added in v1.4.7
func (m *DeleteTagsRequest) String() string
func (*DeleteTagsRequest) Unmarshal ¶ added in v1.5.0
func (m *DeleteTagsRequest) Unmarshal(dAtA []byte) error
func (*DeleteTagsRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteTagsRequest) XXX_DiscardUnknown()
func (*DeleteTagsRequest) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteTagsRequest) XXX_Merge ¶ added in v1.7.12
func (m *DeleteTagsRequest) XXX_Merge(src proto.Message)
func (*DeleteTagsRequest) XXX_Size ¶ added in v1.7.12
func (m *DeleteTagsRequest) XXX_Size() int
func (*DeleteTagsRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteTagsRequest) XXX_Unmarshal(b []byte) error
type DeleteTagsResponse ¶ added in v1.4.7
type DeleteTagsResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteTagsResponse) Descriptor ¶ added in v1.4.7
func (*DeleteTagsResponse) Descriptor() ([]byte, []int)
func (*DeleteTagsResponse) Marshal ¶ added in v1.5.0
func (m *DeleteTagsResponse) Marshal() (dAtA []byte, err error)
func (*DeleteTagsResponse) MarshalTo ¶ added in v1.5.0
func (m *DeleteTagsResponse) MarshalTo(dAtA []byte) (int, error)
func (*DeleteTagsResponse) ProtoMessage ¶ added in v1.4.7
func (*DeleteTagsResponse) ProtoMessage()
func (*DeleteTagsResponse) Reset ¶ added in v1.4.7
func (m *DeleteTagsResponse) Reset()
func (*DeleteTagsResponse) Size ¶ added in v1.5.0
func (m *DeleteTagsResponse) Size() (n int)
func (*DeleteTagsResponse) String ¶ added in v1.4.7
func (m *DeleteTagsResponse) String() string
func (*DeleteTagsResponse) Unmarshal ¶ added in v1.5.0
func (m *DeleteTagsResponse) Unmarshal(dAtA []byte) error
func (*DeleteTagsResponse) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DeleteTagsResponse) XXX_DiscardUnknown()
func (*DeleteTagsResponse) XXX_Marshal ¶ added in v1.7.12
func (m *DeleteTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteTagsResponse) XXX_Merge ¶ added in v1.7.12
func (m *DeleteTagsResponse) XXX_Merge(src proto.Message)
func (*DeleteTagsResponse) XXX_Size ¶ added in v1.7.12
func (m *DeleteTagsResponse) XXX_Size() int
func (*DeleteTagsResponse) XXX_Unmarshal ¶ added in v1.7.12
func (m *DeleteTagsResponse) XXX_Unmarshal(b []byte) error
type Delimiter ¶ added in v1.1.0
type Delimiter int32
func (Delimiter) EnumDescriptor ¶ added in v1.1.0
type DiffFileRequest ¶ added in v1.4.8
type DiffFileRequest struct { NewFile *File `protobuf:"bytes,1,opt,name=new_file,json=newFile,proto3" json:"new_file,omitempty"` // OldFile may be left nil in which case the same path in the parent of // NewFile's commit will be used. OldFile *File `protobuf:"bytes,2,opt,name=old_file,json=oldFile,proto3" json:"old_file,omitempty"` Shallow bool `protobuf:"varint,3,opt,name=shallow,proto3" json:"shallow,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DiffFileRequest) Descriptor ¶ added in v1.4.8
func (*DiffFileRequest) Descriptor() ([]byte, []int)
func (*DiffFileRequest) GetNewFile ¶ added in v1.4.8
func (m *DiffFileRequest) GetNewFile() *File
func (*DiffFileRequest) GetOldFile ¶ added in v1.4.8
func (m *DiffFileRequest) GetOldFile() *File
func (*DiffFileRequest) GetShallow ¶ added in v1.5.2
func (m *DiffFileRequest) GetShallow() bool
func (*DiffFileRequest) Marshal ¶ added in v1.5.0
func (m *DiffFileRequest) Marshal() (dAtA []byte, err error)
func (*DiffFileRequest) MarshalTo ¶ added in v1.5.0
func (m *DiffFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*DiffFileRequest) ProtoMessage ¶ added in v1.4.8
func (*DiffFileRequest) ProtoMessage()
func (*DiffFileRequest) Reset ¶ added in v1.4.8
func (m *DiffFileRequest) Reset()
func (*DiffFileRequest) Size ¶ added in v1.5.0
func (m *DiffFileRequest) Size() (n int)
func (*DiffFileRequest) String ¶ added in v1.4.8
func (m *DiffFileRequest) String() string
func (*DiffFileRequest) Unmarshal ¶ added in v1.5.0
func (m *DiffFileRequest) Unmarshal(dAtA []byte) error
func (*DiffFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DiffFileRequest) XXX_DiscardUnknown()
func (*DiffFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *DiffFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiffFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *DiffFileRequest) XXX_Merge(src proto.Message)
func (*DiffFileRequest) XXX_Size ¶ added in v1.7.12
func (m *DiffFileRequest) XXX_Size() int
func (*DiffFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *DiffFileRequest) XXX_Unmarshal(b []byte) error
type DiffFileResponse ¶ added in v1.4.8
type DiffFileResponse struct { NewFiles []*FileInfo `protobuf:"bytes,1,rep,name=new_files,json=newFiles,proto3" json:"new_files,omitempty"` OldFiles []*FileInfo `protobuf:"bytes,2,rep,name=old_files,json=oldFiles,proto3" json:"old_files,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DiffFileResponse) Descriptor ¶ added in v1.4.8
func (*DiffFileResponse) Descriptor() ([]byte, []int)
func (*DiffFileResponse) GetNewFiles ¶ added in v1.4.8
func (m *DiffFileResponse) GetNewFiles() []*FileInfo
func (*DiffFileResponse) GetOldFiles ¶ added in v1.4.8
func (m *DiffFileResponse) GetOldFiles() []*FileInfo
func (*DiffFileResponse) Marshal ¶ added in v1.5.0
func (m *DiffFileResponse) Marshal() (dAtA []byte, err error)
func (*DiffFileResponse) MarshalTo ¶ added in v1.5.0
func (m *DiffFileResponse) MarshalTo(dAtA []byte) (int, error)
func (*DiffFileResponse) ProtoMessage ¶ added in v1.4.8
func (*DiffFileResponse) ProtoMessage()
func (*DiffFileResponse) Reset ¶ added in v1.4.8
func (m *DiffFileResponse) Reset()
func (*DiffFileResponse) Size ¶ added in v1.5.0
func (m *DiffFileResponse) Size() (n int)
func (*DiffFileResponse) String ¶ added in v1.4.8
func (m *DiffFileResponse) String() string
func (*DiffFileResponse) Unmarshal ¶ added in v1.5.0
func (m *DiffFileResponse) Unmarshal(dAtA []byte) error
func (*DiffFileResponse) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *DiffFileResponse) XXX_DiscardUnknown()
func (*DiffFileResponse) XXX_Marshal ¶ added in v1.7.12
func (m *DiffFileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiffFileResponse) XXX_Merge ¶ added in v1.7.12
func (m *DiffFileResponse) XXX_Merge(src proto.Message)
func (*DiffFileResponse) XXX_Size ¶ added in v1.7.12
func (m *DiffFileResponse) XXX_Size() int
func (*DiffFileResponse) XXX_Unmarshal ¶ added in v1.7.12
func (m *DiffFileResponse) XXX_Unmarshal(b []byte) error
type File ¶
type File struct { Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*File) Descriptor ¶
func (*File) ProtoMessage ¶
func (*File) ProtoMessage()
func (*File) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *File) XXX_DiscardUnknown()
func (*File) XXX_Marshal ¶ added in v1.7.12
func (*File) XXX_Unmarshal ¶ added in v1.7.12
type FileInfo ¶
type FileInfo struct { File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` FileType FileType `protobuf:"varint,2,opt,name=file_type,json=fileType,proto3,enum=pfs.FileType" json:"file_type,omitempty"` SizeBytes uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` // the base names (i.e. just the filenames, not the full paths) of // the children Children []string `protobuf:"bytes,6,rep,name=children,proto3" json:"children,omitempty"` Objects []*Object `protobuf:"bytes,8,rep,name=objects,proto3" json:"objects,omitempty"` Hash []byte `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FileInfo) Descriptor ¶
func (*FileInfo) GetChildren ¶
func (*FileInfo) GetFileType ¶ added in v1.3.5
func (*FileInfo) GetObjects ¶ added in v1.4.6
func (*FileInfo) GetSizeBytes ¶ added in v1.3.5
func (*FileInfo) ProtoMessage ¶
func (*FileInfo) ProtoMessage()
func (*FileInfo) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *FileInfo) XXX_DiscardUnknown()
func (*FileInfo) XXX_Marshal ¶ added in v1.7.12
func (*FileInfo) XXX_Unmarshal ¶ added in v1.7.12
type FileInfos ¶
type FileInfos struct { FileInfo []*FileInfo `protobuf:"bytes,1,rep,name=file_info,json=fileInfo,proto3" json:"file_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
FileInfos is the result of both ListFile and GlobFile
func (*FileInfos) Descriptor ¶
func (*FileInfos) GetFileInfo ¶
func (*FileInfos) ProtoMessage ¶
func (*FileInfos) ProtoMessage()
func (*FileInfos) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *FileInfos) XXX_DiscardUnknown()
func (*FileInfos) XXX_Marshal ¶ added in v1.7.12
func (*FileInfos) XXX_Unmarshal ¶ added in v1.7.12
type FinishCommitRequest ¶
type FinishCommitRequest struct { Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` // description is a user-provided string describing this commit. Setting this // will overwrite the description set in StartCommit Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` Tree *Object `protobuf:"bytes,3,opt,name=tree,proto3" json:"tree,omitempty"` // If set, 'commit' will be closed (its 'finished' field will be set to the // current time) but its 'tree' will be left nil. Empty bool `protobuf:"varint,4,opt,name=empty,proto3" json:"empty,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FinishCommitRequest) Descriptor ¶
func (*FinishCommitRequest) Descriptor() ([]byte, []int)
func (*FinishCommitRequest) GetCommit ¶
func (m *FinishCommitRequest) GetCommit() *Commit
func (*FinishCommitRequest) GetDescription ¶ added in v1.6.6
func (m *FinishCommitRequest) GetDescription() string
func (*FinishCommitRequest) GetEmpty ¶ added in v1.7.0
func (m *FinishCommitRequest) GetEmpty() bool
func (*FinishCommitRequest) GetTree ¶ added in v1.7.0
func (m *FinishCommitRequest) GetTree() *Object
func (*FinishCommitRequest) Marshal ¶ added in v1.5.0
func (m *FinishCommitRequest) Marshal() (dAtA []byte, err error)
func (*FinishCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *FinishCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*FinishCommitRequest) ProtoMessage ¶
func (*FinishCommitRequest) ProtoMessage()
func (*FinishCommitRequest) Reset ¶
func (m *FinishCommitRequest) Reset()
func (*FinishCommitRequest) Size ¶ added in v1.5.0
func (m *FinishCommitRequest) Size() (n int)
func (*FinishCommitRequest) String ¶
func (m *FinishCommitRequest) String() string
func (*FinishCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *FinishCommitRequest) Unmarshal(dAtA []byte) error
func (*FinishCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *FinishCommitRequest) XXX_DiscardUnknown()
func (*FinishCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *FinishCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FinishCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *FinishCommitRequest) XXX_Merge(src proto.Message)
func (*FinishCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *FinishCommitRequest) XXX_Size() int
func (*FinishCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *FinishCommitRequest) XXX_Unmarshal(b []byte) error
type FlushCommitRequest ¶ added in v1.1.0
type FlushCommitRequest struct { Commits []*Commit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"` ToRepos []*Repo `protobuf:"bytes,2,rep,name=to_repos,json=toRepos,proto3" json:"to_repos,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FlushCommitRequest) Descriptor ¶ added in v1.1.0
func (*FlushCommitRequest) Descriptor() ([]byte, []int)
func (*FlushCommitRequest) GetCommits ¶ added in v1.3.19
func (m *FlushCommitRequest) GetCommits() []*Commit
func (*FlushCommitRequest) GetToRepos ¶ added in v1.3.19
func (m *FlushCommitRequest) GetToRepos() []*Repo
func (*FlushCommitRequest) Marshal ¶ added in v1.5.0
func (m *FlushCommitRequest) Marshal() (dAtA []byte, err error)
func (*FlushCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *FlushCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*FlushCommitRequest) ProtoMessage ¶ added in v1.1.0
func (*FlushCommitRequest) ProtoMessage()
func (*FlushCommitRequest) Reset ¶ added in v1.1.0
func (m *FlushCommitRequest) Reset()
func (*FlushCommitRequest) Size ¶ added in v1.5.0
func (m *FlushCommitRequest) Size() (n int)
func (*FlushCommitRequest) String ¶ added in v1.1.0
func (m *FlushCommitRequest) String() string
func (*FlushCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *FlushCommitRequest) Unmarshal(dAtA []byte) error
func (*FlushCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *FlushCommitRequest) XXX_DiscardUnknown()
func (*FlushCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *FlushCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FlushCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *FlushCommitRequest) XXX_Merge(src proto.Message)
func (*FlushCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *FlushCommitRequest) XXX_Size() int
func (*FlushCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *FlushCommitRequest) XXX_Unmarshal(b []byte) error
type GetFileRequest ¶
type GetFileRequest struct { File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` OffsetBytes int64 `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes,proto3" json:"offset_bytes,omitempty"` SizeBytes int64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetFileRequest) Descriptor ¶
func (*GetFileRequest) Descriptor() ([]byte, []int)
func (*GetFileRequest) GetFile ¶
func (m *GetFileRequest) GetFile() *File
func (*GetFileRequest) GetOffsetBytes ¶ added in v1.3.5
func (m *GetFileRequest) GetOffsetBytes() int64
func (*GetFileRequest) GetSizeBytes ¶ added in v1.3.5
func (m *GetFileRequest) GetSizeBytes() int64
func (*GetFileRequest) Marshal ¶ added in v1.5.0
func (m *GetFileRequest) Marshal() (dAtA []byte, err error)
func (*GetFileRequest) MarshalTo ¶ added in v1.5.0
func (m *GetFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetFileRequest) ProtoMessage ¶
func (*GetFileRequest) ProtoMessage()
func (*GetFileRequest) Reset ¶
func (m *GetFileRequest) Reset()
func (*GetFileRequest) Size ¶ added in v1.5.0
func (m *GetFileRequest) Size() (n int)
func (*GetFileRequest) String ¶
func (m *GetFileRequest) String() string
func (*GetFileRequest) Unmarshal ¶ added in v1.5.0
func (m *GetFileRequest) Unmarshal(dAtA []byte) error
func (*GetFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *GetFileRequest) XXX_DiscardUnknown()
func (*GetFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *GetFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *GetFileRequest) XXX_Merge(src proto.Message)
func (*GetFileRequest) XXX_Size ¶ added in v1.7.12
func (m *GetFileRequest) XXX_Size() int
func (*GetFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *GetFileRequest) XXX_Unmarshal(b []byte) error
type GetObjectsRequest ¶ added in v1.3.19
type GetObjectsRequest struct { Objects []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"` OffsetBytes uint64 `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes,proto3" json:"offset_bytes,omitempty"` // The number of bytes we intend to read. SizeBytes uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` // The total amount of bytes in these objects. It's OK if it's not // entirely accurate or if it's unknown (in which case it'd be set to 0). // It's used primarily as a hint for cache eviction. TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetObjectsRequest) Descriptor ¶ added in v1.3.19
func (*GetObjectsRequest) Descriptor() ([]byte, []int)
func (*GetObjectsRequest) GetObjects ¶ added in v1.3.19
func (m *GetObjectsRequest) GetObjects() []*Object
func (*GetObjectsRequest) GetOffsetBytes ¶ added in v1.3.19
func (m *GetObjectsRequest) GetOffsetBytes() uint64
func (*GetObjectsRequest) GetSizeBytes ¶ added in v1.3.19
func (m *GetObjectsRequest) GetSizeBytes() uint64
func (*GetObjectsRequest) GetTotalSize ¶ added in v1.6.0
func (m *GetObjectsRequest) GetTotalSize() uint64
func (*GetObjectsRequest) Marshal ¶ added in v1.5.0
func (m *GetObjectsRequest) Marshal() (dAtA []byte, err error)
func (*GetObjectsRequest) MarshalTo ¶ added in v1.5.0
func (m *GetObjectsRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetObjectsRequest) ProtoMessage ¶ added in v1.3.19
func (*GetObjectsRequest) ProtoMessage()
func (*GetObjectsRequest) Reset ¶ added in v1.3.19
func (m *GetObjectsRequest) Reset()
func (*GetObjectsRequest) Size ¶ added in v1.5.0
func (m *GetObjectsRequest) Size() (n int)
func (*GetObjectsRequest) String ¶ added in v1.3.19
func (m *GetObjectsRequest) String() string
func (*GetObjectsRequest) Unmarshal ¶ added in v1.5.0
func (m *GetObjectsRequest) Unmarshal(dAtA []byte) error
func (*GetObjectsRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *GetObjectsRequest) XXX_DiscardUnknown()
func (*GetObjectsRequest) XXX_Marshal ¶ added in v1.7.12
func (m *GetObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetObjectsRequest) XXX_Merge ¶ added in v1.7.12
func (m *GetObjectsRequest) XXX_Merge(src proto.Message)
func (*GetObjectsRequest) XXX_Size ¶ added in v1.7.12
func (m *GetObjectsRequest) XXX_Size() int
func (*GetObjectsRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *GetObjectsRequest) XXX_Unmarshal(b []byte) error
type GlobFileRequest ¶ added in v1.3.19
type GlobFileRequest struct { Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` Pattern string `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GlobFileRequest) Descriptor ¶ added in v1.3.19
func (*GlobFileRequest) Descriptor() ([]byte, []int)
func (*GlobFileRequest) GetCommit ¶ added in v1.3.19
func (m *GlobFileRequest) GetCommit() *Commit
func (*GlobFileRequest) GetPattern ¶ added in v1.3.19
func (m *GlobFileRequest) GetPattern() string
func (*GlobFileRequest) Marshal ¶ added in v1.5.0
func (m *GlobFileRequest) Marshal() (dAtA []byte, err error)
func (*GlobFileRequest) MarshalTo ¶ added in v1.5.0
func (m *GlobFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*GlobFileRequest) ProtoMessage ¶ added in v1.3.19
func (*GlobFileRequest) ProtoMessage()
func (*GlobFileRequest) Reset ¶ added in v1.3.19
func (m *GlobFileRequest) Reset()
func (*GlobFileRequest) Size ¶ added in v1.5.0
func (m *GlobFileRequest) Size() (n int)
func (*GlobFileRequest) String ¶ added in v1.3.19
func (m *GlobFileRequest) String() string
func (*GlobFileRequest) Unmarshal ¶ added in v1.5.0
func (m *GlobFileRequest) Unmarshal(dAtA []byte) error
func (*GlobFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *GlobFileRequest) XXX_DiscardUnknown()
func (*GlobFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *GlobFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GlobFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *GlobFileRequest) XXX_Merge(src proto.Message)
func (*GlobFileRequest) XXX_Size ¶ added in v1.7.12
func (m *GlobFileRequest) XXX_Size() int
func (*GlobFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *GlobFileRequest) XXX_Unmarshal(b []byte) error
type InspectBranchRequest ¶ added in v1.7.0
type InspectBranchRequest struct { Branch *Branch `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InspectBranchRequest) Descriptor ¶ added in v1.7.0
func (*InspectBranchRequest) Descriptor() ([]byte, []int)
func (*InspectBranchRequest) GetBranch ¶ added in v1.7.0
func (m *InspectBranchRequest) GetBranch() *Branch
func (*InspectBranchRequest) Marshal ¶ added in v1.7.0
func (m *InspectBranchRequest) Marshal() (dAtA []byte, err error)
func (*InspectBranchRequest) MarshalTo ¶ added in v1.7.0
func (m *InspectBranchRequest) MarshalTo(dAtA []byte) (int, error)
func (*InspectBranchRequest) ProtoMessage ¶ added in v1.7.0
func (*InspectBranchRequest) ProtoMessage()
func (*InspectBranchRequest) Reset ¶ added in v1.7.0
func (m *InspectBranchRequest) Reset()
func (*InspectBranchRequest) Size ¶ added in v1.7.0
func (m *InspectBranchRequest) Size() (n int)
func (*InspectBranchRequest) String ¶ added in v1.7.0
func (m *InspectBranchRequest) String() string
func (*InspectBranchRequest) Unmarshal ¶ added in v1.7.0
func (m *InspectBranchRequest) Unmarshal(dAtA []byte) error
func (*InspectBranchRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *InspectBranchRequest) XXX_DiscardUnknown()
func (*InspectBranchRequest) XXX_Marshal ¶ added in v1.7.12
func (m *InspectBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InspectBranchRequest) XXX_Merge ¶ added in v1.7.12
func (m *InspectBranchRequest) XXX_Merge(src proto.Message)
func (*InspectBranchRequest) XXX_Size ¶ added in v1.7.12
func (m *InspectBranchRequest) XXX_Size() int
func (*InspectBranchRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *InspectBranchRequest) XXX_Unmarshal(b []byte) error
type InspectCommitRequest ¶
type InspectCommitRequest struct { Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` // BlockState causes inspect commit to block until the commit is in the desired state. BlockState CommitState `protobuf:"varint,2,opt,name=block_state,json=blockState,proto3,enum=pfs.CommitState" json:"block_state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InspectCommitRequest) Descriptor ¶
func (*InspectCommitRequest) Descriptor() ([]byte, []int)
func (*InspectCommitRequest) GetBlockState ¶ added in v1.7.1
func (m *InspectCommitRequest) GetBlockState() CommitState
func (*InspectCommitRequest) GetCommit ¶
func (m *InspectCommitRequest) GetCommit() *Commit
func (*InspectCommitRequest) Marshal ¶ added in v1.5.0
func (m *InspectCommitRequest) Marshal() (dAtA []byte, err error)
func (*InspectCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *InspectCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*InspectCommitRequest) ProtoMessage ¶
func (*InspectCommitRequest) ProtoMessage()
func (*InspectCommitRequest) Reset ¶
func (m *InspectCommitRequest) Reset()
func (*InspectCommitRequest) Size ¶ added in v1.5.0
func (m *InspectCommitRequest) Size() (n int)
func (*InspectCommitRequest) String ¶
func (m *InspectCommitRequest) String() string
func (*InspectCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *InspectCommitRequest) Unmarshal(dAtA []byte) error
func (*InspectCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *InspectCommitRequest) XXX_DiscardUnknown()
func (*InspectCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *InspectCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InspectCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *InspectCommitRequest) XXX_Merge(src proto.Message)
func (*InspectCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *InspectCommitRequest) XXX_Size() int
func (*InspectCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *InspectCommitRequest) XXX_Unmarshal(b []byte) error
type InspectFileRequest ¶
type InspectFileRequest struct { File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InspectFileRequest) Descriptor ¶
func (*InspectFileRequest) Descriptor() ([]byte, []int)
func (*InspectFileRequest) GetFile ¶
func (m *InspectFileRequest) GetFile() *File
func (*InspectFileRequest) Marshal ¶ added in v1.5.0
func (m *InspectFileRequest) Marshal() (dAtA []byte, err error)
func (*InspectFileRequest) MarshalTo ¶ added in v1.5.0
func (m *InspectFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*InspectFileRequest) ProtoMessage ¶
func (*InspectFileRequest) ProtoMessage()
func (*InspectFileRequest) Reset ¶
func (m *InspectFileRequest) Reset()
func (*InspectFileRequest) Size ¶ added in v1.5.0
func (m *InspectFileRequest) Size() (n int)
func (*InspectFileRequest) String ¶
func (m *InspectFileRequest) String() string
func (*InspectFileRequest) Unmarshal ¶ added in v1.5.0
func (m *InspectFileRequest) Unmarshal(dAtA []byte) error
func (*InspectFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *InspectFileRequest) XXX_DiscardUnknown()
func (*InspectFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *InspectFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InspectFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *InspectFileRequest) XXX_Merge(src proto.Message)
func (*InspectFileRequest) XXX_Size ¶ added in v1.7.12
func (m *InspectFileRequest) XXX_Size() int
func (*InspectFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *InspectFileRequest) XXX_Unmarshal(b []byte) error
type InspectRepoRequest ¶
type InspectRepoRequest struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InspectRepoRequest) Descriptor ¶
func (*InspectRepoRequest) Descriptor() ([]byte, []int)
func (*InspectRepoRequest) GetRepo ¶
func (m *InspectRepoRequest) GetRepo() *Repo
func (*InspectRepoRequest) Marshal ¶ added in v1.5.0
func (m *InspectRepoRequest) Marshal() (dAtA []byte, err error)
func (*InspectRepoRequest) MarshalTo ¶ added in v1.5.0
func (m *InspectRepoRequest) MarshalTo(dAtA []byte) (int, error)
func (*InspectRepoRequest) ProtoMessage ¶
func (*InspectRepoRequest) ProtoMessage()
func (*InspectRepoRequest) Reset ¶
func (m *InspectRepoRequest) Reset()
func (*InspectRepoRequest) Size ¶ added in v1.5.0
func (m *InspectRepoRequest) Size() (n int)
func (*InspectRepoRequest) String ¶
func (m *InspectRepoRequest) String() string
func (*InspectRepoRequest) Unmarshal ¶ added in v1.5.0
func (m *InspectRepoRequest) Unmarshal(dAtA []byte) error
func (*InspectRepoRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *InspectRepoRequest) XXX_DiscardUnknown()
func (*InspectRepoRequest) XXX_Marshal ¶ added in v1.7.12
func (m *InspectRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InspectRepoRequest) XXX_Merge ¶ added in v1.7.12
func (m *InspectRepoRequest) XXX_Merge(src proto.Message)
func (*InspectRepoRequest) XXX_Size ¶ added in v1.7.12
func (m *InspectRepoRequest) XXX_Size() int
func (*InspectRepoRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *InspectRepoRequest) XXX_Unmarshal(b []byte) error
type ListBranchRequest ¶
type ListBranchRequest struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListBranchRequest) Descriptor ¶
func (*ListBranchRequest) Descriptor() ([]byte, []int)
func (*ListBranchRequest) GetRepo ¶
func (m *ListBranchRequest) GetRepo() *Repo
func (*ListBranchRequest) Marshal ¶ added in v1.5.0
func (m *ListBranchRequest) Marshal() (dAtA []byte, err error)
func (*ListBranchRequest) MarshalTo ¶ added in v1.5.0
func (m *ListBranchRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListBranchRequest) ProtoMessage ¶
func (*ListBranchRequest) ProtoMessage()
func (*ListBranchRequest) Reset ¶
func (m *ListBranchRequest) Reset()
func (*ListBranchRequest) Size ¶ added in v1.5.0
func (m *ListBranchRequest) Size() (n int)
func (*ListBranchRequest) String ¶
func (m *ListBranchRequest) String() string
func (*ListBranchRequest) Unmarshal ¶ added in v1.5.0
func (m *ListBranchRequest) Unmarshal(dAtA []byte) error
func (*ListBranchRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListBranchRequest) XXX_DiscardUnknown()
func (*ListBranchRequest) XXX_Marshal ¶ added in v1.7.12
func (m *ListBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListBranchRequest) XXX_Merge ¶ added in v1.7.12
func (m *ListBranchRequest) XXX_Merge(src proto.Message)
func (*ListBranchRequest) XXX_Size ¶ added in v1.7.12
func (m *ListBranchRequest) XXX_Size() int
func (*ListBranchRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListBranchRequest) XXX_Unmarshal(b []byte) error
type ListCommitRequest ¶
type ListCommitRequest struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` From *Commit `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` To *Commit `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` Number uint64 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListCommitRequest) Descriptor ¶
func (*ListCommitRequest) Descriptor() ([]byte, []int)
func (*ListCommitRequest) GetFrom ¶ added in v1.3.19
func (m *ListCommitRequest) GetFrom() *Commit
func (*ListCommitRequest) GetNumber ¶ added in v1.3.19
func (m *ListCommitRequest) GetNumber() uint64
func (*ListCommitRequest) GetRepo ¶
func (m *ListCommitRequest) GetRepo() *Repo
func (*ListCommitRequest) GetTo ¶ added in v1.3.19
func (m *ListCommitRequest) GetTo() *Commit
func (*ListCommitRequest) Marshal ¶ added in v1.5.0
func (m *ListCommitRequest) Marshal() (dAtA []byte, err error)
func (*ListCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *ListCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListCommitRequest) ProtoMessage ¶
func (*ListCommitRequest) ProtoMessage()
func (*ListCommitRequest) Reset ¶
func (m *ListCommitRequest) Reset()
func (*ListCommitRequest) Size ¶ added in v1.5.0
func (m *ListCommitRequest) Size() (n int)
func (*ListCommitRequest) String ¶
func (m *ListCommitRequest) String() string
func (*ListCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *ListCommitRequest) Unmarshal(dAtA []byte) error
func (*ListCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListCommitRequest) XXX_DiscardUnknown()
func (*ListCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *ListCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *ListCommitRequest) XXX_Merge(src proto.Message)
func (*ListCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *ListCommitRequest) XXX_Size() int
func (*ListCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListCommitRequest) XXX_Unmarshal(b []byte) error
type ListFileRequest ¶
type ListFileRequest struct { // File is the parent directory of the files we want to list. This fixes the // repo, the commit/branch, and path prefix of files we're interested it File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` // Full indicates whether the result should include file contents, which may // be large (i.e. the list of children for directories, and the list of object // references for regular files) Full bool `protobuf:"varint,2,opt,name=full,proto3" json:"full,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListFileRequest) Descriptor ¶
func (*ListFileRequest) Descriptor() ([]byte, []int)
func (*ListFileRequest) GetFile ¶
func (m *ListFileRequest) GetFile() *File
func (*ListFileRequest) GetFull ¶ added in v1.6.0
func (m *ListFileRequest) GetFull() bool
func (*ListFileRequest) Marshal ¶ added in v1.5.0
func (m *ListFileRequest) Marshal() (dAtA []byte, err error)
func (*ListFileRequest) MarshalTo ¶ added in v1.5.0
func (m *ListFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListFileRequest) ProtoMessage ¶
func (*ListFileRequest) ProtoMessage()
func (*ListFileRequest) Reset ¶
func (m *ListFileRequest) Reset()
func (*ListFileRequest) Size ¶ added in v1.5.0
func (m *ListFileRequest) Size() (n int)
func (*ListFileRequest) String ¶
func (m *ListFileRequest) String() string
func (*ListFileRequest) Unmarshal ¶ added in v1.5.0
func (m *ListFileRequest) Unmarshal(dAtA []byte) error
func (*ListFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListFileRequest) XXX_DiscardUnknown()
func (*ListFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *ListFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *ListFileRequest) XXX_Merge(src proto.Message)
func (*ListFileRequest) XXX_Size ¶ added in v1.7.12
func (m *ListFileRequest) XXX_Size() int
func (*ListFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListFileRequest) XXX_Unmarshal(b []byte) error
type ListObjectsRequest ¶ added in v1.4.7
type ListObjectsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListObjectsRequest) Descriptor ¶ added in v1.4.7
func (*ListObjectsRequest) Descriptor() ([]byte, []int)
func (*ListObjectsRequest) Marshal ¶ added in v1.5.0
func (m *ListObjectsRequest) Marshal() (dAtA []byte, err error)
func (*ListObjectsRequest) MarshalTo ¶ added in v1.5.0
func (m *ListObjectsRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListObjectsRequest) ProtoMessage ¶ added in v1.4.7
func (*ListObjectsRequest) ProtoMessage()
func (*ListObjectsRequest) Reset ¶ added in v1.4.7
func (m *ListObjectsRequest) Reset()
func (*ListObjectsRequest) Size ¶ added in v1.5.0
func (m *ListObjectsRequest) Size() (n int)
func (*ListObjectsRequest) String ¶ added in v1.4.7
func (m *ListObjectsRequest) String() string
func (*ListObjectsRequest) Unmarshal ¶ added in v1.5.0
func (m *ListObjectsRequest) Unmarshal(dAtA []byte) error
func (*ListObjectsRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListObjectsRequest) XXX_DiscardUnknown()
func (*ListObjectsRequest) XXX_Marshal ¶ added in v1.7.12
func (m *ListObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListObjectsRequest) XXX_Merge ¶ added in v1.7.12
func (m *ListObjectsRequest) XXX_Merge(src proto.Message)
func (*ListObjectsRequest) XXX_Size ¶ added in v1.7.12
func (m *ListObjectsRequest) XXX_Size() int
func (*ListObjectsRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListObjectsRequest) XXX_Unmarshal(b []byte) error
type ListRepoRequest ¶
type ListRepoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRepoRequest) Descriptor ¶
func (*ListRepoRequest) Descriptor() ([]byte, []int)
func (*ListRepoRequest) Marshal ¶ added in v1.5.0
func (m *ListRepoRequest) Marshal() (dAtA []byte, err error)
func (*ListRepoRequest) MarshalTo ¶ added in v1.5.0
func (m *ListRepoRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListRepoRequest) ProtoMessage ¶
func (*ListRepoRequest) ProtoMessage()
func (*ListRepoRequest) Reset ¶
func (m *ListRepoRequest) Reset()
func (*ListRepoRequest) Size ¶ added in v1.5.0
func (m *ListRepoRequest) Size() (n int)
func (*ListRepoRequest) String ¶
func (m *ListRepoRequest) String() string
func (*ListRepoRequest) Unmarshal ¶ added in v1.5.0
func (m *ListRepoRequest) Unmarshal(dAtA []byte) error
func (*ListRepoRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListRepoRequest) XXX_DiscardUnknown()
func (*ListRepoRequest) XXX_Marshal ¶ added in v1.7.12
func (m *ListRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRepoRequest) XXX_Merge ¶ added in v1.7.12
func (m *ListRepoRequest) XXX_Merge(src proto.Message)
func (*ListRepoRequest) XXX_Size ¶ added in v1.7.12
func (m *ListRepoRequest) XXX_Size() int
func (*ListRepoRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListRepoRequest) XXX_Unmarshal(b []byte) error
type ListRepoResponse ¶ added in v1.6.0
type ListRepoResponse struct { RepoInfo []*RepoInfo `protobuf:"bytes,1,rep,name=repo_info,json=repoInfo,proto3" json:"repo_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRepoResponse) Descriptor ¶ added in v1.6.0
func (*ListRepoResponse) Descriptor() ([]byte, []int)
func (*ListRepoResponse) GetRepoInfo ¶ added in v1.6.0
func (m *ListRepoResponse) GetRepoInfo() []*RepoInfo
func (*ListRepoResponse) Marshal ¶ added in v1.6.0
func (m *ListRepoResponse) Marshal() (dAtA []byte, err error)
func (*ListRepoResponse) MarshalTo ¶ added in v1.6.0
func (m *ListRepoResponse) MarshalTo(dAtA []byte) (int, error)
func (*ListRepoResponse) ProtoMessage ¶ added in v1.6.0
func (*ListRepoResponse) ProtoMessage()
func (*ListRepoResponse) Reset ¶ added in v1.6.0
func (m *ListRepoResponse) Reset()
func (*ListRepoResponse) Size ¶ added in v1.6.0
func (m *ListRepoResponse) Size() (n int)
func (*ListRepoResponse) String ¶ added in v1.6.0
func (m *ListRepoResponse) String() string
func (*ListRepoResponse) Unmarshal ¶ added in v1.6.0
func (m *ListRepoResponse) Unmarshal(dAtA []byte) error
func (*ListRepoResponse) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListRepoResponse) XXX_DiscardUnknown()
func (*ListRepoResponse) XXX_Marshal ¶ added in v1.7.12
func (m *ListRepoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRepoResponse) XXX_Merge ¶ added in v1.7.12
func (m *ListRepoResponse) XXX_Merge(src proto.Message)
func (*ListRepoResponse) XXX_Size ¶ added in v1.7.12
func (m *ListRepoResponse) XXX_Size() int
func (*ListRepoResponse) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListRepoResponse) XXX_Unmarshal(b []byte) error
type ListTagsRequest ¶ added in v1.4.7
type ListTagsRequest struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` IncludeObject bool `protobuf:"varint,2,opt,name=include_object,json=includeObject,proto3" json:"include_object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListTagsRequest) Descriptor ¶ added in v1.4.7
func (*ListTagsRequest) Descriptor() ([]byte, []int)
func (*ListTagsRequest) GetIncludeObject ¶ added in v1.4.7
func (m *ListTagsRequest) GetIncludeObject() bool
func (*ListTagsRequest) GetPrefix ¶ added in v1.4.7
func (m *ListTagsRequest) GetPrefix() string
func (*ListTagsRequest) Marshal ¶ added in v1.5.0
func (m *ListTagsRequest) Marshal() (dAtA []byte, err error)
func (*ListTagsRequest) MarshalTo ¶ added in v1.5.0
func (m *ListTagsRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListTagsRequest) ProtoMessage ¶ added in v1.4.7
func (*ListTagsRequest) ProtoMessage()
func (*ListTagsRequest) Reset ¶ added in v1.4.7
func (m *ListTagsRequest) Reset()
func (*ListTagsRequest) Size ¶ added in v1.5.0
func (m *ListTagsRequest) Size() (n int)
func (*ListTagsRequest) String ¶ added in v1.4.7
func (m *ListTagsRequest) String() string
func (*ListTagsRequest) Unmarshal ¶ added in v1.5.0
func (m *ListTagsRequest) Unmarshal(dAtA []byte) error
func (*ListTagsRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListTagsRequest) XXX_DiscardUnknown()
func (*ListTagsRequest) XXX_Marshal ¶ added in v1.7.12
func (m *ListTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTagsRequest) XXX_Merge ¶ added in v1.7.12
func (m *ListTagsRequest) XXX_Merge(src proto.Message)
func (*ListTagsRequest) XXX_Size ¶ added in v1.7.12
func (m *ListTagsRequest) XXX_Size() int
func (*ListTagsRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListTagsRequest) XXX_Unmarshal(b []byte) error
type ListTagsResponse ¶ added in v1.4.7
type ListTagsResponse struct { Tag *Tag `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` Object *Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListTagsResponse) Descriptor ¶ added in v1.4.7
func (*ListTagsResponse) Descriptor() ([]byte, []int)
func (*ListTagsResponse) GetObject ¶ added in v1.4.7
func (m *ListTagsResponse) GetObject() *Object
func (*ListTagsResponse) GetTag ¶ added in v1.4.7
func (m *ListTagsResponse) GetTag() *Tag
func (*ListTagsResponse) Marshal ¶ added in v1.5.0
func (m *ListTagsResponse) Marshal() (dAtA []byte, err error)
func (*ListTagsResponse) MarshalTo ¶ added in v1.5.0
func (m *ListTagsResponse) MarshalTo(dAtA []byte) (int, error)
func (*ListTagsResponse) ProtoMessage ¶ added in v1.4.7
func (*ListTagsResponse) ProtoMessage()
func (*ListTagsResponse) Reset ¶ added in v1.4.7
func (m *ListTagsResponse) Reset()
func (*ListTagsResponse) Size ¶ added in v1.5.0
func (m *ListTagsResponse) Size() (n int)
func (*ListTagsResponse) String ¶ added in v1.4.7
func (m *ListTagsResponse) String() string
func (*ListTagsResponse) Unmarshal ¶ added in v1.5.0
func (m *ListTagsResponse) Unmarshal(dAtA []byte) error
func (*ListTagsResponse) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ListTagsResponse) XXX_DiscardUnknown()
func (*ListTagsResponse) XXX_Marshal ¶ added in v1.7.12
func (m *ListTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTagsResponse) XXX_Merge ¶ added in v1.7.12
func (m *ListTagsResponse) XXX_Merge(src proto.Message)
func (*ListTagsResponse) XXX_Size ¶ added in v1.7.12
func (m *ListTagsResponse) XXX_Size() int
func (*ListTagsResponse) XXX_Unmarshal ¶ added in v1.7.12
func (m *ListTagsResponse) XXX_Unmarshal(b []byte) error
type Metadata ¶ added in v1.7.10
type Metadata struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Metadata struct allows us to distinguish between cases where header/footer are not specified vs explicitly empty
func (*Metadata) Descriptor ¶ added in v1.7.10
func (*Metadata) ProtoMessage ¶ added in v1.7.10
func (*Metadata) ProtoMessage()
func (*Metadata) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Metadata) XXX_DiscardUnknown()
func (*Metadata) XXX_Marshal ¶ added in v1.7.12
func (*Metadata) XXX_Unmarshal ¶ added in v1.7.12
type Object ¶ added in v1.3.9
type Object struct { Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Object) Descriptor ¶ added in v1.3.9
func (*Object) ProtoMessage ¶ added in v1.3.9
func (*Object) ProtoMessage()
func (*Object) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Object) XXX_DiscardUnknown()
func (*Object) XXX_Marshal ¶ added in v1.7.12
func (*Object) XXX_Unmarshal ¶ added in v1.7.12
type ObjectAPIClient ¶ added in v1.3.9
type ObjectAPIClient interface { PutObject(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectClient, error) PutObjectSplit(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectSplitClient, error) GetObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (ObjectAPI_GetObjectClient, error) GetObjects(ctx context.Context, in *GetObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_GetObjectsClient, error) TagObject(ctx context.Context, in *TagObjectRequest, opts ...grpc.CallOption) (*types.Empty, error) InspectObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (*ObjectInfo, error) // CheckObject checks if an object exists in the blob store without // actually reading the object. CheckObject(ctx context.Context, in *CheckObjectRequest, opts ...grpc.CallOption) (*CheckObjectResponse, error) ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_ListObjectsClient, error) DeleteObjects(ctx context.Context, in *DeleteObjectsRequest, opts ...grpc.CallOption) (*DeleteObjectsResponse, error) GetTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (ObjectAPI_GetTagClient, error) InspectTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (*ObjectInfo, error) ListTags(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (ObjectAPI_ListTagsClient, error) DeleteTags(ctx context.Context, in *DeleteTagsRequest, opts ...grpc.CallOption) (*DeleteTagsResponse, error) Compact(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error) }
ObjectAPIClient is the client API for ObjectAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewObjectAPIClient ¶ added in v1.3.9
func NewObjectAPIClient(cc *grpc.ClientConn) ObjectAPIClient
type ObjectAPIServer ¶ added in v1.3.9
type ObjectAPIServer interface { PutObject(ObjectAPI_PutObjectServer) error PutObjectSplit(ObjectAPI_PutObjectSplitServer) error GetObject(*Object, ObjectAPI_GetObjectServer) error GetObjects(*GetObjectsRequest, ObjectAPI_GetObjectsServer) error TagObject(context.Context, *TagObjectRequest) (*types.Empty, error) InspectObject(context.Context, *Object) (*ObjectInfo, error) // CheckObject checks if an object exists in the blob store without // actually reading the object. CheckObject(context.Context, *CheckObjectRequest) (*CheckObjectResponse, error) ListObjects(*ListObjectsRequest, ObjectAPI_ListObjectsServer) error DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error) GetTag(*Tag, ObjectAPI_GetTagServer) error InspectTag(context.Context, *Tag) (*ObjectInfo, error) ListTags(*ListTagsRequest, ObjectAPI_ListTagsServer) error DeleteTags(context.Context, *DeleteTagsRequest) (*DeleteTagsResponse, error) Compact(context.Context, *types.Empty) (*types.Empty, error) }
ObjectAPIServer is the server API for ObjectAPI service.
type ObjectAPI_GetObjectClient ¶ added in v1.3.9
type ObjectAPI_GetObjectClient interface { Recv() (*types.BytesValue, error) grpc.ClientStream }
type ObjectAPI_GetObjectServer ¶ added in v1.3.9
type ObjectAPI_GetObjectServer interface { Send(*types.BytesValue) error grpc.ServerStream }
type ObjectAPI_GetObjectsClient ¶ added in v1.3.19
type ObjectAPI_GetObjectsClient interface { Recv() (*types.BytesValue, error) grpc.ClientStream }
type ObjectAPI_GetObjectsServer ¶ added in v1.3.19
type ObjectAPI_GetObjectsServer interface { Send(*types.BytesValue) error grpc.ServerStream }
type ObjectAPI_GetTagClient ¶ added in v1.3.9
type ObjectAPI_GetTagClient interface { Recv() (*types.BytesValue, error) grpc.ClientStream }
type ObjectAPI_GetTagServer ¶ added in v1.3.9
type ObjectAPI_GetTagServer interface { Send(*types.BytesValue) error grpc.ServerStream }
type ObjectAPI_ListObjectsClient ¶ added in v1.4.7
type ObjectAPI_ListObjectsClient interface { Recv() (*Object, error) grpc.ClientStream }
type ObjectAPI_ListObjectsServer ¶ added in v1.4.7
type ObjectAPI_ListObjectsServer interface { Send(*Object) error grpc.ServerStream }
type ObjectAPI_ListTagsClient ¶ added in v1.4.7
type ObjectAPI_ListTagsClient interface { Recv() (*ListTagsResponse, error) grpc.ClientStream }
type ObjectAPI_ListTagsServer ¶ added in v1.4.7
type ObjectAPI_ListTagsServer interface { Send(*ListTagsResponse) error grpc.ServerStream }
type ObjectAPI_PutObjectClient ¶ added in v1.3.9
type ObjectAPI_PutObjectClient interface { Send(*PutObjectRequest) error CloseAndRecv() (*Object, error) grpc.ClientStream }
type ObjectAPI_PutObjectServer ¶ added in v1.3.9
type ObjectAPI_PutObjectServer interface { SendAndClose(*Object) error Recv() (*PutObjectRequest, error) grpc.ServerStream }
type ObjectAPI_PutObjectSplitClient ¶ added in v1.6.0
type ObjectAPI_PutObjectSplitClient interface { Send(*PutObjectRequest) error CloseAndRecv() (*Objects, error) grpc.ClientStream }
type ObjectAPI_PutObjectSplitServer ¶ added in v1.6.0
type ObjectAPI_PutObjectSplitServer interface { SendAndClose(*Objects) error Recv() (*PutObjectRequest, error) grpc.ServerStream }
type ObjectIndex ¶ added in v1.3.9
type ObjectIndex struct { Objects map[string]*BlockRef `` /* 155-byte string literal not displayed */ Tags map[string]*Object `` /* 149-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ObjectIndex) Descriptor ¶ added in v1.3.9
func (*ObjectIndex) Descriptor() ([]byte, []int)
func (*ObjectIndex) GetObjects ¶ added in v1.3.9
func (m *ObjectIndex) GetObjects() map[string]*BlockRef
func (*ObjectIndex) GetTags ¶ added in v1.3.9
func (m *ObjectIndex) GetTags() map[string]*Object
func (*ObjectIndex) Marshal ¶ added in v1.5.0
func (m *ObjectIndex) Marshal() (dAtA []byte, err error)
func (*ObjectIndex) MarshalTo ¶ added in v1.5.0
func (m *ObjectIndex) MarshalTo(dAtA []byte) (int, error)
func (*ObjectIndex) ProtoMessage ¶ added in v1.3.9
func (*ObjectIndex) ProtoMessage()
func (*ObjectIndex) Reset ¶ added in v1.3.9
func (m *ObjectIndex) Reset()
func (*ObjectIndex) Size ¶ added in v1.5.0
func (m *ObjectIndex) Size() (n int)
func (*ObjectIndex) String ¶ added in v1.3.9
func (m *ObjectIndex) String() string
func (*ObjectIndex) Unmarshal ¶ added in v1.5.0
func (m *ObjectIndex) Unmarshal(dAtA []byte) error
func (*ObjectIndex) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ObjectIndex) XXX_DiscardUnknown()
func (*ObjectIndex) XXX_Marshal ¶ added in v1.7.12
func (m *ObjectIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectIndex) XXX_Merge ¶ added in v1.7.12
func (m *ObjectIndex) XXX_Merge(src proto.Message)
func (*ObjectIndex) XXX_Size ¶ added in v1.7.12
func (m *ObjectIndex) XXX_Size() int
func (*ObjectIndex) XXX_Unmarshal ¶ added in v1.7.12
func (m *ObjectIndex) XXX_Unmarshal(b []byte) error
type ObjectInfo ¶ added in v1.3.9
type ObjectInfo struct { Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` BlockRef *BlockRef `protobuf:"bytes,2,opt,name=block_ref,json=blockRef,proto3" json:"block_ref,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ObjectInfo) Descriptor ¶ added in v1.3.9
func (*ObjectInfo) Descriptor() ([]byte, []int)
func (*ObjectInfo) GetBlockRef ¶ added in v1.3.9
func (m *ObjectInfo) GetBlockRef() *BlockRef
func (*ObjectInfo) GetObject ¶ added in v1.3.9
func (m *ObjectInfo) GetObject() *Object
func (*ObjectInfo) Marshal ¶ added in v1.5.0
func (m *ObjectInfo) Marshal() (dAtA []byte, err error)
func (*ObjectInfo) MarshalTo ¶ added in v1.5.0
func (m *ObjectInfo) MarshalTo(dAtA []byte) (int, error)
func (*ObjectInfo) ProtoMessage ¶ added in v1.3.9
func (*ObjectInfo) ProtoMessage()
func (*ObjectInfo) Reset ¶ added in v1.3.9
func (m *ObjectInfo) Reset()
func (*ObjectInfo) Size ¶ added in v1.5.0
func (m *ObjectInfo) Size() (n int)
func (*ObjectInfo) String ¶ added in v1.3.9
func (m *ObjectInfo) String() string
func (*ObjectInfo) Unmarshal ¶ added in v1.5.0
func (m *ObjectInfo) Unmarshal(dAtA []byte) error
func (*ObjectInfo) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *ObjectInfo) XXX_DiscardUnknown()
func (*ObjectInfo) XXX_Marshal ¶ added in v1.7.12
func (m *ObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectInfo) XXX_Merge ¶ added in v1.7.12
func (m *ObjectInfo) XXX_Merge(src proto.Message)
func (*ObjectInfo) XXX_Size ¶ added in v1.7.12
func (m *ObjectInfo) XXX_Size() int
func (*ObjectInfo) XXX_Unmarshal ¶ added in v1.7.12
func (m *ObjectInfo) XXX_Unmarshal(b []byte) error
type Objects ¶ added in v1.6.0
type Objects struct { Objects []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Objects) Descriptor ¶ added in v1.6.0
func (*Objects) GetObjects ¶ added in v1.6.0
func (*Objects) ProtoMessage ¶ added in v1.6.0
func (*Objects) ProtoMessage()
func (*Objects) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Objects) XXX_DiscardUnknown()
func (*Objects) XXX_Marshal ¶ added in v1.7.12
func (*Objects) XXX_Unmarshal ¶ added in v1.7.12
type OverwriteIndex ¶ added in v1.6.0
type OverwriteIndex struct { Index int64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
An OverwriteIndex specifies the index of objects from which new writes are applied to. Existing objects starting from the index are deleted. We want a separate message for ObjectIndex because we want to be able to distinguish between a zero index and a non-existent index.
func (*OverwriteIndex) Descriptor ¶ added in v1.6.0
func (*OverwriteIndex) Descriptor() ([]byte, []int)
func (*OverwriteIndex) GetIndex ¶ added in v1.6.0
func (m *OverwriteIndex) GetIndex() int64
func (*OverwriteIndex) Marshal ¶ added in v1.6.0
func (m *OverwriteIndex) Marshal() (dAtA []byte, err error)
func (*OverwriteIndex) MarshalTo ¶ added in v1.6.0
func (m *OverwriteIndex) MarshalTo(dAtA []byte) (int, error)
func (*OverwriteIndex) ProtoMessage ¶ added in v1.6.0
func (*OverwriteIndex) ProtoMessage()
func (*OverwriteIndex) Reset ¶ added in v1.6.0
func (m *OverwriteIndex) Reset()
func (*OverwriteIndex) Size ¶ added in v1.6.0
func (m *OverwriteIndex) Size() (n int)
func (*OverwriteIndex) String ¶ added in v1.6.0
func (m *OverwriteIndex) String() string
func (*OverwriteIndex) Unmarshal ¶ added in v1.6.0
func (m *OverwriteIndex) Unmarshal(dAtA []byte) error
func (*OverwriteIndex) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *OverwriteIndex) XXX_DiscardUnknown()
func (*OverwriteIndex) XXX_Marshal ¶ added in v1.7.12
func (m *OverwriteIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OverwriteIndex) XXX_Merge ¶ added in v1.7.12
func (m *OverwriteIndex) XXX_Merge(src proto.Message)
func (*OverwriteIndex) XXX_Size ¶ added in v1.7.12
func (m *OverwriteIndex) XXX_Size() int
func (*OverwriteIndex) XXX_Unmarshal ¶ added in v1.7.12
func (m *OverwriteIndex) XXX_Unmarshal(b []byte) error
type PutFileRecord ¶ added in v1.6.0
type PutFileRecord struct { SizeBytes int64 `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` ObjectHash string `protobuf:"bytes,2,opt,name=object_hash,json=objectHash,proto3" json:"object_hash,omitempty"` OverwriteIndex *OverwriteIndex `protobuf:"bytes,3,opt,name=overwrite_index,json=overwriteIndex,proto3" json:"overwrite_index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PutFileRecord is used to record PutFile requests in etcd temporarily.
func (*PutFileRecord) Descriptor ¶ added in v1.6.0
func (*PutFileRecord) Descriptor() ([]byte, []int)
func (*PutFileRecord) GetObjectHash ¶ added in v1.6.0
func (m *PutFileRecord) GetObjectHash() string
func (*PutFileRecord) GetOverwriteIndex ¶ added in v1.6.0
func (m *PutFileRecord) GetOverwriteIndex() *OverwriteIndex
func (*PutFileRecord) GetSizeBytes ¶ added in v1.6.0
func (m *PutFileRecord) GetSizeBytes() int64
func (*PutFileRecord) Marshal ¶ added in v1.6.0
func (m *PutFileRecord) Marshal() (dAtA []byte, err error)
func (*PutFileRecord) MarshalTo ¶ added in v1.6.0
func (m *PutFileRecord) MarshalTo(dAtA []byte) (int, error)
func (*PutFileRecord) ProtoMessage ¶ added in v1.6.0
func (*PutFileRecord) ProtoMessage()
func (*PutFileRecord) Reset ¶ added in v1.6.0
func (m *PutFileRecord) Reset()
func (*PutFileRecord) Size ¶ added in v1.6.0
func (m *PutFileRecord) Size() (n int)
func (*PutFileRecord) String ¶ added in v1.6.0
func (m *PutFileRecord) String() string
func (*PutFileRecord) Unmarshal ¶ added in v1.6.0
func (m *PutFileRecord) Unmarshal(dAtA []byte) error
func (*PutFileRecord) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *PutFileRecord) XXX_DiscardUnknown()
func (*PutFileRecord) XXX_Marshal ¶ added in v1.7.12
func (m *PutFileRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutFileRecord) XXX_Merge ¶ added in v1.7.12
func (m *PutFileRecord) XXX_Merge(src proto.Message)
func (*PutFileRecord) XXX_Size ¶ added in v1.7.12
func (m *PutFileRecord) XXX_Size() int
func (*PutFileRecord) XXX_Unmarshal ¶ added in v1.7.12
func (m *PutFileRecord) XXX_Unmarshal(b []byte) error
type PutFileRecords ¶ added in v1.6.0
type PutFileRecords struct { Split bool `protobuf:"varint,1,opt,name=split,proto3" json:"split,omitempty"` Records []*PutFileRecord `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"` Tombstone bool `protobuf:"varint,3,opt,name=tombstone,proto3" json:"tombstone,omitempty"` Header *PutFileRecord `protobuf:"bytes,4,opt,name=header,proto3" json:"header,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutFileRecords) Descriptor ¶ added in v1.6.0
func (*PutFileRecords) Descriptor() ([]byte, []int)
func (*PutFileRecords) GetFooter ¶ added in v1.7.10
func (m *PutFileRecords) GetFooter() *PutFileRecord
func (*PutFileRecords) GetHeader ¶ added in v1.7.10
func (m *PutFileRecords) GetHeader() *PutFileRecord
func (*PutFileRecords) GetRecords ¶ added in v1.6.0
func (m *PutFileRecords) GetRecords() []*PutFileRecord
func (*PutFileRecords) GetSplit ¶ added in v1.6.0
func (m *PutFileRecords) GetSplit() bool
func (*PutFileRecords) GetTombstone ¶ added in v1.6.7
func (m *PutFileRecords) GetTombstone() bool
func (*PutFileRecords) Marshal ¶ added in v1.6.0
func (m *PutFileRecords) Marshal() (dAtA []byte, err error)
func (*PutFileRecords) MarshalTo ¶ added in v1.6.0
func (m *PutFileRecords) MarshalTo(dAtA []byte) (int, error)
func (*PutFileRecords) ProtoMessage ¶ added in v1.6.0
func (*PutFileRecords) ProtoMessage()
func (*PutFileRecords) Reset ¶ added in v1.6.0
func (m *PutFileRecords) Reset()
func (*PutFileRecords) Size ¶ added in v1.6.0
func (m *PutFileRecords) Size() (n int)
func (*PutFileRecords) String ¶ added in v1.6.0
func (m *PutFileRecords) String() string
func (*PutFileRecords) Unmarshal ¶ added in v1.6.0
func (m *PutFileRecords) Unmarshal(dAtA []byte) error
func (*PutFileRecords) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *PutFileRecords) XXX_DiscardUnknown()
func (*PutFileRecords) XXX_Marshal ¶ added in v1.7.12
func (m *PutFileRecords) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutFileRecords) XXX_Merge ¶ added in v1.7.12
func (m *PutFileRecords) XXX_Merge(src proto.Message)
func (*PutFileRecords) XXX_Size ¶ added in v1.7.12
func (m *PutFileRecords) XXX_Size() int
func (*PutFileRecords) XXX_Unmarshal ¶ added in v1.7.12
func (m *PutFileRecords) XXX_Unmarshal(b []byte) error
type PutFileRequest ¶
type PutFileRequest struct { File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Url string `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"` // applies only to URLs that can be recursively walked, for example s3:// URLs Recursive bool `protobuf:"varint,6,opt,name=recursive,proto3" json:"recursive,omitempty"` // Delimiter causes data to be broken up into separate files with File.Path // as a prefix. Delimiter Delimiter `protobuf:"varint,7,opt,name=delimiter,proto3,enum=pfs.Delimiter" json:"delimiter,omitempty"` // TargetFileDatums specifies the target number of datums in each written // file it may be lower if data does not split evenly, but will never be // higher, unless the value is 0. TargetFileDatums int64 `protobuf:"varint,8,opt,name=target_file_datums,json=targetFileDatums,proto3" json:"target_file_datums,omitempty"` // TargetFileBytes specifies the target number of bytes in each written // file, files may have more or fewer bytes than the target. TargetFileBytes int64 `protobuf:"varint,9,opt,name=target_file_bytes,json=targetFileBytes,proto3" json:"target_file_bytes,omitempty"` // overwrite_index is the object index where the write starts from. All // existing objects starting from the index are deleted. OverwriteIndex *OverwriteIndex `protobuf:"bytes,10,opt,name=overwrite_index,json=overwriteIndex,proto3" json:"overwrite_index,omitempty"` Header *Metadata `protobuf:"bytes,11,opt,name=header,proto3" json:"header,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutFileRequest) Descriptor ¶
func (*PutFileRequest) Descriptor() ([]byte, []int)
func (*PutFileRequest) GetDelimiter ¶ added in v1.3.5
func (m *PutFileRequest) GetDelimiter() Delimiter
func (*PutFileRequest) GetFile ¶
func (m *PutFileRequest) GetFile() *File
func (*PutFileRequest) GetFooter ¶ added in v1.7.10
func (m *PutFileRequest) GetFooter() *Metadata
func (*PutFileRequest) GetHeader ¶ added in v1.7.10
func (m *PutFileRequest) GetHeader() *Metadata
func (*PutFileRequest) GetOverwriteIndex ¶ added in v1.6.0
func (m *PutFileRequest) GetOverwriteIndex() *OverwriteIndex
func (*PutFileRequest) GetRecursive ¶ added in v1.3.5
func (m *PutFileRequest) GetRecursive() bool
func (*PutFileRequest) GetTargetFileBytes ¶ added in v1.3.19
func (m *PutFileRequest) GetTargetFileBytes() int64
func (*PutFileRequest) GetTargetFileDatums ¶ added in v1.3.19
func (m *PutFileRequest) GetTargetFileDatums() int64
func (*PutFileRequest) GetUrl ¶ added in v1.3.5
func (m *PutFileRequest) GetUrl() string
func (*PutFileRequest) GetValue ¶ added in v1.3.5
func (m *PutFileRequest) GetValue() []byte
func (*PutFileRequest) Marshal ¶ added in v1.5.0
func (m *PutFileRequest) Marshal() (dAtA []byte, err error)
func (*PutFileRequest) MarshalTo ¶ added in v1.5.0
func (m *PutFileRequest) MarshalTo(dAtA []byte) (int, error)
func (*PutFileRequest) ProtoMessage ¶
func (*PutFileRequest) ProtoMessage()
func (*PutFileRequest) Reset ¶
func (m *PutFileRequest) Reset()
func (*PutFileRequest) Size ¶ added in v1.5.0
func (m *PutFileRequest) Size() (n int)
func (*PutFileRequest) String ¶
func (m *PutFileRequest) String() string
func (*PutFileRequest) Unmarshal ¶ added in v1.5.0
func (m *PutFileRequest) Unmarshal(dAtA []byte) error
func (*PutFileRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *PutFileRequest) XXX_DiscardUnknown()
func (*PutFileRequest) XXX_Marshal ¶ added in v1.7.12
func (m *PutFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutFileRequest) XXX_Merge ¶ added in v1.7.12
func (m *PutFileRequest) XXX_Merge(src proto.Message)
func (*PutFileRequest) XXX_Size ¶ added in v1.7.12
func (m *PutFileRequest) XXX_Size() int
func (*PutFileRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *PutFileRequest) XXX_Unmarshal(b []byte) error
type PutObjectRequest ¶ added in v1.3.9
type PutObjectRequest struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` Tags []*Tag `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutObjectRequest) Descriptor ¶ added in v1.3.9
func (*PutObjectRequest) Descriptor() ([]byte, []int)
func (*PutObjectRequest) GetTags ¶ added in v1.3.9
func (m *PutObjectRequest) GetTags() []*Tag
func (*PutObjectRequest) GetValue ¶ added in v1.3.9
func (m *PutObjectRequest) GetValue() []byte
func (*PutObjectRequest) Marshal ¶ added in v1.5.0
func (m *PutObjectRequest) Marshal() (dAtA []byte, err error)
func (*PutObjectRequest) MarshalTo ¶ added in v1.5.0
func (m *PutObjectRequest) MarshalTo(dAtA []byte) (int, error)
func (*PutObjectRequest) ProtoMessage ¶ added in v1.3.9
func (*PutObjectRequest) ProtoMessage()
func (*PutObjectRequest) Reset ¶ added in v1.3.9
func (m *PutObjectRequest) Reset()
func (*PutObjectRequest) Size ¶ added in v1.5.0
func (m *PutObjectRequest) Size() (n int)
func (*PutObjectRequest) String ¶ added in v1.3.9
func (m *PutObjectRequest) String() string
func (*PutObjectRequest) Unmarshal ¶ added in v1.5.0
func (m *PutObjectRequest) Unmarshal(dAtA []byte) error
func (*PutObjectRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *PutObjectRequest) XXX_DiscardUnknown()
func (*PutObjectRequest) XXX_Marshal ¶ added in v1.7.12
func (m *PutObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutObjectRequest) XXX_Merge ¶ added in v1.7.12
func (m *PutObjectRequest) XXX_Merge(src proto.Message)
func (*PutObjectRequest) XXX_Size ¶ added in v1.7.12
func (m *PutObjectRequest) XXX_Size() int
func (*PutObjectRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *PutObjectRequest) XXX_Unmarshal(b []byte) error
type Repo ¶
type Repo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Repo) Descriptor ¶
func (*Repo) ProtoMessage ¶
func (*Repo) ProtoMessage()
func (*Repo) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Repo) XXX_DiscardUnknown()
func (*Repo) XXX_Marshal ¶ added in v1.7.12
func (*Repo) XXX_Unmarshal ¶ added in v1.7.12
type RepoAuthInfo ¶ added in v1.6.0
type RepoAuthInfo struct { // The callers access level to the relevant repo (e.g. may be OWNER even if // the user isn't an OWNER of the repo, if they're an admin for the cluster) AccessLevel auth.Scope `protobuf:"varint,1,opt,name=access_level,json=accessLevel,proto3,enum=auth.Scope" json:"access_level,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RepoAuthInfo includes the caller's access scope for a repo, and is returned by ListRepo and InspectRepo but not persisted in etcd. It's used by the Pachyderm dashboard to render repo access appropriately. To set a user's auth scope for a repo, use the Pachyderm Auth API (in src/client/auth/auth.proto)
func (*RepoAuthInfo) Descriptor ¶ added in v1.6.0
func (*RepoAuthInfo) Descriptor() ([]byte, []int)
func (*RepoAuthInfo) GetAccessLevel ¶ added in v1.6.0
func (m *RepoAuthInfo) GetAccessLevel() auth.Scope
func (*RepoAuthInfo) Marshal ¶ added in v1.6.0
func (m *RepoAuthInfo) Marshal() (dAtA []byte, err error)
func (*RepoAuthInfo) MarshalTo ¶ added in v1.6.0
func (m *RepoAuthInfo) MarshalTo(dAtA []byte) (int, error)
func (*RepoAuthInfo) ProtoMessage ¶ added in v1.6.0
func (*RepoAuthInfo) ProtoMessage()
func (*RepoAuthInfo) Reset ¶ added in v1.6.0
func (m *RepoAuthInfo) Reset()
func (*RepoAuthInfo) Size ¶ added in v1.6.0
func (m *RepoAuthInfo) Size() (n int)
func (*RepoAuthInfo) String ¶ added in v1.6.0
func (m *RepoAuthInfo) String() string
func (*RepoAuthInfo) Unmarshal ¶ added in v1.6.0
func (m *RepoAuthInfo) Unmarshal(dAtA []byte) error
func (*RepoAuthInfo) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *RepoAuthInfo) XXX_DiscardUnknown()
func (*RepoAuthInfo) XXX_Marshal ¶ added in v1.7.12
func (m *RepoAuthInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RepoAuthInfo) XXX_Merge ¶ added in v1.7.12
func (m *RepoAuthInfo) XXX_Merge(src proto.Message)
func (*RepoAuthInfo) XXX_Size ¶ added in v1.7.12
func (m *RepoAuthInfo) XXX_Size() int
func (*RepoAuthInfo) XXX_Unmarshal ¶ added in v1.7.12
func (m *RepoAuthInfo) XXX_Unmarshal(b []byte) error
type RepoInfo ¶
type RepoInfo struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` Created *types.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"` SizeBytes uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` Branches []*Branch `protobuf:"bytes,7,rep,name=branches,proto3" json:"branches,omitempty"` // Set by ListRepo and InspectRepo if Pachyderm's auth system is active, but // not stored in etcd. To set a user's auth scope for a repo, use the // Pachyderm Auth API (in src/client/auth/auth.proto) AuthInfo *RepoAuthInfo `protobuf:"bytes,6,opt,name=auth_info,json=authInfo,proto3" json:"auth_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RepoInfo is the main data structure representing a Repo in etcd
func (*RepoInfo) Descriptor ¶
func (*RepoInfo) GetAuthInfo ¶ added in v1.6.0
func (m *RepoInfo) GetAuthInfo() *RepoAuthInfo
func (*RepoInfo) GetBranches ¶ added in v1.7.0
func (*RepoInfo) GetCreated ¶
func (*RepoInfo) GetDescription ¶ added in v1.4.7
func (*RepoInfo) GetSizeBytes ¶ added in v1.3.5
func (*RepoInfo) ProtoMessage ¶
func (*RepoInfo) ProtoMessage()
func (*RepoInfo) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *RepoInfo) XXX_DiscardUnknown()
func (*RepoInfo) XXX_Marshal ¶ added in v1.7.12
func (*RepoInfo) XXX_Unmarshal ¶ added in v1.7.12
type StartCommitRequest ¶
type StartCommitRequest struct { // Parent.ID may be empty in which case the commit that Branch points to will be used as the parent. // If branch is empty, or if branch does not exist, the commit will have no parent. Parent *Commit `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // description is a user-provided string describing this commit Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` Branch string `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"` Provenance []*Commit `protobuf:"bytes,2,rep,name=provenance,proto3" json:"provenance,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartCommitRequest) Descriptor ¶
func (*StartCommitRequest) Descriptor() ([]byte, []int)
func (*StartCommitRequest) GetBranch ¶ added in v1.3.19
func (m *StartCommitRequest) GetBranch() string
func (*StartCommitRequest) GetDescription ¶ added in v1.6.6
func (m *StartCommitRequest) GetDescription() string
func (*StartCommitRequest) GetParent ¶ added in v1.2.0
func (m *StartCommitRequest) GetParent() *Commit
func (*StartCommitRequest) GetProvenance ¶ added in v1.1.0
func (m *StartCommitRequest) GetProvenance() []*Commit
func (*StartCommitRequest) Marshal ¶ added in v1.5.0
func (m *StartCommitRequest) Marshal() (dAtA []byte, err error)
func (*StartCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *StartCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*StartCommitRequest) ProtoMessage ¶
func (*StartCommitRequest) ProtoMessage()
func (*StartCommitRequest) Reset ¶
func (m *StartCommitRequest) Reset()
func (*StartCommitRequest) Size ¶ added in v1.5.0
func (m *StartCommitRequest) Size() (n int)
func (*StartCommitRequest) String ¶
func (m *StartCommitRequest) String() string
func (*StartCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *StartCommitRequest) Unmarshal(dAtA []byte) error
func (*StartCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *StartCommitRequest) XXX_DiscardUnknown()
func (*StartCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *StartCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *StartCommitRequest) XXX_Merge(src proto.Message)
func (*StartCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *StartCommitRequest) XXX_Size() int
func (*StartCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *StartCommitRequest) XXX_Unmarshal(b []byte) error
type SubscribeCommitRequest ¶ added in v1.3.19
type SubscribeCommitRequest struct { Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` Branch string `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"` // only commits created since this commit are returned From *Commit `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` // Don't return commits until they're in (at least) the desired state. State CommitState `protobuf:"varint,4,opt,name=state,proto3,enum=pfs.CommitState" json:"state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SubscribeCommitRequest) Descriptor ¶ added in v1.3.19
func (*SubscribeCommitRequest) Descriptor() ([]byte, []int)
func (*SubscribeCommitRequest) GetBranch ¶ added in v1.3.19
func (m *SubscribeCommitRequest) GetBranch() string
func (*SubscribeCommitRequest) GetFrom ¶ added in v1.3.19
func (m *SubscribeCommitRequest) GetFrom() *Commit
func (*SubscribeCommitRequest) GetRepo ¶ added in v1.3.19
func (m *SubscribeCommitRequest) GetRepo() *Repo
func (*SubscribeCommitRequest) GetState ¶ added in v1.7.1
func (m *SubscribeCommitRequest) GetState() CommitState
func (*SubscribeCommitRequest) Marshal ¶ added in v1.5.0
func (m *SubscribeCommitRequest) Marshal() (dAtA []byte, err error)
func (*SubscribeCommitRequest) MarshalTo ¶ added in v1.5.0
func (m *SubscribeCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*SubscribeCommitRequest) ProtoMessage ¶ added in v1.3.19
func (*SubscribeCommitRequest) ProtoMessage()
func (*SubscribeCommitRequest) Reset ¶ added in v1.3.19
func (m *SubscribeCommitRequest) Reset()
func (*SubscribeCommitRequest) Size ¶ added in v1.5.0
func (m *SubscribeCommitRequest) Size() (n int)
func (*SubscribeCommitRequest) String ¶ added in v1.3.19
func (m *SubscribeCommitRequest) String() string
func (*SubscribeCommitRequest) Unmarshal ¶ added in v1.5.0
func (m *SubscribeCommitRequest) Unmarshal(dAtA []byte) error
func (*SubscribeCommitRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *SubscribeCommitRequest) XXX_DiscardUnknown()
func (*SubscribeCommitRequest) XXX_Marshal ¶ added in v1.7.12
func (m *SubscribeCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubscribeCommitRequest) XXX_Merge ¶ added in v1.7.12
func (m *SubscribeCommitRequest) XXX_Merge(src proto.Message)
func (*SubscribeCommitRequest) XXX_Size ¶ added in v1.7.12
func (m *SubscribeCommitRequest) XXX_Size() int
func (*SubscribeCommitRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *SubscribeCommitRequest) XXX_Unmarshal(b []byte) error
type Tag ¶ added in v1.3.9
type Tag struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Tag) Descriptor ¶ added in v1.3.9
func (*Tag) ProtoMessage ¶ added in v1.3.9
func (*Tag) ProtoMessage()
func (*Tag) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Tag) XXX_DiscardUnknown()
func (*Tag) XXX_Marshal ¶ added in v1.7.12
func (*Tag) XXX_Unmarshal ¶ added in v1.7.12
type TagObjectRequest ¶ added in v1.3.9
type TagObjectRequest struct { Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` Tags []*Tag `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TagObjectRequest) Descriptor ¶ added in v1.3.9
func (*TagObjectRequest) Descriptor() ([]byte, []int)
func (*TagObjectRequest) GetObject ¶ added in v1.3.9
func (m *TagObjectRequest) GetObject() *Object
func (*TagObjectRequest) GetTags ¶ added in v1.3.9
func (m *TagObjectRequest) GetTags() []*Tag
func (*TagObjectRequest) Marshal ¶ added in v1.5.0
func (m *TagObjectRequest) Marshal() (dAtA []byte, err error)
func (*TagObjectRequest) MarshalTo ¶ added in v1.5.0
func (m *TagObjectRequest) MarshalTo(dAtA []byte) (int, error)
func (*TagObjectRequest) ProtoMessage ¶ added in v1.3.9
func (*TagObjectRequest) ProtoMessage()
func (*TagObjectRequest) Reset ¶ added in v1.3.9
func (m *TagObjectRequest) Reset()
func (*TagObjectRequest) Size ¶ added in v1.5.0
func (m *TagObjectRequest) Size() (n int)
func (*TagObjectRequest) String ¶ added in v1.3.9
func (m *TagObjectRequest) String() string
func (*TagObjectRequest) Unmarshal ¶ added in v1.5.0
func (m *TagObjectRequest) Unmarshal(dAtA []byte) error
func (*TagObjectRequest) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *TagObjectRequest) XXX_DiscardUnknown()
func (*TagObjectRequest) XXX_Marshal ¶ added in v1.7.12
func (m *TagObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TagObjectRequest) XXX_Merge ¶ added in v1.7.12
func (m *TagObjectRequest) XXX_Merge(src proto.Message)
func (*TagObjectRequest) XXX_Size ¶ added in v1.7.12
func (m *TagObjectRequest) XXX_Size() int
func (*TagObjectRequest) XXX_Unmarshal ¶ added in v1.7.12
func (m *TagObjectRequest) XXX_Unmarshal(b []byte) error