pfs

package
v1.10.0-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 3, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPfs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPfs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPfs = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CommitState_name = map[int32]string{
	0: "STARTED",
	1: "READY",
	2: "FINISHED",
}
View Source 
var CommitState_value = map[string]int32{
	"STARTED":  0,
	"READY":    1,
	"FINISHED": 2,
}
View Source 
var Delimiter_name = map[int32]string{
	0: "NONE",
	1: "JSON",
	2: "LINE",
	3: "SQL",
	4: "CSV",
}
View Source 
var Delimiter_value = map[string]int32{
	"NONE": 0,
	"JSON": 1,
	"LINE": 2,
	"SQL":  3,
	"CSV":  4,
}
View Source 
var FileType_name = map[int32]string{
	0: "RESERVED",
	1: "FILE",
	2: "DIR",
}
View Source 
var FileType_value = map[string]int32{
	"RESERVED": 0,
	"FILE":     1,
	"DIR":      2,
}
View Source 
var OriginKind_name = map[int32]string{
	0: "USER",
	1: "AUTO",
	2: "FSCK",
}
View Source 
var OriginKind_value = map[string]int32{
	"USER": 0,
	"AUTO": 1,
	"FSCK": 2,
}

Functions

func RegisterAPIServer 

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

func RegisterObjectAPIServer 

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

Types

type APIClient 

type APIClient interface {
	// Repo rpcs
	// CreateRepo creates a new repo.
	// An error is returned if the repo already exists.
	CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// InspectRepo returns info about a repo.
	InspectRepo(ctx context.Context, in *InspectRepoRequest, opts ...grpc.CallOption) (*RepoInfo, error)
	// ListRepo returns info about all repos.
	ListRepo(ctx context.Context, in *ListRepoRequest, opts ...grpc.CallOption) (*ListRepoResponse, error)
	// DeleteRepo deletes a repo.
	DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Commit rpcs
	// StartCommit creates a new write commit from a parent commit.
	StartCommit(ctx context.Context, in *StartCommitRequest, opts ...grpc.CallOption) (*Commit, error)
	// FinishCommit turns a write commit into a read commit.
	FinishCommit(ctx context.Context, in *FinishCommitRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// InspectCommit returns the info about a commit.
	InspectCommit(ctx context.Context, in *InspectCommitRequest, opts ...grpc.CallOption) (*CommitInfo, error)
	// ListCommit returns info about all commits. This is deprecated in favor of
	// ListCommitStream.
	ListCommit(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)
	// ListCommitStream is like ListCommit, but returns its results in a GRPC stream
	ListCommitStream(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (API_ListCommitStreamClient, error)
	// DeleteCommit deletes a commit.
	DeleteCommit(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(ctx context.Context, in *FlushCommitRequest, opts ...grpc.CallOption) (API_FlushCommitClient, error)
	// SubscribeCommit subscribes for new commits on a given branch
	SubscribeCommit(ctx context.Context, in *SubscribeCommitRequest, opts ...grpc.CallOption) (API_SubscribeCommitClient, error)
	// BuildCommit builds a commit that's backed by the given tree
	BuildCommit(ctx context.Context, in *BuildCommitRequest, opts ...grpc.CallOption) (*Commit, error)
	// CreateBranch creates a new branch
	CreateBranch(ctx context.Context, in *CreateBranchRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// InspectBranch returns info about a branch.
	InspectBranch(ctx context.Context, in *InspectBranchRequest, opts ...grpc.CallOption) (*BranchInfo, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*BranchInfos, error)
	// DeleteBranch deletes a branch; note that the commits still exist.
	DeleteBranch(ctx context.Context, in *DeleteBranchRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// File rpcs
	// PutFile writes the specified file to pfs.
	PutFile(ctx context.Context, opts ...grpc.CallOption) (API_PutFileClient, error)
	// CopyFile copies the contents of one file to another.
	CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// GetFile returns a byte stream of the contents of the file.
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (API_GetFileClient, error)
	// InspectFile returns info about a file.
	InspectFile(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error)
	// ListFile returns info about all files. This is deprecated in favor of
	// ListFileStream
	ListFile(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*FileInfos, error)
	// ListFileStream is a streaming version of ListFile
	// TODO(msteffen): When the dash has been updated to use ListFileStream,
	// replace ListFile with this RPC (https://github.com/pachyderm/dash/issues/201)
	ListFileStream(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (API_ListFileStreamClient, error)
	// 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 *FsckRequest, opts ...grpc.CallOption) (API_FsckClient, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	// Repo rpcs
	// CreateRepo creates a new repo.
	// An error is returned if the repo already exists.
	CreateRepo(context.Context, *CreateRepoRequest) (*types.Empty, error)
	// InspectRepo returns info about a repo.
	InspectRepo(context.Context, *InspectRepoRequest) (*RepoInfo, error)
	// ListRepo returns info about all repos.
	ListRepo(context.Context, *ListRepoRequest) (*ListRepoResponse, error)
	// DeleteRepo deletes a repo.
	DeleteRepo(context.Context, *DeleteRepoRequest) (*types.Empty, error)
	// Commit rpcs
	// StartCommit creates a new write commit from a parent commit.
	StartCommit(context.Context, *StartCommitRequest) (*Commit, error)
	// FinishCommit turns a write commit into a read commit.
	FinishCommit(context.Context, *FinishCommitRequest) (*types.Empty, error)
	// InspectCommit returns the info about a commit.
	InspectCommit(context.Context, *InspectCommitRequest) (*CommitInfo, error)
	// ListCommit returns info about all commits. This is deprecated in favor of
	// ListCommitStream.
	ListCommit(context.Context, *ListCommitRequest) (*CommitInfos, error)
	// ListCommitStream is like ListCommit, but returns its results in a GRPC stream
	ListCommitStream(*ListCommitRequest, API_ListCommitStreamServer) error
	// DeleteCommit deletes a commit.
	DeleteCommit(context.Context, *DeleteCommitRequest) (*types.Empty, error)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(*FlushCommitRequest, API_FlushCommitServer) error
	// SubscribeCommit subscribes for new commits on a given branch
	SubscribeCommit(*SubscribeCommitRequest, API_SubscribeCommitServer) error
	// BuildCommit builds a commit that's backed by the given tree
	BuildCommit(context.Context, *BuildCommitRequest) (*Commit, error)
	// CreateBranch creates a new branch
	CreateBranch(context.Context, *CreateBranchRequest) (*types.Empty, error)
	// InspectBranch returns info about a branch.
	InspectBranch(context.Context, *InspectBranchRequest) (*BranchInfo, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(context.Context, *ListBranchRequest) (*BranchInfos, error)
	// DeleteBranch deletes a branch; note that the commits still exist.
	DeleteBranch(context.Context, *DeleteBranchRequest) (*types.Empty, error)
	// File rpcs
	// PutFile writes the specified file to pfs.
	PutFile(API_PutFileServer) error
	// CopyFile copies the contents of one file to another.
	CopyFile(context.Context, *CopyFileRequest) (*types.Empty, error)
	// GetFile returns a byte stream of the contents of the file.
	GetFile(*GetFileRequest, API_GetFileServer) error
	// InspectFile returns info about a file.
	InspectFile(context.Context, *InspectFileRequest) (*FileInfo, error)
	// ListFile returns info about all files. This is deprecated in favor of
	// ListFileStream
	ListFile(context.Context, *ListFileRequest) (*FileInfos, error)
	// ListFileStream is a streaming version of ListFile
	// TODO(msteffen): When the dash has been updated to use ListFileStream,
	// replace ListFile with this RPC (https://github.com/pachyderm/dash/issues/201)
	ListFileStream(*ListFileRequest, API_ListFileStreamServer) error
	// 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(*FsckRequest, API_FsckServer) error
}

APIServer is the server API for API service.

type API_FlushCommitClient 

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

type API_FlushCommitServer 

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

type API_FsckClient 

type API_FsckClient interface {
	Recv() (*FsckResponse, error)
	grpc.ClientStream
}

type API_FsckServer 

type API_FsckServer interface {
	Send(*FsckResponse) error
	grpc.ServerStream
}

type API_GetFileClient 

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

type API_GetFileServer 

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

type API_GlobFileStreamClient 

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

type API_GlobFileStreamServer 

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

type API_ListCommitStreamClient 

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

type API_ListCommitStreamServer 

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

type API_ListFileStreamClient 

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

type API_ListFileStreamServer 

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

type API_PutFileClient 

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

type API_PutFileServer 

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

type API_SubscribeCommitClient 

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

type API_SubscribeCommitServer 

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

type API_WalkFileClient 

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

type API_WalkFileServer 

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

type Block 

type Block struct {
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Block) Descriptor 

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

func (*Block) GetHash 

func (m *Block) GetHash() string

func (*Block) Marshal 

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

func (*Block) MarshalTo 

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

func (*Block) MarshalToSizedBuffer 

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

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) Size 

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

func (*Block) String 

func (m *Block) String() string

func (*Block) Unmarshal 

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

func (*Block) XXX_DiscardUnknown 

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal 

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

func (*Block) XXX_Merge 

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

func (*Block) XXX_Size 

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal 

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

type BlockRef 

type BlockRef struct {
	Block                *Block     `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	Range                *ByteRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*BlockRef) Descriptor 

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

func (*BlockRef) GetBlock 

func (m *BlockRef) GetBlock() *Block

func (*BlockRef) GetRange 

func (m *BlockRef) GetRange() *ByteRange

func (*BlockRef) Marshal 

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

func (*BlockRef) MarshalTo 

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

func (*BlockRef) MarshalToSizedBuffer 

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

func (*BlockRef) ProtoMessage 

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset 

func (m *BlockRef) Reset()

func (*BlockRef) Size 

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

func (*BlockRef) String 

func (m *BlockRef) String() string

func (*BlockRef) Unmarshal 

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

func (*BlockRef) XXX_DiscardUnknown 

func (m *BlockRef) XXX_DiscardUnknown()

func (*BlockRef) XXX_Marshal 

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

func (*BlockRef) XXX_Merge 

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

func (*BlockRef) XXX_Size 

func (m *BlockRef) XXX_Size() int

func (*BlockRef) XXX_Unmarshal 

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

type Branch 

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 

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

func (*Branch) GetName 

func (m *Branch) GetName() string

func (*Branch) GetRepo 

func (m *Branch) GetRepo() *Repo

func (*Branch) Marshal 

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

func (*Branch) MarshalTo 

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

func (*Branch) MarshalToSizedBuffer 

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

func (*Branch) ProtoMessage 

func (*Branch) ProtoMessage()

func (*Branch) Reset 

func (m *Branch) Reset()

func (*Branch) Size 

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

func (*Branch) String 

func (m *Branch) String() string

func (*Branch) Unmarshal 

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

func (*Branch) XXX_DiscardUnknown 

func (m *Branch) XXX_DiscardUnknown()

func (*Branch) XXX_Marshal 

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

func (*Branch) XXX_Merge 

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

func (*Branch) XXX_Size 

func (m *Branch) XXX_Size() int

func (*Branch) XXX_Unmarshal 

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

type BranchInfo 

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 

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

func (*BranchInfo) GetBranch 

func (m *BranchInfo) GetBranch() *Branch

func (*BranchInfo) GetDirectProvenance 

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

func (*BranchInfo) GetHead 

func (m *BranchInfo) GetHead() *Commit

func (*BranchInfo) GetName 

func (m *BranchInfo) GetName() string

func (*BranchInfo) GetProvenance 

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

func (*BranchInfo) GetSubvenance 

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

func (*BranchInfo) Marshal 

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

func (*BranchInfo) MarshalTo 

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

func (*BranchInfo) MarshalToSizedBuffer 

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

func (*BranchInfo) ProtoMessage 

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) Reset 

func (m *BranchInfo) Reset()

func (*BranchInfo) Size 

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

func (*BranchInfo) String 

func (m *BranchInfo) String() string

func (*BranchInfo) Unmarshal 

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

func (*BranchInfo) XXX_DiscardUnknown 

func (m *BranchInfo) XXX_DiscardUnknown()

func (*BranchInfo) XXX_Marshal 

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

func (*BranchInfo) XXX_Merge 

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

func (*BranchInfo) XXX_Size 

func (m *BranchInfo) XXX_Size() int

func (*BranchInfo) XXX_Unmarshal 

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

type BranchInfos 

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 

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

func (*BranchInfos) GetBranchInfo 

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

func (*BranchInfos) Marshal 

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

func (*BranchInfos) MarshalTo 

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

func (*BranchInfos) MarshalToSizedBuffer 

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

func (*BranchInfos) ProtoMessage 

func (*BranchInfos) ProtoMessage()

func (*BranchInfos) Reset 

func (m *BranchInfos) Reset()

func (*BranchInfos) Size 

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

func (*BranchInfos) String 

func (m *BranchInfos) String() string

func (*BranchInfos) Unmarshal 

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

func (*BranchInfos) XXX_DiscardUnknown 

func (m *BranchInfos) XXX_DiscardUnknown()

func (*BranchInfos) XXX_Marshal 

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

func (*BranchInfos) XXX_Merge 

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

func (*BranchInfos) XXX_Size 

func (m *BranchInfos) XXX_Size() int

func (*BranchInfos) XXX_Unmarshal 

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

type BuildCommitRequest 

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"`
	Trees      []*Object           `protobuf:"bytes,7,rep,name=trees,proto3" json:"trees,omitempty"`
	Datums     *Object             `protobuf:"bytes,8,opt,name=datums,proto3" json:"datums,omitempty"`
	// ID sets the ID of the created commit.
	ID                   string   `protobuf:"bytes,5,opt,name=ID,proto3" json:"ID,omitempty"`
	SizeBytes            uint64   `protobuf:"varint,9,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BuildCommitRequest) Descriptor 

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

func (*BuildCommitRequest) GetBranch 

func (m *BuildCommitRequest) GetBranch() string

func (*BuildCommitRequest) GetDatums 

func (m *BuildCommitRequest) GetDatums() *Object

func (*BuildCommitRequest) GetID 

func (m *BuildCommitRequest) GetID() string

func (*BuildCommitRequest) GetParent 

func (m *BuildCommitRequest) GetParent() *Commit

func (*BuildCommitRequest) GetProvenance 

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

func (*BuildCommitRequest) GetSizeBytes 

func (m *BuildCommitRequest) GetSizeBytes() uint64

func (*BuildCommitRequest) GetTree 

func (m *BuildCommitRequest) GetTree() *Object

func (*BuildCommitRequest) GetTrees 

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

func (*BuildCommitRequest) Marshal 

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

func (*BuildCommitRequest) MarshalTo 

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

func (*BuildCommitRequest) MarshalToSizedBuffer 

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

func (*BuildCommitRequest) ProtoMessage 

func (*BuildCommitRequest) ProtoMessage()

func (*BuildCommitRequest) Reset 

func (m *BuildCommitRequest) Reset()

func (*BuildCommitRequest) Size 

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

func (*BuildCommitRequest) String 

func (m *BuildCommitRequest) String() string

func (*BuildCommitRequest) Unmarshal 

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

func (*BuildCommitRequest) XXX_DiscardUnknown 

func (m *BuildCommitRequest) XXX_DiscardUnknown()

func (*BuildCommitRequest) XXX_Marshal 

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

func (*BuildCommitRequest) XXX_Merge 

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

func (*BuildCommitRequest) XXX_Size 

func (m *BuildCommitRequest) XXX_Size() int

func (*BuildCommitRequest) XXX_Unmarshal 

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

type ByteRange 

type ByteRange struct {
	Lower                uint64   `protobuf:"varint,1,opt,name=lower,proto3" json:"lower,omitempty"`
	Upper                uint64   `protobuf:"varint,2,opt,name=upper,proto3" json:"upper,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ByteRange) Descriptor 

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

func (*ByteRange) GetLower 

func (m *ByteRange) GetLower() uint64

func (*ByteRange) GetUpper 

func (m *ByteRange) GetUpper() uint64

func (*ByteRange) Marshal 

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

func (*ByteRange) MarshalTo 

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

func (*ByteRange) MarshalToSizedBuffer 

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

func (*ByteRange) ProtoMessage 

func (*ByteRange) ProtoMessage()

func (*ByteRange) Reset 

func (m *ByteRange) Reset()

func (*ByteRange) Size 

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

func (*ByteRange) String 

func (m *ByteRange) String() string

func (*ByteRange) Unmarshal 

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

func (*ByteRange) XXX_DiscardUnknown 

func (m *ByteRange) XXX_DiscardUnknown()

func (*ByteRange) XXX_Marshal 

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

func (*ByteRange) XXX_Merge 

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

func (*ByteRange) XXX_Size 

func (m *ByteRange) XXX_Size() int

func (*ByteRange) XXX_Unmarshal 

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

type CheckObjectRequest 

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 

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

func (*CheckObjectRequest) GetObject 

func (m *CheckObjectRequest) GetObject() *Object

func (*CheckObjectRequest) Marshal 

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

func (*CheckObjectRequest) MarshalTo 

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

func (*CheckObjectRequest) MarshalToSizedBuffer 

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

func (*CheckObjectRequest) ProtoMessage 

func (*CheckObjectRequest) ProtoMessage()

func (*CheckObjectRequest) Reset 

func (m *CheckObjectRequest) Reset()

func (*CheckObjectRequest) Size 

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

func (*CheckObjectRequest) String 

func (m *CheckObjectRequest) String() string

func (*CheckObjectRequest) Unmarshal 

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

func (*CheckObjectRequest) XXX_DiscardUnknown 

func (m *CheckObjectRequest) XXX_DiscardUnknown()

func (*CheckObjectRequest) XXX_Marshal 

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

func (*CheckObjectRequest) XXX_Merge 

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

func (*CheckObjectRequest) XXX_Size 

func (m *CheckObjectRequest) XXX_Size() int

func (*CheckObjectRequest) XXX_Unmarshal 

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

type CheckObjectResponse 

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 

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

func (*CheckObjectResponse) GetExists 

func (m *CheckObjectResponse) GetExists() bool

func (*CheckObjectResponse) Marshal 

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

func (*CheckObjectResponse) MarshalTo 

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

func (*CheckObjectResponse) MarshalToSizedBuffer 

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

func (*CheckObjectResponse) ProtoMessage 

func (*CheckObjectResponse) ProtoMessage()

func (*CheckObjectResponse) Reset 

func (m *CheckObjectResponse) Reset()

func (*CheckObjectResponse) Size 

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

func (*CheckObjectResponse) String 

func (m *CheckObjectResponse) String() string

func (*CheckObjectResponse) Unmarshal 

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

func (*CheckObjectResponse) XXX_DiscardUnknown 

func (m *CheckObjectResponse) XXX_DiscardUnknown()

func (*CheckObjectResponse) XXX_Marshal 

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

func (*CheckObjectResponse) XXX_Merge 

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

func (*CheckObjectResponse) XXX_Size 

func (m *CheckObjectResponse) XXX_Size() int

func (*CheckObjectResponse) XXX_Unmarshal 

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

type Commit 

type Commit struct {
	Repo                 *Repo    `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	ID                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Commit is a reference to a commit (e.g. the collection of branches and the collection of currently-open commits in etcd are collections of Commit protos)

func (*Commit) Descriptor 

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

func (*Commit) GetID 

func (m *Commit) GetID() string

func (*Commit) GetRepo 

func (m *Commit) GetRepo() *Repo

func (*Commit) Marshal 

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

func (*Commit) MarshalTo 

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

func (*Commit) MarshalToSizedBuffer 

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

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) Size 

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

func (*Commit) String 

func (m *Commit) String() string

func (*Commit) Unmarshal 

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

func (*Commit) XXX_DiscardUnknown 

func (m *Commit) XXX_DiscardUnknown()

func (*Commit) XXX_Marshal 

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

func (*Commit) XXX_Merge 

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

func (*Commit) XXX_Size 

func (m *Commit) XXX_Size() int

func (*Commit) XXX_Unmarshal 

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

type CommitInfo 

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"`
	SubvenantCommitsSuccess int64     `` /* 134-byte string literal not displayed */
	SubvenantCommitsFailure int64     `` /* 134-byte string literal not displayed */
	SubvenantCommitsTotal   int64     `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}  `json:"-"`
	XXX_unrecognized        []byte    `json:"-"`
	XXX_sizecache           int32     `json:"-"`
}

CommitInfo is the main data structure representing a commit in etcd

func (*CommitInfo) Descriptor 

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

func (*CommitInfo) GetBranch 

func (m *CommitInfo) GetBranch() *Branch

func (*CommitInfo) GetChildCommits 

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

func (*CommitInfo) GetCommit 

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetDatums 

func (m *CommitInfo) GetDatums() *Object

func (*CommitInfo) GetDescription 

func (m *CommitInfo) GetDescription() string

func (*CommitInfo) GetFinished 

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

func (*CommitInfo) GetOrigin 

func (m *CommitInfo) GetOrigin() *CommitOrigin

func (*CommitInfo) GetParentCommit 

func (m *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetProvenance 

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

func (*CommitInfo) GetReadyProvenance 

func (m *CommitInfo) GetReadyProvenance() int64

func (*CommitInfo) GetSizeBytes 

func (m *CommitInfo) GetSizeBytes() uint64

func (*CommitInfo) GetStarted 

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

func (*CommitInfo) GetSubvenance 

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

func (*CommitInfo) GetSubvenantCommitsFailure 

func (m *CommitInfo) GetSubvenantCommitsFailure() int64

func (*CommitInfo) GetSubvenantCommitsSuccess 

func (m *CommitInfo) GetSubvenantCommitsSuccess() int64

func (*CommitInfo) GetSubvenantCommitsTotal 

func (m *CommitInfo) GetSubvenantCommitsTotal() int64

func (*CommitInfo) GetTree 

func (m *CommitInfo) GetTree() *Object

func (*CommitInfo) GetTrees 

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

func (*CommitInfo) Marshal 

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

func (*CommitInfo) MarshalTo 

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

func (*CommitInfo) MarshalToSizedBuffer 

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

func (*CommitInfo) ProtoMessage 

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset 

func (m *CommitInfo) Reset()

func (*CommitInfo) Size 

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

func (*CommitInfo) String 

func (m *CommitInfo) String() string

func (*CommitInfo) Unmarshal 

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

func (*CommitInfo) XXX_DiscardUnknown 

func (m *CommitInfo) XXX_DiscardUnknown()

func (*CommitInfo) XXX_Marshal 

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

func (*CommitInfo) XXX_Merge 

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

func (*CommitInfo) XXX_Size 

func (m *CommitInfo) XXX_Size() int

func (*CommitInfo) XXX_Unmarshal 

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

type CommitInfos 

type CommitInfos struct {
	CommitInfo           []*CommitInfo `protobuf:"bytes,1,rep,name=commit_info,json=commitInfo,proto3" json:"commit_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CommitInfos) Descriptor 

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

func (*CommitInfos) GetCommitInfo 

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

func (*CommitInfos) Marshal 

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

func (*CommitInfos) MarshalTo 

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

func (*CommitInfos) MarshalToSizedBuffer 

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

func (*CommitInfos) ProtoMessage 

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset 

func (m *CommitInfos) Reset()

func (*CommitInfos) Size 

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

func (*CommitInfos) String 

func (m *CommitInfos) String() string

func (*CommitInfos) Unmarshal 

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

func (*CommitInfos) XXX_DiscardUnknown 

func (m *CommitInfos) XXX_DiscardUnknown()

func (*CommitInfos) XXX_Marshal 

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

func (*CommitInfos) XXX_Merge 

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

func (*CommitInfos) XXX_Size 

func (m *CommitInfos) XXX_Size() int

func (*CommitInfos) XXX_Unmarshal 

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

type CommitOrigin 

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

func (*CommitOrigin) Descriptor 

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

func (*CommitOrigin) GetKind 

func (m *CommitOrigin) GetKind() OriginKind

func (*CommitOrigin) Marshal 

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

func (*CommitOrigin) MarshalTo 

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

func (*CommitOrigin) MarshalToSizedBuffer 

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

func (*CommitOrigin) ProtoMessage 

func (*CommitOrigin) ProtoMessage()

func (*CommitOrigin) Reset 

func (m *CommitOrigin) Reset()

func (*CommitOrigin) Size 

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

func (*CommitOrigin) String 

func (m *CommitOrigin) String() string

func (*CommitOrigin) Unmarshal 

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

func (*CommitOrigin) XXX_DiscardUnknown 

func (m *CommitOrigin) XXX_DiscardUnknown()

func (*CommitOrigin) XXX_Marshal 

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

func (*CommitOrigin) XXX_Merge 

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

func (*CommitOrigin) XXX_Size 

func (m *CommitOrigin) XXX_Size() int

func (*CommitOrigin) XXX_Unmarshal 

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

type CommitProvenance 

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 

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

func (*CommitProvenance) GetBranch 

func (m *CommitProvenance) GetBranch() *Branch

func (*CommitProvenance) GetCommit 

func (m *CommitProvenance) GetCommit() *Commit

func (*CommitProvenance) Marshal 

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

func (*CommitProvenance) MarshalTo 

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

func (*CommitProvenance) MarshalToSizedBuffer 

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

func (*CommitProvenance) ProtoMessage 

func (*CommitProvenance) ProtoMessage()

func (*CommitProvenance) Reset 

func (m *CommitProvenance) Reset()

func (*CommitProvenance) Size 

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

func (*CommitProvenance) String 

func (m *CommitProvenance) String() string

func (*CommitProvenance) Unmarshal 

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

func (*CommitProvenance) XXX_DiscardUnknown 

func (m *CommitProvenance) XXX_DiscardUnknown()

func (*CommitProvenance) XXX_Marshal 

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

func (*CommitProvenance) XXX_Merge 

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

func (*CommitProvenance) XXX_Size 

func (m *CommitProvenance) XXX_Size() int

func (*CommitProvenance) XXX_Unmarshal 

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

type CommitRange 

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 

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

func (*CommitRange) GetLower 

func (m *CommitRange) GetLower() *Commit

func (*CommitRange) GetUpper 

func (m *CommitRange) GetUpper() *Commit

func (*CommitRange) Marshal 

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

func (*CommitRange) MarshalTo 

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

func (*CommitRange) MarshalToSizedBuffer 

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

func (*CommitRange) ProtoMessage 

func (*CommitRange) ProtoMessage()

func (*CommitRange) Reset 

func (m *CommitRange) Reset()

func (*CommitRange) Size 

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

func (*CommitRange) String 

func (m *CommitRange) String() string

func (*CommitRange) Unmarshal 

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

func (*CommitRange) XXX_DiscardUnknown 

func (m *CommitRange) XXX_DiscardUnknown()

func (*CommitRange) XXX_Marshal 

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

func (*CommitRange) XXX_Merge 

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

func (*CommitRange) XXX_Size 

func (m *CommitRange) XXX_Size() int

func (*CommitRange) XXX_Unmarshal 

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

type CommitState 

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 

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

func (CommitState) String 

func (x CommitState) String() string

type CopyFileRequest 

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 

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

func (*CopyFileRequest) GetDst 

func (m *CopyFileRequest) GetDst() *File

func (*CopyFileRequest) GetOverwrite 

func (m *CopyFileRequest) GetOverwrite() bool

func (*CopyFileRequest) GetSrc 

func (m *CopyFileRequest) GetSrc() *File

func (*CopyFileRequest) Marshal 

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

func (*CopyFileRequest) MarshalTo 

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

func (*CopyFileRequest) MarshalToSizedBuffer 

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

func (*CopyFileRequest) ProtoMessage 

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset 

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) Size 

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

func (*CopyFileRequest) String 

func (m *CopyFileRequest) String() string

func (*CopyFileRequest) Unmarshal 

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

func (*CopyFileRequest) XXX_DiscardUnknown 

func (m *CopyFileRequest) XXX_DiscardUnknown()

func (*CopyFileRequest) XXX_Marshal 

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

func (*CopyFileRequest) XXX_Merge 

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

func (*CopyFileRequest) XXX_Size 

func (m *CopyFileRequest) XXX_Size() int

func (*CopyFileRequest) XXX_Unmarshal 

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

type CreateBranchRequest 

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 

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

func (*CreateBranchRequest) GetBranch 

func (m *CreateBranchRequest) GetBranch() *Branch

func (*CreateBranchRequest) GetHead 

func (m *CreateBranchRequest) GetHead() *Commit

func (*CreateBranchRequest) GetProvenance 

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

func (*CreateBranchRequest) GetSBranch 

func (m *CreateBranchRequest) GetSBranch() string

func (*CreateBranchRequest) Marshal 

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

func (*CreateBranchRequest) MarshalTo 

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

func (*CreateBranchRequest) MarshalToSizedBuffer 

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

func (*CreateBranchRequest) ProtoMessage 

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) Reset 

func (m *CreateBranchRequest) Reset()

func (*CreateBranchRequest) Size 

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

func (*CreateBranchRequest) String 

func (m *CreateBranchRequest) String() string

func (*CreateBranchRequest) Unmarshal 

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

func (*CreateBranchRequest) XXX_DiscardUnknown 

func (m *CreateBranchRequest) XXX_DiscardUnknown()

func (*CreateBranchRequest) XXX_Marshal 

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

func (*CreateBranchRequest) XXX_Merge 

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

func (*CreateBranchRequest) XXX_Size 

func (m *CreateBranchRequest) XXX_Size() int

func (*CreateBranchRequest) XXX_Unmarshal 

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

type CreateObjectRequest 

type CreateObjectRequest 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 (*CreateObjectRequest) Descriptor 

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

func (*CreateObjectRequest) GetBlockRef 

func (m *CreateObjectRequest) GetBlockRef() *BlockRef

func (*CreateObjectRequest) GetObject 

func (m *CreateObjectRequest) GetObject() *Object

func (*CreateObjectRequest) Marshal 

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

func (*CreateObjectRequest) MarshalTo 

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

func (*CreateObjectRequest) MarshalToSizedBuffer 

func (m *CreateObjectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateObjectRequest) ProtoMessage 

func (*CreateObjectRequest) ProtoMessage()

func (*CreateObjectRequest) Reset 

func (m *CreateObjectRequest) Reset()

func (*CreateObjectRequest) Size 

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

func (*CreateObjectRequest) String 

func (m *CreateObjectRequest) String() string

func (*CreateObjectRequest) Unmarshal 

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

func (*CreateObjectRequest) XXX_DiscardUnknown 

func (m *CreateObjectRequest) XXX_DiscardUnknown()

func (*CreateObjectRequest) XXX_Marshal 

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

func (*CreateObjectRequest) XXX_Merge 

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

func (*CreateObjectRequest) XXX_Size 

func (m *CreateObjectRequest) XXX_Size() int

func (*CreateObjectRequest) XXX_Unmarshal 

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

type CreateRepoRequest 

type CreateRepoRequest struct {
	Repo                 *Repo    `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Update               bool     `protobuf:"varint,4,opt,name=update,proto3" json:"update,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRepoRequest) Descriptor 

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

func (*CreateRepoRequest) GetDescription 

func (m *CreateRepoRequest) GetDescription() string

func (*CreateRepoRequest) GetRepo 

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) GetUpdate 

func (m *CreateRepoRequest) GetUpdate() bool

func (*CreateRepoRequest) Marshal 

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

func (*CreateRepoRequest) MarshalTo 

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

func (*CreateRepoRequest) MarshalToSizedBuffer 

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

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset 

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) Size 

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

func (*CreateRepoRequest) String 

func (m *CreateRepoRequest) String() string

func (*CreateRepoRequest) Unmarshal 

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

func (*CreateRepoRequest) XXX_DiscardUnknown 

func (m *CreateRepoRequest) XXX_DiscardUnknown()

func (*CreateRepoRequest) XXX_Marshal 

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

func (*CreateRepoRequest) XXX_Merge 

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

func (*CreateRepoRequest) XXX_Size 

func (m *CreateRepoRequest) XXX_Size() int

func (*CreateRepoRequest) XXX_Unmarshal 

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

type DeleteBranchRequest 

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 

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

func (*DeleteBranchRequest) GetBranch 

func (m *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) GetForce 

func (m *DeleteBranchRequest) GetForce() bool

func (*DeleteBranchRequest) Marshal 

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

func (*DeleteBranchRequest) MarshalTo 

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

func (*DeleteBranchRequest) MarshalToSizedBuffer 

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

func (*DeleteBranchRequest) ProtoMessage 

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset 

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) Size 

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

func (*DeleteBranchRequest) String 

func (m *DeleteBranchRequest) String() string

func (*DeleteBranchRequest) Unmarshal 

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

func (*DeleteBranchRequest) XXX_DiscardUnknown 

func (m *DeleteBranchRequest) XXX_DiscardUnknown()

func (*DeleteBranchRequest) XXX_Marshal 

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

func (*DeleteBranchRequest) XXX_Merge 

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

func (*DeleteBranchRequest) XXX_Size 

func (m *DeleteBranchRequest) XXX_Size() int

func (*DeleteBranchRequest) XXX_Unmarshal 

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

type DeleteCommitRequest 

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

func (*DeleteCommitRequest) Descriptor 

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

func (*DeleteCommitRequest) GetCommit 

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) Marshal 

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

func (*DeleteCommitRequest) MarshalTo 

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

func (*DeleteCommitRequest) MarshalToSizedBuffer 

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

func (*DeleteCommitRequest) ProtoMessage 

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset 

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) Size 

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

func (*DeleteCommitRequest) String 

func (m *DeleteCommitRequest) String() string

func (*DeleteCommitRequest) Unmarshal 

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

func (*DeleteCommitRequest) XXX_DiscardUnknown 

func (m *DeleteCommitRequest) XXX_DiscardUnknown()

func (*DeleteCommitRequest) XXX_Marshal 

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

func (*DeleteCommitRequest) XXX_Merge 

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

func (*DeleteCommitRequest) XXX_Size 

func (m *DeleteCommitRequest) XXX_Size() int

func (*DeleteCommitRequest) XXX_Unmarshal 

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

type DeleteFileRequest 

type DeleteFileRequest struct {
	File                 *File    `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteFileRequest) Descriptor 

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

func (*DeleteFileRequest) GetFile 

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) Marshal 

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

func (*DeleteFileRequest) MarshalTo 

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

func (*DeleteFileRequest) MarshalToSizedBuffer 

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

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset 

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) Size 

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

func (*DeleteFileRequest) String 

func (m *DeleteFileRequest) String() string

func (*DeleteFileRequest) Unmarshal 

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

func (*DeleteFileRequest) XXX_DiscardUnknown 

func (m *DeleteFileRequest) XXX_DiscardUnknown()

func (*DeleteFileRequest) XXX_Marshal 

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

func (*DeleteFileRequest) XXX_Merge 

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

func (*DeleteFileRequest) XXX_Size 

func (m *DeleteFileRequest) XXX_Size() int

func (*DeleteFileRequest) XXX_Unmarshal 

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

type DeleteObjectsRequest 

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 

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

func (*DeleteObjectsRequest) GetObjects 

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

func (*DeleteObjectsRequest) Marshal 

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

func (*DeleteObjectsRequest) MarshalTo 

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

func (*DeleteObjectsRequest) MarshalToSizedBuffer 

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

func (*DeleteObjectsRequest) ProtoMessage 

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) Reset 

func (m *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) Size 

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

func (*DeleteObjectsRequest) String 

func (m *DeleteObjectsRequest) String() string

func (*DeleteObjectsRequest) Unmarshal 

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

func (*DeleteObjectsRequest) XXX_DiscardUnknown 

func (m *DeleteObjectsRequest) XXX_DiscardUnknown()

func (*DeleteObjectsRequest) XXX_Marshal 

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

func (*DeleteObjectsRequest) XXX_Merge 

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

func (*DeleteObjectsRequest) XXX_Size 

func (m *DeleteObjectsRequest) XXX_Size() int

func (*DeleteObjectsRequest) XXX_Unmarshal 

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

type DeleteObjectsResponse 

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

func (*DeleteObjectsResponse) Descriptor 

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

func (*DeleteObjectsResponse) Marshal 

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

func (*DeleteObjectsResponse) MarshalTo 

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

func (*DeleteObjectsResponse) MarshalToSizedBuffer 

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

func (*DeleteObjectsResponse) ProtoMessage 

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) Reset 

func (m *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) Size 

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

func (*DeleteObjectsResponse) String 

func (m *DeleteObjectsResponse) String() string

func (*DeleteObjectsResponse) Unmarshal 

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

func (*DeleteObjectsResponse) XXX_DiscardUnknown 

func (m *DeleteObjectsResponse) XXX_DiscardUnknown()

func (*DeleteObjectsResponse) XXX_Marshal 

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

func (*DeleteObjectsResponse) XXX_Merge 

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

func (*DeleteObjectsResponse) XXX_Size 

func (m *DeleteObjectsResponse) XXX_Size() int

func (*DeleteObjectsResponse) XXX_Unmarshal 

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

type DeleteRepoRequest 

type DeleteRepoRequest struct {
	Repo                 *Repo    `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Force                bool     `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	All                  bool     `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRepoRequest) Descriptor 

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

func (*DeleteRepoRequest) GetAll 

func (m *DeleteRepoRequest) GetAll() bool

func (*DeleteRepoRequest) GetForce 

func (m *DeleteRepoRequest) GetForce() bool

func (*DeleteRepoRequest) GetRepo 

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) Marshal 

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

func (*DeleteRepoRequest) MarshalTo 

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

func (*DeleteRepoRequest) MarshalToSizedBuffer 

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

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset 

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) Size 

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

func (*DeleteRepoRequest) String 

func (m *DeleteRepoRequest) String() string

func (*DeleteRepoRequest) Unmarshal 

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

func (*DeleteRepoRequest) XXX_DiscardUnknown 

func (m *DeleteRepoRequest) XXX_DiscardUnknown()

func (*DeleteRepoRequest) XXX_Marshal 

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

func (*DeleteRepoRequest) XXX_Merge 

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

func (*DeleteRepoRequest) XXX_Size 

func (m *DeleteRepoRequest) XXX_Size() int

func (*DeleteRepoRequest) XXX_Unmarshal 

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

type DeleteTagsRequest 

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 

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

func (*DeleteTagsRequest) GetTags 

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

func (*DeleteTagsRequest) Marshal 

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

func (*DeleteTagsRequest) MarshalTo 

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

func (*DeleteTagsRequest) MarshalToSizedBuffer 

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

func (*DeleteTagsRequest) ProtoMessage 

func (*DeleteTagsRequest) ProtoMessage()

func (*DeleteTagsRequest) Reset 

func (m *DeleteTagsRequest) Reset()

func (*DeleteTagsRequest) Size 

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

func (*DeleteTagsRequest) String 

func (m *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Unmarshal 

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

func (*DeleteTagsRequest) XXX_DiscardUnknown 

func (m *DeleteTagsRequest) XXX_DiscardUnknown()

func (*DeleteTagsRequest) XXX_Marshal 

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

func (*DeleteTagsRequest) XXX_Merge 

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

func (*DeleteTagsRequest) XXX_Size 

func (m *DeleteTagsRequest) XXX_Size() int

func (*DeleteTagsRequest) XXX_Unmarshal 

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

type DeleteTagsResponse 

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

func (*DeleteTagsResponse) Descriptor 

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

func (*DeleteTagsResponse) Marshal 

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

func (*DeleteTagsResponse) MarshalTo 

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

func (*DeleteTagsResponse) MarshalToSizedBuffer 

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

func (*DeleteTagsResponse) ProtoMessage 

func (*DeleteTagsResponse) ProtoMessage()

func (*DeleteTagsResponse) Reset 

func (m *DeleteTagsResponse) Reset()

func (*DeleteTagsResponse) Size 

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

func (*DeleteTagsResponse) String 

func (m *DeleteTagsResponse) String() string

func (*DeleteTagsResponse) Unmarshal 

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

func (*DeleteTagsResponse) XXX_DiscardUnknown 

func (m *DeleteTagsResponse) XXX_DiscardUnknown()

func (*DeleteTagsResponse) XXX_Marshal 

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

func (*DeleteTagsResponse) XXX_Merge 

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

func (*DeleteTagsRes