pfs

package
v1.8.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPfs = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPfs   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	// ChunkSize is the size of file chunks when resumable upload is used
	ChunkSize = int64(512 * 1024 * 1024) // 512 MB
)
View Source 
var CommitState_name = map[int32]string{
	0: "STARTED",
	1: "READY",
	2: "FINISHED",
}
View Source 
var CommitState_value = map[string]int32{
	"STARTED":  0,
	"READY":    1,
	"FINISHED": 2,
}
View Source 
var Delimiter_name = map[int32]string{
	0: "NONE",
	1: "JSON",
	2: "LINE",
	3: "SQL",
	4: "CSV",
}
View Source 
var Delimiter_value = map[string]int32{
	"NONE": 0,
	"JSON": 1,
	"LINE": 2,
	"SQL":  3,
	"CSV":  4,
}
View Source 
var FileType_name = map[int32]string{
	0: "RESERVED",
	1: "FILE",
	2: "DIR",
}
View Source 
var FileType_value = map[string]int32{
	"RESERVED": 0,
	"FILE":     1,
	"DIR":      2,
}

Functions

func DecodeHash added in v1.8.0 

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

DecodeHash decodes a hash into bytes.

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

APIClient is the client API for API service.

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

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

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

APIServer is the server API for API service.

type API_FlushCommitClient added in v1.3.19 

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

type API_FlushCommitServer added in v1.3.19 

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

type API_GetFileClient 

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

type API_GetFileServer 

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

type API_GlobFileStreamClient added in v1.6.2 

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

type API_GlobFileStreamServer added in v1.6.2 

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

type API_ListCommitStreamClient added in v1.6.4 

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

type API_ListCommitStreamServer added in v1.6.4 

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

type API_ListFileStreamClient added in v1.6.2 

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

type API_ListFileStreamServer added in v1.6.2 

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

type API_PutFileClient 

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

type API_PutFileServer 

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

type API_SubscribeCommitClient added in v1.3.19 

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

type API_SubscribeCommitServer added in v1.3.19 

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

type API_WalkFileClient added in v1.8.0 

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

type API_WalkFileServer added in v1.8.0 

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

type Block 

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

func GetBlock added in v1.0.348 

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

func (*Block) XXX_DiscardUnknown added in v1.8.1 

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal added in v1.8.1 

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

func (*Block) XXX_Merge added in v1.8.1 

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

func (*Block) XXX_Size added in v1.8.1 

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal added in v1.8.1 

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

type BlockRef 

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

func (*BlockRef) Descriptor 

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

func (*BlockRef) GetBlock 

func (m *BlockRef) GetBlock() *Block

func (*BlockRef) GetRange 

func (m *BlockRef) GetRange() *ByteRange

func (*BlockRef) Marshal 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

func (*BlockRef) XXX_DiscardUnknown added in v1.8.1 

func (m *BlockRef) XXX_DiscardUnknown()

func (*BlockRef) XXX_Marshal added in v1.8.1 

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

func (*BlockRef) XXX_Merge added in v1.8.1 

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

func (*BlockRef) XXX_Size added in v1.8.1 

func (m *BlockRef) XXX_Size() int

func (*BlockRef) XXX_Unmarshal added in v1.8.1 

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

type Branch added in v1.3.19 

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

func (*Branch) Descriptor added in v1.3.19 

func (*Branch) 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

func (*Branch) XXX_DiscardUnknown added in v1.8.1 

func (m *Branch) XXX_DiscardUnknown()

func (*Branch) XXX_Marshal added in v1.8.1 

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

func (*Branch) XXX_Merge added in v1.8.1 

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

func (*Branch) XXX_Size added in v1.8.1 

func (m *Branch) XXX_Size() int

func (*Branch) XXX_Unmarshal added in v1.8.1 

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

type BranchInfo added in v1.5.0 

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

func (*BranchInfo) Descriptor added in v1.5.0 

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

func (*BranchInfo) GetBranch added in v1.7.0 

func (m *BranchInfo) GetBranch() *Branch

func (*BranchInfo) GetDirectProvenance added in v1.7.0 

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

func (*BranchInfo) GetHead added in v1.5.0 

func (m *BranchInfo) GetHead() *Commit

func (*BranchInfo) GetName added in v1.5.0 

func (m *BranchInfo) GetName() string

func (*BranchInfo) GetProvenance added in v1.7.0 

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

func (*BranchInfo) GetSubvenance added in v1.7.0 

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

func (*BranchInfo) Marshal added in v1.5.0 

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

func (*BranchInfo) MarshalTo added in v1.5.0 

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

func (*BranchInfo) ProtoMessage added in v1.5.0 

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) Reset added in v1.5.0 

func (m *BranchInfo) Reset()

func (*BranchInfo) Size added in v1.5.0 

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

func (*BranchInfo) String added in v1.5.0 

func (m *BranchInfo) String() string

func (*BranchInfo) Unmarshal added in v1.5.0 

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

func (*BranchInfo) XXX_DiscardUnknown added in v1.8.1 

func (m *BranchInfo) XXX_DiscardUnknown()

func (*BranchInfo) XXX_Marshal added in v1.8.1 

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

func (*BranchInfo) XXX_Merge added in v1.8.1 

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

func (*BranchInfo) XXX_Size added in v1.8.1 

func (m *BranchInfo) XXX_Size() int

func (*BranchInfo) XXX_Unmarshal added in v1.8.1 

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

type BranchInfos added in v1.5.0 

type BranchInfos struct {
	BranchInfo           []*BranchInfo `protobuf:"bytes,1,rep,name=branch_info,json=branchInfo,proto3" json:"branch_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*BranchInfos) Descriptor added in v1.5.0 

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

func (*BranchInfos) GetBranchInfo added in v1.5.0 

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

func (*BranchInfos) Marshal added in v1.5.0 

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

func (*BranchInfos) MarshalTo added in v1.5.0 

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

func (*BranchInfos) ProtoMessage added in v1.5.0 

func (*BranchInfos) ProtoMessage()

func (*BranchInfos) Reset added in v1.5.0 

func (m *BranchInfos) Reset()

func (*BranchInfos) Size added in v1.5.0 

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

func (*BranchInfos) String added in v1.5.0 

func (m *BranchInfos) String() string

func (*BranchInfos) Unmarshal added in v1.5.0 

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

func (*BranchInfos) XXX_DiscardUnknown added in v1.8.1 

func (m *BranchInfos) XXX_DiscardUnknown()

func (*BranchInfos) XXX_Marshal added in v1.8.1 

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

func (*BranchInfos) XXX_Merge added in v1.8.1 

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

func (*BranchInfos) XXX_Size added in v1.8.1 

func (m *BranchInfos) XXX_Size() int

func (*BranchInfos) XXX_Unmarshal added in v1.8.1 

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

type BuildCommitRequest added in v1.3.19 

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

func (*BuildCommitRequest) Descriptor added in v1.3.19 

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

func (*BuildCommitRequest) GetBranch added in v1.3.19 

func (m *BuildCommitRequest) GetBranch() string

func (*BuildCommitRequest) GetID added in v1.6.9 

func (m *BuildCommitRequest) GetID() string

func (*BuildCommitRequest) GetParent added in v1.3.19 

func (m *BuildCommitRequest) GetParent() *Commit

func (*BuildCommitRequest) GetProvenance added in v1.3.19 

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

func (*BuildCommitRequest) GetTree added in v1.3.19 

func (m *BuildCommitRequest) GetTree() *Object

func (*BuildCommitRequest) Marshal added in v1.5.0 

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

func (*BuildCommitRequest) MarshalTo added in v1.5.0 

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

func (*BuildCommitRequest) ProtoMessage added in v1.3.19 

func (*BuildCommitRequest) ProtoMessage()

func (*BuildCommitRequest) Reset added in v1.3.19 

func (m *BuildCommitRequest) Reset()

func (*BuildCommitRequest) Size added in v1.5.0 

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

func (*BuildCommitRequest) String added in v1.3.19 

func (m *BuildCommitRequest) String() string

func (*BuildCommitRequest) Unmarshal added in v1.5.0 

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

func (*BuildCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *BuildCommitRequest) XXX_DiscardUnknown()

func (*BuildCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*BuildCommitRequest) XXX_Merge added in v1.8.1 

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

func (*BuildCommitRequest) XXX_Size added in v1.8.1 

func (m *BuildCommitRequest) XXX_Size() int

func (*BuildCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type ByteRange 

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

func (*ByteRange) Descriptor 

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

func (*ByteRange) GetLower 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

func (*ByteRange) XXX_DiscardUnknown added in v1.8.1 

func (m *ByteRange) XXX_DiscardUnknown()

func (*ByteRange) XXX_Marshal added in v1.8.1 

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

func (*ByteRange) XXX_Merge added in v1.8.1 

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

func (*ByteRange) XXX_Size added in v1.8.1 

func (m *ByteRange) XXX_Size() int

func (*ByteRange) XXX_Unmarshal added in v1.8.1 

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

type CheckObjectRequest added in v1.4.7 

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

func (*CheckObjectRequest) Descriptor added in v1.4.7 

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

func (*CheckObjectRequest) GetObject added in v1.4.7 

func (m *CheckObjectRequest) GetObject() *Object

func (*CheckObjectRequest) Marshal added in v1.5.0 

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

func (*CheckObjectRequest) MarshalTo added in v1.5.0 

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

func (*CheckObjectRequest) ProtoMessage added in v1.4.7 

func (*CheckObjectRequest) ProtoMessage()

func (*CheckObjectRequest) Reset added in v1.4.7 

func (m *CheckObjectRequest) Reset()

func (*CheckObjectRequest) Size added in v1.5.0 

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

func (*CheckObjectRequest) String added in v1.4.7 

func (m *CheckObjectRequest) String() string

func (*CheckObjectRequest) Unmarshal added in v1.5.0 

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

func (*CheckObjectRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *CheckObjectRequest) XXX_DiscardUnknown()

func (*CheckObjectRequest) XXX_Marshal added in v1.8.1 

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

func (*CheckObjectRequest) XXX_Merge added in v1.8.1 

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

func (*CheckObjectRequest) XXX_Size added in v1.8.1 

func (m *CheckObjectRequest) XXX_Size() int

func (*CheckObjectRequest) XXX_Unmarshal added in v1.8.1 

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

type CheckObjectResponse added in v1.4.7 

type CheckObjectResponse struct {
	Exists               bool     `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckObjectResponse) Descriptor added in v1.4.7 

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

func (*CheckObjectResponse) GetExists added in v1.4.7 

func (m *CheckObjectResponse) GetExists() bool

func (*CheckObjectResponse) Marshal added in v1.5.0 

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

func (*CheckObjectResponse) MarshalTo added in v1.5.0 

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

func (*CheckObjectResponse) ProtoMessage added in v1.4.7 

func (*CheckObjectResponse) ProtoMessage()

func (*CheckObjectResponse) Reset added in v1.4.7 

func (m *CheckObjectResponse) Reset()

func (*CheckObjectResponse) Size added in v1.5.0 

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

func (*CheckObjectResponse) String added in v1.4.7 

func (m *CheckObjectResponse) String() string

func (*CheckObjectResponse) Unmarshal added in v1.5.0 

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

func (*CheckObjectResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *CheckObjectResponse) XXX_DiscardUnknown()

func (*CheckObjectResponse) XXX_Marshal added in v1.8.1 

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

func (*CheckObjectResponse) XXX_Merge added in v1.8.1 

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

func (*CheckObjectResponse) XXX_Size added in v1.8.1 

func (m *CheckObjectResponse) XXX_Size() int

func (*CheckObjectResponse) XXX_Unmarshal added in v1.8.1 

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

type Commit 

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

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

func (*Commit) Descriptor 

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

func (*Commit) 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

func (*Commit) XXX_DiscardUnknown added in v1.8.1 

func (m *Commit) XXX_DiscardUnknown()

func (*Commit) XXX_Marshal added in v1.8.1 

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

func (*Commit) XXX_Merge added in v1.8.1 

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

func (*Commit) XXX_Size added in v1.8.1 

func (m *Commit) XXX_Size() int

func (*Commit) XXX_Unmarshal added in v1.8.1 

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

type CommitInfo 

type CommitInfo struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// description is a user-provided script describing this commit
	Description  string           `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"`
	ParentCommit *Commit          `protobuf:"bytes,2,opt,name=parent_commit,json=parentCommit,proto3" json:"parent_commit,omitempty"`
	ChildCommits []*Commit        `protobuf:"bytes,11,rep,name=child_commits,json=childCommits,proto3" json:"child_commits,omitempty"`
	Started      *types.Timestamp `protobuf:"bytes,3,opt,name=started,proto3" json:"started,omitempty"`
	Finished     *types.Timestamp `protobuf:"bytes,4,opt,name=finished,proto3" json:"finished,omitempty"`
	SizeBytes    uint64           `protobuf:"varint,5,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// Commits on which this commit is provenant. provenance[i] is a commit in
	// branch_provenance[i] (a branch name, and one of the branches on which this
	// commit's branch is provenant)
	Provenance       []*Commit `protobuf:"bytes,6,rep,name=provenance,proto3" json:"provenance,omitempty"`
	BranchProvenance []*Branch `protobuf:"bytes,10,rep,name=branch_provenance,json=branchProvenance,proto3" json:"branch_provenance,omitempty"`
	// ReadyProvenance is the number of provenant commits which have been
	// finished, if ReadyProvenance == len(Provenance) then the commit is ready
	// to be processed by pps.
	ReadyProvenance int64          `protobuf:"varint,12,opt,name=ready_provenance,json=readyProvenance,proto3" json:"ready_provenance,omitempty"`
	Subvenance      []*CommitRange `protobuf:"bytes,9,rep,name=subvenance,proto3" json:"subvenance,omitempty"`
	// this is the block that stores the serialized form of a tree that
	// represents the entire file system hierarchy of the repo at this commit
	// If this is nil, then the commit is either open (in which case 'finished'
	// will also be nil) or is the output commit of a failed job (in which case
	// 'finished' will have a value -- the end time of the job)
	Tree                 *Object   `protobuf:"bytes,7,opt,name=tree,proto3" json:"tree,omitempty"`
	Trees                []*Object `protobuf:"bytes,13,rep,name=trees,proto3" json:"trees,omitempty"`
	Datums               *Object   `protobuf:"bytes,14,opt,name=datums,proto3" json:"datums,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

CommitInfo is the main data structure representing a commit in etcd

func (*CommitInfo) Descriptor 

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) GetDatums added in v1.8.0 

func (m *CommitInfo) GetDatums() *Object

func (*CommitInfo) GetDescription added in v1.6.6 

func (m *CommitInfo) GetDescription() string

func (*CommitInfo) GetFinished 

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

func (*CommitInfo) GetParentCommit 

func (m *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetProvenance 

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

func (*CommitInfo) GetReadyProvenance added in v1.7.1 

func (m *CommitInfo) GetReadyProvenance() int64

func (*CommitInfo) GetSizeBytes added in v1.3.5 

func (m *CommitInfo) GetSizeBytes() uint64

func (*CommitInfo) GetStarted 

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

func (*CommitInfo) GetSubvenance added in v1.7.0 

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

func (*CommitInfo) GetTree added in v1.3.19 

func (m *CommitInfo) GetTree() *Object

func (*CommitInfo) GetTrees added in v1.8.0 

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

func (*CommitInfo) Marshal added in v1.5.0 

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

func (*CommitInfo) MarshalTo added in v1.5.0 

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

func (*CommitInfo) ProtoMessage 

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset 

func (m *CommitInfo) Reset()

func (*CommitInfo) Size added in v1.5.0 

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

func (*CommitInfo) String 

func (m *CommitInfo) String() string

func (*CommitInfo) Unmarshal added in v1.5.0 

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

func (*CommitInfo) XXX_DiscardUnknown added in v1.8.1 

func (m *CommitInfo) XXX_DiscardUnknown()

func (*CommitInfo) XXX_Marshal added in v1.8.1 

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

func (*CommitInfo) XXX_Merge added in v1.8.1 

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

func (*CommitInfo) XXX_Size added in v1.8.1 

func (m *CommitInfo) XXX_Size() int

func (*CommitInfo) XXX_Unmarshal added in v1.8.1 

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

type CommitInfos 

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

func (*CommitInfos) Descriptor 

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

func (*CommitInfos) GetCommitInfo 

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

func (*CommitInfos) Marshal added in v1.5.0 

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

func (*CommitInfos) MarshalTo added in v1.5.0 

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

func (*CommitInfos) ProtoMessage 

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset 

func (m *CommitInfos) Reset()

func (*CommitInfos) Size added in v1.5.0 

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

func (*CommitInfos) String 

func (m *CommitInfos) String() string

func (*CommitInfos) Unmarshal added in v1.5.0 

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

func (*CommitInfos) XXX_DiscardUnknown added in v1.8.1 

func (m *CommitInfos) XXX_DiscardUnknown()

func (*CommitInfos) XXX_Marshal added in v1.8.1 

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

func (*CommitInfos) XXX_Merge added in v1.8.1 

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

func (*CommitInfos) XXX_Size added in v1.8.1 

func (m *CommitInfos) XXX_Size() int

func (*CommitInfos) XXX_Unmarshal added in v1.8.1 

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

type CommitRange added in v1.7.0 

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

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

func (*CommitRange) Descriptor added in v1.7.0 

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

func (*CommitRange) GetLower added in v1.7.0 

func (m *CommitRange) GetLower() *Commit

func (*CommitRange) GetUpper added in v1.7.0 

func (m *CommitRange) GetUpper() *Commit

func (*CommitRange) Marshal added in v1.7.0 

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

func (*CommitRange) MarshalTo added in v1.7.0 

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

func (*CommitRange) ProtoMessage added in v1.7.0 

func (*CommitRange) ProtoMessage()

func (*CommitRange) Reset added in v1.7.0 

func (m *CommitRange) Reset()

func (*CommitRange) Size added in v1.7.0 

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

func (*CommitRange) String added in v1.7.0 

func (m *CommitRange) String() string

func (*CommitRange) Unmarshal added in v1.7.0 

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

func (*CommitRange) XXX_DiscardUnknown added in v1.8.1 

func (m *CommitRange) XXX_DiscardUnknown()

func (*CommitRange) XXX_Marshal added in v1.8.1 

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

func (*CommitRange) XXX_Merge added in v1.8.1 

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

func (*CommitRange) XXX_Size added in v1.8.1 

func (m *CommitRange) XXX_Size() int

func (*CommitRange) XXX_Unmarshal added in v1.8.1 

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

type CommitState added in v1.7.1 

type CommitState int32

CommitState describes the states a commit can be in. The states are increasingly specific, i.e. a commit that is FINISHED also counts as STARTED. 

const (
	CommitState_STARTED  CommitState = 0
	CommitState_READY    CommitState = 1
	CommitState_FINISHED CommitState = 2
)

func (CommitState) EnumDescriptor added in v1.7.1 

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

func (CommitState) String added in v1.7.1 

func (x CommitState) String() string

type CopyFileRequest added in v1.6.0 

type CopyFileRequest struct {
	Src                  *File    `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst                  *File    `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	Overwrite            bool     `protobuf:"varint,3,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CopyFileRequest) Descriptor added in v1.6.0 

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

func (*CopyFileRequest) GetDst added in v1.6.0 

func (m *CopyFileRequest) GetDst() *File

func (*CopyFileRequest) GetOverwrite added in v1.6.0 

func (m *CopyFileRequest) GetOverwrite() bool

func (*CopyFileRequest) GetSrc added in v1.6.0 

func (m *CopyFileRequest) GetSrc() *File

func (*CopyFileRequest) Marshal added in v1.6.0 

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

func (*CopyFileRequest) MarshalTo added in v1.6.0 

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

func (*CopyFileRequest) ProtoMessage added in v1.6.0 

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset added in v1.6.0 

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) Size added in v1.6.0 

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

func (*CopyFileRequest) String added in v1.6.0 

func (m *CopyFileRequest) String() string

func (*CopyFileRequest) Unmarshal added in v1.6.0 

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

func (*CopyFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *CopyFileRequest) XXX_DiscardUnknown()

func (*CopyFileRequest) XXX_Marshal added in v1.8.1 

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

func (*CopyFileRequest) XXX_Merge added in v1.8.1 

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

func (*CopyFileRequest) XXX_Size added in v1.8.1 

func (m *CopyFileRequest) XXX_Size() int

func (*CopyFileRequest) XXX_Unmarshal added in v1.8.1 

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

type CreateBranchRequest added in v1.7.0 

type CreateBranchRequest struct {
	Head *Commit `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	// s_branch matches the field number and type of SetBranchRequest.Branch in
	// Pachyderm 1.6--so that operations (generated by pachyderm 1.6's
	// Admin.Export) can be deserialized by pachyderm 1.7 correctly
	SBranch              string    `protobuf:"bytes,2,opt,name=s_branch,json=sBranch,proto3" json:"s_branch,omitempty"`
	Branch               *Branch   `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance           []*Branch `protobuf:"bytes,4,rep,name=provenance,proto3" json:"provenance,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateBranchRequest) Descriptor added in v1.7.0 

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

func (*CreateBranchRequest) GetBranch added in v1.7.0 

func (m *CreateBranchRequest) GetBranch() *Branch

func (*CreateBranchRequest) GetHead added in v1.7.0 

func (m *CreateBranchRequest) GetHead() *Commit

func (*CreateBranchRequest) GetProvenance added in v1.7.0 

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

func (*CreateBranchRequest) GetSBranch added in v1.7.0 

func (m *CreateBranchRequest) GetSBranch() string

func (*CreateBranchRequest) Marshal added in v1.7.0 

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

func (*CreateBranchRequest) MarshalTo added in v1.7.0 

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

func (*CreateBranchRequest) ProtoMessage added in v1.7.0 

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) Reset added in v1.7.0 

func (m *CreateBranchRequest) Reset()

func (*CreateBranchRequest) Size added in v1.7.0 

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

func (*CreateBranchRequest) String added in v1.7.0 

func (m *CreateBranchRequest) String() string

func (*CreateBranchRequest) Unmarshal added in v1.7.0 

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

func (*CreateBranchRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *CreateBranchRequest) XXX_DiscardUnknown()

func (*CreateBranchRequest) XXX_Marshal added in v1.8.1 

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

func (*CreateBranchRequest) XXX_Merge added in v1.8.1 

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

func (*CreateBranchRequest) XXX_Size added in v1.8.1 

func (m *CreateBranchRequest) XXX_Size() int

func (*CreateBranchRequest) XXX_Unmarshal added in v1.8.1 

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

type CreateRepoRequest 

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

func (*CreateRepoRequest) Descriptor 

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

func (*CreateRepoRequest) GetDescription added in v1.4.7 

func (m *CreateRepoRequest) GetDescription() string

func (*CreateRepoRequest) GetRepo 

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) GetUpdate added in v1.5.0 

func (m *CreateRepoRequest) GetUpdate() bool

func (*CreateRepoRequest) Marshal added in v1.5.0 

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

func (*CreateRepoRequest) MarshalTo added in v1.5.0 

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

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset 

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) Size added in v1.5.0 

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

func (*CreateRepoRequest) String 

func (m *CreateRepoRequest) String() string

func (*CreateRepoRequest) Unmarshal added in v1.5.0 

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

func (*CreateRepoRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *CreateRepoRequest) XXX_DiscardUnknown()

func (*CreateRepoRequest) XXX_Marshal added in v1.8.1 

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

func (*CreateRepoRequest) XXX_Merge added in v1.8.1 

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

func (*CreateRepoRequest) XXX_Size added in v1.8.1 

func (m *CreateRepoRequest) XXX_Size() int

func (*CreateRepoRequest) XXX_Unmarshal added in v1.8.1 

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

type DeleteBranchRequest added in v1.3.19 

type DeleteBranchRequest struct {
	Branch               *Branch  `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
	Force                bool     `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteBranchRequest) Descriptor added in v1.3.19 

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

func (*DeleteBranchRequest) GetBranch added in v1.3.19 

func (m *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) GetForce added in v1.7.0 

func (m *DeleteBranchRequest) GetForce() bool

func (*DeleteBranchRequest) Marshal added in v1.5.0 

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

func (*DeleteBranchRequest) MarshalTo added in v1.5.0 

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

func (*DeleteBranchRequest) ProtoMessage added in v1.3.19 

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset added in v1.3.19 

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) Size added in v1.5.0 

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

func (*DeleteBranchRequest) String added in v1.3.19 

func (m *DeleteBranchRequest) String() string

func (*DeleteBranchRequest) Unmarshal added in v1.5.0 

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

func (*DeleteBranchRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteBranchRequest) XXX_DiscardUnknown()

func (*DeleteBranchRequest) XXX_Marshal added in v1.8.1 

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

func (*DeleteBranchRequest) XXX_Merge added in v1.8.1 

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

func (*DeleteBranchRequest) XXX_Size added in v1.8.1 

func (m *DeleteBranchRequest) XXX_Size() int

func (*DeleteBranchRequest) XXX_Unmarshal added in v1.8.1 

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

type DeleteCommitRequest 

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

func (*DeleteCommitRequest) Descriptor 

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

func (*DeleteCommitRequest) GetCommit 

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) Marshal added in v1.5.0 

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

func (*DeleteCommitRequest) MarshalTo added in v1.5.0 

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

func (*DeleteCommitRequest) ProtoMessage 

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset 

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) Size added in v1.5.0 

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

func (*DeleteCommitRequest) String 

func (m *DeleteCommitRequest) String() string

func (*DeleteCommitRequest) Unmarshal added in v1.5.0 

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

func (*DeleteCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteCommitRequest) XXX_DiscardUnknown()

func (*DeleteCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*DeleteCommitRequest) XXX_Merge added in v1.8.1 

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

func (*DeleteCommitRequest) XXX_Size added in v1.8.1 

func (m *DeleteCommitRequest) XXX_Size() int

func (*DeleteCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type DeleteFileRequest 

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

func (*DeleteFileRequest) Descriptor 

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

func (*DeleteFileRequest) GetFile 

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) Marshal added in v1.5.0 

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

func (*DeleteFileRequest) MarshalTo added in v1.5.0 

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

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset 

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) Size added in v1.5.0 

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

func (*DeleteFileRequest) String 

func (m *DeleteFileRequest) String() string

func (*DeleteFileRequest) Unmarshal added in v1.5.0 

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

func (*DeleteFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteFileRequest) XXX_DiscardUnknown()

func (*DeleteFileRequest) XXX_Marshal added in v1.8.1 

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

func (*DeleteFileRequest) XXX_Merge added in v1.8.1 

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

func (*DeleteFileRequest) XXX_Size added in v1.8.1 

func (m *DeleteFileRequest) XXX_Size() int

func (*DeleteFileRequest) XXX_Unmarshal added in v1.8.1 

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

type DeleteObjectsRequest added in v1.4.7 

type DeleteObjectsRequest struct {
	Objects              []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteObjectsRequest) Descriptor added in v1.4.7 

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

func (*DeleteObjectsRequest) GetObjects added in v1.4.7 

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

func (*DeleteObjectsRequest) Marshal added in v1.5.0 

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

func (*DeleteObjectsRequest) MarshalTo added in v1.5.0 

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

func (*DeleteObjectsRequest) ProtoMessage added in v1.4.7 

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) Reset added in v1.4.7 

func (m *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) Size added in v1.5.0 

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

func (*DeleteObjectsRequest) String added in v1.4.7 

func (m *DeleteObjectsRequest) String() string

func (*DeleteObjectsRequest) Unmarshal added in v1.5.0 

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

func (*DeleteObjectsRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteObjectsRequest) XXX_DiscardUnknown()

func (*DeleteObjectsRequest) XXX_Marshal added in v1.8.1 

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

func (*DeleteObjectsRequest) XXX_Merge added in v1.8.1 

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

func (*DeleteObjectsRequest) XXX_Size added in v1.8.1 

func (m *DeleteObjectsRequest) XXX_Size() int

func (*DeleteObjectsRequest) XXX_Unmarshal added in v1.8.1 

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

type DeleteObjectsResponse added in v1.4.7 

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

func (*DeleteObjectsResponse) Descriptor added in v1.4.7 

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

func (*DeleteObjectsResponse) Marshal added in v1.5.0 

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

func (*DeleteObjectsResponse) MarshalTo added in v1.5.0 

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

func (*DeleteObjectsResponse) ProtoMessage added in v1.4.7 

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) Reset added in v1.4.7 

func (m *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) Size added in v1.5.0 

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

func (*DeleteObjectsResponse) String added in v1.4.7 

func (m *DeleteObjectsResponse) String() string

func (*DeleteObjectsResponse) Unmarshal added in v1.5.0 

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

func (*DeleteObjectsResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteObjectsResponse) XXX_DiscardUnknown()

func (*DeleteObjectsResponse) XXX_Marshal added in v1.8.1 

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

func (*DeleteObjectsResponse) XXX_Merge added in v1.8.1 

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

func (*DeleteObjectsResponse) XXX_Size added in v1.8.1 

func (m *DeleteObjectsResponse) XXX_Size() int

func (*DeleteObjectsResponse) XXX_Unmarshal added in v1.8.1 

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

type DeleteRepoRequest 

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

func (*DeleteRepoRequest) Descriptor 

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

func (*DeleteRepoRequest) GetAll added in v1.4.8 

func (m *DeleteRepoRequest) GetAll() bool

func (*DeleteRepoRequest) GetForce added in v1.3.5 

func (m *DeleteRepoRequest) GetForce() bool

func (*DeleteRepoRequest) GetRepo 

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) Marshal added in v1.5.0 

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

func (*DeleteRepoRequest) MarshalTo added in v1.5.0 

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

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset 

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) Size added in v1.5.0 

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

func (*DeleteRepoRequest) String 

func (m *DeleteRepoRequest) String() string

func (*DeleteRepoRequest) Unmarshal added in v1.5.0 

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

func (*DeleteRepoRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteRepoRequest) XXX_DiscardUnknown()

func (*DeleteRepoRequest) XXX_Marshal added in v1.8.1 

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

func (*DeleteRepoRequest) XXX_Merge added in v1.8.1 

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

func (*DeleteRepoRequest) XXX_Size added in v1.8.1 

func (m *DeleteRepoRequest) XXX_Size() int

func (*DeleteRepoRequest) XXX_Unmarshal added in v1.8.1 

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

type DeleteTagsRequest added in v1.4.7 

type DeleteTagsRequest struct {
	Tags                 []*Tag   `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTagsRequest) Descriptor added in v1.4.7 

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

func (*DeleteTagsRequest) GetTags added in v1.4.7 

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

func (*DeleteTagsRequest) Marshal added in v1.5.0 

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

func (*DeleteTagsRequest) MarshalTo added in v1.5.0 

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

func (*DeleteTagsRequest) ProtoMessage added in v1.4.7 

func (*DeleteTagsRequest) ProtoMessage()

func (*DeleteTagsRequest) Reset added in v1.4.7 

func (m *DeleteTagsRequest) Reset()

func (*DeleteTagsRequest) Size added in v1.5.0 

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

func (*DeleteTagsRequest) String added in v1.4.7 

func (m *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Unmarshal added in v1.5.0 

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

func (*DeleteTagsRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteTagsRequest) XXX_DiscardUnknown()

func (*DeleteTagsRequest) XXX_Marshal added in v1.8.1 

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

func (*DeleteTagsRequest) XXX_Merge added in v1.8.1 

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

func (*DeleteTagsRequest) XXX_Size added in v1.8.1 

func (m *DeleteTagsRequest) XXX_Size() int

func (*DeleteTagsRequest) XXX_Unmarshal added in v1.8.1 

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

type DeleteTagsResponse added in v1.4.7 

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

func (*DeleteTagsResponse) Descriptor added in v1.4.7 

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

func (*DeleteTagsResponse) Marshal added in v1.5.0 

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

func (*DeleteTagsResponse) MarshalTo added in v1.5.0 

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

func (*DeleteTagsResponse) ProtoMessage added in v1.4.7 

func (*DeleteTagsResponse) ProtoMessage()

func (*DeleteTagsResponse) Reset added in v1.4.7 

func (m *DeleteTagsResponse) Reset()

func (*DeleteTagsResponse) Size added in v1.5.0 

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

func (*DeleteTagsResponse) String added in v1.4.7 

func (m *DeleteTagsResponse) String() string

func (*DeleteTagsResponse) Unmarshal added in v1.5.0 

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

func (*DeleteTagsResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *DeleteTagsResponse) XXX_DiscardUnknown()

func (*DeleteTagsResponse) XXX_Marshal added in v1.8.1 

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

func (*DeleteTagsResponse) XXX_Merge added in v1.8.1 

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

func (*DeleteTagsResponse) XXX_Size added in v1.8.1 

func (m *DeleteTagsResponse) XXX_Size() int

func (*DeleteTagsResponse) XXX_Unmarshal added in v1.8.1 

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

type Delimiter 

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

func (Delimiter) EnumDescriptor 

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

func (Delimiter) String 

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,proto3" json:"new_file,omitempty"`
	// OldFile may be left nil in which case the same path in the parent of
	// NewFile's commit will be used.
	OldFile              *File    `protobuf:"bytes,2,opt,name=old_file,json=oldFile,proto3" json:"old_file,omitempty"`
	Shallow              bool     `protobuf:"varint,3,opt,name=shallow,proto3" json:"shallow,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiffFileRequest) Descriptor added in v1.4.8 

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

func (*DiffFileRequest) GetNewFile added in v1.4.8 

func (m *DiffFileRequest) GetNewFile() *File

func (*DiffFileRequest) GetOldFile added in v1.4.8 

func (m *DiffFileRequest) GetOldFile() *File

func (*DiffFileRequest) GetShallow added in v1.5.2 

func (m *DiffFileRequest) GetShallow() bool

func (*DiffFileRequest) Marshal added in v1.5.0 

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

func (*DiffFileRequest) MarshalTo added in v1.5.0 

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

func (*DiffFileRequest) ProtoMessage added in v1.4.8 

func (*DiffFileRequest) ProtoMessage()

func (*DiffFileRequest) Reset added in v1.4.8 

func (m *DiffFileRequest) Reset()

func (*DiffFileRequest) Size added in v1.5.0 

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

func (*DiffFileRequest) String added in v1.4.8 

func (m *DiffFileRequest) String() string

func (*DiffFileRequest) Unmarshal added in v1.5.0 

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

func (*DiffFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *DiffFileRequest) XXX_DiscardUnknown()

func (*DiffFileRequest) XXX_Marshal added in v1.8.1 

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

func (*DiffFileRequest) XXX_Merge added in v1.8.1 

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

func (*DiffFileRequest) XXX_Size added in v1.8.1 

func (m *DiffFileRequest) XXX_Size() int

func (*DiffFileRequest) XXX_Unmarshal added in v1.8.1 

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

type DiffFileResponse added in v1.4.8 

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

func (*DiffFileResponse) Descriptor added in v1.4.8 

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

func (*DiffFileResponse) GetNewFiles added in v1.4.8 

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

func (*DiffFileResponse) GetOldFiles added in v1.4.8 

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

func (*DiffFileResponse) Marshal added in v1.5.0 

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

func (*DiffFileResponse) MarshalTo added in v1.5.0 

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

func (*DiffFileResponse) ProtoMessage added in v1.4.8 

func (*DiffFileResponse) ProtoMessage()

func (*DiffFileResponse) Reset added in v1.4.8 

func (m *DiffFileResponse) Reset()

func (*DiffFileResponse) Size added in v1.5.0 

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

func (*DiffFileResponse) String added in v1.4.8 

func (m *DiffFileResponse) String() string

func (*DiffFileResponse) Unmarshal added in v1.5.0 

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

func (*DiffFileResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *DiffFileResponse) XXX_DiscardUnknown()

func (*DiffFileResponse) XXX_Marshal added in v1.8.1 

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

func (*DiffFileResponse) XXX_Merge added in v1.8.1 

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

func (*DiffFileResponse) XXX_Size added in v1.8.1 

func (m *DiffFileResponse) XXX_Size() int

func (*DiffFileResponse) XXX_Unmarshal added in v1.8.1 

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

type File 

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

func (*File) Descriptor 

func (*File) 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

func (*File) XXX_DiscardUnknown added in v1.8.1 

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal added in v1.8.1 

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

func (*File) XXX_Merge added in v1.8.1 

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

func (*File) XXX_Size added in v1.8.1 

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal added in v1.8.1 

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

type FileInfo 

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

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetBlockRefs added in v1.8.0 

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

func (*FileInfo) GetChildren 

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

func (*FileInfo) GetCommitted added in v1.8.1 

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

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

func (*FileInfo) XXX_DiscardUnknown added in v1.8.1 

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal added in v1.8.1 

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

func (*FileInfo) XXX_Merge added in v1.8.1 

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

func (*FileInfo) XXX_Size added in v1.8.1 

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal added in v1.8.1 

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

type FileInfos 

type FileInfos struct {
	FileInfo             []*FileInfo `protobuf:"bytes,1,rep,name=file_info,json=fileInfo,proto3" json:"file_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

FileInfos is the result of both ListFile and GlobFile

func (*FileInfos) Descriptor 

func (*FileInfos) 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

func (*FileInfos) XXX_DiscardUnknown added in v1.8.1 

func (m *FileInfos) XXX_DiscardUnknown()

func (*FileInfos) XXX_Marshal added in v1.8.1 

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

func (*FileInfos) XXX_Merge added in v1.8.1 

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

func (*FileInfos) XXX_Size added in v1.8.1 

func (m *FileInfos) XXX_Size() int

func (*FileInfos) XXX_Unmarshal added in v1.8.1 

func (m *FileInfos) XXX_Unmarshal(b []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,proto3" json:"commit,omitempty"`
	// description is a user-provided string describing this commit. Setting this
	// will overwrite the description set in StartCommit
	Description string    `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Tree        *Object   `protobuf:"bytes,3,opt,name=tree,proto3" json:"tree,omitempty"`
	Trees       []*Object `protobuf:"bytes,5,rep,name=trees,proto3" json:"trees,omitempty"`
	Datums      *Object   `protobuf:"bytes,7,opt,name=datums,proto3" json:"datums,omitempty"`
	SizeBytes   uint64    `protobuf:"varint,6,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// If set, 'commit' will be closed (its 'finished' field will be set to the
	// current time) but its 'tree' will be left nil.
	Empty                bool     `protobuf:"varint,4,opt,name=empty,proto3" json:"empty,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FinishCommitRequest) Descriptor 

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

func (*FinishCommitRequest) GetCommit 

func (m *FinishCommitRequest) GetCommit() *Commit

func (*FinishCommitRequest) GetDatums added in v1.8.0 

func (m *FinishCommitRequest) GetDatums() *Object

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) GetSizeBytes added in v1.8.0 

func (m *FinishCommitRequest) GetSizeBytes() uint64

func (*FinishCommitRequest) GetTree added in v1.7.0 

func (m *FinishCommitRequest) GetTree() *Object

func (*FinishCommitRequest) GetTrees added in v1.8.0 

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

func (*FinishCommitRequest) Marshal added in v1.5.0 

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

func (*FinishCommitRequest) MarshalTo added in v1.5.0 

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

func (*FinishCommitRequest) ProtoMessage 

func (*FinishCommitRequest) ProtoMessage()

func (*FinishCommitRequest) Reset 

func (m *FinishCommitRequest) Reset()

func (*FinishCommitRequest) Size added in v1.5.0 

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

func (*FinishCommitRequest) String 

func (m *FinishCommitRequest) String() string

func (*FinishCommitRequest) Unmarshal added in v1.5.0 

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

func (*FinishCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *FinishCommitRequest) XXX_DiscardUnknown()

func (*FinishCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*FinishCommitRequest) XXX_Merge added in v1.8.1 

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

func (*FinishCommitRequest) XXX_Size added in v1.8.1 

func (m *FinishCommitRequest) XXX_Size() int

func (*FinishCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type FlushCommitRequest 

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

func (*FlushCommitRequest) Descriptor 

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 

func (*FlushCommitRequest) ProtoMessage()

func (*FlushCommitRequest) Reset 

func (m *FlushCommitRequest) Reset()

func (*FlushCommitRequest) Size added in v1.5.0 

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

func (*FlushCommitRequest) String 

func (m *FlushCommitRequest) String() string

func (*FlushCommitRequest) Unmarshal added in v1.5.0 

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

func (*FlushCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *FlushCommitRequest) XXX_DiscardUnknown()

func (*FlushCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*FlushCommitRequest) XXX_Merge added in v1.8.1 

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

func (*FlushCommitRequest) XXX_Size added in v1.8.1 

func (m *FlushCommitRequest) XXX_Size() int

func (*FlushCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type GetBlocksRequest added in v1.8.0 

type GetBlocksRequest struct {
	BlockRefs   []*BlockRef `protobuf:"bytes,1,rep,name=blockRefs,proto3" json:"blockRefs,omitempty"`
	OffsetBytes uint64      `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes,proto3" json:"offset_bytes,omitempty"`
	// The number of bytes requested.
	SizeBytes uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// The total amount of bytes in these blocks.  It's OK if it's not
	// entirely accurate or if it's unknown (in which case it'd be set to 0).
	// It's used primarily as a hint for cache eviction.
	TotalSize            uint64   `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlocksRequest) Descriptor added in v1.8.0 

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

func (*GetBlocksRequest) GetBlockRefs added in v1.8.0 

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

func (*GetBlocksRequest) GetOffsetBytes added in v1.8.0 

func (m *GetBlocksRequest) GetOffsetBytes() uint64

func (*GetBlocksRequest) GetSizeBytes added in v1.8.0 

func (m *GetBlocksRequest) GetSizeBytes() uint64

func (*GetBlocksRequest) GetTotalSize added in v1.8.0 

func (m *GetBlocksRequest) GetTotalSize() uint64

func (*GetBlocksRequest) Marshal added in v1.8.0 

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

func (*GetBlocksRequest) MarshalTo added in v1.8.0 

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

func (*GetBlocksRequest) ProtoMessage added in v1.8.0 

func (*GetBlocksRequest) ProtoMessage()

func (*GetBlocksRequest) Reset added in v1.8.0 

func (m *GetBlocksRequest) Reset()

func (*GetBlocksRequest) Size added in v1.8.0 

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

func (*GetBlocksRequest) String added in v1.8.0 

func (m *GetBlocksRequest) String() string

func (*GetBlocksRequest) Unmarshal added in v1.8.0 

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

func (*GetBlocksRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *GetBlocksRequest) XXX_DiscardUnknown()

func (*GetBlocksRequest) XXX_Marshal added in v1.8.1 

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

func (*GetBlocksRequest) XXX_Merge added in v1.8.1 

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

func (*GetBlocksRequest) XXX_Size added in v1.8.1 

func (m *GetBlocksRequest) XXX_Size() int

func (*GetBlocksRequest) XXX_Unmarshal added in v1.8.1 

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

type GetFileRequest 

type GetFileRequest struct {
	File                 *File    `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	OffsetBytes          int64    `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes,proto3" json:"offset_bytes,omitempty"`
	SizeBytes            int64    `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFileRequest) Descriptor 

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

func (*GetFileRequest) GetFile 

func (m *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetOffsetBytes added in v1.3.5 

func (m *GetFileRequest) GetOffsetBytes() int64

func (*GetFileRequest) GetSizeBytes added in v1.3.5 

func (m *GetFileRequest) GetSizeBytes() int64

func (*GetFileRequest) Marshal added in v1.5.0 

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

func (*GetFileRequest) MarshalTo added in v1.5.0 

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

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) Reset 

func (m *GetFileRequest) Reset()

func (*GetFileRequest) Size added in v1.5.0 

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

func (*GetFileRequest) String 

func (m *GetFileRequest) String() string

func (*GetFileRequest) Unmarshal added in v1.5.0 

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

func (*GetFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *GetFileRequest) XXX_DiscardUnknown()

func (*GetFileRequest) XXX_Marshal added in v1.8.1 

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

func (*GetFileRequest) XXX_Merge added in v1.8.1 

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

func (*GetFileRequest) XXX_Size added in v1.8.1 

func (m *GetFileRequest) XXX_Size() int

func (*GetFileRequest) XXX_Unmarshal added in v1.8.1 

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

type GetObjectsRequest added in v1.3.19 

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

func (*GetObjectsRequest) Descriptor added in v1.3.19 

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

func (*GetObjectsRequest) GetObjects added in v1.3.19 

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

func (*GetObjectsRequest) GetOffsetBytes added in v1.3.19 

func (m *GetObjectsRequest) GetOffsetBytes() uint64

func (*GetObjectsRequest) GetSizeBytes added in v1.3.19 

func (m *GetObjectsRequest) GetSizeBytes() uint64

func (*GetObjectsRequest) GetTotalSize added in v1.6.0 

func (m *GetObjectsRequest) GetTotalSize() uint64

func (*GetObjectsRequest) Marshal added in v1.5.0 

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

func (*GetObjectsRequest) MarshalTo added in v1.5.0 

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

func (*GetObjectsRequest) ProtoMessage added in v1.3.19 

func (*GetObjectsRequest) ProtoMessage()

func (*GetObjectsRequest) Reset added in v1.3.19 

func (m *GetObjectsRequest) Reset()

func (*GetObjectsRequest) Size added in v1.5.0 

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

func (*GetObjectsRequest) String added in v1.3.19 

func (m *GetObjectsRequest) String() string

func (*GetObjectsRequest) Unmarshal added in v1.5.0 

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

func (*GetObjectsRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *GetObjectsRequest) XXX_DiscardUnknown()

func (*GetObjectsRequest) XXX_Marshal added in v1.8.1 

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

func (*GetObjectsRequest) XXX_Merge added in v1.8.1 

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

func (*GetObjectsRequest) XXX_Size added in v1.8.1 

func (m *GetObjectsRequest) XXX_Size() int

func (*GetObjectsRequest) XXX_Unmarshal added in v1.8.1 

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

type GlobFileRequest added in v1.3.19 

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

func (*GlobFileRequest) Descriptor added in v1.3.19 

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

func (*GlobFileRequest) GetCommit added in v1.3.19 

func (m *GlobFileRequest) GetCommit() *Commit

func (*GlobFileRequest) GetPattern added in v1.3.19 

func (m *GlobFileRequest) GetPattern() string

func (*GlobFileRequest) Marshal added in v1.5.0 

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

func (*GlobFileRequest) MarshalTo added in v1.5.0 

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

func (*GlobFileRequest) ProtoMessage added in v1.3.19 

func (*GlobFileRequest) ProtoMessage()

func (*GlobFileRequest) Reset added in v1.3.19 

func (m *GlobFileRequest) Reset()

func (*GlobFileRequest) Size added in v1.5.0 

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

func (*GlobFileRequest) String added in v1.3.19 

func (m *GlobFileRequest) String() string

func (*GlobFileRequest) Unmarshal added in v1.5.0 

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

func (*GlobFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *GlobFileRequest) XXX_DiscardUnknown()

func (*GlobFileRequest) XXX_Marshal added in v1.8.1 

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

func (*GlobFileRequest) XXX_Merge added in v1.8.1 

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

func (*GlobFileRequest) XXX_Size added in v1.8.1 

func (m *GlobFileRequest) XXX_Size() int

func (*GlobFileRequest) XXX_Unmarshal added in v1.8.1 

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

type InspectBranchRequest added in v1.7.0 

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

func (*InspectBranchRequest) Descriptor added in v1.7.0 

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

func (*InspectBranchRequest) GetBranch added in v1.7.0 

func (m *InspectBranchRequest) GetBranch() *Branch

func (*InspectBranchRequest) Marshal added in v1.7.0 

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

func (*InspectBranchRequest) MarshalTo added in v1.7.0 

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

func (*InspectBranchRequest) ProtoMessage added in v1.7.0 

func (*InspectBranchRequest) ProtoMessage()

func (*InspectBranchRequest) Reset added in v1.7.0 

func (m *InspectBranchRequest) Reset()

func (*InspectBranchRequest) Size added in v1.7.0 

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

func (*InspectBranchRequest) String added in v1.7.0 

func (m *InspectBranchRequest) String() string

func (*InspectBranchRequest) Unmarshal added in v1.7.0 

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

func (*InspectBranchRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *InspectBranchRequest) XXX_DiscardUnknown()

func (*InspectBranchRequest) XXX_Marshal added in v1.8.1 

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

func (*InspectBranchRequest) XXX_Merge added in v1.8.1 

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

func (*InspectBranchRequest) XXX_Size added in v1.8.1 

func (m *InspectBranchRequest) XXX_Size() int

func (*InspectBranchRequest) XXX_Unmarshal added in v1.8.1 

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

type InspectCommitRequest 

type InspectCommitRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// BlockState causes inspect commit to block until the commit is in the desired state.
	BlockState           CommitState `protobuf:"varint,2,opt,name=block_state,json=blockState,proto3,enum=pfs.CommitState" json:"block_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*InspectCommitRequest) Descriptor 

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

func (*InspectCommitRequest) GetBlockState added in v1.7.1 

func (m *InspectCommitRequest) GetBlockState() CommitState

func (*InspectCommitRequest) GetCommit 

func (m *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) Marshal added in v1.5.0 

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

func (*InspectCommitRequest) MarshalTo added in v1.5.0 

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

func (*InspectCommitRequest) ProtoMessage 

func (*InspectCommitRequest) ProtoMessage()

func (*InspectCommitRequest) Reset 

func (m *InspectCommitRequest) Reset()

func (*InspectCommitRequest) Size added in v1.5.0 

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

func (*InspectCommitRequest) String 

func (m *InspectCommitRequest) String() string

func (*InspectCommitRequest) Unmarshal added in v1.5.0 

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

func (*InspectCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *InspectCommitRequest) XXX_DiscardUnknown()

func (*InspectCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*InspectCommitRequest) XXX_Merge added in v1.8.1 

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

func (*InspectCommitRequest) XXX_Size added in v1.8.1 

func (m *InspectCommitRequest) XXX_Size() int

func (*InspectCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type InspectFileRequest 

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

func (*InspectFileRequest) Descriptor 

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

func (*InspectFileRequest) GetFile 

func (m *InspectFileRequest) GetFile() *File

func (*InspectFileRequest) Marshal added in v1.5.0 

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

func (*InspectFileRequest) MarshalTo added in v1.5.0 

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

func (*InspectFileRequest) ProtoMessage 

func (*InspectFileRequest) ProtoMessage()

func (*InspectFileRequest) Reset 

func (m *InspectFileRequest) Reset()

func (*InspectFileRequest) Size added in v1.5.0 

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

func (*InspectFileRequest) String 

func (m *InspectFileRequest) String() string

func (*InspectFileRequest) Unmarshal added in v1.5.0 

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

func (*InspectFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *InspectFileRequest) XXX_DiscardUnknown()

func (*InspectFileRequest) XXX_Marshal added in v1.8.1 

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

func (*InspectFileRequest) XXX_Merge added in v1.8.1 

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

func (*InspectFileRequest) XXX_Size added in v1.8.1 

func (m *InspectFileRequest) XXX_Size() int

func (*InspectFileRequest) XXX_Unmarshal added in v1.8.1 

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

type InspectRepoRequest 

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

func (*InspectRepoRequest) Descriptor 

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

func (*InspectRepoRequest) GetRepo 

func (m *InspectRepoRequest) GetRepo() *Repo

func (*InspectRepoRequest) Marshal added in v1.5.0 

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

func (*InspectRepoRequest) MarshalTo added in v1.5.0 

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

func (*InspectRepoRequest) ProtoMessage 

func (*InspectRepoRequest) ProtoMessage()

func (*InspectRepoRequest) Reset 

func (m *InspectRepoRequest) Reset()

func (*InspectRepoRequest) Size added in v1.5.0 

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

func (*InspectRepoRequest) String 

func (m *InspectRepoRequest) String() string

func (*InspectRepoRequest) Unmarshal added in v1.5.0 

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

func (*InspectRepoRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *InspectRepoRequest) XXX_DiscardUnknown()

func (*InspectRepoRequest) XXX_Marshal added in v1.8.1 

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

func (*InspectRepoRequest) XXX_Merge added in v1.8.1 

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

func (*InspectRepoRequest) XXX_Size added in v1.8.1 

func (m *InspectRepoRequest) XXX_Size() int

func (*InspectRepoRequest) XXX_Unmarshal added in v1.8.1 

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

type ListBranchRequest 

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

func (*ListBranchRequest) Descriptor 

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

func (*ListBranchRequest) GetRepo 

func (m *ListBranchRequest) GetRepo() *Repo

func (*ListBranchRequest) Marshal added in v1.5.0 

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

func (*ListBranchRequest) MarshalTo added in v1.5.0 

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

func (*ListBranchRequest) ProtoMessage 

func (*ListBranchRequest) ProtoMessage()

func (*ListBranchRequest) Reset 

func (m *ListBranchRequest) Reset()

func (*ListBranchRequest) Size added in v1.5.0 

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

func (*ListBranchRequest) String 

func (m *ListBranchRequest) String() string

func (*ListBranchRequest) Unmarshal added in v1.5.0 

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

func (*ListBranchRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *ListBranchRequest) XXX_DiscardUnknown()

func (*ListBranchRequest) XXX_Marshal added in v1.8.1 

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

func (*ListBranchRequest) XXX_Merge added in v1.8.1 

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

func (*ListBranchRequest) XXX_Size added in v1.8.1 

func (m *ListBranchRequest) XXX_Size() int

func (*ListBranchRequest) XXX_Unmarshal added in v1.8.1 

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

type ListCommitRequest 

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

func (*ListCommitRequest) Descriptor 

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

func (*ListCommitRequest) GetFrom added in v1.3.19 

func (m *ListCommitRequest) GetFrom() *Commit

func (*ListCommitRequest) GetNumber added in v1.3.19 

func (m *ListCommitRequest) GetNumber() uint64

func (*ListCommitRequest) GetRepo 

func (m *ListCommitRequest) GetRepo() *Repo

func (*ListCommitRequest) GetTo added in v1.3.19 

func (m *ListCommitRequest) GetTo() *Commit

func (*ListCommitRequest) Marshal added in v1.5.0 

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

func (*ListCommitRequest) MarshalTo added in v1.5.0 

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

func (*ListCommitRequest) ProtoMessage 

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) Reset 

func (m *ListCommitRequest) Reset()

func (*ListCommitRequest) Size added in v1.5.0 

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

func (*ListCommitRequest) String 

func (m *ListCommitRequest) String() string

func (*ListCommitRequest) Unmarshal added in v1.5.0 

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

func (*ListCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *ListCommitRequest) XXX_DiscardUnknown()

func (*ListCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*ListCommitRequest) XXX_Merge added in v1.8.1 

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

func (*ListCommitRequest) XXX_Size added in v1.8.1 

func (m *ListCommitRequest) XXX_Size() int

func (*ListCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type ListFileRequest 

type ListFileRequest struct {
	// File is the parent directory of the files we want to list. This sets the
	// repo, the commit/branch, and path prefix of files we're interested in
	// If the "path" field is omitted, a list of files at the top level of the repo
	// is returned
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// Full indicates whether the result should include file contents, which may
	// be large (i.e. the list of children for directories, and the list of object
	// references for regular files)
	Full bool `protobuf:"varint,2,opt,name=full,proto3" json:"full,omitempty"`
	// History indicates how many historical versions you want returned. Its
	// semantics are:
	// 0: Return the files as they are at the commit in `file`. FileInfo.File
	//    will equal File in this request.
	// 1: Return the files as they are in the last commit they were modified in.
	//    (This will have the same hash as if you'd passed 0, but
	//    FileInfo.File.Commit will be different.
	// 2: Return the above and the files as they are in the next-last commit they
	//    were modified in.
	// 3: etc.
	// -1: Return all historical versions.
	History              int64    `protobuf:"varint,3,opt,name=history,proto3" json:"history,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListFileRequest) Descriptor 

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) GetHistory added in v1.8.1 

func (m *ListFileRequest) GetHistory() int64

func (*ListFileRequest) Marshal added in v1.5.0 

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

func (*ListFileRequest) MarshalTo added in v1.5.0 

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

func (*ListFileRequest) ProtoMessage 

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) Reset 

func (m *ListFileRequest) Reset()

func (*ListFileRequest) Size added in v1.5.0 

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

func (*ListFileRequest) String 

func (m *ListFileRequest) String() string

func (*ListFileRequest) Unmarshal added in v1.5.0 

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

func (*ListFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *ListFileRequest) XXX_DiscardUnknown()

func (*ListFileRequest) XXX_Marshal added in v1.8.1 

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

func (*ListFileRequest) XXX_Merge added in v1.8.1 

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

func (*ListFileRequest) XXX_Size added in v1.8.1 

func (m *ListFileRequest) XXX_Size() int

func (*ListFileRequest) XXX_Unmarshal added in v1.8.1 

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

type ListObjectsRequest added in v1.4.7 

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

func (*ListObjectsRequest) Descriptor added in v1.4.7 

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

func (*ListObjectsRequest) Marshal added in v1.5.0 

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

func (*ListObjectsRequest) MarshalTo added in v1.5.0 

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

func (*ListObjectsRequest) ProtoMessage added in v1.4.7 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset added in v1.4.7 

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) Size added in v1.5.0 

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

func (*ListObjectsRequest) String added in v1.4.7 

func (m *ListObjectsRequest) String() string

func (*ListObjectsRequest) Unmarshal added in v1.5.0 

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

func (*ListObjectsRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *ListObjectsRequest) XXX_DiscardUnknown()

func (*ListObjectsRequest) XXX_Marshal added in v1.8.1 

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

func (*ListObjectsRequest) XXX_Merge added in v1.8.1 

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

func (*ListObjectsRequest) XXX_Size added in v1.8.1 

func (m *ListObjectsRequest) XXX_Size() int

func (*ListObjectsRequest) XXX_Unmarshal added in v1.8.1 

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

type ListRepoRequest 

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

func (*ListRepoRequest) Descriptor 

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

func (*ListRepoRequest) Marshal added in v1.5.0 

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

func (*ListRepoRequest) MarshalTo added in v1.5.0 

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

func (*ListRepoRequest) ProtoMessage 

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset 

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) Size added in v1.5.0 

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

func (*ListRepoRequest) String 

func (m *ListRepoRequest) String() string

func (*ListRepoRequest) Unmarshal added in v1.5.0 

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

func (*ListRepoRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *ListRepoRequest) XXX_DiscardUnknown()

func (*ListRepoRequest) XXX_Marshal added in v1.8.1 

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

func (*ListRepoRequest) XXX_Merge added in v1.8.1 

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

func (*ListRepoRequest) XXX_Size added in v1.8.1 

func (m *ListRepoRequest) XXX_Size() int

func (*ListRepoRequest) XXX_Unmarshal added in v1.8.1 

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

type ListRepoResponse added in v1.6.0 

type ListRepoResponse struct {
	RepoInfo             []*RepoInfo `protobuf:"bytes,1,rep,name=repo_info,json=repoInfo,proto3" json:"repo_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ListRepoResponse) Descriptor added in v1.6.0 

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

func (*ListRepoResponse) GetRepoInfo added in v1.6.0 

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

func (*ListRepoResponse) Marshal added in v1.6.0 

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

func (*ListRepoResponse) MarshalTo added in v1.6.0 

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

func (*ListRepoResponse) ProtoMessage added in v1.6.0 

func (*ListRepoResponse) ProtoMessage()

func (*ListRepoResponse) Reset added in v1.6.0 

func (m *ListRepoResponse) Reset()

func (*ListRepoResponse) Size added in v1.6.0 

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

func (*ListRepoResponse) String added in v1.6.0 

func (m *ListRepoResponse) String() string

func (*ListRepoResponse) Unmarshal added in v1.6.0 

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

func (*ListRepoResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *ListRepoResponse) XXX_DiscardUnknown()

func (*ListRepoResponse) XXX_Marshal added in v1.8.1 

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

func (*ListRepoResponse) XXX_Merge added in v1.8.1 

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

func (*ListRepoResponse) XXX_Size added in v1.8.1 

func (m *ListRepoResponse) XXX_Size() int

func (*ListRepoResponse) XXX_Unmarshal added in v1.8.1 

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

type ListTagsRequest added in v1.4.7 

type ListTagsRequest struct {
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	IncludeObject        bool     `protobuf:"varint,2,opt,name=include_object,json=includeObject,proto3" json:"include_object,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTagsRequest) Descriptor added in v1.4.7 

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

func (*ListTagsRequest) GetIncludeObject added in v1.4.7 

func (m *ListTagsRequest) GetIncludeObject() bool

func (*ListTagsRequest) GetPrefix added in v1.4.7 

func (m *ListTagsRequest) GetPrefix() string

func (*ListTagsRequest) Marshal added in v1.5.0 

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

func (*ListTagsRequest) MarshalTo added in v1.5.0 

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

func (*ListTagsRequest) ProtoMessage added in v1.4.7 

func (*ListTagsRequest) ProtoMessage()

func (*ListTagsRequest) Reset added in v1.4.7 

func (m *ListTagsRequest) Reset()

func (*ListTagsRequest) Size added in v1.5.0 

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

func (*ListTagsRequest) String added in v1.4.7 

func (m *ListTagsRequest) String() string

func (*ListTagsRequest) Unmarshal added in v1.5.0 

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

func (*ListTagsRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *ListTagsRequest) XXX_DiscardUnknown()

func (*ListTagsRequest) XXX_Marshal added in v1.8.1 

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

func (*ListTagsRequest) XXX_Merge added in v1.8.1 

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

func (*ListTagsRequest) XXX_Size added in v1.8.1 

func (m *ListTagsRequest) XXX_Size() int

func (*ListTagsRequest) XXX_Unmarshal added in v1.8.1 

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

type ListTagsResponse added in v1.4.7 

type ListTagsResponse struct {
	Tag                  *Tag     `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Object               *Object  `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTagsResponse) Descriptor added in v1.4.7 

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

func (*ListTagsResponse) GetObject added in v1.4.7 

func (m *ListTagsResponse) GetObject() *Object

func (*ListTagsResponse) GetTag added in v1.4.7 

func (m *ListTagsResponse) GetTag() *Tag

func (*ListTagsResponse) Marshal added in v1.5.0 

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

func (*ListTagsResponse) MarshalTo added in v1.5.0 

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

func (*ListTagsResponse) ProtoMessage added in v1.4.7 

func (*ListTagsResponse) ProtoMessage()

func (*ListTagsResponse) Reset added in v1.4.7 

func (m *ListTagsResponse) Reset()

func (*ListTagsResponse) Size added in v1.5.0 

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

func (*ListTagsResponse) String added in v1.4.7 

func (m *ListTagsResponse) String() string

func (*ListTagsResponse) Unmarshal added in v1.5.0 

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

func (*ListTagsResponse) XXX_DiscardUnknown added in v1.8.1 

func (m *ListTagsResponse) XXX_DiscardUnknown()

func (*ListTagsResponse) XXX_Marshal added in v1.8.1 

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

func (*ListTagsResponse) XXX_Merge added in v1.8.1 

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

func (*ListTagsResponse) XXX_Size added in v1.8.1 

func (m *ListTagsResponse) XXX_Size() int

func (*ListTagsResponse) XXX_Unmarshal added in v1.8.1 

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

type Object added in v1.3.9 

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

func (*Object) Descriptor added in v1.3.9 

func (*Object) 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

func (*Object) XXX_DiscardUnknown added in v1.8.1 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal added in v1.8.1 

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

func (*Object) XXX_Merge added in v1.8.1 

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

func (*Object) XXX_Size added in v1.8.1 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal added in v1.8.1 

func (m *Object) XXX_Unmarshal(b []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)
	PutObjects(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectsClient, error)
	GetObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (ObjectAPI_GetObjectClient, error)
	GetObjects(ctx context.Context, in *GetObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_GetObjectsClient, error)
	GetBlocks(ctx context.Context, in *GetBlocksRequest, opts ...grpc.CallOption) (ObjectAPI_GetBlocksClient, error)
	TagObject(ctx context.Context, in *TagObjectRequest, opts ...grpc.CallOption) (*types.Empty, error)
	InspectObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (*ObjectInfo, error)
	// CheckObject checks if an object exists in the blob store without
	// actually reading the object.
	CheckObject(ctx context.Context, in *CheckObjectRequest, opts ...grpc.CallOption) (*CheckObjectResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_ListObjectsClient, error)
	DeleteObjects(ctx context.Context, in *DeleteObjectsRequest, opts ...grpc.CallOption) (*DeleteObjectsResponse, error)
	GetTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (ObjectAPI_GetTagClient, error)
	InspectTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (*ObjectInfo, error)
	ListTags(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (ObjectAPI_ListTagsClient, error)
	DeleteTags(ctx context.Context, in *DeleteTagsRequest, opts ...grpc.CallOption) (*DeleteTagsResponse, error)
	Compact(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)
}

ObjectAPIClient is the client API for ObjectAPI service.

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

func NewObjectAPIClient 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
	PutObjects(ObjectAPI_PutObjectsServer) error
	GetObject(*Object, ObjectAPI_GetObjectServer) error
	GetObjects(*GetObjectsRequest, ObjectAPI_GetObjectsServer) error
	GetBlocks(*GetBlocksRequest, ObjectAPI_GetBlocksServer) error
	TagObject(context.Context, *TagObjectRequest) (*types.Empty, error)
	InspectObject(context.Context, *Object) (*ObjectInfo, error)
	// CheckObject checks if an object exists in the blob store without
	// actually reading the object.
	CheckObject(context.Context, *CheckObjectRequest) (*CheckObjectResponse, error)
	ListObjects(*ListObjectsRequest, ObjectAPI_ListObjectsServer) error
	DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)
	GetTag(*Tag, ObjectAPI_GetTagServer) error
	InspectTag(context.Context, *Tag) (*ObjectInfo, error)
	ListTags(*ListTagsRequest, ObjectAPI_ListTagsServer) error
	DeleteTags(context.Context, *DeleteTagsRequest) (*DeleteTagsResponse, error)
	Compact(context.Context, *types.Empty) (*types.Empty, error)
}

ObjectAPIServer is the server API for ObjectAPI service.

type ObjectAPI_GetBlocksClient added in v1.8.0 

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

type ObjectAPI_GetBlocksServer added in v1.8.0 

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

type ObjectAPI_GetObjectClient added in v1.3.9 

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

type ObjectAPI_GetObjectServer added in v1.3.9 

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

type ObjectAPI_GetObjectsClient added in v1.3.19 

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

type ObjectAPI_GetObjectsServer added in v1.3.19 

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

type ObjectAPI_GetTagClient added in v1.3.9 

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

type ObjectAPI_GetTagServer added in v1.3.9 

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

type ObjectAPI_ListObjectsClient added in v1.4.7 

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

type ObjectAPI_ListObjectsServer added in v1.4.7 

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

type ObjectAPI_ListTagsClient added in v1.4.7 

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

type ObjectAPI_ListTagsServer added in v1.4.7 

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

type ObjectAPI_PutObjectClient added in v1.3.9 

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

type ObjectAPI_PutObjectServer added in v1.3.9 

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

type ObjectAPI_PutObjectSplitClient added in v1.6.0 

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

type ObjectAPI_PutObjectSplitServer added in v1.6.0 

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

type ObjectAPI_PutObjectsClient added in v1.8.0 

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

type ObjectAPI_PutObjectsServer added in v1.8.0 

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

type ObjectIndex added in v1.3.9 

type ObjectIndex struct {
	Objects              map[string]*BlockRef `` /* 155-byte string literal not displayed */
	Tags                 map[string]*Object   `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ObjectIndex) Descriptor added in v1.3.9 

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

func (*ObjectIndex) GetObjects added in v1.3.9 

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

func (*ObjectIndex) GetTags added in v1.3.9 

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

func (*ObjectIndex) Marshal added in v1.5.0 

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

func (*ObjectIndex) MarshalTo added in v1.5.0 

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

func (*ObjectIndex) ProtoMessage added in v1.3.9 

func (*ObjectIndex) ProtoMessage()

func (*ObjectIndex) Reset added in v1.3.9 

func (m *ObjectIndex) Reset()

func (*ObjectIndex) Size added in v1.5.0 

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

func (*ObjectIndex) String added in v1.3.9 

func (m *ObjectIndex) String() string

func (*ObjectIndex) Unmarshal added in v1.5.0 

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

func (*ObjectIndex) XXX_DiscardUnknown added in v1.8.1 

func (m *ObjectIndex) XXX_DiscardUnknown()

func (*ObjectIndex) XXX_Marshal added in v1.8.1 

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

func (*ObjectIndex) XXX_Merge added in v1.8.1 

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

func (*ObjectIndex) XXX_Size added in v1.8.1 

func (m *ObjectIndex) XXX_Size() int

func (*ObjectIndex) XXX_Unmarshal added in v1.8.1 

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

type ObjectInfo added in v1.3.9 

type ObjectInfo struct {
	Object               *Object   `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	BlockRef             *BlockRef `protobuf:"bytes,2,opt,name=block_ref,json=blockRef,proto3" json:"block_ref,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ObjectInfo) Descriptor added in v1.3.9 

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

func (*ObjectInfo) GetBlockRef added in v1.3.9 

func (m *ObjectInfo) GetBlockRef() *BlockRef

func (*ObjectInfo) GetObject added in v1.3.9 

func (m *ObjectInfo) GetObject() *Object

func (*ObjectInfo) Marshal added in v1.5.0 

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

func (*ObjectInfo) MarshalTo added in v1.5.0 

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

func (*ObjectInfo) ProtoMessage added in v1.3.9 

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) Reset added in v1.3.9 

func (m *ObjectInfo) Reset()

func (*ObjectInfo) Size added in v1.5.0 

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

func (*ObjectInfo) String added in v1.3.9 

func (m *ObjectInfo) String() string

func (*ObjectInfo) Unmarshal added in v1.5.0 

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

func (*ObjectInfo) XXX_DiscardUnknown added in v1.8.1 

func (m *ObjectInfo) XXX_DiscardUnknown()

func (*ObjectInfo) XXX_Marshal added in v1.8.1 

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

func (*ObjectInfo) XXX_Merge added in v1.8.1 

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

func (*ObjectInfo) XXX_Size added in v1.8.1 

func (m *ObjectInfo) XXX_Size() int

func (*ObjectInfo) XXX_Unmarshal added in v1.8.1 

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

type Objects added in v1.6.0 

type Objects struct {
	Objects              []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Objects) Descriptor added in v1.6.0 

func (*Objects) 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

func (*Objects) XXX_DiscardUnknown added in v1.8.1 

func (m *Objects) XXX_DiscardUnknown()

func (*Objects) XXX_Marshal added in v1.8.1 

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

func (*Objects) XXX_Merge added in v1.8.1 

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

func (*Objects) XXX_Size added in v1.8.1 

func (m *Objects) XXX_Size() int

func (*Objects) XXX_Unmarshal added in v1.8.1 

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

type OverwriteIndex added in v1.6.0 

type OverwriteIndex struct {
	Index                int64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*OverwriteIndex) Descriptor added in v1.6.0 

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

func (*OverwriteIndex) GetIndex added in v1.6.0 

func (m *OverwriteIndex) GetIndex() int64

func (*OverwriteIndex) Marshal added in v1.6.0 

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

func (*OverwriteIndex) MarshalTo added in v1.6.0 

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

func (*OverwriteIndex) ProtoMessage added in v1.6.0 

func (*OverwriteIndex) ProtoMessage()

func (*OverwriteIndex) Reset added in v1.6.0 

func (m *OverwriteIndex) Reset()

func (*OverwriteIndex) Size added in v1.6.0 

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

func (*OverwriteIndex) String added in v1.6.0 

func (m *OverwriteIndex) String() string

func (*OverwriteIndex) Unmarshal added in v1.6.0 

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

func (*OverwriteIndex) XXX_DiscardUnknown added in v1.8.1 

func (m *OverwriteIndex) XXX_DiscardUnknown()

func (*OverwriteIndex) XXX_Marshal added in v1.8.1 

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

func (*OverwriteIndex) XXX_Merge added in v1.8.1 

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

func (*OverwriteIndex) XXX_Size added in v1.8.1 

func (m *OverwriteIndex) XXX_Size() int

func (*OverwriteIndex) XXX_Unmarshal added in v1.8.1 

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

type PutFileRecord added in v1.6.0 

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

PutFileRecord is used to record PutFile requests in etcd temporarily.

func (*PutFileRecord) Descriptor added in v1.6.0 

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

func (*PutFileRecord) GetObjectHash added in v1.6.0 

func (m *PutFileRecord) GetObjectHash() string

func (*PutFileRecord) GetOverwriteIndex added in v1.6.0 

func (m *PutFileRecord) GetOverwriteIndex() *OverwriteIndex

func (*PutFileRecord) GetSizeBytes added in v1.6.0 

func (m *PutFileRecord) GetSizeBytes() int64

func (*PutFileRecord) Marshal added in v1.6.0 

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

func (*PutFileRecord) MarshalTo added in v1.6.0 

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

func (*PutFileRecord) ProtoMessage added in v1.6.0 

func (*PutFileRecord) ProtoMessage()

func (*PutFileRecord) Reset added in v1.6.0 

func (m *PutFileRecord) Reset()

func (*PutFileRecord) Size added in v1.6.0 

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

func (*PutFileRecord) String added in v1.6.0 

func (m *PutFileRecord) String() string

func (*PutFileRecord) Unmarshal added in v1.6.0 

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

func (*PutFileRecord) XXX_DiscardUnknown added in v1.8.1 

func (m *PutFileRecord) XXX_DiscardUnknown()

func (*PutFileRecord) XXX_Marshal added in v1.8.1 

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

func (*PutFileRecord) XXX_Merge added in v1.8.1 

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

func (*PutFileRecord) XXX_Size added in v1.8.1 

func (m *PutFileRecord) XXX_Size() int

func (*PutFileRecord) XXX_Unmarshal added in v1.8.1 

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

type PutFileRecords added in v1.6.0 

type PutFileRecords struct {
	Split                bool             `protobuf:"varint,1,opt,name=split,proto3" json:"split,omitempty"`
	Records              []*PutFileRecord `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	Tombstone            bool             `protobuf:"varint,3,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	Header               *PutFileRecord   `protobuf:"bytes,4,opt,name=header,proto3" json:"header,omitempty"`
	Footer               *PutFileRecord   `protobuf:"bytes,5,opt,name=footer,proto3" json:"footer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PutFileRecords) Descriptor added in v1.6.0 

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

func (*PutFileRecords) GetFooter added in v1.7.10 

func (m *PutFileRecords) GetFooter() *PutFileRecord

func (*PutFileRecords) GetHeader added in v1.7.10 

func (m *PutFileRecords) GetHeader() *PutFileRecord

func (*PutFileRecords) GetRecords added in v1.6.0 

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

func (*PutFileRecords) GetSplit added in v1.6.0 

func (m *PutFileRecords) GetSplit() bool

func (*PutFileRecords) GetTombstone added in v1.6.7 

func (m *PutFileRecords) GetTombstone() bool

func (*PutFileRecords) Marshal added in v1.6.0 

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

func (*PutFileRecords) MarshalTo added in v1.6.0 

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

func (*PutFileRecords) ProtoMessage added in v1.6.0 

func (*PutFileRecords) ProtoMessage()

func (*PutFileRecords) Reset added in v1.6.0 

func (m *PutFileRecords) Reset()

func (*PutFileRecords) Size added in v1.6.0 

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

func (*PutFileRecords) String added in v1.6.0 

func (m *PutFileRecords) String() string

func (*PutFileRecords) Unmarshal added in v1.6.0 

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

func (*PutFileRecords) XXX_DiscardUnknown added in v1.8.1 

func (m *PutFileRecords) XXX_DiscardUnknown()

func (*PutFileRecords) XXX_Marshal added in v1.8.1 

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

func (*PutFileRecords) XXX_Merge added in v1.8.1 

func (dst *PutFileRecords) XXX_Merge(src proto.Message)

func (*PutFileRecords) XXX_Size added in v1.8.1 

func (m *PutFileRecords) XXX_Size() int

func (*PutFileRecords) XXX_Unmarshal added in v1.8.1 

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

type PutFileRequest 

type PutFileRequest struct {
	File  *File  `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Url   string `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// applies only to URLs that can be recursively walked, for example s3:// URLs
	Recursive bool `protobuf:"varint,6,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// Delimiter causes data to be broken up into separate files with File.Path
	// as a prefix.
	Delimiter Delimiter `protobuf:"varint,7,opt,name=delimiter,proto3,enum=pfs.Delimiter" json:"delimiter,omitempty"`
	// TargetFileDatums specifies the target number of datums in each written
	// file it may be lower if data does not split evenly, but will never be
	// higher, unless the value is 0.
	TargetFileDatums int64 `protobuf:"varint,8,opt,name=target_file_datums,json=targetFileDatums,proto3" json:"target_file_datums,omitempty"`
	// TargetFileBytes specifies the target number of bytes in each written
	// file, files may have more or fewer bytes than the target.
	TargetFileBytes int64 `protobuf:"varint,9,opt,name=target_file_bytes,json=targetFileBytes,proto3" json:"target_file_bytes,omitempty"`
	// header_records is an option for splitting data when 'delimiter' is not NONE
	// (or SQL). It specifies the number of records that are converted to a
	// header and applied to all file shards.
	//
	// This is particularly useful for CSV files, where the first row often
	// contains column titles; if 'header_records' is set to one in that case,
	// the first row will be associated with the directory that contains the rest
	// of the split-up csv rows as files, and if any data is retrieved from that
	// directory by GetFile, it will appear to begin with that first row of
	// column labels (including in pipeline workers).
	//
	// Note that SQL files have their own logic for determining headers (their
	// header is not a number of records, but a collection of SQL commands that
	// create the relevant tables and such). This way, SQL files retrieved by
	// GetFile can be passed to psql, and they will set up the appropriate tables
	// before inserting the records in the files that were retrieved.
	HeaderRecords int64 `protobuf:"varint,11,opt,name=header_records,json=headerRecords,proto3" json:"header_records,omitempty"`
	// overwrite_index is the object index where the write starts from.  All
	// existing objects starting from the index are deleted.
	OverwriteIndex       *OverwriteIndex `protobuf:"bytes,10,opt,name=overwrite_index,json=overwriteIndex,proto3" json:"overwrite_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PutFileRequest) Descriptor 

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

func (*PutFileRequest) GetDelimiter added in v1.3.5 

func (m *PutFileRequest) GetDelimiter() Delimiter

func (*PutFileRequest) GetFile 

func (m *PutFileRequest) GetFile() *File

func (*PutFileRequest) GetHeaderRecords added in v1.8.0 

func (m *PutFileRequest) GetHeaderRecords() int64

func (*PutFileRequest) GetOverwriteIndex added in v1.6.0 

func (m *PutFileRequest) GetOverwriteIndex() *OverwriteIndex

func (*PutFileRequest) GetRecursive added in v1.3.5 

func (m *PutFileRequest) GetRecursive() bool

func (*PutFileRequest) GetTargetFileBytes added in v1.3.19 

func (m *PutFileRequest) GetTargetFileBytes() int64

func (*PutFileRequest) GetTargetFileDatums added in v1.3.19 

func (m *PutFileRequest) GetTargetFileDatums() int64

func (*PutFileRequest) GetUrl added in v1.3.5 

func (m *PutFileRequest) GetUrl() string

func (*PutFileRequest) GetValue added in v1.3.5 

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

func (*PutFileRequest) Marshal added in v1.5.0 

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

func (*PutFileRequest) MarshalTo added in v1.5.0 

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

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) Reset 

func (m *PutFileRequest) Reset()

func (*PutFileRequest) Size added in v1.5.0 

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

func (*PutFileRequest) String 

func (m *PutFileRequest) String() string

func (*PutFileRequest) Unmarshal added in v1.5.0 

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

func (*PutFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *PutFileRequest) XXX_DiscardUnknown()

func (*PutFileRequest) XXX_Marshal added in v1.8.1 

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

func (*PutFileRequest) XXX_Merge added in v1.8.1 

func (dst *PutFileRequest) XXX_Merge(src proto.Message)

func (*PutFileRequest) XXX_Size added in v1.8.1 

func (m *PutFileRequest) XXX_Size() int

func (*PutFileRequest) XXX_Unmarshal added in v1.8.1 

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

type PutObjectRequest added in v1.3.9 

type PutObjectRequest struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Tags                 []*Tag   `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	Block                *Block   `protobuf:"bytes,3,opt,name=block,proto3" json:"block,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutObjectRequest) Descriptor added in v1.3.9 

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

func (*PutObjectRequest) GetBlock added in v1.8.0 

func (m *PutObjectRequest) GetBlock() *Block

func (*PutObjectRequest) GetTags added in v1.3.9 

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

func (*PutObjectRequest) GetValue added in v1.3.9 

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

func (*PutObjectRequest) Marshal added in v1.5.0 

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

func (*PutObjectRequest) MarshalTo added in v1.5.0 

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

func (*PutObjectRequest) ProtoMessage added in v1.3.9 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) Reset added in v1.3.9 

func (m *PutObjectRequest) Reset()

func (*PutObjectRequest) Size added in v1.5.0 

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

func (*PutObjectRequest) String added in v1.3.9 

func (m *PutObjectRequest) String() string

func (*PutObjectRequest) Unmarshal added in v1.5.0 

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

func (*PutObjectRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *PutObjectRequest) XXX_DiscardUnknown()

func (*PutObjectRequest) XXX_Marshal added in v1.8.1 

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

func (*PutObjectRequest) XXX_Merge added in v1.8.1 

func (dst *PutObjectRequest) XXX_Merge(src proto.Message)

func (*PutObjectRequest) XXX_Size added in v1.8.1 

func (m *PutObjectRequest) XXX_Size() int

func (*PutObjectRequest) XXX_Unmarshal added in v1.8.1 

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

type Repo 

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

func (*Repo) Descriptor 

func (*Repo) 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

func (*Repo) XXX_DiscardUnknown added in v1.8.1 

func (m *Repo) XXX_DiscardUnknown()

func (*Repo) XXX_Marshal added in v1.8.1 

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

func (*Repo) XXX_Merge added in v1.8.1 

func (dst *Repo) XXX_Merge(src proto.Message)

func (*Repo) XXX_Size added in v1.8.1 

func (m *Repo) XXX_Size() int

func (*Repo) XXX_Unmarshal added in v1.8.1 

func (m *Repo) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

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

func (*RepoAuthInfo) Descriptor added in v1.6.0 

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

func (*RepoAuthInfo) GetAccessLevel added in v1.6.0 

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

func (*RepoAuthInfo) Marshal added in v1.6.0 

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

func (*RepoAuthInfo) MarshalTo added in v1.6.0 

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

func (*RepoAuthInfo) ProtoMessage added in v1.6.0 

func (*RepoAuthInfo) ProtoMessage()

func (*RepoAuthInfo) Reset added in v1.6.0 

func (m *RepoAuthInfo) Reset()

func (*RepoAuthInfo) Size added in v1.6.0 

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

func (*RepoAuthInfo) String added in v1.6.0 

func (m *RepoAuthInfo) String() string

func (*RepoAuthInfo) Unmarshal added in v1.6.0 

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

func (*RepoAuthInfo) XXX_DiscardUnknown added in v1.8.1 

func (m *RepoAuthInfo) XXX_DiscardUnknown()

func (*RepoAuthInfo) XXX_Marshal added in v1.8.1 

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

func (*RepoAuthInfo) XXX_Merge added in v1.8.1 

func (dst *RepoAuthInfo) XXX_Merge(src proto.Message)

func (*RepoAuthInfo) XXX_Size added in v1.8.1 

func (m *RepoAuthInfo) XXX_Size() int

func (*RepoAuthInfo) XXX_Unmarshal added in v1.8.1 

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

type RepoInfo 

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

RepoInfo is the main data structure representing a Repo in etcd

func (*RepoInfo) Descriptor 

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

func (*RepoInfo) GetAuthInfo added in v1.6.0 

func (m *RepoInfo) GetAuthInfo() *RepoAuthInfo

func (*RepoInfo) GetBranches added in v1.7.0 

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

func (*RepoInfo) GetCreated 

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

func (*RepoInfo) GetDescription added in v1.4.7 

func (m *RepoInfo) GetDescription() string

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

func (*RepoInfo) XXX_DiscardUnknown added in v1.8.1 

func (m *RepoInfo) XXX_DiscardUnknown()

func (*RepoInfo) XXX_Marshal added in v1.8.1 

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

func (*RepoInfo) XXX_Merge added in v1.8.1 

func (dst *RepoInfo) XXX_Merge(src proto.Message)

func (*RepoInfo) XXX_Size added in v1.8.1 

func (m *RepoInfo) XXX_Size() int

func (*RepoInfo) XXX_Unmarshal added in v1.8.1 

func (m *RepoInfo) XXX_Unmarshal(b []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,proto3" json:"parent,omitempty"`
	// description is a user-provided string describing this commit
	Description          string    `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Branch               string    `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance           []*Commit `protobuf:"bytes,2,rep,name=provenance,proto3" json:"provenance,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StartCommitRequest) Descriptor 

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

func (*StartCommitRequest) GetBranch added in v1.3.19 

func (m *StartCommitRequest) GetBranch() string

func (*StartCommitRequest) GetDescription added in v1.6.6 

func (m *StartCommitRequest) GetDescription() string

func (*StartCommitRequest) GetParent added in v1.2.0 

func (m *StartCommitRequest) GetParent() *Commit

func (*StartCommitRequest) GetProvenance 

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

func (*StartCommitRequest) Marshal added in v1.5.0 

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

func (*StartCommitRequest) MarshalTo added in v1.5.0 

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

func (*StartCommitRequest) ProtoMessage 

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) Reset 

func (m *StartCommitRequest) Reset()

func (*StartCommitRequest) Size added in v1.5.0 

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

func (*StartCommitRequest) String 

func (m *StartCommitRequest) String() string

func (*StartCommitRequest) Unmarshal added in v1.5.0 

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

func (*StartCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *StartCommitRequest) XXX_DiscardUnknown()

func (*StartCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*StartCommitRequest) XXX_Merge added in v1.8.1 

func (dst *StartCommitRequest) XXX_Merge(src proto.Message)

func (*StartCommitRequest) XXX_Size added in v1.8.1 

func (m *StartCommitRequest) XXX_Size() int

func (*StartCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type SubscribeCommitRequest added in v1.3.19 

type SubscribeCommitRequest struct {
	Repo   *Repo  `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Branch string `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	// only commits created since this commit are returned
	From *Commit `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	// Don't return commits until they're in (at least) the desired state.
	State                CommitState `protobuf:"varint,4,opt,name=state,proto3,enum=pfs.CommitState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SubscribeCommitRequest) Descriptor added in v1.3.19 

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

func (*SubscribeCommitRequest) GetBranch added in v1.3.19 

func (m *SubscribeCommitRequest) GetBranch() string

func (*SubscribeCommitRequest) GetFrom added in v1.3.19 

func (m *SubscribeCommitRequest) GetFrom() *Commit

func (*SubscribeCommitRequest) GetRepo added in v1.3.19 

func (m *SubscribeCommitRequest) GetRepo() *Repo

func (*SubscribeCommitRequest) GetState added in v1.7.1 

func (m *SubscribeCommitRequest) GetState() CommitState

func (*SubscribeCommitRequest) Marshal added in v1.5.0 

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

func (*SubscribeCommitRequest) MarshalTo added in v1.5.0 

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

func (*SubscribeCommitRequest) ProtoMessage added in v1.3.19 

func (*SubscribeCommitRequest) ProtoMessage()

func (*SubscribeCommitRequest) Reset added in v1.3.19 

func (m *SubscribeCommitRequest) Reset()

func (*SubscribeCommitRequest) Size added in v1.5.0 

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

func (*SubscribeCommitRequest) String added in v1.3.19 

func (m *SubscribeCommitRequest) String() string

func (*SubscribeCommitRequest) Unmarshal added in v1.5.0 

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

func (*SubscribeCommitRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *SubscribeCommitRequest) XXX_DiscardUnknown()

func (*SubscribeCommitRequest) XXX_Marshal added in v1.8.1 

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

func (*SubscribeCommitRequest) XXX_Merge added in v1.8.1 

func (dst *SubscribeCommitRequest) XXX_Merge(src proto.Message)

func (*SubscribeCommitRequest) XXX_Size added in v1.8.1 

func (m *SubscribeCommitRequest) XXX_Size() int

func (*SubscribeCommitRequest) XXX_Unmarshal added in v1.8.1 

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

type Tag added in v1.3.9 

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

func (*Tag) Descriptor added in v1.3.9 

func (*Tag) 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

func (*Tag) XXX_DiscardUnknown added in v1.8.1 

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal added in v1.8.1 

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

func (*Tag) XXX_Merge added in v1.8.1 

func (dst *Tag) XXX_Merge(src proto.Message)

func (*Tag) XXX_Size added in v1.8.1 

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal added in v1.8.1 

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

type TagObjectRequest added in v1.3.9 

type TagObjectRequest struct {
	Object               *Object  `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Tags                 []*Tag   `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TagObjectRequest) Descriptor added in v1.3.9 

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

func (*TagObjectRequest) GetObject added in v1.3.9 

func (m *TagObjectRequest) GetObject() *Object

func (*TagObjectRequest) GetTags added in v1.3.9 

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

func (*TagObjectRequest) Marshal added in v1.5.0 

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

func (*TagObjectRequest) MarshalTo added in v1.5.0 

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

func (*TagObjectRequest) ProtoMessage added in v1.3.9 

func (*TagObjectRequest) ProtoMessage()

func (*TagObjectRequest) Reset added in v1.3.9 

func (m *TagObjectRequest) Reset()

func (*TagObjectRequest) Size added in v1.5.0 

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

func (*TagObjectRequest) String added in v1.3.9 

func (m *TagObjectRequest) String() string

func (*TagObjectRequest) Unmarshal added in v1.5.0 

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

func (*TagObjectRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *TagObjectRequest) XXX_DiscardUnknown()

func (*TagObjectRequest) XXX_Marshal added in v1.8.1 

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

func (*TagObjectRequest) XXX_Merge added in v1.8.1 

func (dst *TagObjectRequest) XXX_Merge(src proto.Message)

func (*TagObjectRequest) XXX_Size added in v1.8.1 

func (m *TagObjectRequest) XXX_Size() int

func (*TagObjectRequest) XXX_Unmarshal added in v1.8.1 

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

type WalkFileRequest added in v1.8.0 

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

func (*WalkFileRequest) Descriptor added in v1.8.0 

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

func (*WalkFileRequest) GetFile added in v1.8.0 

func (m *WalkFileRequest) GetFile() *File

func (*WalkFileRequest) Marshal added in v1.8.0 

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

func (*WalkFileRequest) MarshalTo added in v1.8.0 

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

func (*WalkFileRequest) ProtoMessage added in v1.8.0 

func (*WalkFileRequest) ProtoMessage()

func (*WalkFileRequest) Reset added in v1.8.0 

func (m *WalkFileRequest) Reset()

func (*WalkFileRequest) Size added in v1.8.0 

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

func (*WalkFileRequest) String added in v1.8.0 

func (m *WalkFileRequest) String() string

func (*WalkFileRequest) Unmarshal added in v1.8.0 

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

func (*WalkFileRequest) XXX_DiscardUnknown added in v1.8.1 

func (m *WalkFileRequest) XXX_DiscardUnknown()

func (*WalkFileRequest) XXX_Marshal added in v1.8.1 

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

func (*WalkFileRequest) XXX_Merge added in v1.8.1 

func (dst *WalkFileRequest) XXX_Merge(src proto.Message)

func (*WalkFileRequest) XXX_Size added in v1.8.1 

func (m *WalkFileRequest) XXX_Size() int

func (*WalkFileRequest) XXX_Unmarshal added in v1.8.1 

func (m *WalkFileRequest) XXX_Unmarshal(b []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.