pachyderm: github.com/pachyderm/pachyderm/src/client/pfs Index | Files

package pfs

import "github.com/pachyderm/pachyderm/src/client/pfs"

Index

Package Files

pfs.go pfs.pb.go

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",
    4:  "CSV",
}
var Delimiter_value = map[string]int32{
    "NONE": 0,
    "JSON": 1,
    "LINE": 2,
    "SQL":  3,
    "CSV":  4,
}
var FileType_name = map[int32]string{
    0:  "RESERVED",
    1:  "FILE",
    2:  "DIR",
}
var FileType_value = map[string]int32{
    "RESERVED": 0,
    "FILE":     1,
    "DIR":      2,
}
var OriginKind_name = map[int32]string{
    0:  "USER",
    1:  "AUTO",
}
var OriginKind_value = map[string]int32{
    "USER": 0,
    "AUTO": 1,
}

func DecodeHash Uses

func DecodeHash(hash string) ([]byte, error)

DecodeHash decodes a hash into bytes.

func EncodeHash Uses

func EncodeHash(bytes []byte) string

EncodeHash encodes a hash into a readable format.

func NewHash Uses

func NewHash() hash.Hash

NewHash returns a hash that PFS uses internally to compute checksums.

func RegisterAPIServer Uses

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

func RegisterObjectAPIServer Uses

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

type APIClient Uses

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)
    // WalkFile walks over all the files under a directory, including children of children.
    WalkFile(ctx context.Context, in *WalkFileRequest, opts ...grpc.CallOption) (API_WalkFileClient, 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)
    // Fsck does a file system consistency check for pfs
    Fsck(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 Uses

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer Uses

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
    // WalkFile walks over all the files under a directory, including children of children.
    WalkFile(*WalkFileRequest, API_WalkFileServer) 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)
    // Fsck does a file system consistency check for pfs
    Fsck(context.Context, *types.Empty) (*types.Empty, error)
}

APIServer is the server API for API service.

type API_FlushCommitClient Uses

type API_FlushCommitClient interface {
    Recv() (*CommitInfo, error)
    grpc.ClientStream
}

type API_FlushCommitServer Uses

type API_FlushCommitServer interface {
    Send(*CommitInfo) error
    grpc.ServerStream
}

type API_GetFileClient Uses

type API_GetFileClient interface {
    Recv() (*types.BytesValue, error)
    grpc.ClientStream
}

type API_GetFileServer Uses

type API_GetFileServer interface {
    Send(*types.BytesValue) error
    grpc.ServerStream
}

type API_GlobFileStreamClient Uses

type API_GlobFileStreamClient interface {
    Recv() (*FileInfo, error)
    grpc.ClientStream
}

type API_GlobFileStreamServer Uses

type API_GlobFileStreamServer interface {
    Send(*FileInfo) error
    grpc.ServerStream
}

type API_ListCommitStreamClient Uses

type API_ListCommitStreamClient interface {
    Recv() (*CommitInfo, error)
    grpc.ClientStream
}

type API_ListCommitStreamServer Uses

type API_ListCommitStreamServer interface {
    Send(*CommitInfo) error
    grpc.ServerStream
}

type API_ListFileStreamClient Uses

type API_ListFileStreamClient interface {
    Recv() (*FileInfo, error)
    grpc.ClientStream
}

type API_ListFileStreamServer Uses

type API_ListFileStreamServer interface {
    Send(*FileInfo) error
    grpc.ServerStream
}

type API_PutFileClient Uses

type API_PutFileClient interface {
    Send(*PutFileRequest) error
    CloseAndRecv() (*types.Empty, error)
    grpc.ClientStream
}

type API_PutFileServer Uses

type API_PutFileServer interface {
    SendAndClose(*types.Empty) error
    Recv() (*PutFileRequest, error)
    grpc.ServerStream
}

type API_SubscribeCommitClient Uses

type API_SubscribeCommitClient interface {
    Recv() (*CommitInfo, error)
    grpc.ClientStream
}

type API_SubscribeCommitServer Uses

type API_SubscribeCommitServer interface {
    Send(*CommitInfo) error
    grpc.ServerStream
}

type API_WalkFileClient Uses

type API_WalkFileClient interface {
    Recv() (*FileInfo, error)
    grpc.ClientStream
}

type API_WalkFileServer Uses

type API_WalkFileServer interface {
    Send(*FileInfo) error
    grpc.ServerStream
}

type Block Uses

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 GetBlock Uses

func GetBlock(hash hash.Hash) *Block

GetBlock encodes a hash into a readable format in the form of a Block.

func (*Block) Descriptor Uses

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

func (*Block) GetHash Uses

func (m *Block) GetHash() string

func (*Block) Marshal Uses

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

func (*Block) MarshalTo Uses

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

func (*Block) ProtoMessage Uses

func (*Block) ProtoMessage()

func (*Block) Reset Uses

func (m *Block) Reset()

func (*Block) Size Uses

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

func (*Block) String Uses

func (m *Block) String() string

func (*Block) Unmarshal Uses

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

func (*Block) XXX_DiscardUnknown Uses

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal Uses

func (m *Block) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Block) XXX_Merge Uses

func (m *Block) XXX_Merge(src proto.Message)

func (*Block) XXX_Size Uses

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal Uses

func (m *Block) XXX_Unmarshal(b []byte) error

type BlockRef Uses

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 Uses

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

func (*BlockRef) GetBlock Uses

func (m *BlockRef) GetBlock() *Block

func (*BlockRef) GetRange Uses

func (m *BlockRef) GetRange() *ByteRange

func (*BlockRef) Marshal Uses

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

func (*BlockRef) MarshalTo Uses

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

func (*BlockRef) ProtoMessage Uses

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset Uses

func (m *BlockRef) Reset()

func (*BlockRef) Size Uses

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

func (*BlockRef) String Uses

func (m *BlockRef) String() string

func (*BlockRef) Unmarshal Uses

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

func (*BlockRef) XXX_DiscardUnknown Uses

func (m *BlockRef) XXX_DiscardUnknown()

func (*BlockRef) XXX_Marshal Uses

func (m *BlockRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockRef) XXX_Merge Uses

func (m *BlockRef) XXX_Merge(src proto.Message)

func (*BlockRef) XXX_Size Uses

func (m *BlockRef) XXX_Size() int

func (*BlockRef) XXX_Unmarshal Uses

func (m *BlockRef) XXX_Unmarshal(b []byte) error

type Branch Uses

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 Uses

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

func (*Branch) GetName Uses

func (m *Branch) GetName() string

func (*Branch) GetRepo Uses

func (m *Branch) GetRepo() *Repo

func (*Branch) Marshal Uses

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

func (*Branch) MarshalTo Uses

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

func (*Branch) ProtoMessage Uses

func (*Branch) ProtoMessage()

func (*Branch) Reset Uses

func (m *Branch) Reset()

func (*Branch) Size Uses

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

func (*Branch) String Uses

func (m *Branch) String() string

func (*Branch) Unmarshal Uses

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

func (*Branch) XXX_DiscardUnknown Uses

func (m *Branch) XXX_DiscardUnknown()

func (*Branch) XXX_Marshal Uses

func (m *Branch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Branch) XXX_Merge Uses

func (m *Branch) XXX_Merge(src proto.Message)

func (*Branch) XXX_Size Uses

func (m *Branch) XXX_Size() int

func (*Branch) XXX_Unmarshal Uses

func (m *Branch) XXX_Unmarshal(b []byte) error

type BranchInfo Uses

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 Uses

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

func (*BranchInfo) GetBranch Uses

func (m *BranchInfo) GetBranch() *Branch

func (*BranchInfo) GetDirectProvenance Uses

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

func (*BranchInfo) GetHead Uses

func (m *BranchInfo) GetHead() *Commit

func (*BranchInfo) GetName Uses

func (m *BranchInfo) GetName() string

func (*BranchInfo) GetProvenance Uses

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

func (*BranchInfo) GetSubvenance Uses

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

func (*BranchInfo) Marshal Uses

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

func (*BranchInfo) MarshalTo Uses

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

func (*BranchInfo) ProtoMessage Uses

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) Reset Uses

func (m *BranchInfo) Reset()

func (*BranchInfo) Size Uses

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

func (*BranchInfo) String Uses

func (m *BranchInfo) String() string

func (*BranchInfo) Unmarshal Uses

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

func (*BranchInfo) XXX_DiscardUnknown Uses

func (m *BranchInfo) XXX_DiscardUnknown()

func (*BranchInfo) XXX_Marshal Uses

func (m *BranchInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchInfo) XXX_Merge Uses

func (m *BranchInfo) XXX_Merge(src proto.Message)

func (*BranchInfo) XXX_Size Uses

func (m *BranchInfo) XXX_Size() int

func (*BranchInfo) XXX_Unmarshal Uses

func (m *BranchInfo) XXX_Unmarshal(b []byte) error

type BranchInfos Uses

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 Uses

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

func (*BranchInfos) GetBranchInfo Uses

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

func (*BranchInfos) Marshal Uses

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

func (*BranchInfos) MarshalTo Uses

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

func (*BranchInfos) ProtoMessage Uses

func (*BranchInfos) ProtoMessage()

func (*BranchInfos) Reset Uses

func (m *BranchInfos) Reset()

func (*BranchInfos) Size Uses

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

func (*BranchInfos) String Uses

func (m *BranchInfos) String() string

func (*BranchInfos) Unmarshal Uses

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

func (*BranchInfos) XXX_DiscardUnknown Uses

func (m *BranchInfos) XXX_DiscardUnknown()

func (*BranchInfos) XXX_Marshal Uses

func (m *BranchInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchInfos) XXX_Merge Uses

func (m *BranchInfos) XXX_Merge(src proto.Message)

func (*BranchInfos) XXX_Size Uses

func (m *BranchInfos) XXX_Size() int

func (*BranchInfos) XXX_Unmarshal Uses

func (m *BranchInfos) XXX_Unmarshal(b []byte) error

type BuildCommitRequest Uses

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 []*CommitProvenance `protobuf:"bytes,6,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 Uses

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

func (*BuildCommitRequest) GetBranch Uses

func (m *BuildCommitRequest) GetBranch() string

func (*BuildCommitRequest) GetID Uses

func (m *BuildCommitRequest) GetID() string

func (*BuildCommitRequest) GetParent Uses

func (m *BuildCommitRequest) GetParent() *Commit

func (*BuildCommitRequest) GetProvenance Uses

func (m *BuildCommitRequest) GetProvenance() []*CommitProvenance

func (*BuildCommitRequest) GetTree Uses

func (m *BuildCommitRequest) GetTree() *Object

func (*BuildCommitRequest) Marshal Uses

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

func (*BuildCommitRequest) MarshalTo Uses

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

func (*BuildCommitRequest) ProtoMessage Uses

func (*BuildCommitRequest) ProtoMessage()

func (*BuildCommitRequest) Reset Uses

func (m *BuildCommitRequest) Reset()

func (*BuildCommitRequest) Size Uses

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

func (*BuildCommitRequest) String Uses

func (m *BuildCommitRequest) String() string

func (*BuildCommitRequest) Unmarshal Uses

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

func (*BuildCommitRequest) XXX_DiscardUnknown Uses

func (m *BuildCommitRequest) XXX_DiscardUnknown()

func (*BuildCommitRequest) XXX_Marshal Uses

func (m *BuildCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BuildCommitRequest) XXX_Merge Uses

func (m *BuildCommitRequest) XXX_Merge(src proto.Message)

func (*BuildCommitRequest) XXX_Size Uses

func (m *BuildCommitRequest) XXX_Size() int

func (*BuildCommitRequest) XXX_Unmarshal Uses

func (m *BuildCommitRequest) XXX_Unmarshal(b []byte) error

type ByteRange Uses

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 Uses

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

func (*ByteRange) GetLower Uses

func (m *ByteRange) GetLower() uint64

func (*ByteRange) GetUpper Uses

func (m *ByteRange) GetUpper() uint64

func (*ByteRange) Marshal Uses

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

func (*ByteRange) MarshalTo Uses

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

func (*ByteRange) ProtoMessage Uses

func (*ByteRange) ProtoMessage()

func (*ByteRange) Reset Uses

func (m *ByteRange) Reset()

func (*ByteRange) Size Uses

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

func (*ByteRange) String Uses

func (m *ByteRange) String() string

func (*ByteRange) Unmarshal Uses

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

func (*ByteRange) XXX_DiscardUnknown Uses

func (m *ByteRange) XXX_DiscardUnknown()

func (*ByteRange) XXX_Marshal Uses

func (m *ByteRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ByteRange) XXX_Merge Uses

func (m *ByteRange) XXX_Merge(src proto.Message)

func (*ByteRange) XXX_Size Uses

func (m *ByteRange) XXX_Size() int

func (*ByteRange) XXX_Unmarshal Uses

func (m *ByteRange) XXX_Unmarshal(b []byte) error

type CheckObjectRequest Uses

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 Uses

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

func (*CheckObjectRequest) GetObject Uses

func (m *CheckObjectRequest) GetObject() *Object

func (*CheckObjectRequest) Marshal Uses

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

func (*CheckObjectRequest) MarshalTo Uses

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

func (*CheckObjectRequest) ProtoMessage Uses

func (*CheckObjectRequest) ProtoMessage()

func (*CheckObjectRequest) Reset Uses

func (m *CheckObjectRequest) Reset()

func (*CheckObjectRequest) Size Uses

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

func (*CheckObjectRequest) String Uses

func (m *CheckObjectRequest) String() string

func (*CheckObjectRequest) Unmarshal Uses

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

func (*CheckObjectRequest) XXX_DiscardUnknown Uses

func (m *CheckObjectRequest) XXX_DiscardUnknown()

func (*CheckObjectRequest) XXX_Marshal Uses

func (m *CheckObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckObjectRequest) XXX_Merge Uses

func (m *CheckObjectRequest) XXX_Merge(src proto.Message)

func (*CheckObjectRequest) XXX_Size Uses

func (m *CheckObjectRequest) XXX_Size() int

func (*CheckObjectRequest) XXX_Unmarshal Uses

func (m *CheckObjectRequest) XXX_Unmarshal(b []byte) error

type CheckObjectResponse Uses

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 Uses

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

func (*CheckObjectResponse) GetExists Uses

func (m *CheckObjectResponse) GetExists() bool

func (*CheckObjectResponse) Marshal Uses

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

func (*CheckObjectResponse) MarshalTo Uses

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

func (*CheckObjectResponse) ProtoMessage Uses

func (*CheckObjectResponse) ProtoMessage()

func (*CheckObjectResponse) Reset Uses

func (m *CheckObjectResponse) Reset()

func (*CheckObjectResponse) Size Uses

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

func (*CheckObjectResponse) String Uses

func (m *CheckObjectResponse) String() string

func (*CheckObjectResponse) Unmarshal Uses

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

func (*CheckObjectResponse) XXX_DiscardUnknown Uses

func (m *CheckObjectResponse) XXX_DiscardUnknown()

func (*CheckObjectResponse) XXX_Marshal Uses

func (m *CheckObjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckObjectResponse) XXX_Merge Uses

func (m *CheckObjectResponse) XXX_Merge(src proto.Message)

func (*CheckObjectResponse) XXX_Size Uses

func (m *CheckObjectResponse) XXX_Size() int

func (*CheckObjectResponse) XXX_Unmarshal Uses

func (m *CheckObjectResponse) XXX_Unmarshal(b []byte) error

type Commit Uses

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 Uses

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

func (*Commit) FullID Uses

func (c *Commit) FullID() string

FullID prints repoName/CommitID

func (*Commit) GetID Uses

func (m *Commit) GetID() string

func (*Commit) GetRepo Uses

func (m *Commit) GetRepo() *Repo

func (*Commit) Marshal Uses

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

func (*Commit) MarshalTo Uses

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

func (*Commit) ProtoMessage Uses

func (*Commit) ProtoMessage()

func (*Commit) Reset Uses

func (m *Commit) Reset()

func (*Commit) Size Uses

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

func (*Commit) String Uses

func (m *Commit) String() string

func (*Commit) Unmarshal Uses

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

func (*Commit) XXX_DiscardUnknown Uses

func (m *Commit) XXX_DiscardUnknown()

func (*Commit) XXX_Marshal Uses

func (m *Commit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Commit) XXX_Merge Uses

func (m *Commit) XXX_Merge(src proto.Message)

func (*Commit) XXX_Size Uses

func (m *Commit) XXX_Size() int

func (*Commit) XXX_Unmarshal Uses

func (m *Commit) XXX_Unmarshal(b []byte) error

type CommitInfo Uses

type CommitInfo struct {
    Commit *Commit       `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
    Branch *Branch       `protobuf:"bytes,15,opt,name=branch,proto3" json:"branch,omitempty"`
    Origin *CommitOrigin `protobuf:"bytes,17,opt,name=origin,proto3" json:"origin,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"`
    // the commits and their original branches on which this commit is provenant
    Provenance []*CommitProvenance `protobuf:"bytes,16,rep,name=provenance,proto3" json:"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"`
    Trees                []*Object `protobuf:"bytes,13,rep,name=trees,proto3" json:"trees,omitempty"`
    Datums               *Object   `protobuf:"bytes,14,opt,name=datums,proto3" json:"datums,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 Uses

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

func (*CommitInfo) GetBranch Uses

func (m *CommitInfo) GetBranch() *Branch

func (*CommitInfo) GetChildCommits Uses

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

func (*CommitInfo) GetCommit Uses

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetDatums Uses

func (m *CommitInfo) GetDatums() *Object

func (*CommitInfo) GetDescription Uses

func (m *CommitInfo) GetDescription() string

func (*CommitInfo) GetFinished Uses

func (m *CommitInfo) GetFinished() *types.Timestamp

func (*CommitInfo) GetOrigin Uses

func (m *CommitInfo) GetOrigin() *CommitOrigin

func (*CommitInfo) GetParentCommit Uses

func (m *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetProvenance Uses

func (m *CommitInfo) GetProvenance() []*CommitProvenance

func (*CommitInfo) GetReadyProvenance Uses

func (m *CommitInfo) GetReadyProvenance() int64

func (*CommitInfo) GetSizeBytes Uses

func (m *CommitInfo) GetSizeBytes() uint64

func (*CommitInfo) GetStarted Uses

func (m *CommitInfo) GetStarted() *types.Timestamp

func (*CommitInfo) GetSubvenance Uses

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

func (*CommitInfo) GetTree Uses

func (m *CommitInfo) GetTree() *Object

func (*CommitInfo) GetTrees Uses

func (m *CommitInfo) GetTrees() []*Object

func (*CommitInfo) Marshal Uses

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

func (*CommitInfo) MarshalTo Uses

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

func (*CommitInfo) ProtoMessage Uses

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset Uses

func (m *CommitInfo) Reset()

func (*CommitInfo) Size Uses

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

func (*CommitInfo) String Uses

func (m *CommitInfo) String() string

func (*CommitInfo) Unmarshal Uses

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

func (*CommitInfo) XXX_DiscardUnknown Uses

func (m *CommitInfo) XXX_DiscardUnknown()

func (*CommitInfo) XXX_Marshal Uses

func (m *CommitInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitInfo) XXX_Merge Uses

func (m *CommitInfo) XXX_Merge(src proto.Message)

func (*CommitInfo) XXX_Size Uses

func (m *CommitInfo) XXX_Size() int

func (*CommitInfo) XXX_Unmarshal Uses

func (m *CommitInfo) XXX_Unmarshal(b []byte) error

type CommitInfos Uses

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 Uses

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

func (*CommitInfos) GetCommitInfo Uses

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

func (*CommitInfos) Marshal Uses

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

func (*CommitInfos) MarshalTo Uses

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

func (*CommitInfos) ProtoMessage Uses

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset Uses

func (m *CommitInfos) Reset()

func (*CommitInfos) Size Uses

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

func (*CommitInfos) String Uses

func (m *CommitInfos) String() string

func (*CommitInfos) Unmarshal Uses

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

func (*CommitInfos) XXX_DiscardUnknown Uses

func (m *CommitInfos) XXX_DiscardUnknown()

func (*CommitInfos) XXX_Marshal Uses

func (m *CommitInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitInfos) XXX_Merge Uses

func (m *CommitInfos) XXX_Merge(src proto.Message)

func (*CommitInfos) XXX_Size Uses

func (m *CommitInfos) XXX_Size() int

func (*CommitInfos) XXX_Unmarshal Uses

func (m *CommitInfos) XXX_Unmarshal(b []byte) error

type CommitOrigin Uses

type CommitOrigin struct {
    Kind                 OriginKind `protobuf:"varint,1,opt,name=kind,proto3,enum=pfs.OriginKind" json:"kind,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*CommitOrigin) Descriptor Uses

func (*CommitOrigin) Descriptor() ([]byte, []int)

func (*CommitOrigin) GetKind Uses

func (m *CommitOrigin) GetKind() OriginKind

func (*CommitOrigin) Marshal Uses

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

func (*CommitOrigin) MarshalTo Uses

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

func (*CommitOrigin) ProtoMessage Uses

func (*CommitOrigin) ProtoMessage()

func (*CommitOrigin) Reset Uses

func (m *CommitOrigin) Reset()

func (*CommitOrigin) Size Uses

func (m *CommitOrigin) Size() (n int)

func (*CommitOrigin) String Uses

func (m *CommitOrigin) String() string

func (*CommitOrigin) Unmarshal Uses

func (m *CommitOrigin) Unmarshal(dAtA []byte) error

func (*CommitOrigin) XXX_DiscardUnknown Uses

func (m *CommitOrigin) XXX_DiscardUnknown()

func (*CommitOrigin) XXX_Marshal Uses

func (m *CommitOrigin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitOrigin) XXX_Merge Uses

func (m *CommitOrigin) XXX_Merge(src proto.Message)

func (*CommitOrigin) XXX_Size Uses

func (m *CommitOrigin) XXX_Size() int

func (*CommitOrigin) XXX_Unmarshal Uses

func (m *CommitOrigin) XXX_Unmarshal(b []byte) error

type CommitProvenance Uses

type CommitProvenance struct {
    Commit               *Commit  `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
    Branch               *Branch  `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CommitProvenance keeps track of where (i.e. which branch) a certain commit originated from. A commit's provenance consists of the commits of the commits which are in its causal history.

func (*CommitProvenance) Descriptor Uses

func (*CommitProvenance) Descriptor() ([]byte, []int)

func (*CommitProvenance) GetBranch Uses

func (m *CommitProvenance) GetBranch() *Branch

func (*CommitProvenance) GetCommit Uses

func (m *CommitProvenance) GetCommit() *Commit

func (*CommitProvenance) Marshal Uses

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

func (*CommitProvenance) MarshalTo Uses

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

func (*CommitProvenance) ProtoMessage Uses

func (*CommitProvenance) ProtoMessage()

func (*CommitProvenance) Reset Uses

func (m *CommitProvenance) Reset()

func (*CommitProvenance) Size Uses

func (m *CommitProvenance) Size() (n int)

func (*CommitProvenance) String Uses

func (m *CommitProvenance) String() string

func (*CommitProvenance) Unmarshal Uses

func (m *CommitProvenance) Unmarshal(dAtA []byte) error

func (*CommitProvenance) XXX_DiscardUnknown Uses

func (m *CommitProvenance) XXX_DiscardUnknown()

func (*CommitProvenance) XXX_Marshal Uses

func (m *CommitProvenance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitProvenance) XXX_Merge Uses

func (m *CommitProvenance) XXX_Merge(src proto.Message)

func (*CommitProvenance) XXX_Size Uses

func (m *CommitProvenance) XXX_Size() int

func (*CommitProvenance) XXX_Unmarshal Uses

func (m *CommitProvenance) XXX_Unmarshal(b []byte) error

type CommitRange Uses

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 Uses

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

func (*CommitRange) GetLower Uses

func (m *CommitRange) GetLower() *Commit

func (*CommitRange) GetUpper Uses

func (m *CommitRange) GetUpper() *Commit

func (*CommitRange) Marshal Uses

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

func (*CommitRange) MarshalTo Uses

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

func (*CommitRange) ProtoMessage Uses

func (*CommitRange) ProtoMessage()

func (*CommitRange) Reset Uses

func (m *CommitRange) Reset()

func (*CommitRange) Size Uses

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

func (*CommitRange) String Uses

func (m *CommitRange) String() string

func (*CommitRange) Unmarshal Uses

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

func (*CommitRange) XXX_DiscardUnknown Uses

func (m *CommitRange) XXX_DiscardUnknown()

func (*CommitRange) XXX_Marshal Uses

func (m *CommitRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitRange) XXX_Merge Uses

func (m *CommitRange) XXX_Merge(src proto.Message)

func (*CommitRange) XXX_Size Uses

func (m *CommitRange) XXX_Size() int

func (*CommitRange) XXX_Unmarshal Uses

func (m *CommitRange) XXX_Unmarshal(b []byte) error

type CommitState Uses

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 Uses

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

func (CommitState) String Uses

func (x CommitState) String() string

type CopyFileRequest Uses

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 Uses

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

func (*CopyFileRequest) GetDst Uses

func (m *CopyFileRequest) GetDst() *File

func (*CopyFileRequest) GetOverwrite Uses

func (m *CopyFileRequest) GetOverwrite() bool

func (*CopyFileRequest) GetSrc Uses

func (m *CopyFileRequest) GetSrc() *File

func (*CopyFileRequest) Marshal Uses

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

func (*CopyFileRequest) MarshalTo Uses

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

func (*CopyFileRequest) ProtoMessage Uses

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset Uses

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) Size Uses

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

func (*CopyFileRequest) String Uses

func (m *CopyFileRequest) String() string

func (*CopyFileRequest) Unmarshal Uses

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

func (*CopyFileRequest) XXX_DiscardUnknown Uses

func (m *CopyFileRequest) XXX_DiscardUnknown()

func (*CopyFileRequest) XXX_Marshal Uses

func (m *CopyFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyFileRequest) XXX_Merge Uses

func (m *CopyFileRequest) XXX_Merge(src proto.Message)

func (*CopyFileRequest) XXX_Size Uses

func (m *CopyFileRequest) XXX_Size() int

func (*CopyFileRequest) XXX_Unmarshal Uses

func (m *CopyFileRequest) XXX_Unmarshal(b []byte) error

type CreateBranchRequest Uses

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 Uses

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

func (*CreateBranchRequest) GetBranch Uses

func (m *CreateBranchRequest) GetBranch() *Branch

func (*CreateBranchRequest) GetHead Uses

func (m *CreateBranchRequest) GetHead() *Commit

func (*CreateBranchRequest) GetProvenance Uses

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

func (*CreateBranchRequest) GetSBranch Uses

func (m *CreateBranchRequest) GetSBranch() string

func (*CreateBranchRequest) Marshal Uses

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

func (*CreateBranchRequest) MarshalTo Uses

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

func (*CreateBranchRequest) ProtoMessage Uses

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) Reset Uses

func (m *CreateBranchRequest) Reset()

func (*CreateBranchRequest) Size Uses

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

func (*CreateBranchRequest) String Uses

func (m *CreateBranchRequest) String() string

func (*CreateBranchRequest) Unmarshal Uses

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

func (*CreateBranchRequest) XXX_DiscardUnknown Uses

func (m *CreateBranchRequest) XXX_DiscardUnknown()

func (*CreateBranchRequest) XXX_Marshal Uses

func (m *CreateBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateBranchRequest) XXX_Merge Uses

func (m *CreateBranchRequest) XXX_Merge(src proto.Message)

func (*CreateBranchRequest) XXX_Size Uses

func (m *CreateBranchRequest) XXX_Size() int

func (*CreateBranchRequest) XXX_Unmarshal Uses

func (m *CreateBranchRequest) XXX_Unmarshal(b []byte) error

type CreateRepoRequest Uses

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 Uses

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

func (*CreateRepoRequest) GetDescription Uses

func (m *CreateRepoRequest) GetDescription() string

func (*CreateRepoRequest) GetRepo Uses

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) GetUpdate Uses

func (m *CreateRepoRequest) GetUpdate() bool

func (*CreateRepoRequest) Marshal Uses

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

func (*CreateRepoRequest) MarshalTo Uses

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

func (*CreateRepoRequest) ProtoMessage Uses

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset Uses

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) Size Uses

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

func (*CreateRepoRequest) String Uses

func (m *CreateRepoRequest) String() string

func (*CreateRepoRequest) Unmarshal Uses

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

func (*CreateRepoRequest) XXX_DiscardUnknown Uses

func (m *CreateRepoRequest) XXX_DiscardUnknown()

func (*CreateRepoRequest) XXX_Marshal Uses

func (m *CreateRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRepoRequest) XXX_Merge Uses

func (m *CreateRepoRequest) XXX_Merge(src proto.Message)

func (*CreateRepoRequest) XXX_Size Uses

func (m *CreateRepoRequest) XXX_Size() int

func (*CreateRepoRequest) XXX_Unmarshal Uses

func (m *CreateRepoRequest) XXX_Unmarshal(b []byte) error

type DeleteBranchRequest Uses

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 Uses

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

func (*DeleteBranchRequest) GetBranch Uses

func (m *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) GetForce Uses

func (m *DeleteBranchRequest) GetForce() bool

func (*DeleteBranchRequest) Marshal Uses

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

func (*DeleteBranchRequest) MarshalTo Uses

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

func (*DeleteBranchRequest) ProtoMessage Uses

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset Uses

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) Size Uses

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

func (*DeleteBranchRequest) String Uses

func (m *DeleteBranchRequest) String() string

func (*DeleteBranchRequest) Unmarshal Uses

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

func (*DeleteBranchRequest) XXX_DiscardUnknown Uses

func (m *DeleteBranchRequest) XXX_DiscardUnknown()

func (*DeleteBranchRequest) XXX_Marshal Uses

func (m *DeleteBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteBranchRequest) XXX_Merge Uses

func (m *DeleteBranchRequest) XXX_Merge(src proto.Message)

func (*DeleteBranchRequest) XXX_Size Uses

func (m *DeleteBranchRequest) XXX_Size() int

func (*DeleteBranchRequest) XXX_Unmarshal Uses

func (m *DeleteBranchRequest) XXX_Unmarshal(b []byte) error

type DeleteCommitRequest Uses

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 Uses

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

func (*DeleteCommitRequest) GetCommit Uses

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) Marshal Uses

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

func (*DeleteCommitRequest) MarshalTo Uses

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

func (*DeleteCommitRequest) ProtoMessage Uses

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset Uses

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) Size Uses

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

func (*DeleteCommitRequest) String Uses

func (m *DeleteCommitRequest) String() string

func (*DeleteCommitRequest) Unmarshal Uses

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

func (*DeleteCommitRequest) XXX_DiscardUnknown Uses

func (m *DeleteCommitRequest) XXX_DiscardUnknown()

func (*DeleteCommitRequest) XXX_Marshal Uses

func (m *DeleteCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteCommitRequest) XXX_Merge Uses

func (m *DeleteCommitRequest) XXX_Merge(src proto.Message)

func (*DeleteCommitRequest) XXX_Size Uses

func (m *DeleteCommitRequest) XXX_Size() int

func (*DeleteCommitRequest) XXX_Unmarshal Uses

func (m *DeleteCommitRequest) XXX_Unmarshal(b []byte) error

type DeleteFileRequest Uses

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 Uses

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

func (*DeleteFileRequest) GetFile Uses

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) Marshal Uses

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

func (*DeleteFileRequest) MarshalTo Uses

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

func (*DeleteFileRequest) ProtoMessage Uses

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset Uses

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) Size Uses

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

func (*DeleteFileRequest) String Uses

func (m *DeleteFileRequest) String() string

func (*DeleteFileRequest) Unmarshal Uses

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

func (*DeleteFileRequest) XXX_DiscardUnknown Uses

func (m *DeleteFileRequest) XXX_DiscardUnknown()

func (*DeleteFileRequest) XXX_Marshal Uses

func (m *DeleteFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteFileRequest) XXX_Merge Uses

func (m *DeleteFileRequest) XXX_Merge(src proto.Message)

func (*DeleteFileRequest) XXX_Size Uses

func (m *DeleteFileRequest) XXX_Size() int

func (*DeleteFileRequest) XXX_Unmarshal Uses

func (m *DeleteFileRequest) XXX_Unmarshal(b []byte) error

type DeleteObjectsRequest Uses

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 Uses

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

func (*DeleteObjectsRequest) GetObjects Uses

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

func (*DeleteObjectsRequest) Marshal Uses

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

func (*DeleteObjectsRequest) MarshalTo Uses

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

func (*DeleteObjectsRequest) ProtoMessage Uses

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) Reset Uses

func (m *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) Size Uses

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

func (*DeleteObjectsRequest) String Uses

func (m *DeleteObjectsRequest) String() string

func (*DeleteObjectsRequest) Unmarshal Uses

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

func (*DeleteObjectsRequest) XXX_DiscardUnknown Uses

func (m *DeleteObjectsRequest) XXX_DiscardUnknown()

func (*DeleteObjectsRequest) XXX_Marshal Uses

func (m *DeleteObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteObjectsRequest) XXX_Merge Uses

func (m *DeleteObjectsRequest) XXX_Merge(src proto.Message)

func (*DeleteObjectsRequest) XXX_Size Uses

func (m *DeleteObjectsRequest) XXX_Size() int

func (*DeleteObjectsRequest) XXX_Unmarshal Uses

func (m *DeleteObjectsRequest) XXX_Unmarshal(b []byte) error

type DeleteObjectsResponse Uses

type DeleteObjectsResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteObjectsResponse) Descriptor Uses

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

func (*DeleteObjectsResponse) Marshal Uses

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

func (*DeleteObjectsResponse) MarshalTo Uses

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

func (*DeleteObjectsResponse) ProtoMessage Uses

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) Reset Uses

func (m *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) Size Uses

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

func (*DeleteObjectsResponse) String Uses

func (m *DeleteObjectsResponse) String() string

func (*DeleteObjectsResponse) Unmarshal Uses

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

func (*DeleteObjectsResponse) XXX_DiscardUnknown Uses

func (m *DeleteObjectsResponse) XXX_DiscardUnknown()

func (*DeleteObjectsResponse) XXX_Marshal Uses

func (m *DeleteObjectsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteObjectsResponse) XXX_Merge Uses

func (m *DeleteObjectsResponse) XXX_Merge(src proto.Message)

func (*DeleteObjectsResponse) XXX_Size Uses

func (m *DeleteObjectsResponse) XXX_Size() int

func (*DeleteObjectsResponse) XXX_Unmarshal Uses

func (m *DeleteObjectsResponse) XXX_Unmarshal(b []byte) error

type DeleteRepoRequest Uses

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 Uses

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

func (*DeleteRepoRequest) GetAll Uses

func (m *DeleteRepoRequest) GetAll() bool

func (*DeleteRepoRequest) GetForce Uses

func (m *DeleteRepoRequest) GetForce() bool

func (*DeleteRepoRequest) GetRepo Uses

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) Marshal Uses

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

func (*DeleteRepoRequest) MarshalTo Uses

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

func (*DeleteRepoRequest) ProtoMessage Uses

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset Uses

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) Size Uses

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

func (*DeleteRepoRequest) String Uses

func (m *DeleteRepoRequest) String() string

func (*DeleteRepoRequest) Unmarshal Uses

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

func (*DeleteRepoRequest) XXX_DiscardUnknown Uses

func (m *DeleteRepoRequest) XXX_DiscardUnknown()

func (*DeleteRepoRequest) XXX_Marshal Uses

func (m *DeleteRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRepoRequest) XXX_Merge Uses

func (m *DeleteRepoRequest) XXX_Merge(src proto.Message)

func (*DeleteRepoRequest) XXX_Size Uses

func (m *DeleteRepoRequest) XXX_Size() int

func (*DeleteRepoRequest) XXX_Unmarshal Uses

func (m *DeleteRepoRequest) XXX_Unmarshal(b []byte) error

type DeleteTagsRequest Uses

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 Uses

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

func (*DeleteTagsRequest) GetTags Uses

func (m *DeleteTagsRequest) GetTags() []*Tag

func (*DeleteTagsRequest) Marshal Uses

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

func (*DeleteTagsRequest) MarshalTo Uses

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

func (*DeleteTagsRequest) ProtoMessage Uses

func (*DeleteTagsRequest) ProtoMessage()

func (*DeleteTagsRequest) Reset Uses

func (m *DeleteTagsRequest) Reset()

func (*DeleteTagsRequest) Size Uses

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

func (*DeleteTagsRequest) String Uses

func (m *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Unmarshal Uses

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

func (*DeleteTagsRequest) XXX_DiscardUnknown Uses

func (m *DeleteTagsRequest) XXX_DiscardUnknown()

func (*DeleteTagsRequest) XXX_Marshal Uses

func (m *DeleteTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTagsRequest) XXX_Merge Uses

func (m *DeleteTagsRequest) XXX_Merge(src proto.Message)

func (*DeleteTagsRequest) XXX_Size Uses

func (m *DeleteTagsRequest) XXX_Size() int

func (*DeleteTagsRequest) XXX_Unmarshal Uses

func (m *DeleteTagsRequest) XXX_Unmarshal(b []byte) error

type DeleteTagsResponse Uses

type DeleteTagsResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTagsResponse) Descriptor Uses

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

func (*DeleteTagsResponse) Marshal Uses

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

func (*DeleteTagsResponse) MarshalTo Uses

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

func (*DeleteTagsResponse) ProtoMessage Uses

func (*DeleteTagsResponse) ProtoMessage()

func (*DeleteTagsResponse) Reset Uses

func (m *DeleteTagsResponse) Reset()

func (*DeleteTagsResponse) Size Uses

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

func (*DeleteTagsResponse) String Uses

func (m *DeleteTagsResponse) String() string

func (*DeleteTagsResponse) Unmarshal Uses

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

func (*DeleteTagsResponse) XXX_DiscardUnknown Uses

func (m *DeleteTagsResponse) XXX_DiscardUnknown()

func (*DeleteTagsResponse) XXX_Marshal Uses

func (m *DeleteTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTagsResponse) XXX_Merge Uses

func (m *DeleteTagsResponse) XXX_Merge(src proto.Message)

func (*DeleteTagsResponse) XXX_Size Uses

func (m *DeleteTagsResponse) XXX_Size() int

func (*DeleteTagsResponse) XXX_Unmarshal Uses

func (m *DeleteTagsResponse) XXX_Unmarshal(b []byte) error

type Delimiter Uses

type Delimiter int32
const (
    Delimiter_NONE Delimiter = 0
    Delimiter_JSON Delimiter = 1
    Delimiter_LINE Delimiter = 2
    Delimiter_SQL  Delimiter = 3
    Delimiter_CSV  Delimiter = 4
)

func (Delimiter) EnumDescriptor Uses

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

func (Delimiter) String Uses

func (x Delimiter) String() string

type DiffFileRequest Uses

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 Uses

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

func (*DiffFileRequest) GetNewFile Uses

func (m *DiffFileRequest) GetNewFile() *File

func (*DiffFileRequest) GetOldFile Uses

func (m *DiffFileRequest) GetOldFile() *File

func (*DiffFileRequest) GetShallow Uses

func (m *DiffFileRequest) GetShallow() bool

func (*DiffFileRequest) Marshal Uses

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

func (*DiffFileRequest) MarshalTo Uses

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

func (*DiffFileRequest) ProtoMessage Uses

func (*DiffFileRequest) ProtoMessage()

func (*DiffFileRequest) Reset Uses

func (m *DiffFileRequest) Reset()

func (*DiffFileRequest) Size Uses

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

func (*DiffFileRequest) String Uses

func (m *DiffFileRequest) String() string

func (*DiffFileRequest) Unmarshal Uses

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

func (*DiffFileRequest) XXX_DiscardUnknown Uses

func (m *DiffFileRequest) XXX_DiscardUnknown()

func (*DiffFileRequest) XXX_Marshal Uses

func (m *DiffFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiffFileRequest) XXX_Merge Uses

func (m *DiffFileRequest) XXX_Merge(src proto.Message)

func (*DiffFileRequest) XXX_Size Uses

func (m *DiffFileRequest) XXX_Size() int

func (*DiffFileRequest) XXX_Unmarshal Uses

func (m *DiffFileRequest) XXX_Unmarshal(b []byte) error

type DiffFileResponse Uses

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 Uses

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

func (*DiffFileResponse) GetNewFiles Uses

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

func (*DiffFileResponse) GetOldFiles Uses

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

func (*DiffFileResponse) Marshal Uses

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

func (*DiffFileResponse) MarshalTo Uses

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

func (*DiffFileResponse) ProtoMessage Uses

func (*DiffFileResponse) ProtoMessage()

func (*DiffFileResponse) Reset Uses

func (m *DiffFileResponse) Reset()

func (*DiffFileResponse) Size Uses

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

func (*DiffFileResponse) String Uses

func (m *DiffFileResponse) String() string

func (*DiffFileResponse) Unmarshal Uses

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

func (*DiffFileResponse) XXX_DiscardUnknown Uses

func (m *DiffFileResponse) XXX_DiscardUnknown()

func (*DiffFileResponse) XXX_Marshal Uses

func (m *DiffFileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiffFileResponse) XXX_Merge Uses

func (m *DiffFileResponse) XXX_Merge(src proto.Message)

func (*DiffFileResponse) XXX_Size Uses

func (m *DiffFileResponse) XXX_Size() int

func (*DiffFileResponse) XXX_Unmarshal Uses

func (m *DiffFileResponse) XXX_Unmarshal(b []byte) error

type File Uses

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 Uses

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

func (*File) GetCommit Uses

func (m *File) GetCommit() *Commit

func (*File) GetPath Uses

func (m *File) GetPath() string

func (*File) Marshal Uses

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

func (*File) MarshalTo Uses

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

func (*File) ProtoMessage Uses

func (*File) ProtoMessage()

func (*File) Reset Uses

func (m *File) Reset()

func (*File) Size Uses

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

func (*File) String Uses

func (m *File) String() string

func (*File) Unmarshal Uses

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

func (*File) XXX_DiscardUnknown Uses

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal Uses

func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*File) XXX_Merge Uses

func (m *File) XXX_Merge(src proto.Message)

func (*File) XXX_Size Uses

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal Uses

func (m *File) XXX_Unmarshal(b []byte) error

type FileInfo Uses

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"`
    Committed *types.Timestamp `protobuf:"bytes,10,opt,name=committed,proto3" json:"committed,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"`
    BlockRefs            []*BlockRef `protobuf:"bytes,9,rep,name=blockRefs,proto3" json:"blockRefs,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 Uses

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

func (*FileInfo) GetBlockRefs Uses

func (m *FileInfo) GetBlockRefs() []*BlockRef

func (*FileInfo) GetChildren Uses

func (m *FileInfo) GetChildren() []string

func (*FileInfo) GetCommitted Uses

func (m *FileInfo) GetCommitted() *types.Timestamp

func (*FileInfo) GetFile Uses

func (m *FileInfo) GetFile() *File

func (*FileInfo) GetFileType Uses

func (m *FileInfo) GetFileType() FileType

func (*FileInfo) GetHash Uses

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

func (*FileInfo) GetObjects Uses

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

func (*FileInfo) GetSizeBytes Uses

func (m *FileInfo) GetSizeBytes() uint64

func (*FileInfo) Marshal Uses

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

func (*FileInfo) MarshalTo Uses

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

func (*FileInfo) ProtoMessage Uses

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset Uses

func (m *FileInfo) Reset()

func (*FileInfo) Size Uses

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

func (*FileInfo) String Uses

func (m *FileInfo) String() string

func (*FileInfo) Unmarshal Uses

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

func (*FileInfo) XXX_DiscardUnknown Uses

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal Uses

func (m *FileInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileInfo) XXX_Merge Uses

func (m *FileInfo) XXX_Merge(src proto.Message)

func (*FileInfo) XXX_Size Uses

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal Uses

func (m *FileInfo) XXX_Unmarshal(b []byte) error

type FileInfos Uses

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 Uses

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

func (*FileInfos) GetFileInfo Uses

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

func (*FileInfos) Marshal Uses

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

func (*FileInfos) MarshalTo Uses

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

func (*FileInfos) ProtoMessage Uses

func (*FileInfos) ProtoMessage()

func (*FileInfos) Reset Uses

func (m *FileInfos) Reset()

func (*FileInfos) Size Uses

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

func (*FileInfos) String Uses

func (m *FileInfos) String() string

func (*FileInfos) Unmarshal Uses

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

func (*FileInfos) XXX_DiscardUnknown Uses

func (m *FileInfos) XXX_DiscardUnknown()

func (*FileInfos) XXX_Marshal Uses

func (m *FileInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileInfos) XXX_Merge Uses

func (m *FileInfos) XXX_Merge(src proto.Message)

func (*FileInfos) XXX_Size Uses

func (m *FileInfos) XXX_Size() int

func (*FileInfos) XXX_Unmarshal Uses

func (m *FileInfos) XXX_Unmarshal(b []byte) error

type FileType Uses

type FileType int32
const (
    FileType_RESERVED FileType = 0
    FileType_FILE     FileType = 1
    FileType_DIR      FileType = 2
)

func (FileType) EnumDescriptor Uses

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

func (FileType) String Uses

func (x FileType) String() string

type FinishCommitRequest Uses

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"`
    Trees       []*Object `protobuf:"bytes,5,rep,name=trees,proto3" json:"trees,omitempty"`
    Datums      *Object   `protobuf:"bytes,7,opt,name=datums,proto3" json:"datums,omitempty"`
    SizeBytes   uint64    `protobuf:"varint,6,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,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 Uses

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

func (*FinishCommitRequest) GetCommit Uses

func (m *FinishCommitRequest) GetCommit() *Commit

func (*FinishCommitRequest) GetDatums Uses

func (m *FinishCommitRequest) GetDatums() *Object

func (*FinishCommitRequest) GetDescription Uses

func (m *FinishCommitRequest) GetDescription() string

func (*FinishCommitRequest) GetEmpty Uses

func (m *FinishCommitRequest) GetEmpty() bool

func (*FinishCommitRequest) GetSizeBytes Uses

func (m *FinishCommitRequest) GetSizeBytes() uint64

func (*FinishCommitRequest) GetTree Uses

func (m *FinishCommitRequest) GetTree() *Object

func (*FinishCommitRequest) GetTrees Uses

func (m *FinishCommitRequest) GetTrees() []*Object

func (*FinishCommitRequest) Marshal Uses

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

func (*FinishCommitRequest) MarshalTo Uses

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

func (*FinishCommitRequest) ProtoMessage Uses

func (*FinishCommitRequest) ProtoMessage()

func (*FinishCommitRequest) Reset Uses

func (m *FinishCommitRequest) Reset()

func (*FinishCommitRequest) Size Uses

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

func (*FinishCommitRequest) String Uses

func (m *FinishCommitRequest) String() string

func (*FinishCommitRequest) Unmarshal Uses

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

func (*FinishCommitRequest) XXX_DiscardUnknown Uses

func (m *FinishCommitRequest) XXX_DiscardUnknown()

func (*FinishCommitRequest) XXX_Marshal Uses

func (m *FinishCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FinishCommitRequest) XXX_Merge Uses

func (m *FinishCommitRequest) XXX_Merge(src proto.Message)

func (*FinishCommitRequest) XXX_Size Uses

func (m *FinishCommitRequest) XXX_Size() int

func (*FinishCommitRequest) XXX_Unmarshal Uses

func (m *FinishCommitRequest) XXX_Unmarshal(b []byte) error

type FlushCommitRequest Uses

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 Uses

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

func (*FlushCommitRequest) GetCommits Uses

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

func (*FlushCommitRequest) GetToRepos Uses

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

func (*FlushCommitRequest) Marshal Uses

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

func (*FlushCommitRequest) MarshalTo Uses

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

func (*FlushCommitRequest) ProtoMessage Uses

func (*FlushCommitRequest) ProtoMessage()

func (*FlushCommitRequest) Reset Uses

func (m *FlushCommitRequest) Reset()

func (*FlushCommitRequest) Size Uses

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

func (*FlushCommitRequest) String Uses

func (m *FlushCommitRequest) String() string

func (*FlushCommitRequest) Unmarshal Uses

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

func (*FlushCommitRequest) XXX_DiscardUnknown Uses

func (m *FlushCommitRequest) XXX_DiscardUnknown()

func (*FlushCommitRequest) XXX_Marshal Uses

func (m *FlushCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushCommitRequest) XXX_Merge Uses

func (m *FlushCommitRequest) XXX_Merge(src proto.Message)

func (*FlushCommitRequest) XXX_Size Uses

func (m *FlushCommitRequest) XXX_Size() int

func (*FlushCommitRequest) XXX_Unmarshal Uses

func (m *FlushCommitRequest) XXX_Unmarshal(b []byte) error

type GetBlocksRequest Uses

type GetBlocksRequest struct {
    BlockRefs   []*BlockRef `protobuf:"bytes,1,rep,name=blockRefs,proto3" json:"blockRefs,omitempty"`
    OffsetBytes uint64      `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes,proto3" json:"offset_bytes,omitempty"`
    // The number of bytes requested.
    SizeBytes uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
    // The total amount of bytes in these blocks.  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 (*GetBlocksRequest) Descriptor Uses

func (*GetBlocksRequest) Descriptor() ([]byte, []int)

func (*GetBlocksRequest) GetBlockRefs Uses

func (m *GetBlocksRequest) GetBlockRefs() []*BlockRef

func (*GetBlocksRequest) GetOffsetBytes Uses

func (m *GetBlocksRequest) GetOffsetBytes() uint64

func (*GetBlocksRequest) GetSizeBytes Uses

func (m *GetBlocksRequest) GetSizeBytes() uint64

func (*GetBlocksRequest) GetTotalSize Uses

func (m *GetBlocksRequest) GetTotalSize() uint64

func (*GetBlocksRequest) Marshal Uses

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

func (*GetBlocksRequest) MarshalTo Uses

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

func (*GetBlocksRequest) ProtoMessage Uses

func (*GetBlocksRequest) ProtoMessage()

func (*GetBlocksRequest) Reset Uses

func (m *GetBlocksRequest) Reset()

func (*GetBlocksRequest) Size Uses

func (m *GetBlocksRequest) Size() (n int)

func (*GetBlocksRequest) String Uses

func (m *GetBlocksRequest) String() string

func (*GetBlocksRequest) Unmarshal Uses

func (m *GetBlocksRequest) Unmarshal(dAtA []byte) error

func (*GetBlocksRequest) XXX_DiscardUnknown Uses

func (m *GetBlocksRequest) XXX_DiscardUnknown()

func (*GetBlocksRequest) XXX_Marshal Uses

func (m *GetBlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBlocksRequest) XXX_Merge Uses

func (m *GetBlocksRequest) XXX_Merge(src proto.Message)

func (*GetBlocksRequest) XXX_Size Uses

func (m *GetBlocksRequest) XXX_Size() int

func (*GetBlocksRequest) XXX_Unmarshal Uses

func (m *GetBlocksRequest) XXX_Unmarshal(b []byte) error

type GetFileRequest Uses

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 Uses

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

func (*GetFileRequest) GetFile Uses

func (m *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetOffsetBytes Uses

func (m *GetFileRequest) GetOffsetBytes() int64

func (*GetFileRequest) GetSizeBytes Uses

func (m *GetFileRequest) GetSizeBytes() int64

func (*GetFileRequest) Marshal Uses

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

func (*GetFileRequest) MarshalTo Uses

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

func (*GetFileRequest) ProtoMessage Uses

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) Reset Uses

func (m *GetFileRequest) Reset()

func (*GetFileRequest) Size Uses

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

func (*GetFileRequest) String Uses

func (m *GetFileRequest) String() string

func (*GetFileRequest) Unmarshal Uses

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

func (*GetFileRequest) XXX_DiscardUnknown Uses

func (m *GetFileRequest) XXX_DiscardUnknown()

func (*GetFileRequest) XXX_Marshal Uses

func (m *GetFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFileRequest) XXX_Merge Uses

func (m *GetFileRequest) XXX_Merge(src proto.Message)

func (*GetFileRequest) XXX_Size Uses

func (m *GetFileRequest) XXX_Size() int

func (*GetFileRequest) XXX_Unmarshal Uses

func (m *GetFileRequest) XXX_Unmarshal(b []byte) error

type GetObjectsRequest Uses

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 requested.
    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 Uses

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

func (*GetObjectsRequest) GetObjects Uses

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

func (*GetObjectsRequest) GetOffsetBytes Uses

func (m *GetObjectsRequest) GetOffsetBytes() uint64

func (*GetObjectsRequest) GetSizeBytes Uses

func (m *GetObjectsRequest) GetSizeBytes() uint64

func (*GetObjectsRequest) GetTotalSize Uses

func (m *GetObjectsRequest) GetTotalSize() uint64

func (*GetObjectsRequest) Marshal Uses

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

func (*GetObjectsRequest) MarshalTo Uses

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

func (*GetObjectsRequest) ProtoMessage Uses

func (*GetObjectsRequest) ProtoMessage()

func (*GetObjectsRequest) Reset Uses

func (m *GetObjectsRequest) Reset()

func (*GetObjectsRequest) Size Uses

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

func (*GetObjectsRequest) String Uses

func (m *GetObjectsRequest) String() string

func (*GetObjectsRequest) Unmarshal Uses

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

func (*GetObjectsRequest) XXX_DiscardUnknown Uses

func (m *GetObjectsRequest) XXX_DiscardUnknown()

func (*GetObjectsRequest) XXX_Marshal Uses

func (m *GetObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetObjectsRequest) XXX_Merge Uses

func (m *GetObjectsRequest) XXX_Merge(src proto.Message)

func (*GetObjectsRequest) XXX_Size Uses

func (m *GetObjectsRequest) XXX_Size() int

func (*GetObjectsRequest) XXX_Unmarshal Uses

func (m *GetObjectsRequest) XXX_Unmarshal(b []byte) error

type GlobFileRequest Uses

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 Uses

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

func (*GlobFileRequest) GetCommit Uses

func (m *GlobFileRequest) GetCommit() *Commit

func (*GlobFileRequest) GetPattern Uses

func (m *GlobFileRequest) GetPattern() string

func (*GlobFileRequest) Marshal Uses

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

func (*GlobFileRequest) MarshalTo Uses

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

func (*GlobFileRequest) ProtoMessage Uses

func (*GlobFileRequest) ProtoMessage()

func (*GlobFileRequest) Reset Uses

func (m *GlobFileRequest) Reset()

func (*GlobFileRequest) Size Uses

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

func (*GlobFileRequest) String Uses

func (m *GlobFileRequest) String() string

func (*GlobFileRequest) Unmarshal Uses

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

func (*GlobFileRequest) XXX_DiscardUnknown Uses

func (m *GlobFileRequest) XXX_DiscardUnknown()

func (*GlobFileRequest) XXX_Marshal Uses

func (m *GlobFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobFileRequest) XXX_Merge Uses

func (m *GlobFileRequest) XXX_Merge(src proto.Message)

func (*GlobFileRequest) XXX_Size Uses

func (m *GlobFileRequest) XXX_Size() int

func (*GlobFileRequest) XXX_Unmarshal Uses

func (m *GlobFileRequest) XXX_Unmarshal(b []byte) error

type InspectBranchRequest Uses

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 Uses

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

func (*InspectBranchRequest) GetBranch Uses

func (m *InspectBranchRequest) GetBranch() *Branch

func (*InspectBranchRequest) Marshal Uses

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

func (*InspectBranchRequest) MarshalTo Uses

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

func (*InspectBranchRequest) ProtoMessage Uses

func (*InspectBranchRequest) ProtoMessage()

func (*InspectBranchRequest) Reset Uses

func (m *InspectBranchRequest) Reset()

func (*InspectBranchRequest) Size Uses

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

func (*InspectBranchRequest) String Uses

func (m *InspectBranchRequest) String() string

func (*InspectBranchRequest) Unmarshal Uses

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

func (*InspectBranchRequest) XXX_DiscardUnknown Uses

func (m *InspectBranchRequest) XXX_DiscardUnknown()

func (*InspectBranchRequest) XXX_Marshal Uses

func (m *InspectBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectBranchRequest) XXX_Merge Uses

func (m *InspectBranchRequest) XXX_Merge(src proto.Message)

func (*InspectBranchRequest) XXX_Size Uses

func (m *InspectBranchRequest) XXX_Size() int

func (*InspectBranchRequest) XXX_Unmarshal Uses

func (m *InspectBranchRequest) XXX_Unmarshal(b []byte) error

type InspectCommitRequest Uses

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 Uses

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

func (*InspectCommitRequest) GetBlockState Uses

func (m *InspectCommitRequest) GetBlockState() CommitState

func (*InspectCommitRequest) GetCommit Uses

func (m *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) Marshal Uses

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

func (*InspectCommitRequest) MarshalTo Uses

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

func (*InspectCommitRequest) ProtoMessage Uses

func (*InspectCommitRequest) ProtoMessage()

func (*InspectCommitRequest) Reset Uses

func (m *InspectCommitRequest) Reset()

func (*InspectCommitRequest) Size Uses

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

func (*InspectCommitRequest) String Uses

func (m *InspectCommitRequest) String() string

func (*InspectCommitRequest) Unmarshal Uses

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

func (*InspectCommitRequest) XXX_DiscardUnknown Uses

func (m *InspectCommitRequest) XXX_DiscardUnknown()

func (*InspectCommitRequest) XXX_Marshal Uses

func (m *InspectCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectCommitRequest) XXX_Merge Uses

func (m *InspectCommitRequest) XXX_Merge(src proto.Message)

func (*InspectCommitRequest) XXX_Size Uses

func (m *InspectCommitRequest) XXX_Size() int

func (*InspectCommitRequest) XXX_Unmarshal Uses

func (m *InspectCommitRequest) XXX_Unmarshal(b []byte) error

type InspectFileRequest Uses

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 Uses

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

func (*InspectFileRequest) GetFile Uses

func (m *InspectFileRequest) GetFile() *File

func (*InspectFileRequest) Marshal Uses

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

func (*InspectFileRequest) MarshalTo Uses

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

func (*InspectFileRequest) ProtoMessage Uses

func (*InspectFileRequest) ProtoMessage()

func (*InspectFileRequest) Reset Uses

func (m *InspectFileRequest) Reset()

func (*InspectFileRequest) Size Uses

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

func (*InspectFileRequest) String Uses

func (m *InspectFileRequest) String() string

func (*InspectFileRequest) Unmarshal Uses

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

func (*InspectFileRequest) XXX_DiscardUnknown Uses

func (m *InspectFileRequest) XXX_DiscardUnknown()

func (*InspectFileRequest) XXX_Marshal Uses

func (m *InspectFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectFileRequest) XXX_Merge Uses

func (m *InspectFileRequest) XXX_Merge(src proto.Message)

func (*InspectFileRequest) XXX_Size Uses

func (m *InspectFileRequest) XXX_Size() int

func (*InspectFileRequest) XXX_Unmarshal Uses

func (m *InspectFileRequest) XXX_Unmarshal(b []byte) error

type InspectRepoRequest Uses

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 Uses

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

func (*InspectRepoRequest) GetRepo Uses

func (m *InspectRepoRequest) GetRepo() *Repo

func (*InspectRepoRequest) Marshal Uses

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

func (*InspectRepoRequest) MarshalTo Uses

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

func (*InspectRepoRequest) ProtoMessage Uses

func (*InspectRepoRequest) ProtoMessage()

func (*InspectRepoRequest) Reset Uses

func (m *InspectRepoRequest) Reset()

func (*InspectRepoRequest) Size Uses

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

func (*InspectRepoRequest) String Uses

func (m *InspectRepoRequest) String() string

func (*InspectRepoRequest) Unmarshal Uses

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

func (*InspectRepoRequest) XXX_DiscardUnknown Uses

func (m *InspectRepoRequest) XXX_DiscardUnknown()

func (*InspectRepoRequest) XXX_Marshal Uses

func (m *InspectRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectRepoRequest) XXX_Merge Uses

func (m *InspectRepoRequest) XXX_Merge(src proto.Message)

func (*InspectRepoRequest) XXX_Size Uses

func (m *InspectRepoRequest) XXX_Size() int

func (*InspectRepoRequest) XXX_Unmarshal Uses

func (m *InspectRepoRequest) XXX_Unmarshal(b []byte) error

type ListBranchRequest Uses

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 Uses

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

func (*ListBranchRequest) GetRepo Uses

func (m *ListBranchRequest) GetRepo() *Repo

func (*ListBranchRequest) Marshal Uses

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

func (*ListBranchRequest) MarshalTo Uses

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

func (*ListBranchRequest) ProtoMessage Uses

func (*ListBranchRequest) ProtoMessage()

func (*ListBranchRequest) Reset Uses

func (m *ListBranchRequest) Reset()

func (*ListBranchRequest) Size Uses

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

func (*ListBranchRequest) String Uses

func (m *ListBranchRequest) String() string

func (*ListBranchRequest) Unmarshal Uses

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

func (*ListBranchRequest) XXX_DiscardUnknown Uses

func (m *ListBranchRequest) XXX_DiscardUnknown()

func (*ListBranchRequest) XXX_Marshal Uses

func (m *ListBranchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListBranchRequest) XXX_Merge Uses

func (m *ListBranchRequest) XXX_Merge(src proto.Message)

func (*ListBranchRequest) XXX_Size Uses

func (m *ListBranchRequest) XXX_Size() int

func (*ListBranchRequest) XXX_Unmarshal Uses

func (m *ListBranchRequest) XXX_Unmarshal(b []byte) error

type ListCommitRequest Uses

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 Uses

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

func (*ListCommitRequest) GetFrom Uses

func (m *ListCommitRequest) GetFrom() *Commit

func (*ListCommitRequest) GetNumber Uses

func (m *ListCommitRequest) GetNumber() uint64

func (*ListCommitRequest) GetRepo Uses

func (m *ListCommitRequest) GetRepo() *Repo

func (*ListCommitRequest) GetTo Uses

func (m *ListCommitRequest) GetTo() *Commit

func (*ListCommitRequest) Marshal Uses

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

func (*ListCommitRequest) MarshalTo Uses

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

func (*ListCommitRequest) ProtoMessage Uses

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) Reset Uses

func (m *ListCommitRequest) Reset()

func (*ListCommitRequest) Size Uses

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

func (*ListCommitRequest) String Uses

func (m *ListCommitRequest) String() string

func (*ListCommitRequest) Unmarshal Uses

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

func (*ListCommitRequest) XXX_DiscardUnknown Uses

func (m *ListCommitRequest) XXX_DiscardUnknown()

func (*ListCommitRequest) XXX_Marshal Uses

func (m *ListCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListCommitRequest) XXX_Merge Uses

func (m *ListCommitRequest) XXX_Merge(src proto.Message)

func (*ListCommitRequest) XXX_Size Uses

func (m *ListCommitRequest) XXX_Size() int

func (*ListCommitRequest) XXX_Unmarshal Uses

func (m *ListCommitRequest) XXX_Unmarshal(b []byte) error

type ListFileRequest Uses

type ListFileRequest struct {
    // File is the parent directory of the files we want to list. This sets the
    // repo, the commit/branch, and path prefix of files we're interested in
    // If the "path" field is omitted, a list of files at the top level of the repo
    // is returned
    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"`
    // History indicates how many historical versions you want returned. Its
    // semantics are:
    // 0: Return the files as they are at the commit in `file`. FileInfo.File
    //    will equal File in this request.
    // 1: Return the files as they are in the last commit they were modified in.
    //    (This will have the same hash as if you'd passed 0, but
    //    FileInfo.File.Commit will be different.
    // 2: Return the above and the files as they are in the next-last commit they
    //    were modified in.
    // 3: etc.
    //-1: Return all historical versions.
    History              int64    `protobuf:"varint,3,opt,name=history,proto3" json:"history,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListFileRequest) Descriptor Uses

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

func (*ListFileRequest) GetFile Uses

func (m *ListFileRequest) GetFile() *File

func (*ListFileRequest) GetFull Uses

func (m *ListFileRequest) GetFull() bool

func (*ListFileRequest) GetHistory Uses

func (m *ListFileRequest) GetHistory() int64

func (*ListFileRequest) Marshal Uses

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

func (*ListFileRequest) MarshalTo Uses

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

func (*ListFileRequest) ProtoMessage Uses

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) Reset Uses

func (m *ListFileRequest) Reset()

func (*ListFileRequest) Size Uses

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

func (*ListFileRequest) String Uses

func (m *ListFileRequest) String() string

func (*ListFileRequest) Unmarshal Uses

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

func (*ListFileRequest) XXX_DiscardUnknown Uses

func (m *ListFileRequest) XXX_DiscardUnknown()

func (*ListFileRequest) XXX_Marshal Uses

func (m *ListFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListFileRequest) XXX_Merge Uses

func (m *ListFileRequest) XXX_Merge(src proto.Message)

func (*ListFileRequest) XXX_Size Uses

func (m *ListFileRequest) XXX_Size() int

func (*ListFileRequest) XXX_Unmarshal Uses

func (m *ListFileRequest) XXX_Unmarshal(b []byte) error

type ListObjectsRequest Uses

type ListObjectsRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListObjectsRequest) Descriptor Uses

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

func (*ListObjectsRequest) Marshal Uses

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

func (*ListObjectsRequest) MarshalTo Uses

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

func (*ListObjectsRequest) ProtoMessage Uses

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset Uses

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) Size Uses

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

func (*ListObjectsRequest) String Uses

func (m *ListObjectsRequest) String() string

func (*ListObjectsRequest) Unmarshal Uses

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

func (*ListObjectsRequest) XXX_DiscardUnknown Uses

func (m *ListObjectsRequest) XXX_DiscardUnknown()

func (*ListObjectsRequest) XXX_Marshal Uses

func (m *ListObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListObjectsRequest) XXX_Merge Uses

func (m *ListObjectsRequest) XXX_Merge(src proto.Message)

func (*ListObjectsRequest) XXX_Size Uses

func (m *ListObjectsRequest) XXX_Size() int

func (*ListObjectsRequest) XXX_Unmarshal Uses

func (m *ListObjectsRequest) XXX_Unmarshal(b []byte) error

type ListRepoRequest Uses

type ListRepoRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListRepoRequest) Descriptor Uses

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

func (*ListRepoRequest) Marshal Uses

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

func (*ListRepoRequest) MarshalTo Uses

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

func (*ListRepoRequest) ProtoMessage Uses

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset Uses

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) Size Uses

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

func (*ListRepoRequest) String Uses

func (m *ListRepoRequest) String() string

func (*ListRepoRequest) Unmarshal Uses

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

func (*ListRepoRequest) XXX_DiscardUnknown Uses

func (m *ListRepoRequest) XXX_DiscardUnknown()

func (*ListRepoRequest) XXX_Marshal Uses

func (m *ListRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRepoRequest) XXX_Merge Uses

func (m *ListRepoRequest) XXX_Merge(src proto.Message)

func (*ListRepoRequest) XXX_Size Uses

func (m *ListRepoRequest) XXX_Size() int

func (*ListRepoRequest) XXX_Unmarshal Uses

func (m *ListRepoRequest) XXX_Unmarshal(b []byte) error

type ListRepoResponse Uses

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 Uses

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

func (*ListRepoResponse) GetRepoInfo Uses

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

func (*ListRepoResponse) Marshal Uses

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

func (*ListRepoResponse) MarshalTo Uses

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

func (*ListRepoResponse) ProtoMessage Uses

func (*ListRepoResponse) ProtoMessage()

func (*ListRepoResponse) Reset Uses

func (m *ListRepoResponse) Reset()

func (*ListRepoResponse) Size Uses

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

func (*ListRepoResponse) String Uses

func (m *ListRepoResponse) String() string

func (*ListRepoResponse) Unmarshal Uses

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

func (*ListRepoResponse) XXX_DiscardUnknown Uses

func (m *ListRepoResponse) XXX_DiscardUnknown()

func (*ListRepoResponse) XXX_Marshal Uses

func (m *ListRepoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRepoResponse) XXX_Merge Uses

func (m *ListRepoResponse) XXX_Merge(src proto.Message)

func (*ListRepoResponse) XXX_Size Uses

func (m *ListRepoResponse) XXX_Size() int

func (*ListRepoResponse) XXX_Unmarshal Uses

func (m *ListRepoResponse) XXX_Unmarshal(b []byte) error

type ListTagsRequest Uses

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 Uses

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

func (*ListTagsRequest) GetIncludeObject Uses

func (m *ListTagsRequest) GetIncludeObject() bool

func (*ListTagsRequest) GetPrefix Uses

func (m *ListTagsRequest) GetPrefix() string

func (*ListTagsRequest) Marshal Uses

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

func (*ListTagsRequest) MarshalTo Uses

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

func (*ListTagsRequest) ProtoMessage Uses

func (*ListTagsRequest) ProtoMessage()

func (*ListTagsRequest) Reset Uses

func (m *ListTagsRequest) Reset()

func (*ListTagsRequest) Size Uses

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

func (*ListTagsRequest) String Uses

func (m *ListTagsRequest) String() string

func (*ListTagsRequest) Unmarshal Uses

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

func (*ListTagsRequest) XXX_DiscardUnknown Uses

func (m *ListTagsRequest) XXX_DiscardUnknown()

func (*ListTagsRequest) XXX_Marshal Uses

func (m *ListTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTagsRequest) XXX_Merge Uses

func (m *ListTagsRequest) XXX_Merge(src proto.Message)

func (*ListTagsRequest) XXX_Size Uses

func (m *ListTagsRequest) XXX_Size() int

func (*ListTagsRequest) XXX_Unmarshal Uses

func (m *ListTagsRequest) XXX_Unmarshal(b []byte) error

type ListTagsResponse Uses

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 Uses

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

func (*ListTagsResponse) GetObject Uses

func (m *ListTagsResponse) GetObject() *Object

func (*ListTagsResponse) GetTag Uses

func (m *ListTagsResponse) GetTag() *Tag

func (*ListTagsResponse) Marshal Uses

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

func (*ListTagsResponse) MarshalTo Uses

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

func (*ListTagsResponse) ProtoMessage Uses

func (*ListTagsResponse) ProtoMessage()

func (*ListTagsResponse) Reset Uses

func (m *ListTagsResponse) Reset()

func (*ListTagsResponse) Size Uses

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

func (*ListTagsResponse) String Uses

func (m *ListTagsResponse) String() string

func (*ListTagsResponse) Unmarshal Uses

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

func (*ListTagsResponse) XXX_DiscardUnknown Uses

func (m *ListTagsResponse) XXX_DiscardUnknown()

func (*ListTagsResponse) XXX_Marshal Uses

func (m *ListTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTagsResponse) XXX_Merge Uses

func (m *ListTagsResponse) XXX_Merge(src proto.Message)

func (*ListTagsResponse) XXX_Size Uses

func (m *ListTagsResponse) XXX_Size() int

func (*ListTagsResponse) XXX_Unmarshal Uses

func (m *ListTagsResponse) XXX_Unmarshal(b []byte) error

type Object Uses

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 Uses

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

func (*Object) GetHash Uses

func (m *Object) GetHash() string

func (*Object) Marshal Uses

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

func (*Object) MarshalTo Uses

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

func (*Object) ProtoMessage Uses

func (*Object) ProtoMessage()

func (*Object) Reset Uses

func (m *Object) Reset()

func (*Object) Size Uses

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

func (*Object) String Uses

func (m *Object) String() string

func (*Object) Unmarshal Uses

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

func (*Object) XXX_DiscardUnknown Uses

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal Uses

func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Object) XXX_Merge Uses

func (m *Object) XXX_Merge(src proto.Message)

func (*Object) XXX_Size Uses

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal Uses

func (m *Object) XXX_Unmarshal(b []byte) error

type ObjectAPIClient Uses

type ObjectAPIClient interface {
    PutObject(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectClient, error)
    PutObjectSplit(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectSplitClient, error)
    PutObjects(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectsClient, 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)
    GetBlocks(ctx context.Context, in *GetBlocksRequest, opts ...grpc.CallOption) (ObjectAPI_GetBlocksClient, 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 Uses

func NewObjectAPIClient(cc *grpc.ClientConn) ObjectAPIClient

type ObjectAPIServer Uses

type ObjectAPIServer interface {
    PutObject(ObjectAPI_PutObjectServer) error
    PutObjectSplit(ObjectAPI_PutObjectSplitServer) error
    PutObjects(ObjectAPI_PutObjectsServer) error
    GetObject(*Object, ObjectAPI_GetObjectServer) error
    GetObjects(*GetObjectsRequest, ObjectAPI_GetObjectsServer) error
    GetBlocks(*GetBlocksRequest, ObjectAPI_GetBlocksServer) 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_GetBlocksClient Uses

type ObjectAPI_GetBlocksClient interface {
    Recv() (*types.BytesValue, error)
    grpc.ClientStream
}

type ObjectAPI_GetBlocksServer Uses

type ObjectAPI_GetBlocksServer interface {
    Send(*types.BytesValue) error
    grpc.ServerStream
}

type ObjectAPI_GetObjectClient Uses

type ObjectAPI_GetObjectClient interface {
    Recv() (*types.BytesValue, error)
    grpc.ClientStream
}

type ObjectAPI_GetObjectServer Uses

type ObjectAPI_GetObjectServer interface {
    Send(*types.BytesValue) error
    grpc.ServerStream
}

type ObjectAPI_GetObjectsClient Uses

type ObjectAPI_GetObjectsClient interface {
    Recv() (*types.BytesValue, error)
    grpc.ClientStream
}

type ObjectAPI_GetObjectsServer Uses

type ObjectAPI_GetObjectsServer interface {
    Send(*types.BytesValue) error
    grpc.ServerStream
}

type ObjectAPI_GetTagClient Uses

type ObjectAPI_GetTagClient interface {
    Recv() (*types.BytesValue, error)
    grpc.ClientStream
}

type ObjectAPI_GetTagServer Uses

type ObjectAPI_GetTagServer interface {
    Send(*types.BytesValue) error
    grpc.ServerStream
}

type ObjectAPI_ListObjectsClient Uses

type ObjectAPI_ListObjectsClient interface {
    Recv() (*Object, error)
    grpc.ClientStream
}

type ObjectAPI_ListObjectsServer Uses

type ObjectAPI_ListObjectsServer interface {
    Send(*Object) error
    grpc.ServerStream
}

type ObjectAPI_ListTagsClient Uses

type ObjectAPI_ListTagsClient interface {
    Recv() (*ListTagsResponse, error)
    grpc.ClientStream
}

type ObjectAPI_ListTagsServer Uses

type ObjectAPI_ListTagsServer interface {
    Send(*ListTagsResponse) error
    grpc.ServerStream
}

type ObjectAPI_PutObjectClient Uses

type ObjectAPI_PutObjectClient interface {
    Send(*PutObjectRequest) error
    CloseAndRecv() (*Object, error)
    grpc.ClientStream
}

type ObjectAPI_PutObjectServer Uses

type ObjectAPI_PutObjectServer interface {
    SendAndClose(*Object) error
    Recv() (*PutObjectRequest, error)
    grpc.ServerStream
}

type ObjectAPI_PutObjectSplitClient Uses

type ObjectAPI_PutObjectSplitClient interface {
    Send(*PutObjectRequest) error
    CloseAndRecv() (*Objects, error)
    grpc.ClientStream
}

type ObjectAPI_PutObjectSplitServer Uses

type ObjectAPI_PutObjectSplitServer interface {
    SendAndClose(*Objects) error
    Recv() (*PutObjectRequest, error)
    grpc.ServerStream
}

type ObjectAPI_PutObjectsClient Uses

type ObjectAPI_PutObjectsClient interface {
    Send(*PutObjectRequest) error
    CloseAndRecv() (*types.Empty, error)
    grpc.ClientStream
}

type ObjectAPI_PutObjectsServer Uses

type ObjectAPI_PutObjectsServer interface {
    SendAndClose(*types.Empty) error
    Recv() (*PutObjectRequest, error)
    grpc.ServerStream
}

type ObjectIndex Uses

type ObjectIndex struct {
    Objects              map[string]*BlockRef `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    Tags                 map[string]*Object   `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

func (*ObjectIndex) Descriptor Uses

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

func (*ObjectIndex) GetObjects Uses

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

func (*ObjectIndex) GetTags Uses

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

func (*ObjectIndex) Marshal Uses

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

func (*ObjectIndex) MarshalTo Uses

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

func (*ObjectIndex) ProtoMessage Uses

func (*ObjectIndex) ProtoMessage()

func (*ObjectIndex) Reset Uses

func (m *ObjectIndex) Reset()

func (*ObjectIndex) Size Uses

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

func (*ObjectIndex) String Uses

func (m *ObjectIndex) String() string

func (*ObjectIndex) Unmarshal Uses

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

func (*ObjectIndex) XXX_DiscardUnknown Uses

func (m *ObjectIndex) XXX_DiscardUnknown()

func (*ObjectIndex) XXX_Marshal Uses

func (m *ObjectIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectIndex) XXX_Merge Uses

func (m *ObjectIndex) XXX_Merge(src proto.Message)

func (*ObjectIndex) XXX_Size Uses

func (m *ObjectIndex) XXX_Size() int

func (*ObjectIndex) XXX_Unmarshal Uses

func (m *ObjectIndex) XXX_Unmarshal(b []byte) error

type ObjectInfo Uses

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 Uses

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

func (*ObjectInfo) GetBlockRef Uses

func (m *ObjectInfo) GetBlockRef() *BlockRef

func (*ObjectInfo) GetObject Uses

func (m *ObjectInfo) GetObject() *Object

func (*ObjectInfo) Marshal Uses

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

func (*ObjectInfo) MarshalTo Uses

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

func (*ObjectInfo) ProtoMessage Uses

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) Reset Uses

func (m *ObjectInfo) Reset()

func (*ObjectInfo) Size Uses

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

func (*ObjectInfo) String Uses

func (m *ObjectInfo) String() string

func (*ObjectInfo) Unmarshal Uses

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

func (*ObjectInfo) XXX_DiscardUnknown Uses

func (m *ObjectInfo) XXX_DiscardUnknown()

func (*ObjectInfo) XXX_Marshal Uses

func (m *ObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectInfo) XXX_Merge Uses

func (m *ObjectInfo) XXX_Merge(src proto.Message)

func (*ObjectInfo) XXX_Size Uses

func (m *ObjectInfo) XXX_Size() int

func (*ObjectInfo) XXX_Unmarshal Uses

func (m *ObjectInfo) XXX_Unmarshal(b []byte) error

type Objects Uses

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 Uses

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

func (*Objects) GetObjects Uses

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

func (*Objects) Marshal Uses

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

func (*Objects) MarshalTo Uses

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

func (*Objects) ProtoMessage Uses

func (*Objects) ProtoMessage()

func (*Objects) Reset Uses

func (m *Objects) Reset()

func (*Objects) Size Uses

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

func (*Objects) String Uses

func (m *Objects) String() string

func (*Objects) Unmarshal Uses

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

func (*Objects) XXX_DiscardUnknown Uses

func (m *Objects) XXX_DiscardUnknown()

func (*Objects) XXX_Marshal Uses

func (m *Objects) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Objects) XXX_Merge Uses

func (m *Objects) XXX_Merge(src proto.Message)

func (*Objects) XXX_Size Uses

func (m *Objects) XXX_Size() int

func (*Objects) XXX_Unmarshal Uses

func (m *Objects) XXX_Unmarshal(b []byte) error

type OriginKind Uses

type OriginKind int32

These are the different places where a commit may be originated from

const (
    OriginKind_USER OriginKind = 0
    OriginKind_AUTO OriginKind = 1
)

func (OriginKind) EnumDescriptor Uses

func (OriginKind) EnumDescriptor() ([]byte, []int)

func (OriginKind) String Uses

func (x OriginKind) String() string

type OverwriteIndex Uses

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 Uses

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

func (*OverwriteIndex) GetIndex Uses

func (m *OverwriteIndex) GetIndex() int64

func (*OverwriteIndex) Marshal Uses

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

func (*OverwriteIndex) MarshalTo Uses

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

func (*OverwriteIndex) ProtoMessage Uses

func (*OverwriteIndex) ProtoMessage()

func (*OverwriteIndex) Reset Uses

func (m *OverwriteIndex) Reset()

func (*OverwriteIndex) Size Uses

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

func (*OverwriteIndex) String Uses

func (m *OverwriteIndex) String() string

func (*OverwriteIndex) Unmarshal Uses

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

func (*OverwriteIndex) XXX_DiscardUnknown Uses

func (m *OverwriteIndex) XXX_DiscardUnknown()

func (*OverwriteIndex) XXX_Marshal Uses

func (m *OverwriteIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OverwriteIndex) XXX_Merge Uses

func (m *OverwriteIndex) XXX_Merge(src proto.Message)

func (*OverwriteIndex) XXX_Size Uses

func (m *OverwriteIndex) XXX_Size() int

func (*OverwriteIndex) XXX_Unmarshal Uses

func (m *OverwriteIndex) XXX_Unmarshal(b []byte) error

type PutFileRecord Uses

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 Uses

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

func (*PutFileRecord) GetObjectHash Uses

func (m *PutFileRecord) GetObjectHash() string

func (*PutFileRecord) GetOverwriteIndex Uses

func (m *PutFileRecord) GetOverwriteIndex() *OverwriteIndex

func (*PutFileRecord) GetSizeBytes Uses

func (m *PutFileRecord) GetSizeBytes() int64

func (*PutFileRecord) Marshal Uses

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

func (*PutFileRecord) MarshalTo Uses

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

func (*PutFileRecord) ProtoMessage Uses

func (*PutFileRecord) ProtoMessage()

func (*PutFileRecord) Reset Uses

func (m *PutFileRecord) Reset()

func (*PutFileRecord) Size Uses

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

func (*PutFileRecord) String Uses

func (m *PutFileRecord) String() string

func (*PutFileRecord) Unmarshal Uses

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

func (*PutFileRecord) XXX_DiscardUnknown Uses

func (m *PutFileRecord) XXX_DiscardUnknown()

func (*PutFileRecord) XXX_Marshal Uses

func (m *PutFileRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutFileRecord) XXX_Merge Uses

func (m *PutFileRecord) XXX_Merge(src proto.Message)

func (*PutFileRecord) XXX_Size Uses

func (m *PutFileRecord) XXX_Size() int

func (*PutFileRecord) XXX_Unmarshal Uses

func (m *PutFileRecord) XXX_Unmarshal(b []byte) error

type PutFileRecords Uses

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"`
    Footer               *PutFileRecord   `protobuf:"bytes,5,opt,name=footer,proto3" json:"footer,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

func (*PutFileRecords) Descriptor Uses

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

func (*PutFileRecords) GetFooter Uses

func (m *PutFileRecords) GetFooter() *PutFileRecord

func (*PutFileRecords) GetHeader Uses

func (m *PutFileRecords) GetHeader() *PutFileRecord

func (*PutFileRecords) GetRecords Uses

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

func (*PutFileRecords) GetSplit Uses

func (m *PutFileRecords) GetSplit() bool

func (*PutFileRecords) GetTombstone Uses

func (m *PutFileRecords) GetTombstone() bool

func (*PutFileRecords) Marshal Uses

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

func (*PutFileRecords) MarshalTo Uses

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

func (*PutFileRecords) ProtoMessage Uses

func (*PutFileRecords) ProtoMessage()

func (*PutFileRecords) Reset Uses

func (m *PutFileRecords) Reset()

func (*PutFileRecords) Size Uses

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

func (*PutFileRecords) String Uses

func (m *PutFileRecords) String() string

func (*PutFileRecords) Unmarshal Uses

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

func (*PutFileRecords) XXX_DiscardUnknown Uses

func (m *PutFileRecords) XXX_DiscardUnknown()

func (*PutFileRecords) XXX_Marshal Uses

func (m *PutFileRecords) XXX_Marshal(b []byte, deterministic bool)