pfs

package
v1.7.0-6f456f1e02272f5... Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package pfs is a generated protocol buffer package.

It is generated from these files: 

client/pfs/pfs.proto

It has these top-level messages: 

Repo
Branch
BranchInfo
BranchInfos
File
Block
Object
Tag
RepoInfo
RepoAuthInfo
Commit
CommitRange
CommitInfo
FileInfo
ByteRange
BlockRef
ObjectInfo
CreateRepoRequest
InspectRepoRequest
ListRepoRequest
ListRepoResponse
DeleteRepoRequest
StartCommitRequest
BuildCommitRequest
FinishCommitRequest
InspectCommitRequest
ListCommitRequest
CommitInfos
CreateBranchRequest
InspectBranchRequest
ListBranchRequest
DeleteBranchRequest
DeleteCommitRequest
FlushCommitRequest
SubscribeCommitRequest
GetFileRequest
OverwriteIndex
PutFileRequest
PutFileRecord
PutFileRecords
CopyFileRequest
InspectFileRequest
ListFileRequest
GlobFileRequest
FileInfos
DiffFileRequest
DiffFileResponse
DeleteFileRequest
PutObjectRequest
GetObjectsRequest
TagObjectRequest
ListObjectsRequest
ListTagsRequest
ListTagsResponse
DeleteObjectsRequest
DeleteObjectsResponse
DeleteTagsRequest
DeleteTagsResponse
CheckObjectRequest
CheckObjectResponse
Objects
ObjectIndex

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")
)
View Source 
var (
	// ChunkSize is the size of file chunks when resumable upload is used
	ChunkSize = int64(16 * 1024 * 1024) // 16 MB
)
View Source 
var Delimiter_name = map[int32]string{
	0: "NONE",
	1: "JSON",
	2: "LINE",
}
View Source 
var Delimiter_value = map[string]int32{
	"NONE": 0,
	"JSON": 1,
	"LINE": 2,
}
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,
}

Functions

func EncodeHash added in v1.6.0 

func EncodeHash(bytes []byte) string

EncodeHash encodes a hash into a readable format.

func NewHash added in v1.6.0 

func NewHash() hash.Hash

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

func RegisterAPIServer 

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

func RegisterObjectAPIServer added in v1.3.9 

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

Types

type APIClient 

type APIClient interface {
	// Repo rpcs
	// CreateRepo creates a new repo.
	// An error is returned if the repo already exists.
	CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.Empty, error)
	// GetFile returns a byte stream of the contents of the file.
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (API_GetFileClient, error)
	// InspectFile returns info about a file.
	InspectFile(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error)
	// ListFile returns info about all files. This is deprecated in favor of
	// ListFileStream
	ListFile(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*FileInfos, error)
	// ListFileStream is a streaming version of ListFile
	// TODO(msteffen): When the dash has been updated to use ListFileStream,
	// replace ListFile with this RPC (https://github.com/pachyderm/dash/issues/201)
	ListFileStream(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (API_ListFileStreamClient, error)
	// GlobFile returns info about all files. This is deprecated in favor of
	// GlobFileStream
	GlobFile(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (*FileInfos, error)
	// GlobFileStream is a streaming version of GlobFile
	// TODO(msteffen): When the dash has been updated to use GlobFileStream,
	// replace GlobFile with this RPC (https://github.com/pachyderm/dash/issues/201)
	GlobFileStream(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (API_GlobFileStreamClient, error)
	// DiffFile returns the differences between 2 paths at 2 commits.
	DiffFile(ctx context.Context, in *DiffFileRequest, opts ...grpc.CallOption) (*DiffFileResponse, error)
	// DeleteFile deletes a file.
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	// DeleteAll deletes everything
	DeleteAll(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
}

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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.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) (*google_protobuf.Empty, error)
	// GetFile returns a byte stream of the contents of the file.
	GetFile(*GetFileRequest, API_GetFileServer) error
	// InspectFile returns info about a file.
	InspectFile(context.Context, *InspectFileRequest) (*FileInfo, error)
	// ListFile returns info about all files. This is deprecated in favor of
	// ListFileStream
	ListFile(context.Context, *ListFileRequest) (*FileInfos, error)
	// ListFileStream is a streaming version of ListFile
	// TODO(msteffen): When the dash has been updated to use ListFileStream,
	// replace ListFile with this RPC (https://github.com/pachyderm/dash/issues/201)
	ListFileStream(*ListFileRequest, API_ListFileStreamServer) error
	// GlobFile returns info about all files. This is deprecated in favor of
	// GlobFileStream
	GlobFile(context.Context, *GlobFileRequest) (*FileInfos, error)
	// GlobFileStream is a streaming version of GlobFile
	// TODO(msteffen): When the dash has been updated to use GlobFileStream,
	// replace GlobFile with this RPC (https://github.com/pachyderm/dash/issues/201)
	GlobFileStream(*GlobFileRequest, API_GlobFileStreamServer) error
	// DiffFile returns the differences between 2 paths at 2 commits.
	DiffFile(context.Context, *DiffFileRequest) (*DiffFileResponse, error)
	// DeleteFile deletes a file.
	DeleteFile(context.Context, *DeleteFileRequest) (*google_protobuf.Empty, error)
	// DeleteAll deletes everything
	DeleteAll(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error)
}

type API_FlushCommitClient added in v1.3.19 

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

type API_FlushCommitServer added in v1.3.19 

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

type API_GetFileClient 

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

type API_GetFileServer 

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

type API_GlobFileStreamClient added in v1.6.2 

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

type API_GlobFileStreamServer added in v1.6.2 

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

type API_ListCommitStreamClient added in v1.6.4 

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

type API_ListCommitStreamServer added in v1.6.4 

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

type API_ListFileStreamClient added in v1.6.2 

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

type API_ListFileStreamServer added in v1.6.2 

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

type API_PutFileClient 

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

type API_PutFileServer 

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

type API_SubscribeCommitClient added in v1.3.19 

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

type API_SubscribeCommitServer added in v1.3.19 

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

type Block 

type Block struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

func GetBlock 

func GetBlock(hash hash.Hash) *Block

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

func (*Block) Descriptor 

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

func (*Block) GetHash added in v1.3.5 

func (m *Block) GetHash() string

func (*Block) Marshal added in v1.5.0 

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

func (*Block) MarshalTo added in v1.5.0 

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

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) Size added in v1.5.0 

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

func (*Block) String 

func (m *Block) String() string

func (*Block) Unmarshal added in v1.5.0 

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

type BlockRef 

type BlockRef struct {
	Block *Block     `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
	Range *ByteRange `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
}

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 added in v1.5.0 

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

func (*BlockRef) MarshalTo added in v1.5.0 

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

func (*BlockRef) ProtoMessage 

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset 

func (m *BlockRef) Reset()

func (*BlockRef) Size added in v1.5.0 

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

func (*BlockRef) String 

func (m *BlockRef) String() string

func (*BlockRef) Unmarshal added in v1.5.0 

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

type Branch added in v1.3.19 

type Branch struct {
	Repo *Repo  `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*Branch) Descriptor added in v1.3.19 

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

func (*Branch) GetName added in v1.3.19 

func (m *Branch) GetName() string

func (*Branch) GetRepo added in v1.7.0 

func (m *Branch) GetRepo() *Repo

func (*Branch) Marshal added in v1.7.0 

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

func (*Branch) MarshalTo added in v1.7.0 

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

func (*Branch) ProtoMessage added in v1.3.19 

func (*Branch) ProtoMessage()

func (*Branch) Reset added in v1.3.19 

func (m *Branch) Reset()

func (*Branch) Size added in v1.7.0 

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

func (*Branch) String added in v1.3.19 

func (m *Branch) String() string

func (*Branch) Unmarshal added in v1.7.0 

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

type BranchInfo added in v1.5.0 

type BranchInfo struct {
	Branch           *Branch   `protobuf:"bytes,4,opt,name=branch" json:"branch,omitempty"`
	Head             *Commit   `protobuf:"bytes,2,opt,name=head" json:"head,omitempty"`
	Provenance       []*Branch `protobuf:"bytes,3,rep,name=provenance" json:"provenance,omitempty"`
	Subvenance       []*Branch `protobuf:"bytes,5,rep,name=subvenance" json:"subvenance,omitempty"`
	DirectProvenance []*Branch `protobuf:"bytes,6,rep,name=direct_provenance,json=directProvenance" json:"direct_provenance,omitempty"`
	// Deprecated field left for backward compatibility.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*BranchInfo) Descriptor added in v1.5.0 

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

func (*BranchInfo) GetBranch added in v1.7.0 

func (m *BranchInfo) GetBranch() *Branch

func (*BranchInfo) GetDirectProvenance added in v1.7.0 

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

func (*BranchInfo) GetHead added in v1.5.0 

func (m *BranchInfo) GetHead() *Commit

func (*BranchInfo) GetName added in v1.5.0 

func (m *BranchInfo) GetName() string

func (*BranchInfo) GetProvenance added in v1.7.0 

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

func (*BranchInfo) GetSubvenance added in v1.7.0 

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

func (*BranchInfo) Marshal added in v1.5.0 

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

func (*BranchInfo) MarshalTo added in v1.5.0 

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

func (*BranchInfo) ProtoMessage added in v1.5.0 

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) Reset added in v1.5.0 

func (m *BranchInfo) Reset()

func (*BranchInfo) Size added in v1.5.0 

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

func (*BranchInfo) String added in v1.5.0 

func (m *BranchInfo) String() string

func (*BranchInfo) Unmarshal added in v1.5.0 

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

type BranchInfos added in v1.5.0 

type BranchInfos struct {
	BranchInfo []*BranchInfo `protobuf:"bytes,1,rep,name=branch_info,json=branchInfo" json:"branch_info,omitempty"`
}

func (*BranchInfos) Descriptor added in v1.5.0 

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

func (*BranchInfos) GetBranchInfo added in v1.5.0 

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

func (*BranchInfos) Marshal added in v1.5.0 

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

func (*BranchInfos) MarshalTo added in v1.5.0 

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

func (*BranchInfos) ProtoMessage added in v1.5.0 

func (*BranchInfos) ProtoMessage()

func (*BranchInfos) Reset added in v1.5.0 

func (m *BranchInfos) Reset()

func (*BranchInfos) Size added in v1.5.0 

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

func (*BranchInfos) String added in v1.5.0 

func (m *BranchInfos) String() string

func (*BranchInfos) Unmarshal added in v1.5.0 

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

type BuildCommitRequest added in v1.3.19 

type BuildCommitRequest struct {
	Parent     *Commit   `protobuf:"bytes,1,opt,name=parent" json:"parent,omitempty"`
	Branch     string    `protobuf:"bytes,4,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance []*Commit `protobuf:"bytes,2,rep,name=provenance" json:"provenance,omitempty"`
	Tree       *Object   `protobuf:"bytes,3,opt,name=tree" json:"tree,omitempty"`
	// ID sets the ID of the created commit.
	ID string `protobuf:"bytes,5,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*BuildCommitRequest) Descriptor added in v1.3.19 

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

func (*BuildCommitRequest) GetBranch added in v1.3.19 

func (m *BuildCommitRequest) GetBranch() string

func (*BuildCommitRequest) GetID added in v1.6.9 

func (m *BuildCommitRequest) GetID() string

func (*BuildCommitRequest) GetParent added in v1.3.19 

func (m *BuildCommitRequest) GetParent() *Commit

func (*BuildCommitRequest) GetProvenance added in v1.3.19 

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

func (*BuildCommitRequest) GetTree added in v1.3.19 

func (m *BuildCommitRequest) GetTree() *Object

func (*BuildCommitRequest) Marshal added in v1.5.0 

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

func (*BuildCommitRequest) MarshalTo added in v1.5.0 

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

func (*BuildCommitRequest) ProtoMessage added in v1.3.19 

func (*BuildCommitRequest) ProtoMessage()

func (*BuildCommitRequest) Reset added in v1.3.19 

func (m *BuildCommitRequest) Reset()

func (*BuildCommitRequest) Size added in v1.5.0 

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

func (*BuildCommitRequest) String added in v1.3.19 

func (m *BuildCommitRequest) String() string

func (*BuildCommitRequest) Unmarshal added in v1.5.0 

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

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"`
}

func (*ByteRange) Descriptor 

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

func (*ByteRange) GetLower added in v1.3.5 

func (m *ByteRange) GetLower() uint64

func (*ByteRange) GetUpper added in v1.3.5 

func (m *ByteRange) GetUpper() uint64

func (*ByteRange) Marshal added in v1.5.0 

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

func (*ByteRange) MarshalTo added in v1.5.0 

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

func (*ByteRange) ProtoMessage 

func (*ByteRange) ProtoMessage()

func (*ByteRange) Reset 

func (m *ByteRange) Reset()

func (*ByteRange) Size added in v1.5.0 

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

func (*ByteRange) String 

func (m *ByteRange) String() string

func (*ByteRange) Unmarshal added in v1.5.0 

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

type CheckObjectRequest added in v1.4.7 

type CheckObjectRequest struct {
	Object *Object `protobuf:"bytes,1,opt,name=object" json:"object,omitempty"`
}

func (*CheckObjectRequest) Descriptor added in v1.4.7 

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

func (*CheckObjectRequest) GetObject added in v1.4.7 

func (m *CheckObjectRequest) GetObject() *Object

func (*CheckObjectRequest) Marshal added in v1.5.0 

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

func (*CheckObjectRequest) MarshalTo added in v1.5.0 

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

func (*CheckObjectRequest) ProtoMessage added in v1.4.7 

func (*CheckObjectRequest) ProtoMessage()

func (*CheckObjectRequest) Reset added in v1.4.7 

func (m *CheckObjectRequest) Reset()

func (*CheckObjectRequest) Size added in v1.5.0 

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

func (*CheckObjectRequest) String added in v1.4.7 

func (m *CheckObjectRequest) String() string

func (*CheckObjectRequest) Unmarshal added in v1.5.0 

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

type CheckObjectResponse added in v1.4.7 

type CheckObjectResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
}

func (*CheckObjectResponse) Descriptor added in v1.4.7 

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

func (*CheckObjectResponse) GetExists added in v1.4.7 

func (m *CheckObjectResponse) GetExists() bool

func (*CheckObjectResponse) Marshal added in v1.5.0 

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

func (*CheckObjectResponse) MarshalTo added in v1.5.0 

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

func (*CheckObjectResponse) ProtoMessage added in v1.4.7 

func (*CheckObjectResponse) ProtoMessage()

func (*CheckObjectResponse) Reset added in v1.4.7 

func (m *CheckObjectResponse) Reset()

func (*CheckObjectResponse) Size added in v1.5.0 

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

func (*CheckObjectResponse) String added in v1.4.7 

func (m *CheckObjectResponse) String() string

func (*CheckObjectResponse) Unmarshal added in v1.5.0 

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

type Commit 

type Commit struct {
	Repo *Repo  `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	ID   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}

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) FullID added in v1.3.19 

func (c *Commit) FullID() string

FullID prints repoName/CommitID

func (*Commit) GetID added in v1.3.5 

func (m *Commit) GetID() string

func (*Commit) GetRepo 

func (m *Commit) GetRepo() *Repo

func (*Commit) Marshal added in v1.5.0 

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

func (*Commit) MarshalTo added in v1.5.0 

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

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) Size added in v1.5.0 

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

func (*Commit) String 

func (m *Commit) String() string

func (*Commit) Unmarshal added in v1.5.0 

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

type CommitInfo 

type CommitInfo struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	// description is a user-provided script describing this commit
	Description  string                      `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"`
	ParentCommit *Commit                     `protobuf:"bytes,2,opt,name=parent_commit,json=parentCommit" json:"parent_commit,omitempty"`
	ChildCommits []*Commit                   `protobuf:"bytes,11,rep,name=child_commits,json=childCommits" json:"child_commits,omitempty"`
	Started      *google_protobuf1.Timestamp `protobuf:"bytes,3,opt,name=started" json:"started,omitempty"`
	Finished     *google_protobuf1.Timestamp `protobuf:"bytes,4,opt,name=finished" json:"finished,omitempty"`
	SizeBytes    uint64                      `protobuf:"varint,5,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// Commits on which this commit is provenant. provenance[i] is a commit in
	// branch_provenance[i] (a branch name, and one of the branches on which this
	// commit's branch is provenant)
	Provenance       []*Commit      `protobuf:"bytes,6,rep,name=provenance" json:"provenance,omitempty"`
	BranchProvenance []*Branch      `protobuf:"bytes,10,rep,name=branch_provenance,json=branchProvenance" json:"branch_provenance,omitempty"`
	Subvenance       []*CommitRange `protobuf:"bytes,9,rep,name=subvenance" 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" json:"tree,omitempty"`
}

CommitInfo is the main data structure representing a commit in etcd

func (*CommitInfo) Descriptor 

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

func (*CommitInfo) GetBranchProvenance added in v1.7.0 

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

func (*CommitInfo) GetChildCommits added in v1.7.0 

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

func (*CommitInfo) GetCommit 

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetDescription added in v1.6.6 

func (m *CommitInfo) GetDescription() string

func (*CommitInfo) GetFinished 

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

func (*CommitInfo) GetParentCommit 

func (m *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetProvenance added in v1.1.0 

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

func (*CommitInfo) GetSizeBytes added in v1.3.5 

func (m *CommitInfo) GetSizeBytes() uint64

func (*CommitInfo) GetStarted 

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

func (*CommitInfo) GetSubvenance added in v1.7.0 

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

func (*CommitInfo) GetTree added in v1.3.19 

func (m *CommitInfo) GetTree() *Object

func (*CommitInfo) Marshal added in v1.5.0 

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

func (*CommitInfo) MarshalTo added in v1.5.0 

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

func (*CommitInfo) ProtoMessage 

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset 

func (m *CommitInfo) Reset()

func (*CommitInfo) Size added in v1.5.0 

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

func (*CommitInfo) String 

func (m *CommitInfo) String() string

func (*CommitInfo) Unmarshal added in v1.5.0 

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

type CommitInfos 

type CommitInfos struct {
	CommitInfo []*CommitInfo `protobuf:"bytes,1,rep,name=commit_info,json=commitInfo" json:"commit_info,omitempty"`
}

func (*CommitInfos) Descriptor 

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

func (*CommitInfos) GetCommitInfo 

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

func (*CommitInfos) Marshal added in v1.5.0 

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

func (*CommitInfos) MarshalTo added in v1.5.0 

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

func (*CommitInfos) ProtoMessage 

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset 

func (m *CommitInfos) Reset()

func (*CommitInfos) Size added in v1.5.0 

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

func (*CommitInfos) String 

func (m *CommitInfos) String() string

func (*CommitInfos) Unmarshal added in v1.5.0 

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

type CommitRange added in v1.7.0 

type CommitRange struct {
	Lower *Commit `protobuf:"bytes,1,opt,name=lower" json:"lower,omitempty"`
	Upper *Commit `protobuf:"bytes,2,opt,name=upper" json:"upper,omitempty"`
}

CommitRange represents chain of commits with Lower being an ancestor of Upper or, in the case of a range of size 1, the same commit.

func (*CommitRange) Descriptor added in v1.7.0 

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

func (*CommitRange) GetLower added in v1.7.0 

func (m *CommitRange) GetLower() *Commit

func (*CommitRange) GetUpper added in v1.7.0 

func (m *CommitRange) GetUpper() *Commit

func (*CommitRange) Marshal added in v1.7.0 

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

func (*CommitRange) MarshalTo added in v1.7.0 

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

func (*CommitRange) ProtoMessage added in v1.7.0 

func (*CommitRange) ProtoMessage()

func (*CommitRange) Reset added in v1.7.0 

func (m *CommitRange) Reset()

func (*CommitRange) Size added in v1.7.0 

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

func (*CommitRange) String added in v1.7.0 

func (m *CommitRange) String() string

func (*CommitRange) Unmarshal added in v1.7.0 

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

type CopyFileRequest added in v1.6.0 

type CopyFileRequest struct {
	Src       *File `protobuf:"bytes,1,opt,name=src" json:"src,omitempty"`
	Dst       *File `protobuf:"bytes,2,opt,name=dst" json:"dst,omitempty"`
	Overwrite bool  `protobuf:"varint,3,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
}

func (*CopyFileRequest) Descriptor added in v1.6.0 

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

func (*CopyFileRequest) GetDst added in v1.6.0 

func (m *CopyFileRequest) GetDst() *File

func (*CopyFileRequest) GetOverwrite added in v1.6.0 

func (m *CopyFileRequest) GetOverwrite() bool

func (*CopyFileRequest) GetSrc added in v1.6.0 

func (m *CopyFileRequest) GetSrc() *File

func (*CopyFileRequest) Marshal added in v1.6.0 

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

func (*CopyFileRequest) MarshalTo added in v1.6.0 

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

func (*CopyFileRequest) ProtoMessage added in v1.6.0 

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset added in v1.6.0 

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) Size added in v1.6.0 

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

func (*CopyFileRequest) String added in v1.6.0 

func (m *CopyFileRequest) String() string

func (*CopyFileRequest) Unmarshal added in v1.6.0 

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

type CreateBranchRequest added in v1.7.0 

type CreateBranchRequest struct {
	Head *Commit `protobuf:"bytes,1,opt,name=head" 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" json:"branch,omitempty"`
	Provenance []*Branch `protobuf:"bytes,4,rep,name=provenance" json:"provenance,omitempty"`
}

func (*CreateBranchRequest) Descriptor added in v1.7.0 

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

func (*CreateBranchRequest) GetBranch added in v1.7.0 

func (m *CreateBranchRequest) GetBranch() *Branch

func (*CreateBranchRequest) GetHead added in v1.7.0 

func (m *CreateBranchRequest) GetHead() *Commit

func (*CreateBranchRequest) GetProvenance added in v1.7.0 

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

func (*CreateBranchRequest) GetSBranch added in v1.7.0 

func (m *CreateBranchRequest) GetSBranch() string

func (*CreateBranchRequest) Marshal added in v1.7.0 

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

func (*CreateBranchRequest) MarshalTo added in v1.7.0 

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

func (*CreateBranchRequest) ProtoMessage added in v1.7.0 

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) Reset added in v1.7.0 

func (m *CreateBranchRequest) Reset()

func (*CreateBranchRequest) Size added in v1.7.0 

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

func (*CreateBranchRequest) String added in v1.7.0 

func (m *CreateBranchRequest) String() string

func (*CreateBranchRequest) Unmarshal added in v1.7.0 

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

type CreateRepoRequest 

type CreateRepoRequest struct {
	Repo        *Repo   `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Provenance  []*Repo `protobuf:"bytes,2,rep,name=provenance" json:"provenance,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"`
}

func (*CreateRepoRequest) Descriptor 

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

func (*CreateRepoRequest) GetDescription added in v1.4.7 

func (m *CreateRepoRequest) GetDescription() string

func (*CreateRepoRequest) GetProvenance added in v1.1.0 

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

func (*CreateRepoRequest) GetRepo 

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) GetUpdate added in v1.5.0 

func (m *CreateRepoRequest) GetUpdate() bool

func (*CreateRepoRequest) Marshal added in v1.5.0 

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

func (*CreateRepoRequest) MarshalTo added in v1.5.0 

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

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset 

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) Size added in v1.5.0 

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

func (*CreateRepoRequest) String 

func (m *CreateRepoRequest) String() string

func (*CreateRepoRequest) Unmarshal added in v1.5.0 

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

type DeleteBranchRequest added in v1.3.19 

type DeleteBranchRequest struct {
	Branch *Branch `protobuf:"bytes,1,opt,name=branch" json:"branch,omitempty"`
}

func (*DeleteBranchRequest) Descriptor added in v1.3.19 

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

func (*DeleteBranchRequest) GetBranch added in v1.3.19 

func (m *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) Marshal added in v1.5.0 

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

func (*DeleteBranchRequest) MarshalTo added in v1.5.0 

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

func (*DeleteBranchRequest) ProtoMessage added in v1.3.19 

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset added in v1.3.19 

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) Size added in v1.5.0 

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

func (*DeleteBranchRequest) String added in v1.3.19 

func (m *DeleteBranchRequest) String() string

func (*DeleteBranchRequest) Unmarshal added in v1.5.0 

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

type DeleteCommitRequest 

type DeleteCommitRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
}

func (*DeleteCommitRequest) Descriptor 

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

func (*DeleteCommitRequest) GetCommit 

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) Marshal added in v1.5.0 

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

func (*DeleteCommitRequest) MarshalTo added in v1.5.0 

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

func (*DeleteCommitRequest) ProtoMessage 

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset 

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) Size added in v1.5.0 

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

func (*DeleteCommitRequest) String 

func (m *DeleteCommitRequest) String() string

func (*DeleteCommitRequest) Unmarshal added in v1.5.0 

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

type DeleteFileRequest 

type DeleteFileRequest struct {
	File *File `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
}

func (*DeleteFileRequest) Descriptor 

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

func (*DeleteFileRequest) GetFile 

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) Marshal added in v1.5.0 

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

func (*DeleteFileRequest) MarshalTo added in v1.5.0 

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

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset 

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) Size added in v1.5.0 

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

func (*DeleteFileRequest) String 

func (m *DeleteFileRequest) String() string

func (*DeleteFileRequest) Unmarshal added in v1.5.0 

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

type DeleteObjectsRequest added in v1.4.7 

type DeleteObjectsRequest struct {
	Objects []*Object `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"`
}

func (*DeleteObjectsRequest) Descriptor added in v1.4.7 

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

func (*DeleteObjectsRequest) GetObjects added in v1.4.7 

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

func (*DeleteObjectsRequest) Marshal added in v1.5.0 

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

func (*DeleteObjectsRequest) MarshalTo added in v1.5.0 

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

func (*DeleteObjectsRequest) ProtoMessage added in v1.4.7 

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) Reset added in v1.4.7 

func (m *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) Size added in v1.5.0 

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

func (*DeleteObjectsRequest) String added in v1.4.7 

func (m *DeleteObjectsRequest) String() string

func (*DeleteObjectsRequest) Unmarshal added in v1.5.0 

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

type DeleteObjectsResponse added in v1.4.7 

type DeleteObjectsResponse struct {
}

func (*DeleteObjectsResponse) Descriptor added in v1.4.7 

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

func (*DeleteObjectsResponse) Marshal added in v1.5.0 

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

func (*DeleteObjectsResponse) MarshalTo added in v1.5.0 

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

func (*DeleteObjectsResponse) ProtoMessage added in v1.4.7 

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) Reset added in v1.4.7 

func (m *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) Size added in v1.5.0 

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

func (*DeleteObjectsResponse) String added in v1.4.7 

func (m *DeleteObjectsResponse) String() string

func (*DeleteObjectsResponse) Unmarshal added in v1.5.0 

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

type DeleteRepoRequest 

type DeleteRepoRequest struct {
	Repo  *Repo `protobuf:"bytes,1,opt,name=repo" 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"`
}

func (*DeleteRepoRequest) Descriptor 

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

func (*DeleteRepoRequest) GetAll added in v1.4.8 

func (m *DeleteRepoRequest) GetAll() bool

func (*DeleteRepoRequest) GetForce added in v1.3.5 

func (m *DeleteRepoRequest) GetForce() bool

func (*DeleteRepoRequest) GetRepo 

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) Marshal added in v1.5.0 

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

func (*DeleteRepoRequest) MarshalTo added in v1.5.0 

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

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset 

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) Size added in v1.5.0 

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

func (*DeleteRepoRequest) String 

func (m *DeleteRepoRequest) String() string

func (*DeleteRepoRequest) Unmarshal added in v1.5.0 

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

type DeleteTagsRequest added in v1.4.7 

type DeleteTagsRequest struct {
	Tags []*Tag `protobuf:"bytes,1,rep,name=tags" json:"tags,omitempty"`
}

func (*DeleteTagsRequest) Descriptor added in v1.4.7 

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

func (*DeleteTagsRequest) GetTags added in v1.4.7 

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

func (*DeleteTagsRequest) Marshal added in v1.5.0 

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

func (*DeleteTagsRequest) MarshalTo added in v1.5.0 

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

func (*DeleteTagsRequest) ProtoMessage added in v1.4.7 

func (*DeleteTagsRequest) ProtoMessage()

func (*DeleteTagsRequest) Reset added in v1.4.7 

func (m *DeleteTagsRequest) Reset()

func (*DeleteTagsRequest) Size added in v1.5.0 

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

func (*DeleteTagsRequest) String added in v1.4.7 

func (m *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Unmarshal added in v1.5.0 

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

type DeleteTagsResponse added in v1.4.7 

type DeleteTagsResponse struct {
}

func (*DeleteTagsResponse) Descriptor added in v1.4.7 

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

func (*DeleteTagsResponse) Marshal added in v1.5.0 

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

func (*DeleteTagsResponse) MarshalTo added in v1.5.0 

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

func (*DeleteTagsResponse) ProtoMessage added in v1.4.7 

func (*DeleteTagsResponse) ProtoMessage()

func (*DeleteTagsResponse) Reset added in v1.4.7 

func (m *DeleteTagsResponse) Reset()

func (*DeleteTagsResponse) Size added in v1.5.0 

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

func (*DeleteTagsResponse) String added in v1.4.7 

func (m *DeleteTagsResponse) String() string

func (*DeleteTagsResponse) Unmarshal added in v1.5.0 

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

type Delimiter added in v1.1.0 

type Delimiter int32
const (
	Delimiter_NONE Delimiter = 0
	Delimiter_JSON Delimiter = 1
	Delimiter_LINE Delimiter = 2
)

func (Delimiter) EnumDescriptor added in v1.1.0 

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

func (Delimiter) String added in v1.1.0 

func (x Delimiter) String() string

type DiffFileRequest added in v1.4.8 

type DiffFileRequest struct {
	NewFile *File `protobuf:"bytes,1,opt,name=new_file,json=newFile" 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" json:"old_file,omitempty"`
	Shallow bool  `protobuf:"varint,3,opt,name=shallow,proto3" json:"shallow,omitempty"`
}

func (*DiffFileRequest) Descriptor added in v1.4.8 

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

func (*DiffFileRequest) GetNewFile added in v1.4.8 

func (m *DiffFileRequest) GetNewFile() *File

func (*DiffFileRequest) GetOldFile added in v1.4.8 

func (m *DiffFileRequest) GetOldFile() *File

func (*DiffFileRequest) GetShallow added in v1.5.2 

func (m *DiffFileRequest) GetShallow() bool

func (*DiffFileRequest) Marshal added in v1.5.0 

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

func (*DiffFileRequest) MarshalTo added in v1.5.0 

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

func (*DiffFileRequest) ProtoMessage added in v1.4.8 

func (*DiffFileRequest) ProtoMessage()

func (*DiffFileRequest) Reset added in v1.4.8 

func (m *DiffFileRequest) Reset()

func (*DiffFileRequest) Size added in v1.5.0 

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

func (*DiffFileRequest) String added in v1.4.8 

func (m *DiffFileRequest) String() string

func (*DiffFileRequest) Unmarshal added in v1.5.0 

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

type DiffFileResponse added in v1.4.8 

type DiffFileResponse struct {
	NewFiles []*FileInfo `protobuf:"bytes,1,rep,name=new_files,json=newFiles" json:"new_files,omitempty"`
	OldFiles []*FileInfo `protobuf:"bytes,2,rep,name=old_files,json=oldFiles" json:"old_files,omitempty"`
}

func (*DiffFileResponse) Descriptor added in v1.4.8 

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

func (*DiffFileResponse) GetNewFiles added in v1.4.8 

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

func (*DiffFileResponse) GetOldFiles added in v1.4.8 

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

func (*DiffFileResponse) Marshal added in v1.5.0 

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

func (*DiffFileResponse) MarshalTo added in v1.5.0 

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

func (*DiffFileResponse) ProtoMessage added in v1.4.8 

func (*DiffFileResponse) ProtoMessage()

func (*DiffFileResponse) Reset added in v1.4.8 

func (m *DiffFileResponse) Reset()

func (*DiffFileResponse) Size added in v1.5.0 

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

func (*DiffFileResponse) String added in v1.4.8 

func (m *DiffFileResponse) String() string

func (*DiffFileResponse) Unmarshal added in v1.5.0 

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

type File 

type File struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Path   string  `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
}

func (*File) Descriptor 

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

func (*File) GetCommit 

func (m *File) GetCommit() *Commit

func (*File) GetPath added in v1.3.5 

func (m *File) GetPath() string

func (*File) Marshal added in v1.5.0 

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

func (*File) MarshalTo added in v1.5.0 

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

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) Reset 

func (m *File) Reset()

func (*File) Size added in v1.5.0 

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

func (*File) String 

func (m *File) String() string

func (*File) Unmarshal added in v1.5.0 

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

type FileInfo 

type FileInfo struct {
	File      *File    `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	FileType  FileType `protobuf:"varint,2,opt,name=file_type,json=fileType,proto3,enum=pfs.FileType" json:"file_type,omitempty"`
	SizeBytes uint64   `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// the base names (i.e. just the filenames, not the full paths) of
	// the children
	Children []string  `protobuf:"bytes,6,rep,name=children" json:"children,omitempty"`
	Objects  []*Object `protobuf:"bytes,8,rep,name=objects" json:"objects,omitempty"`
	Hash     []byte    `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
}

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetChildren 

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

func (*FileInfo) GetFile 

func (m *FileInfo) GetFile() *File

func (*FileInfo) GetFileType added in v1.3.5 

func (m *FileInfo) GetFileType() FileType

func (*FileInfo) GetHash added in v1.3.19 

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

func (*FileInfo) GetObjects added in v1.4.6 

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

func (*FileInfo) GetSizeBytes added in v1.3.5 

func (m *FileInfo) GetSizeBytes() uint64

func (*FileInfo) Marshal added in v1.5.0 

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

func (*FileInfo) MarshalTo added in v1.5.0 

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

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) Size added in v1.5.0 

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

func (*FileInfo) String 

func (m *FileInfo) String() string

func (*FileInfo) Unmarshal added in v1.5.0 

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

type FileInfos 

type FileInfos struct {
	FileInfo []*FileInfo `protobuf:"bytes,1,rep,name=file_info,json=fileInfo" json:"file_info,omitempty"`
}

FileInfos is the result of both ListFile and GlobFile

func (*FileInfos) Descriptor 

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

func (*FileInfos) GetFileInfo 

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

func (*FileInfos) Marshal added in v1.5.0 

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

func (*FileInfos) MarshalTo added in v1.5.0 

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

func (*FileInfos) ProtoMessage 

func (*FileInfos) ProtoMessage()

func (*FileInfos) Reset 

func (m *FileInfos) Reset()

func (*FileInfos) Size added in v1.5.0 

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

func (*FileInfos) String 

func (m *FileInfos) String() string

func (*FileInfos) Unmarshal added in v1.5.0 

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

type FileType 

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

func (FileType) EnumDescriptor 

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

func (FileType) String 

func (x FileType) String() string

type FinishCommitRequest 

type FinishCommitRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" 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" json:"tree,omitempty"`
	// If set, 'commit' will be closed (its 'finished' field will be set to the
	// current time) but its 'tree' will be left nil.
	Empty bool `protobuf:"varint,4,opt,name=empty,proto3" json:"empty,omitempty"`
}

func (*FinishCommitRequest) Descriptor 

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

func (*FinishCommitRequest) GetCommit 

func (m *FinishCommitRequest) GetCommit() *Commit

func (*FinishCommitRequest) GetDescription added in v1.6.6 

func (m *FinishCommitRequest) GetDescription() string

func (*FinishCommitRequest) GetEmpty added in v1.7.0 

func (m *FinishCommitRequest) GetEmpty() bool

func (*FinishCommitRequest) GetTree added in v1.7.0 

func (m *FinishCommitRequest) GetTree() *Object

func (*FinishCommitRequest) Marshal added in v1.5.0 

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

func (*FinishCommitRequest) MarshalTo added in v1.5.0 

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

func (*FinishCommitRequest) ProtoMessage 

func (*FinishCommitRequest) ProtoMessage()

func (*FinishCommitRequest) Reset 

func (m *FinishCommitRequest) Reset()

func (*FinishCommitRequest) Size added in v1.5.0 

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

func (*FinishCommitRequest) String 

func (m *FinishCommitRequest) String() string

func (*FinishCommitRequest) Unmarshal added in v1.5.0 

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

type FlushCommitRequest added in v1.1.0 

type FlushCommitRequest struct {
	Commits []*Commit `protobuf:"bytes,1,rep,name=commits" json:"commits,omitempty"`
	ToRepos []*Repo   `protobuf:"bytes,2,rep,name=to_repos,json=toRepos" json:"to_repos,omitempty"`
}

func (*FlushCommitRequest) Descriptor added in v1.1.0 

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

func (*FlushCommitRequest) GetCommits added in v1.3.19 

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

func (*FlushCommitRequest) GetToRepos added in v1.3.19 

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

func (*FlushCommitRequest) Marshal added in v1.5.0 

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

func (*FlushCommitRequest) MarshalTo added in v1.5.0 

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

func (*FlushCommitRequest) ProtoMessage added in v1.1.0 

func (*FlushCommitRequest) ProtoMessage()

func (*FlushCommitRequest) Reset added in v1.1.0 

func (m *FlushCommitRequest) Reset()

func (*FlushCommitRequest) Size added in v1.5.0 

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

func (*FlushCommitRequest) String added in v1.1.0 

func (m *FlushCommitRequest) String() string

func (*FlushCommitRequest) Unmarshal added in v1.5.0 

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

type GetFileRequest 

type GetFileRequest struct {
	File        *File `protobuf:"bytes,1,opt,name=file" 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"`
}

func (*GetFileRequest) Descriptor 

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

func (*GetFileRequest) GetFile 

func (m *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetOffsetBytes added in v1.3.5 

func (m *GetFileRequest) GetOffsetBytes() int64

func (*GetFileRequest) GetSizeBytes added in v1.3.5 

func (m *GetFileRequest) GetSizeBytes() int64

func (*GetFileRequest) Marshal added in v1.5.0 

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

func (*GetFileRequest) MarshalTo added in v1.5.0 

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

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) Reset 

func (m *GetFileRequest) Reset()

func (*GetFileRequest) Size added in v1.5.0 

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

func (*GetFileRequest) String 

func (m *GetFileRequest) String() string

func (*GetFileRequest) Unmarshal added in v1.5.0 

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

type GetObjectsRequest added in v1.3.19 

type GetObjectsRequest struct {
	Objects     []*Object `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"`
	OffsetBytes uint64    `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes,proto3" json:"offset_bytes,omitempty"`
	// The number of bytes we intend to read.
	SizeBytes uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// The total amount of bytes in these objects.  It's OK if it's not
	// entirely accurate or if it's unknown (in which case it'd be set to 0).
	// It's used primarily as a hint for cache eviction.
	TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
}

func (*GetObjectsRequest) Descriptor added in v1.3.19 

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

func (*GetObjectsRequest) GetObjects added in v1.3.19 

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

func (*GetObjectsRequest) GetOffsetBytes added in v1.3.19 

func (m *GetObjectsRequest) GetOffsetBytes() uint64

func (*GetObjectsRequest) GetSizeBytes added in v1.3.19 

func (m *GetObjectsRequest) GetSizeBytes() uint64

func (*GetObjectsRequest) GetTotalSize added in v1.6.0 

func (m *GetObjectsRequest) GetTotalSize() uint64

func (*GetObjectsRequest) Marshal added in v1.5.0 

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

func (*GetObjectsRequest) MarshalTo added in v1.5.0 

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

func (*GetObjectsRequest) ProtoMessage added in v1.3.19 

func (*GetObjectsRequest) ProtoMessage()

func (*GetObjectsRequest) Reset added in v1.3.19 

func (m *GetObjectsRequest) Reset()

func (*GetObjectsRequest) Size added in v1.5.0 

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

func (*GetObjectsRequest) String added in v1.3.19 

func (m *GetObjectsRequest) String() string

func (*GetObjectsRequest) Unmarshal added in v1.5.0 

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

type GlobFileRequest added in v1.3.19 

type GlobFileRequest struct {
	Commit  *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Pattern string  `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"`
}

func (*GlobFileRequest) Descriptor added in v1.3.19 

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

func (*GlobFileRequest) GetCommit added in v1.3.19 

func (m *GlobFileRequest) GetCommit() *Commit

func (*GlobFileRequest) GetPattern added in v1.3.19 

func (m *GlobFileRequest) GetPattern() string

func (*GlobFileRequest) Marshal added in v1.5.0 

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

func (*GlobFileRequest) MarshalTo added in v1.5.0 

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

func (*GlobFileRequest) ProtoMessage added in v1.3.19 

func (*GlobFileRequest) ProtoMessage()

func (*GlobFileRequest) Reset added in v1.3.19 

func (m *GlobFileRequest) Reset()

func (*GlobFileRequest) Size added in v1.5.0 

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

func (*GlobFileRequest) String added in v1.3.19 

func (m *GlobFileRequest) String() string

func (*GlobFileRequest) Unmarshal added in v1.5.0 

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

type InspectBranchRequest added in v1.7.0 

type InspectBranchRequest struct {
	Branch *Branch `protobuf:"bytes,1,opt,name=branch" json:"branch,omitempty"`
}

func (*InspectBranchRequest) Descriptor added in v1.7.0 

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

func (*InspectBranchRequest) GetBranch added in v1.7.0 

func (m *InspectBranchRequest) GetBranch() *Branch

func (*InspectBranchRequest) Marshal added in v1.7.0 

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

func (*InspectBranchRequest) MarshalTo added in v1.7.0 

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

func (*InspectBranchRequest) ProtoMessage added in v1.7.0 

func (*InspectBranchRequest) ProtoMessage()

func (*InspectBranchRequest) Reset added in v1.7.0 

func (m *InspectBranchRequest) Reset()

func (*InspectBranchRequest) Size added in v1.7.0 

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

func (*InspectBranchRequest) String added in v1.7.0 

func (m *InspectBranchRequest) String() string

func (*InspectBranchRequest) Unmarshal added in v1.7.0 

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

type InspectCommitRequest 

type InspectCommitRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	// Block, if true, causes InspectCommit to block until the commit has been
	// finished.
	Block bool `protobuf:"varint,2,opt,name=block,proto3" json:"block,omitempty"`
}

func (*InspectCommitRequest) Descriptor 

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

func (*InspectCommitRequest) GetBlock added in v1.7.0 

func (m *InspectCommitRequest) GetBlock() bool

func (*InspectCommitRequest) GetCommit 

func (m *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) Marshal added in v1.5.0 

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

func (*InspectCommitRequest) MarshalTo added in v1.5.0 

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

func (*InspectCommitRequest) ProtoMessage 

func (*InspectCommitRequest) ProtoMessage()

func (*InspectCommitRequest) Reset 

func (m *InspectCommitRequest) Reset()

func (*InspectCommitRequest) Size added in v1.5.0 

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

func (*InspectCommitRequest) String 

func (m *InspectCommitRequest) String() string

func (*InspectCommitRequest) Unmarshal added in v1.5.0 

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

type InspectFileRequest 

type InspectFileRequest struct {
	File *File `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
}

func (*InspectFileRequest) Descriptor 

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

func (*InspectFileRequest) GetFile 

func (m *InspectFileRequest) GetFile() *File

func (*InspectFileRequest) Marshal added in v1.5.0 

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

func (*InspectFileRequest) MarshalTo added in v1.5.0 

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

func (*InspectFileRequest) ProtoMessage 

func (*InspectFileRequest) ProtoMessage()

func (*InspectFileRequest) Reset 

func (m *InspectFileRequest) Reset()

func (*InspectFileRequest) Size added in v1.5.0 

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

func (*InspectFileRequest) String 

func (m *InspectFileRequest) String() string

func (*InspectFileRequest) Unmarshal added in v1.5.0 

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

type InspectRepoRequest 

type InspectRepoRequest struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
}

func (*InspectRepoRequest) Descriptor 

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

func (*InspectRepoRequest) GetRepo 

func (m *InspectRepoRequest) GetRepo() *Repo

func (*InspectRepoRequest) Marshal added in v1.5.0 

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

func (*InspectRepoRequest) MarshalTo added in v1.5.0 

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

func (*InspectRepoRequest) ProtoMessage 

func (*InspectRepoRequest) ProtoMessage()

func (*InspectRepoRequest) Reset 

func (m *InspectRepoRequest) Reset()

func (*InspectRepoRequest) Size added in v1.5.0 

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

func (*InspectRepoRequest) String 

func (m *InspectRepoRequest) String() string

func (*InspectRepoRequest) Unmarshal added in v1.5.0 

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

type ListBranchRequest 

type ListBranchRequest struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
}

func (*ListBranchRequest) Descriptor 

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

func (*ListBranchRequest) GetRepo 

func (m *ListBranchRequest) GetRepo() *Repo

func (*ListBranchRequest) Marshal added in v1.5.0 

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

func (*ListBranchRequest) MarshalTo added in v1.5.0 

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

func (*ListBranchRequest) ProtoMessage 

func (*ListBranchRequest) ProtoMessage()

func (*ListBranchRequest) Reset 

func (m *ListBranchRequest) Reset()

func (*ListBranchRequest) Size added in v1.5.0 

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

func (*ListBranchRequest) String 

func (m *ListBranchRequest) String() string

func (*ListBranchRequest) Unmarshal added in v1.5.0 

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

type ListCommitRequest 

type ListCommitRequest struct {
	Repo   *Repo   `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	From   *Commit `protobuf:"bytes,2,opt,name=from" json:"from,omitempty"`
	To     *Commit `protobuf:"bytes,3,opt,name=to" json:"to,omitempty"`
	Number uint64  `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
}

func (*ListCommitRequest) Descriptor 

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

func (*ListCommitRequest) GetFrom added in v1.3.19 

func (m *ListCommitRequest) GetFrom() *Commit

func (*ListCommitRequest) GetNumber added in v1.3.19 

func (m *ListCommitRequest) GetNumber() uint64

func (*ListCommitRequest) GetRepo 

func (m *ListCommitRequest) GetRepo() *Repo

func (*ListCommitRequest) GetTo added in v1.3.19 

func (m *ListCommitRequest) GetTo() *Commit

func (*ListCommitRequest) Marshal added in v1.5.0 

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

func (*ListCommitRequest) MarshalTo added in v1.5.0 

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

func (*ListCommitRequest) ProtoMessage 

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) Reset 

func (m *ListCommitRequest) Reset()

func (*ListCommitRequest) Size added in v1.5.0 

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

func (*ListCommitRequest) String 

func (m *ListCommitRequest) String() string

func (*ListCommitRequest) Unmarshal added in v1.5.0 

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

type ListFileRequest 

type ListFileRequest struct {
	// File is the parent directory of the files we want to list. This fixes the
	// repo, the commit/branch, and path prefix of files we're interested it
	File *File `protobuf:"bytes,1,opt,name=file" 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"`
}

func (*ListFileRequest) Descriptor 

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

func (*ListFileRequest) GetFile 

func (m *ListFileRequest) GetFile() *File

func (*ListFileRequest) GetFull added in v1.6.0 

func (m *ListFileRequest) GetFull() bool

func (*ListFileRequest) Marshal added in v1.5.0 

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

func (*ListFileRequest) MarshalTo added in v1.5.0 

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

func (*ListFileRequest) ProtoMessage 

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) Reset 

func (m *ListFileRequest) Reset()

func (*ListFileRequest) Size added in v1.5.0 

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

func (*ListFileRequest) String 

func (m *ListFileRequest) String() string

func (*ListFileRequest) Unmarshal added in v1.5.0 

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

type ListObjectsRequest added in v1.4.7 

type ListObjectsRequest struct {
}

func (*ListObjectsRequest) Descriptor added in v1.4.7 

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

func (*ListObjectsRequest) Marshal added in v1.5.0 

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

func (*ListObjectsRequest) MarshalTo added in v1.5.0 

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

func (*ListObjectsRequest) ProtoMessage added in v1.4.7 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset added in v1.4.7 

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) Size added in v1.5.0 

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

func (*ListObjectsRequest) String added in v1.4.7 

func (m *ListObjectsRequest) String() string

func (*ListObjectsRequest) Unmarshal added in v1.5.0 

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

type ListRepoRequest 

type ListRepoRequest struct {
	Provenance []*Repo `protobuf:"bytes,1,rep,name=provenance" json:"provenance,omitempty"`
}

func (*ListRepoRequest) Descriptor 

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

func (*ListRepoRequest) GetProvenance added in v1.1.0 

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

func (*ListRepoRequest) Marshal added in v1.5.0 

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

func (*ListRepoRequest) MarshalTo added in v1.5.0 

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

func (*ListRepoRequest) ProtoMessage 

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset 

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) Size added in v1.5.0 

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

func (*ListRepoRequest) String 

func (m *ListRepoRequest) String() string

func (*ListRepoRequest) Unmarshal added in v1.5.0 

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

type ListRepoResponse added in v1.6.0 

type ListRepoResponse struct {
	RepoInfo []*RepoInfo `protobuf:"bytes,1,rep,name=repo_info,json=repoInfo" json:"repo_info,omitempty"`
}

func (*ListRepoResponse) Descriptor added in v1.6.0 

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

func (*ListRepoResponse) GetRepoInfo added in v1.6.0 

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

func (*ListRepoResponse) Marshal added in v1.6.0 

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

func (*ListRepoResponse) MarshalTo added in v1.6.0 

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

func (*ListRepoResponse) ProtoMessage added in v1.6.0 

func (*ListRepoResponse) ProtoMessage()

func (*ListRepoResponse) Reset added in v1.6.0 

func (m *ListRepoResponse) Reset()

func (*ListRepoResponse) Size added in v1.6.0 

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

func (*ListRepoResponse) String added in v1.6.0 

func (m *ListRepoResponse) String() string

func (*ListRepoResponse) Unmarshal added in v1.6.0 

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

type ListTagsRequest added in v1.4.7 

type ListTagsRequest struct {
	Prefix        string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	IncludeObject bool   `protobuf:"varint,2,opt,name=include_object,json=includeObject,proto3" json:"include_object,omitempty"`
}

func (*ListTagsRequest) Descriptor added in v1.4.7 

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

func (*ListTagsRequest) GetIncludeObject added in v1.4.7 

func (m *ListTagsRequest) GetIncludeObject() bool

func (*ListTagsRequest) GetPrefix added in v1.4.7 

func (m *ListTagsRequest) GetPrefix() string

func (*ListTagsRequest) Marshal added in v1.5.0 

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

func (*ListTagsRequest) MarshalTo added in v1.5.0 

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

func (*ListTagsRequest) ProtoMessage added in v1.4.7 

func (*ListTagsRequest) ProtoMessage()

func (*ListTagsRequest) Reset added in v1.4.7 

func (m *ListTagsRequest) Reset()

func (*ListTagsRequest) Size added in v1.5.0 

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

func (*ListTagsRequest) String added in v1.4.7 

func (m *ListTagsRequest) String() string

func (*ListTagsRequest) Unmarshal added in v1.5.0 

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

type ListTagsResponse added in v1.4.7 

type ListTagsResponse struct {
	Tag    *Tag    `protobuf:"bytes,1,opt,name=tag" json:"tag,omitempty"`
	Object *Object `protobuf:"bytes,2,opt,name=object" json:"object,omitempty"`
}

func (*ListTagsResponse) Descriptor added in v1.4.7 

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

func (*ListTagsResponse) GetObject added in v1.4.7 

func (m *ListTagsResponse) GetObject() *Object

func (*ListTagsResponse) GetTag added in v1.4.7 

func (m *ListTagsResponse) GetTag() *Tag

func (*ListTagsResponse) Marshal added in v1.5.0 

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

func (*ListTagsResponse) MarshalTo added in v1.5.0 

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

func (*ListTagsResponse) ProtoMessage added in v1.4.7 

func (*ListTagsResponse) ProtoMessage()

func (*ListTagsResponse) Reset added in v1.4.7 

func (m *ListTagsResponse) Reset()

func (*ListTagsResponse) Size added in v1.5.0 

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

func (*ListTagsResponse) String added in v1.4.7 

func (m *ListTagsResponse) String() string

func (*ListTagsResponse) Unmarshal added in v1.5.0 

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

type Object added in v1.3.9 

type Object struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

func (*Object) Descriptor added in v1.3.9 

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

func (*Object) GetHash added in v1.3.9 

func (m *Object) GetHash() string

func (*Object) Marshal added in v1.5.0 

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

func (*Object) MarshalTo added in v1.5.0 

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

func (*Object) ProtoMessage added in v1.3.9 

func (*Object) ProtoMessage()

func (*Object) Reset added in v1.3.9 

func (m *Object) Reset()

func (*Object) Size added in v1.5.0 

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

func (*Object) String added in v1.3.9 

func (m *Object) String() string

func (*Object) Unmarshal added in v1.5.0 

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

type ObjectAPIClient added in v1.3.9 

type ObjectAPIClient interface {
	PutObject(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectClient, error)
	PutObjectSplit(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectSplitClient, error)
	GetObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (ObjectAPI_GetObjectClient, error)
	GetObjects(ctx context.Context, in *GetObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_GetObjectsClient, error)
	TagObject(ctx context.Context, in *TagObjectRequest, opts ...grpc.CallOption) (*google_protobuf.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 *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
}

func NewObjectAPIClient added in v1.3.9 

func NewObjectAPIClient(cc *grpc.ClientConn) ObjectAPIClient

type ObjectAPIServer added in v1.3.9 

type ObjectAPIServer interface {
	PutObject(ObjectAPI_PutObjectServer) error
	PutObjectSplit(ObjectAPI_PutObjectSplitServer) error
	GetObject(*Object, ObjectAPI_GetObjectServer) error
	GetObjects(*GetObjectsRequest, ObjectAPI_GetObjectsServer) error
	TagObject(context.Context, *TagObjectRequest) (*google_protobuf.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, *google_protobuf.Empty) (*google_protobuf.Empty, error)
}

type ObjectAPI_GetObjectClient added in v1.3.9 

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

type ObjectAPI_GetObjectServer added in v1.3.9 

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

type ObjectAPI_GetObjectsClient added in v1.3.19 

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

type ObjectAPI_GetObjectsServer added in v1.3.19 

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

type ObjectAPI_GetTagClient added in v1.3.9 

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

type ObjectAPI_GetTagServer added in v1.3.9 

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

type ObjectAPI_ListObjectsClient added in v1.4.7 

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

type ObjectAPI_ListObjectsServer added in v1.4.7 

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

type ObjectAPI_ListTagsClient added in v1.4.7 

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

type ObjectAPI_ListTagsServer added in v1.4.7 

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

type ObjectAPI_PutObjectClient added in v1.3.9 

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

type ObjectAPI_PutObjectServer added in v1.3.9 

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

type ObjectAPI_PutObjectSplitClient added in v1.6.0 

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

type ObjectAPI_PutObjectSplitServer added in v1.6.0 

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

type ObjectIndex added in v1.3.9 

type ObjectIndex struct {
	Objects map[string]*BlockRef `` /* 141-byte string literal not displayed */
	Tags    map[string]*Object   `` /* 135-byte string literal not displayed */
}

func (*ObjectIndex) Descriptor added in v1.3.9 

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

func (*ObjectIndex) GetObjects added in v1.3.9 

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

func (*ObjectIndex) GetTags added in v1.3.9 

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

func (*ObjectIndex) Marshal added in v1.5.0 

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

func (*ObjectIndex) MarshalTo added in v1.5.0 

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

func (*ObjectIndex) ProtoMessage added in v1.3.9 

func (*ObjectIndex) ProtoMessage()

func (*ObjectIndex) Reset added in v1.3.9 

func (m *ObjectIndex) Reset()

func (*ObjectIndex) Size added in v1.5.0 

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

func (*ObjectIndex) String added in v1.3.9 

func (m *ObjectIndex) String() string

func (*ObjectIndex) Unmarshal added in v1.5.0 

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

type ObjectInfo added in v1.3.9 

type ObjectInfo struct {
	Object   *Object   `protobuf:"bytes,1,opt,name=object" json:"object,omitempty"`
	BlockRef *BlockRef `protobuf:"bytes,2,opt,name=block_ref,json=blockRef" json:"block_ref,omitempty"`
}

func (*ObjectInfo) Descriptor added in v1.3.9 

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

func (*ObjectInfo) GetBlockRef added in v1.3.9 

func (m *ObjectInfo) GetBlockRef() *BlockRef

func (*ObjectInfo) GetObject added in v1.3.9 

func (m *ObjectInfo) GetObject() *Object

func (*ObjectInfo) Marshal added in v1.5.0 

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

func (*ObjectInfo) MarshalTo added in v1.5.0 

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

func (*ObjectInfo) ProtoMessage added in v1.3.9 

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) Reset added in v1.3.9 

func (m *ObjectInfo) Reset()

func (*ObjectInfo) Size added in v1.5.0 

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

func (*ObjectInfo) String added in v1.3.9 

func (m *ObjectInfo) String() string

func (*ObjectInfo) Unmarshal added in v1.5.0 

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

type Objects added in v1.6.0 

type Objects struct {
	Objects []*Object `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"`
}

func (*Objects) Descriptor added in v1.6.0 

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

func (*Objects) GetObjects added in v1.6.0 

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

func (*Objects) Marshal added in v1.6.0 

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

func (*Objects) MarshalTo added in v1.6.0 

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

func (*Objects) ProtoMessage added in v1.6.0 

func (*Objects) ProtoMessage()

func (*Objects) Reset added in v1.6.0 

func (m *Objects) Reset()

func (*Objects) Size added in v1.6.0 

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

func (*Objects) String added in v1.6.0 

func (m *Objects) String() string

func (*Objects) Unmarshal added in v1.6.0 

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

type OverwriteIndex added in v1.6.0 

type OverwriteIndex struct {
	Index int64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
}

An OverwriteIndex specifies the index of objects from which new writes are applied to. Existing objects starting from the index are deleted. We want a separate message for ObjectIndex because we want to be able to distinguish between a zero index and a non-existent index.

func (*OverwriteIndex) Descriptor added in v1.6.0 

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

func (*OverwriteIndex) GetIndex added in v1.6.0 

func (m *OverwriteIndex) GetIndex() int64

func (*OverwriteIndex) Marshal added in v1.6.0 

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

func (*OverwriteIndex) MarshalTo added in v1.6.0 

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

func (*OverwriteIndex) ProtoMessage added in v1.6.0 

func (*OverwriteIndex) ProtoMessage()

func (*OverwriteIndex) Reset added in v1.6.0 

func (m *OverwriteIndex) Reset()

func (*OverwriteIndex) Size added in v1.6.0 

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

func (*OverwriteIndex) String added in v1.6.0 

func (m *OverwriteIndex) String() string

func (*OverwriteIndex) Unmarshal added in v1.6.0 

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

type PutFileRecord added in v1.6.0 

type PutFileRecord struct {
	SizeBytes      int64           `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	ObjectHash     string          `protobuf:"bytes,2,opt,name=object_hash,json=objectHash,proto3" json:"object_hash,omitempty"`
	OverwriteIndex *OverwriteIndex `protobuf:"bytes,3,opt,name=overwrite_index,json=overwriteIndex" json:"overwrite_index,omitempty"`
}

PutFileRecord is used to record PutFile requests in etcd temporarily.

func (*PutFileRecord) Descriptor added in v1.6.0 

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

func (*PutFileRecord) GetObjectHash added in v1.6.0 

func (m *PutFileRecord) GetObjectHash() string

func (*PutFileRecord) GetOverwriteIndex added in v1.6.0 

func (m *PutFileRecord) GetOverwriteIndex() *OverwriteIndex

func (*PutFileRecord) GetSizeBytes added in v1.6.0 

func (m *PutFileRecord) GetSizeBytes() int64

func (*PutFileRecord) Marshal added in v1.6.0 

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

func (*PutFileRecord) MarshalTo added in v1.6.0 

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

func (*PutFileRecord) ProtoMessage added in v1.6.0 

func (*PutFileRecord) ProtoMessage()

func (*PutFileRecord) Reset added in v1.6.0 

func (m *PutFileRecord) Reset()

func (*PutFileRecord) Size added in v1.6.0 

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

func (*PutFileRecord) String added in v1.6.0 

func (m *PutFileRecord) String() string

func (*PutFileRecord) Unmarshal added in v1.6.0 

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

type PutFileRecords added in v1.6.0 

type PutFileRecords struct {
	Split     bool             `protobuf:"varint,1,opt,name=split,proto3" json:"split,omitempty"`
	Records   []*PutFileRecord `protobuf:"bytes,2,rep,name=records" json:"records,omitempty"`
	Tombstone bool             `protobuf:"varint,3,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
}

func (*PutFileRecords) Descriptor added in v1.6.0 

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

func (*PutFileRecords) GetRecords added in v1.6.0 

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

func (*PutFileRecords) GetSplit added in v1.6.0 

func (m *PutFileRecords) GetSplit() bool

func (*PutFileRecords) GetTombstone added in v1.6.7 

func (m *PutFileRecords) GetTombstone() bool

func (*PutFileRecords) Marshal added in v1.6.0 

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

func (*PutFileRecords) MarshalTo added in v1.6.0 

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

func (*PutFileRecords) ProtoMessage added in v1.6.0 

func (*PutFileRecords) ProtoMessage()

func (*PutFileRecords) Reset added in v1.6.0 

func (m *PutFileRecords) Reset()

func (*PutFileRecords) Size added in v1.6.0 

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

func (*PutFileRecords) String added in v1.6.0 

func (m *PutFileRecords) String() string

func (*PutFileRecords) Unmarshal added in v1.6.0 

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

type PutFileRequest 

type PutFileRequest struct {
	File  *File  `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Url   string `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// applies only to URLs that can be recursively walked, for example s3:// URLs
	Recursive bool `protobuf:"varint,6,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// Delimiter causes data to be broken up into separate files with File.Path
	// as a prefix.
	Delimiter Delimiter `protobuf:"varint,7,opt,name=delimiter,proto3,enum=pfs.Delimiter" json:"delimiter,omitempty"`
	// TargetFileDatums specifies the target number of datums in each written
	// file it may be lower if data does not split evenly, but will never be
	// higher, unless the value is 0.
	TargetFileDatums int64 `protobuf:"varint,8,opt,name=target_file_datums,json=targetFileDatums,proto3" json:"target_file_datums,omitempty"`
	// TargetFileBytes specifies the target number of bytes in each written
	// file, files may have more or fewer bytes than the target.
	TargetFileBytes int64 `protobuf:"varint,9,opt,name=target_file_bytes,json=targetFileBytes,proto3" json:"target_file_bytes,omitempty"`
	// overwrite_index is the object index where the write starts from.  All
	// existing objects starting from the index are deleted.
	OverwriteIndex *OverwriteIndex `protobuf:"bytes,10,opt,name=overwrite_index,json=overwriteIndex" json:"overwrite_index,omitempty"`
}

func (*PutFileRequest) Descriptor 

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

func (*PutFileRequest) GetDelimiter added in v1.3.5 

func (m *PutFileRequest) GetDelimiter() Delimiter

func (*PutFileRequest) GetFile 

func (m *PutFileRequest) GetFile() *File

func (*PutFileRequest) GetOverwriteIndex added in v1.6.0 

func (m *PutFileRequest) GetOverwriteIndex() *OverwriteIndex

func (*PutFileRequest) GetRecursive added in v1.3.5 

func (m *PutFileRequest) GetRecursive() bool

func (*PutFileRequest) GetTargetFileBytes added in v1.3.19 

func (m *PutFileRequest) GetTargetFileBytes() int64

func (*PutFileRequest) GetTargetFileDatums added in v1.3.19 

func (m *PutFileRequest) GetTargetFileDatums() int64

func (*PutFileRequest) GetUrl added in v1.3.5 

func (m *PutFileRequest) GetUrl() string

func (*PutFileRequest) GetValue added in v1.3.5 

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

func (*PutFileRequest) Marshal added in v1.5.0 

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

func (*PutFileRequest) MarshalTo added in v1.5.0 

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

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) Reset 

func (m *PutFileRequest) Reset()

func (*PutFileRequest) Size added in v1.5.0 

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

func (*PutFileRequest) String 

func (m *PutFileRequest) String() string

func (*PutFileRequest) Unmarshal added in v1.5.0 

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

type PutObjectRequest added in v1.3.9 

type PutObjectRequest struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Tags  []*Tag `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
}

func (*PutObjectRequest) Descriptor added in v1.3.9 

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

func (*PutObjectRequest) GetTags added in v1.3.9 

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

func (*PutObjectRequest) GetValue added in v1.3.9 

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

func (*PutObjectRequest) Marshal added in v1.5.0 

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

func (*PutObjectRequest) MarshalTo added in v1.5.0 

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

func (*PutObjectRequest) ProtoMessage added in v1.3.9 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) Reset added in v1.3.9 

func (m *PutObjectRequest) Reset()

func (*PutObjectRequest) Size added in v1.5.0 

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

func (*PutObjectRequest) String added in v1.3.9 

func (m *PutObjectRequest) String() string

func (*PutObjectRequest) Unmarshal added in v1.5.0 

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

type Repo 

type Repo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*Repo) Descriptor 

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

func (*Repo) GetName added in v1.3.5 

func (m *Repo) GetName() string

func (*Repo) Marshal added in v1.5.0 

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

func (*Repo) MarshalTo added in v1.5.0 

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

func (*Repo) ProtoMessage 

func (*Repo) ProtoMessage()

func (*Repo) Reset 

func (m *Repo) Reset()

func (*Repo) Size added in v1.5.0 

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

func (*Repo) String 

func (m *Repo) String() string

func (*Repo) Unmarshal added in v1.5.0 

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

type RepoAuthInfo added in v1.6.0 

type RepoAuthInfo struct {
	// The callers access level to the relevant repo (e.g. may be OWNER even if
	// the user isn't an OWNER of the repo, if they're an admin for the cluster)
	AccessLevel auth.Scope `protobuf:"varint,1,opt,name=access_level,json=accessLevel,proto3,enum=auth.Scope" json:"access_level,omitempty"`
}

RepoAuthInfo includes the caller's access scope for a repo, and is returned by ListRepo and InspectRepo but not persisted in etcd. It's used by the Pachyderm dashboard to render repo access appropriately. To set a user's auth scope for a repo, use the Pachyderm Auth API (in src/client/auth/auth.proto)

func (*RepoAuthInfo) Descriptor added in v1.6.0 

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

func (*RepoAuthInfo) GetAccessLevel added in v1.6.0 

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

func (*RepoAuthInfo) Marshal added in v1.6.0 

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

func (*RepoAuthInfo) MarshalTo added in v1.6.0 

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

func (*RepoAuthInfo) ProtoMessage added in v1.6.0 

func (*RepoAuthInfo) ProtoMessage()

func (*RepoAuthInfo) Reset added in v1.6.0 

func (m *RepoAuthInfo) Reset()

func (*RepoAuthInfo) Size added in v1.6.0 

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

func (*RepoAuthInfo) String added in v1.6.0 

func (m *RepoAuthInfo) String() string

func (*RepoAuthInfo) Unmarshal added in v1.6.0 

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

type RepoInfo 

type RepoInfo struct {
	Repo        *Repo                       `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Created     *google_protobuf1.Timestamp `protobuf:"bytes,2,opt,name=created" json:"created,omitempty"`
	SizeBytes   uint64                      `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Provenance  []*Repo                     `protobuf:"bytes,4,rep,name=provenance" json:"provenance,omitempty"`
	Description string                      `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Set by ListRepo and InspectRepo if Pachyderm's auth system is active, but
	// not stored in etcd. To set a user's auth scope for a repo, use the
	// Pachyderm Auth API (in src/client/auth/auth.proto)
	AuthInfo *RepoAuthInfo `protobuf:"bytes,6,opt,name=auth_info,json=authInfo" json:"auth_info,omitempty"`
}

RepoInfo is the main data structure representing a Repo in etcd

func (*RepoInfo) Descriptor 

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

func (*RepoInfo) GetAuthInfo added in v1.6.0 

func (m *RepoInfo) GetAuthInfo() *RepoAuthInfo

func (*RepoInfo) GetCreated 

func (m *RepoInfo) GetCreated() *google_protobuf1.Timestamp

func (*RepoInfo) GetDescription added in v1.4.7 

func (m *RepoInfo) GetDescription() string

func (*RepoInfo) GetProvenance added in v1.1.0 

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

func (*RepoInfo) GetRepo 

func (m *RepoInfo) GetRepo() *Repo

func (*RepoInfo) GetSizeBytes added in v1.3.5 

func (m *RepoInfo) GetSizeBytes() uint64

func (*RepoInfo) Marshal added in v1.5.0 

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

func (*RepoInfo) MarshalTo added in v1.5.0 

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

func (*RepoInfo) ProtoMessage 

func (*RepoInfo) ProtoMessage()

func (*RepoInfo) Reset 

func (m *RepoInfo) Reset()

func (*RepoInfo) Size added in v1.5.0 

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

func (*RepoInfo) String 

func (m *RepoInfo) String() string

func (*RepoInfo) Unmarshal added in v1.5.0 

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

type StartCommitRequest 

type StartCommitRequest struct {
	// Parent.ID may be empty in which case the commit that Branch points to will be used as the parent.
	// If branch is empty, or if branch does not exist, the commit will have no parent.
	Parent *Commit `protobuf:"bytes,1,opt,name=parent" json:"parent,omitempty"`
	// description is a user-provided string describing this commit
	Description string    `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Branch      string    `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance  []*Commit `protobuf:"bytes,2,rep,name=provenance" json:"provenance,omitempty"`
}

func (*StartCommitRequest) Descriptor 

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

func (*StartCommitRequest) GetBranch added in v1.3.19 

func (m *StartCommitRequest) GetBranch() string

func (*StartCommitRequest) GetDescription added in v1.6.6 

func (m *StartCommitRequest) GetDescription() string

func (*StartCommitRequest) GetParent added in v1.2.0 

func (m *StartCommitRequest) GetParent() *Commit

func (*StartCommitRequest) GetProvenance added in v1.1.0 

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

func (*StartCommitRequest) Marshal added in v1.5.0 

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

func (*StartCommitRequest) MarshalTo added in v1.5.0 

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

func (*StartCommitRequest) ProtoMessage 

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) Reset 

func (m *StartCommitRequest) Reset()

func (*StartCommitRequest) Size added in v1.5.0 

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

func (*StartCommitRequest) String 

func (m *StartCommitRequest) String() string

func (*StartCommitRequest) Unmarshal added in v1.5.0 

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

type SubscribeCommitRequest added in v1.3.19 

type SubscribeCommitRequest struct {
	Repo   *Repo  `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Branch string `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	// only commits created since this commit are returned
	From *Commit `protobuf:"bytes,3,opt,name=from" json:"from,omitempty"`
}

func (*SubscribeCommitRequest) Descriptor added in v1.3.19 

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

func (*SubscribeCommitRequest) GetBranch added in v1.3.19 

func (m *SubscribeCommitRequest) GetBranch() string

func (*SubscribeCommitRequest) GetFrom added in v1.3.19 

func (m *SubscribeCommitRequest) GetFrom() *Commit

func (*SubscribeCommitRequest) GetRepo added in v1.3.19 

func (m *SubscribeCommitRequest) GetRepo() *Repo

func (*SubscribeCommitRequest) Marshal added in v1.5.0 

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

func (*SubscribeCommitRequest) MarshalTo added in v1.5.0 

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

func (*SubscribeCommitRequest) ProtoMessage added in v1.3.19 

func (*SubscribeCommitRequest) ProtoMessage()

func (*SubscribeCommitRequest) Reset added in v1.3.19 

func (m *SubscribeCommitRequest) Reset()

func (*SubscribeCommitRequest) Size added in v1.5.0 

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

func (*SubscribeCommitRequest) String added in v1.3.19 

func (m *SubscribeCommitRequest) String() string

func (*SubscribeCommitRequest) Unmarshal added in v1.5.0 

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

type Tag added in v1.3.9 

type Tag struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*Tag) Descriptor added in v1.3.9 

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

func (*Tag) GetName added in v1.3.9 

func (m *Tag) GetName() string

func (*Tag) Marshal added in v1.5.0 

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

func (*Tag) MarshalTo added in v1.5.0 

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

func (*Tag) ProtoMessage added in v1.3.9 

func (*Tag) ProtoMessage()

func (*Tag) Reset added in v1.3.9 

func (m *Tag) Reset()

func (*Tag) Size added in v1.5.0 

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

func (*Tag) String added in v1.3.9 

func (m *Tag) String() string

func (*Tag) Unmarshal added in v1.5.0 

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

type TagObjectRequest added in v1.3.9 

type TagObjectRequest struct {
	Object *Object `protobuf:"bytes,1,opt,name=object" json:"object,omitempty"`
	Tags   []*Tag  `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
}

func (*TagObjectRequest) Descriptor added in v1.3.9 

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

func (*TagObjectRequest) GetObject added in v1.3.9 

func (m *TagObjectRequest) GetObject() *Object

func (*TagObjectRequest) GetTags added in v1.3.9 

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

func (*TagObjectRequest) Marshal added in v1.5.0 

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

func (*TagObjectRequest) MarshalTo added in v1.5.0 

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

func (*TagObjectRequest) ProtoMessage added in v1.3.9 

func (*TagObjectRequest) ProtoMessage()

func (*TagObjectRequest) Reset added in v1.3.9 

func (m *TagObjectRequest) Reset()

func (*TagObjectRequest) Size added in v1.5.0 

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

func (*TagObjectRequest) String added in v1.3.9 

func (m *TagObjectRequest) String() string

func (*TagObjectRequest) Unmarshal added in v1.5.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.