pfs

package
v1.8.2-267bb46df4269ca... Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2019 License: Apache-2.0 Imports: 9 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 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",
}
View Source 
var Delimiter_value = map[string]int32{
	"NONE": 0,
	"JSON": 1,
	"LINE": 2,
	"SQL":  3,
}
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 RegisterAPIServer 

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

func RegisterObjectAPIServer 

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

Types

type APIClient 

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

APIClient is the client API for API service.

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

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

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

APIServer is the server API for API service.

type API_FlushCommitClient 

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

type API_FlushCommitServer 

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 

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

type API_GlobFileStreamServer 

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

type API_ListCommitStreamClient 

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

type API_ListCommitStreamServer 

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

type API_ListFileStreamClient 

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

type API_ListFileStreamServer 

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

type API_PutFileClient 

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

type API_PutFileServer 

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

type API_SubscribeCommitClient 

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

type API_SubscribeCommitServer 

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

type Block 

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

func (*Block) Descriptor 

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

func (*Block) GetHash 

func (m *Block) GetHash() string

func (*Block) Marshal 

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

func (*Block) MarshalTo 

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

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) Size 

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

func (*Block) String 

func (m *Block) String() string

func (*Block) Unmarshal 

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

func (*Block) XXX_DiscardUnknown 

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal 

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

func (*Block) XXX_Merge 

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

func (*Block) XXX_Size 

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal 

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

type BlockRef 

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

func (*BlockRef) Descriptor 

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

func (*BlockRef) GetBlock 

func (m *BlockRef) GetBlock() *Block

func (*BlockRef) GetRange 

func (m *BlockRef) GetRange() *ByteRange

func (*BlockRef) Marshal 

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

func (*BlockRef) MarshalTo 

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

func (*BlockRef) ProtoMessage 

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset 

func (m *BlockRef) Reset()

func (*BlockRef) Size 

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

func (*BlockRef) String 

func (m *BlockRef) String() string

func (*BlockRef) Unmarshal 

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

func (*BlockRef) XXX_DiscardUnknown 

func (m *BlockRef) XXX_DiscardUnknown()

func (*BlockRef) XXX_Marshal 

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

func (*BlockRef) XXX_Merge 

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

func (*BlockRef) XXX_Size 

func (m *BlockRef) XXX_Size() int

func (*BlockRef) XXX_Unmarshal 

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

type Branch 

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

func (*Branch) Descriptor 

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

func (*Branch) GetName 

func (m *Branch) GetName() string

func (*Branch) GetRepo 

func (m *Branch) GetRepo() *Repo

func (*Branch) Marshal 

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

func (*Branch) MarshalTo 

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

func (*Branch) ProtoMessage 

func (*Branch) ProtoMessage()

func (*Branch) Reset 

func (m *Branch) Reset()

func (*Branch) Size 

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

func (*Branch) String 

func (m *Branch) String() string

func (*Branch) Unmarshal 

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

func (*Branch) XXX_DiscardUnknown 

func (m *Branch) XXX_DiscardUnknown()

func (*Branch) XXX_Marshal 

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

func (*Branch) XXX_Merge 

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

func (*Branch) XXX_Size 

func (m *Branch) XXX_Size() int

func (*Branch) XXX_Unmarshal 

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

type BranchInfo 

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

func (*BranchInfo) Descriptor 

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

func (*BranchInfo) GetBranch 

func (m *BranchInfo) GetBranch() *Branch

func (*BranchInfo) GetDirectProvenance 

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

func (*BranchInfo) GetHead 

func (m *BranchInfo) GetHead() *Commit

func (*BranchInfo) GetName 

func (m *BranchInfo) GetName() string

func (*BranchInfo) GetProvenance 

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

func (*BranchInfo) GetSubvenance 

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

func (*BranchInfo) Marshal 

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

func (*BranchInfo) MarshalTo 

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

func (*BranchInfo) ProtoMessage 

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) Reset 

func (m *BranchInfo) Reset()

func (*BranchInfo) Size 

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

func (*BranchInfo) String 

func (m *BranchInfo) String() string

func (*BranchInfo) Unmarshal 

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

func (*BranchInfo) XXX_DiscardUnknown 

func (m *BranchInfo) XXX_DiscardUnknown()

func (*BranchInfo) XXX_Marshal 

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

func (*BranchInfo) XXX_Merge 

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

func (*BranchInfo) XXX_Size 

func (m *BranchInfo) XXX_Size() int

func (*BranchInfo) XXX_Unmarshal 

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

type BranchInfos 

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

func (*BranchInfos) Descriptor 

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

func (*BranchInfos) GetBranchInfo 

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

func (*BranchInfos) Marshal 

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

func (*BranchInfos) MarshalTo 

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

func (*BranchInfos) ProtoMessage 

func (*BranchInfos) ProtoMessage()

func (*BranchInfos) Reset 

func (m *BranchInfos) Reset()

func (*BranchInfos) Size 

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

func (*BranchInfos) String 

func (m *BranchInfos) String() string

func (*BranchInfos) Unmarshal 

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

func (*BranchInfos) XXX_DiscardUnknown 

func (m *BranchInfos) XXX_DiscardUnknown()

func (*BranchInfos) XXX_Marshal 

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

func (*BranchInfos) XXX_Merge 

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

func (*BranchInfos) XXX_Size 

func (m *BranchInfos) XXX_Size() int

func (*BranchInfos) XXX_Unmarshal 

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

type BuildCommitRequest 

type BuildCommitRequest struct {
	Parent     *Commit   `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Branch     string    `protobuf:"bytes,4,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance []*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 

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

func (*BuildCommitRequest) GetBranch 

func (m *BuildCommitRequest) GetBranch() string

func (*BuildCommitRequest) GetID 

func (m *BuildCommitRequest) GetID() string

func (*BuildCommitRequest) GetParent 

func (m *BuildCommitRequest) GetParent() *Commit

func (*BuildCommitRequest) GetProvenance 

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

func (*BuildCommitRequest) GetTree 

func (m *BuildCommitRequest) GetTree() *Object

func (*BuildCommitRequest) Marshal 

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

func (*BuildCommitRequest) MarshalTo 

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

func (*BuildCommitRequest) ProtoMessage 

func (*BuildCommitRequest) ProtoMessage()

func (*BuildCommitRequest) Reset 

func (m *BuildCommitRequest) Reset()

func (*BuildCommitRequest) Size 

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

func (*BuildCommitRequest) String 

func (m *BuildCommitRequest) String() string

func (*BuildCommitRequest) Unmarshal 

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

func (*BuildCommitRequest) XXX_DiscardUnknown 

func (m *BuildCommitRequest) XXX_DiscardUnknown()

func (*BuildCommitRequest) XXX_Marshal 

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

func (*BuildCommitRequest) XXX_Merge 

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

func (*BuildCommitRequest) XXX_Size 

func (m *BuildCommitRequest) XXX_Size() int

func (*BuildCommitRequest) XXX_Unmarshal 

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

type ByteRange 

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

func (*ByteRange) Descriptor 

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

func (*ByteRange) GetLower 

func (m *ByteRange) GetLower() uint64

func (*ByteRange) GetUpper 

func (m *ByteRange) GetUpper() uint64

func (*ByteRange) Marshal 

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

func (*ByteRange) MarshalTo 

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

func (*ByteRange) ProtoMessage 

func (*ByteRange) ProtoMessage()

func (*ByteRange) Reset 

func (m *ByteRange) Reset()

func (*ByteRange) Size 

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

func (*ByteRange) String 

func (m *ByteRange) String() string

func (*ByteRange) Unmarshal 

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

func (*ByteRange) XXX_DiscardUnknown 

func (m *ByteRange) XXX_DiscardUnknown()

func (*ByteRange) XXX_Marshal 

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

func (*ByteRange) XXX_Merge 

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

func (*ByteRange) XXX_Size 

func (m *ByteRange) XXX_Size() int

func (*ByteRange) XXX_Unmarshal 

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

type CheckObjectRequest 

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

func (*CheckObjectRequest) Descriptor 

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

func (*CheckObjectRequest) GetObject 

func (m *CheckObjectRequest) GetObject() *Object

func (*CheckObjectRequest) Marshal 

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

func (*CheckObjectRequest) MarshalTo 

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

func (*CheckObjectRequest) ProtoMessage 

func (*CheckObjectRequest) ProtoMessage()

func (*CheckObjectRequest) Reset 

func (m *CheckObjectRequest) Reset()

func (*CheckObjectRequest) Size 

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

func (*CheckObjectRequest) String 

func (m *CheckObjectRequest) String() string

func (*CheckObjectRequest) Unmarshal 

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

func (*CheckObjectRequest) XXX_DiscardUnknown 

func (m *CheckObjectRequest) XXX_DiscardUnknown()

func (*CheckObjectRequest) XXX_Marshal 

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

func (*CheckObjectRequest) XXX_Merge 

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

func (*CheckObjectRequest) XXX_Size 

func (m *CheckObjectRequest) XXX_Size() int

func (*CheckObjectRequest) XXX_Unmarshal 

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

type CheckObjectResponse 

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

func (*CheckObjectResponse) Descriptor 

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

func (*CheckObjectResponse) GetExists 

func (m *CheckObjectResponse) GetExists() bool

func (*CheckObjectResponse) Marshal 

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

func (*CheckObjectResponse) MarshalTo 

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

func (*CheckObjectResponse) ProtoMessage 

func (*CheckObjectResponse) ProtoMessage()

func (*CheckObjectResponse) Reset 

func (m *CheckObjectResponse) Reset()

func (*CheckObjectResponse) Size 

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

func (*CheckObjectResponse) String 

func (m *CheckObjectResponse) String() string

func (*CheckObjectResponse) Unmarshal 

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

func (*CheckObjectResponse) XXX_DiscardUnknown 

func (m *CheckObjectResponse) XXX_DiscardUnknown()

func (*CheckObjectResponse) XXX_Marshal 

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

func (*CheckObjectResponse) XXX_Merge 

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

func (*CheckObjectResponse) XXX_Size 

func (m *CheckObjectResponse) XXX_Size() int

func (*CheckObjectResponse) XXX_Unmarshal 

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

type Commit 

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

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

func (*Commit) Descriptor 

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

func (*Commit) GetID 

func (m *Commit) GetID() string

func (*Commit) GetRepo 

func (m *Commit) GetRepo() *Repo

func (*Commit) Marshal 

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

func (*Commit) MarshalTo 

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

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) Size 

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

func (*Commit) String 

func (m *Commit) String() string

func (*Commit) Unmarshal 

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

func (*Commit) XXX_DiscardUnknown 

func (m *Commit) XXX_DiscardUnknown()

func (*Commit) XXX_Marshal 

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

func (*Commit) XXX_Merge 

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

func (*Commit) XXX_Size 

func (m *Commit) XXX_Size() int

func (*Commit) XXX_Unmarshal 

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

type CommitInfo 

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

CommitInfo is the main data structure representing a commit in etcd

func (*CommitInfo) Descriptor 

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

func (*CommitInfo) GetBranchProvenance 

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

func (*CommitInfo) GetChildCommits 

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

func (*CommitInfo) GetCommit 

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetDescription 

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 

func (m *CommitInfo) GetReadyProvenance() int64

func (*CommitInfo) GetSizeBytes 

func (m *CommitInfo) GetSizeBytes() uint64

func (*CommitInfo) GetStarted 

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

func (*CommitInfo) GetSubvenance 

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

func (*CommitInfo) GetTree 

func (m *CommitInfo) GetTree() *Object

func (*CommitInfo) Marshal 

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

func (*CommitInfo) MarshalTo 

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

func (*CommitInfo) ProtoMessage 

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset 

func (m *CommitInfo) Reset()

func (*CommitInfo) Size 

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

func (*CommitInfo) String 

func (m *CommitInfo) String() string

func (*CommitInfo) Unmarshal 

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

func (*CommitInfo) XXX_DiscardUnknown 

func (m *CommitInfo) XXX_DiscardUnknown()

func (*CommitInfo) XXX_Marshal 

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

func (*CommitInfo) XXX_Merge 

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

func (*CommitInfo) XXX_Size 

func (m *CommitInfo) XXX_Size() int

func (*CommitInfo) XXX_Unmarshal 

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

type CommitInfos 

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

func (*CommitInfos) Descriptor 

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

func (*CommitInfos) GetCommitInfo 

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

func (*CommitInfos) Marshal 

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

func (*CommitInfos) MarshalTo 

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

func (*CommitInfos) ProtoMessage 

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset 

func (m *CommitInfos) Reset()

func (*CommitInfos) Size 

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

func (*CommitInfos) String 

func (m *CommitInfos) String() string

func (*CommitInfos) Unmarshal 

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

func (*CommitInfos) XXX_DiscardUnknown 

func (m *CommitInfos) XXX_DiscardUnknown()

func (*CommitInfos) XXX_Marshal 

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

func (*CommitInfos) XXX_Merge 

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

func (*CommitInfos) XXX_Size 

func (m *CommitInfos) XXX_Size() int

func (*CommitInfos) XXX_Unmarshal 

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

type CommitRange 

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

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

func (*CommitRange) Descriptor 

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

func (*CommitRange) GetLower 

func (m *CommitRange) GetLower() *Commit

func (*CommitRange) GetUpper 

func (m *CommitRange) GetUpper() *Commit

func (*CommitRange) Marshal 

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

func (*CommitRange) MarshalTo 

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

func (*CommitRange) ProtoMessage 

func (*CommitRange) ProtoMessage()

func (*CommitRange) Reset 

func (m *CommitRange) Reset()

func (*CommitRange) Size 

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

func (*CommitRange) String 

func (m *CommitRange) String() string

func (*CommitRange) Unmarshal 

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

func (*CommitRange) XXX_DiscardUnknown 

func (m *CommitRange) XXX_DiscardUnknown()

func (*CommitRange) XXX_Marshal 

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

func (*CommitRange) XXX_Merge 

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

func (*CommitRange) XXX_Size 

func (m *CommitRange) XXX_Size() int

func (*CommitRange) XXX_Unmarshal 

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

type CommitState 

type CommitState int32

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

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

func (CommitState) EnumDescriptor 

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

func (CommitState) String 

func (x CommitState) String() string

type CopyFileRequest 

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

func (*CopyFileRequest) Descriptor 

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

func (*CopyFileRequest) GetDst 

func (m *CopyFileRequest) GetDst() *File

func (*CopyFileRequest) GetOverwrite 

func (m *CopyFileRequest) GetOverwrite() bool

func (*CopyFileRequest) GetSrc 

func (m *CopyFileRequest) GetSrc() *File

func (*CopyFileRequest) Marshal 

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

func (*CopyFileRequest) MarshalTo 

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

func (*CopyFileRequest) ProtoMessage 

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset 

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) Size 

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

func (*CopyFileRequest) String 

func (m *CopyFileRequest) String() string

func (*CopyFileRequest) Unmarshal 

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

func (*CopyFileRequest) XXX_DiscardUnknown 

func (m *CopyFileRequest) XXX_DiscardUnknown()

func (*CopyFileRequest) XXX_Marshal 

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

func (*CopyFileRequest) XXX_Merge 

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

func (*CopyFileRequest) XXX_Size 

func (m *CopyFileRequest) XXX_Size() int

func (*CopyFileRequest) XXX_Unmarshal 

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

type CreateBranchRequest 

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

func (*CreateBranchRequest) Descriptor 

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

func (*CreateBranchRequest) GetBranch 

func (m *CreateBranchRequest) GetBranch() *Branch

func (*CreateBranchRequest) GetHead 

func (m *CreateBranchRequest) GetHead() *Commit

func (*CreateBranchRequest) GetProvenance 

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

func (*CreateBranchRequest) GetSBranch 

func (m *CreateBranchRequest) GetSBranch() string

func (*CreateBranchRequest) Marshal 

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

func (*CreateBranchRequest) MarshalTo 

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

func (*CreateBranchRequest) ProtoMessage 

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) Reset 

func (m *CreateBranchRequest) Reset()

func (*CreateBranchRequest) Size 

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

func (*CreateBranchRequest) String 

func (m *CreateBranchRequest) String() string

func (*CreateBranchRequest) Unmarshal 

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

func (*CreateBranchRequest) XXX_DiscardUnknown 

func (m *CreateBranchRequest) XXX_DiscardUnknown()

func (*CreateBranchRequest) XXX_Marshal 

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

func (*CreateBranchRequest) XXX_Merge 

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

func (*CreateBranchRequest) XXX_Size 

func (m *CreateBranchRequest) XXX_Size() int

func (*CreateBranchRequest) XXX_Unmarshal 

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

type CreateRepoRequest 

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

func (*CreateRepoRequest) Descriptor 

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

func (*CreateRepoRequest) GetDescription 

func (m *CreateRepoRequest) GetDescription() string

func (*CreateRepoRequest) GetRepo 

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) GetUpdate 

func (m *CreateRepoRequest) GetUpdate() bool

func (*CreateRepoRequest) Marshal 

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

func (*CreateRepoRequest) MarshalTo 

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

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset 

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) Size 

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

func (*CreateRepoRequest) String 

func (m *CreateRepoRequest) String() string

func (*CreateRepoRequest) Unmarshal 

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

func (*CreateRepoRequest) XXX_DiscardUnknown 

func (m *CreateRepoRequest) XXX_DiscardUnknown()

func (*CreateRepoRequest) XXX_Marshal 

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

func (*CreateRepoRequest) XXX_Merge 

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

func (*CreateRepoRequest) XXX_Size 

func (m *CreateRepoRequest) XXX_Size() int

func (*CreateRepoRequest) XXX_Unmarshal 

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

type DeleteBranchRequest 

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

func (*DeleteBranchRequest) Descriptor 

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

func (*DeleteBranchRequest) GetBranch 

func (m *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) GetForce 

func (m *DeleteBranchRequest) GetForce() bool

func (*DeleteBranchRequest) Marshal 

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

func (*DeleteBranchRequest) MarshalTo 

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

func (*DeleteBranchRequest) ProtoMessage 

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset 

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) Size 

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

func (*DeleteBranchRequest) String 

func (m *DeleteBranchRequest) String() string

func (*DeleteBranchRequest) Unmarshal 

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

func (*DeleteBranchRequest) XXX_DiscardUnknown 

func (m *DeleteBranchRequest) XXX_DiscardUnknown()

func (*DeleteBranchRequest) XXX_Marshal 

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

func (*DeleteBranchRequest) XXX_Merge 

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

func (*DeleteBranchRequest) XXX_Size 

func (m *DeleteBranchRequest) XXX_Size() int

func (*DeleteBranchRequest) XXX_Unmarshal 

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

type DeleteCommitRequest 

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

func (*DeleteCommitRequest) Descriptor 

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

func (*DeleteCommitRequest) GetCommit 

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) Marshal 

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

func (*DeleteCommitRequest) MarshalTo 

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

func (*DeleteCommitRequest) ProtoMessage 

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset 

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) Size 

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

func (*DeleteCommitRequest) String 

func (m *DeleteCommitRequest) String() string

func (*DeleteCommitRequest) Unmarshal 

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

func (*DeleteCommitRequest) XXX_DiscardUnknown 

func (m *DeleteCommitRequest) XXX_DiscardUnknown()

func (*DeleteCommitRequest) XXX_Marshal 

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

func (*DeleteCommitRequest) XXX_Merge 

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

func (*DeleteCommitRequest) XXX_Size 

func (m *DeleteCommitRequest) XXX_Size() int

func (*DeleteCommitRequest) XXX_Unmarshal 

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

type DeleteFileRequest 

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

func (*DeleteFileRequest) Descriptor 

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

func (*DeleteFileRequest) GetFile 

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) Marshal 

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

func (*DeleteFileRequest) MarshalTo 

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

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset 

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) Size 

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

func (*DeleteFileRequest) String 

func (m *DeleteFileRequest) String() string

func (*DeleteFileRequest) Unmarshal 

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

func (*DeleteFileRequest) XXX_DiscardUnknown 

func (m *DeleteFileRequest) XXX_DiscardUnknown()

func (*DeleteFileRequest) XXX_Marshal 

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

func (*DeleteFileRequest) XXX_Merge 

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

func (*DeleteFileRequest) XXX_Size 

func (m *DeleteFileRequest) XXX_Size() int

func (*DeleteFileRequest) XXX_Unmarshal 

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

type DeleteObjectsRequest 

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

func (*DeleteObjectsRequest) Descriptor 

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

func (*DeleteObjectsRequest) GetObjects 

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

func (*DeleteObjectsRequest) Marshal 

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

func (*DeleteObjectsRequest) MarshalTo 

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

func (*DeleteObjectsRequest) ProtoMessage 

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) Reset 

func (m *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) Size 

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

func (*DeleteObjectsRequest) String 

func (m *DeleteObjectsRequest) String() string

func (*DeleteObjectsRequest) Unmarshal 

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

func (*DeleteObjectsRequest) XXX_DiscardUnknown 

func (m *DeleteObjectsRequest) XXX_DiscardUnknown()

func (*DeleteObjectsRequest) XXX_Marshal 

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

func (*DeleteObjectsRequest) XXX_Merge 

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

func (*DeleteObjectsRequest) XXX_Size 

func (m *DeleteObjectsRequest) XXX_Size() int

func (*DeleteObjectsRequest) XXX_Unmarshal 

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

type DeleteObjectsResponse 

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

func (*DeleteObjectsResponse) Descriptor 

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

func (*DeleteObjectsResponse) Marshal 

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

func (*DeleteObjectsResponse) MarshalTo 

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

func (*DeleteObjectsResponse) ProtoMessage 

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) Reset 

func (m *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) Size 

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

func (*DeleteObjectsResponse) String 

func (m *DeleteObjectsResponse) String() string

func (*DeleteObjectsResponse) Unmarshal 

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

func (*DeleteObjectsResponse) XXX_DiscardUnknown 

func (m *DeleteObjectsResponse) XXX_DiscardUnknown()

func (*DeleteObjectsResponse) XXX_Marshal 

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

func (*DeleteObjectsResponse) XXX_Merge 

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

func (*DeleteObjectsResponse) XXX_Size 

func (m *DeleteObjectsResponse) XXX_Size() int

func (*DeleteObjectsResponse) XXX_Unmarshal 

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

type DeleteRepoRequest 

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

func (*DeleteRepoRequest) Descriptor 

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

func (*DeleteRepoRequest) GetAll 

func (m *DeleteRepoRequest) GetAll() bool

func (*DeleteRepoRequest) GetForce 

func (m *DeleteRepoRequest) GetForce() bool

func (*DeleteRepoRequest) GetRepo 

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) Marshal 

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

func (*DeleteRepoRequest) MarshalTo 

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

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset 

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) Size 

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

func (*DeleteRepoRequest) String 

func (m *DeleteRepoRequest) String() string

func (*DeleteRepoRequest) Unmarshal 

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

func (*DeleteRepoRequest) XXX_DiscardUnknown 

func (m *DeleteRepoRequest) XXX_DiscardUnknown()

func (*DeleteRepoRequest) XXX_Marshal 

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

func (*DeleteRepoRequest) XXX_Merge 

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

func (*DeleteRepoRequest) XXX_Size 

func (m *DeleteRepoRequest) XXX_Size() int

func (*DeleteRepoRequest) XXX_Unmarshal 

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

type DeleteTagsRequest 

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

func (*DeleteTagsRequest) Descriptor 

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

func (*DeleteTagsRequest) GetTags 

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

func (*DeleteTagsRequest) Marshal 

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

func (*DeleteTagsRequest) MarshalTo 

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

func (*DeleteTagsRequest) ProtoMessage 

func (*DeleteTagsRequest) ProtoMessage()

func (*DeleteTagsRequest) Reset 

func (m *DeleteTagsRequest) Reset()

func (*DeleteTagsRequest) Size 

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

func (*DeleteTagsRequest) String 

func (m *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Unmarshal 

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

func (*DeleteTagsRequest) XXX_DiscardUnknown 

func (m *DeleteTagsRequest) XXX_DiscardUnknown()

func (*DeleteTagsRequest) XXX_Marshal 

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

func (*DeleteTagsRequest) XXX_Merge 

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

func (*DeleteTagsRequest) XXX_Size 

func (m *DeleteTagsRequest) XXX_Size() int

func (*DeleteTagsRequest) XXX_Unmarshal 

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

type DeleteTagsResponse 

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

func (*DeleteTagsResponse) Descriptor 

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

func (*DeleteTagsResponse) Marshal 

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

func (*DeleteTagsResponse) MarshalTo 

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

func (*DeleteTagsResponse) ProtoMessage 

func (*DeleteTagsResponse) ProtoMessage()

func (*DeleteTagsResponse) Reset 

func (m *DeleteTagsResponse) Reset()

func (*DeleteTagsResponse) Size 

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

func (*DeleteTagsResponse) String 

func (m *DeleteTagsResponse) String() string

func (*DeleteTagsResponse) Unmarshal 

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

func (*DeleteTagsResponse) XXX_DiscardUnknown 

func (m *DeleteTagsResponse) XXX_DiscardUnknown()

func (*DeleteTagsResponse) XXX_Marshal 

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

func (*DeleteTagsResponse) XXX_Merge 

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

func (*DeleteTagsResponse) XXX_Size 

func (m *DeleteTagsResponse) XXX_Size() int

func (*DeleteTagsResponse) XXX_Unmarshal 

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
)

func (Delimiter) EnumDescriptor 

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

func (Delimiter) String 

func (x Delimiter) String() string

type DiffFileRequest 

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 

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

func (*DiffFileRequest) GetNewFile 

func (m *DiffFileRequest) GetNewFile() *File

func (*DiffFileRequest) GetOldFile 

func (m *DiffFileRequest) GetOldFile() *File

func (*DiffFileRequest) GetShallow 

func (m *DiffFileRequest) GetShallow() bool

func (*DiffFileRequest) Marshal 

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

func (*DiffFileRequest) MarshalTo 

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

func (*DiffFileRequest) ProtoMessage 

func (*DiffFileRequest) ProtoMessage()

func (*DiffFileRequest) Reset 

func (m *DiffFileRequest) Reset()

func (*DiffFileRequest) Size 

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

func (*DiffFileRequest) String 

func (m *DiffFileRequest) String() string

func (*DiffFileRequest) Unmarshal 

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

func (*DiffFileRequest) XXX_DiscardUnknown 

func (m *DiffFileRequest) XXX_DiscardUnknown()

func (*DiffFileRequest) XXX_Marshal 

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

func (*DiffFileRequest) XXX_Merge 

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

func (*DiffFileRequest) XXX_Size 

func (m *DiffFileRequest) XXX_Size() int

func (*DiffFileRequest) XXX_Unmarshal 

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

type DiffFileResponse 

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 

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

func (*DiffFileResponse) GetNewFiles 

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

func (*DiffFileResponse) GetOldFiles 

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

func (*DiffFileResponse) Marshal 

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

func (*DiffFileResponse) MarshalTo 

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

func (*DiffFileResponse) ProtoMessage 

func (*DiffFileResponse) ProtoMessage()

func (*DiffFileResponse) Reset 

func (m *DiffFileResponse) Reset()

func (*DiffFileResponse) Size 

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

func (*DiffFileResponse) String 

func (m *DiffFileResponse) String() string

func (*DiffFileResponse) Unmarshal 

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

func (*DiffFileResponse) XXX_DiscardUnknown 

func (m *DiffFileResponse) XXX_DiscardUnknown()

func (*DiffFileResponse) XXX_Marshal 

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

func (*DiffFileResponse) XXX_Merge 

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

func (*DiffFileResponse) XXX_Size 

func (m *DiffFileResponse) XXX_Size() int

func (*DiffFileResponse) XXX_Unmarshal 

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 

func (m *File) GetPath() string

func (*File) Marshal 

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

func (*File) MarshalTo 

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

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) Reset 

func (m *File) Reset()

func (*File) Size 

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

func (*File) String 

func (m *File) String() string

func (*File) Unmarshal 

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

func (*File) XXX_DiscardUnknown 

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal 

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

func (*File) XXX_Merge 

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

func (*File) XXX_Size 

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal 

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_1_7.FileType" json:"file_type,omitempty"`
	SizeBytes uint64   `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// the base names (i.e. just the filenames, not the full paths) of
	// the children
	Children             []string  `protobuf:"bytes,6,rep,name=children,proto3" json:"children,omitempty"`
	Objects              []*Object `protobuf:"bytes,8,rep,name=objects,proto3" json:"objects,omitempty"`
	Hash                 []byte    `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetChildren 

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

func (*FileInfo) GetFile 

func (m *FileInfo) GetFile() *File

func (*FileInfo) GetFileType 

func (m *FileInfo) GetFileType() FileType

func (*FileInfo) GetHash 

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

func (*FileInfo) GetObjects 

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

func (*FileInfo) GetSizeBytes 

func (m *FileInfo) GetSizeBytes() uint64

func (*FileInfo) Marshal 

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

func (*FileInfo) MarshalTo 

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

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) Size 

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

func (*FileInfo) String 

func (m *FileInfo) String() string

func (*FileInfo) Unmarshal 

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

func (*FileInfo) XXX_DiscardUnknown 

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal 

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

func (*FileInfo) XXX_Merge 

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

func (*FileInfo) XXX_Size 

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal 

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 

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

func (*FileInfos) MarshalTo 

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

func (*FileInfos) ProtoMessage 

func (*FileInfos) ProtoMessage()

func (*FileInfos) Reset 

func (m *FileInfos) Reset()

func (*FileInfos) Size 

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

func (*FileInfos) String 

func (m *FileInfos) String() string

func (*FileInfos) Unmarshal 

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

func (*FileInfos) XXX_DiscardUnknown 

func (m *FileInfos) XXX_DiscardUnknown()

func (*FileInfos) XXX_Marshal 

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

func (*FileInfos) XXX_Merge 

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

func (*FileInfos) XXX_Size 

func (m *FileInfos) XXX_Size() int

func (*FileInfos) XXX_Unmarshal 

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"`
	// If set, 'commit' will be closed (its 'finished' field will be set to the
	// current time) but its 'tree' will be left nil.
	Empty                bool     `protobuf:"varint,4,opt,name=empty,proto3" json:"empty,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FinishCommitRequest) Descriptor 

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

func (*FinishCommitRequest) GetCommit 

func (m *FinishCommitRequest) GetCommit() *Commit

func (*FinishCommitRequest) GetDescription 

func (m *FinishCommitRequest) GetDescription() string

func (*FinishCommitRequest) GetEmpty 

func (m *FinishCommitRequest) GetEmpty() bool

func (*FinishCommitRequest) GetTree 

func (m *FinishCommitRequest) GetTree() *Object

func (*FinishCommitRequest) Marshal 

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

func (*FinishCommitRequest) MarshalTo 

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

func (*FinishCommitRequest) ProtoMessage 

func (*FinishCommitRequest) ProtoMessage()

func (*FinishCommitRequest) Reset 

func (m *FinishCommitRequest) Reset()

func (*FinishCommitRequest) Size 

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

func (*FinishCommitRequest) String 

func (m *FinishCommitRequest) String() string

func (*FinishCommitRequest) Unmarshal 

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

func (*FinishCommitRequest) XXX_DiscardUnknown 

func (m *FinishCommitRequest) XXX_DiscardUnknown()

func (*FinishCommitRequest) XXX_Marshal 

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

func (*FinishCommitRequest) XXX_Merge 

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

func (*FinishCommitRequest) XXX_Size 

func (m *FinishCommitRequest) XXX_Size() int

func (*FinishCommitRequest) XXX_Unmarshal 

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 

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

func (*FlushCommitRequest) GetToRepos 

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

func (*FlushCommitRequest) Marshal 

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

func (*FlushCommitRequest) MarshalTo 

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

func (*FlushCommitRequest) ProtoMessage 

func (*FlushCommitRequest) ProtoMessage()

func (*FlushCommitRequest) Reset 

func (m *FlushCommitRequest) Reset()

func (*FlushCommitRequest) Size 

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

func (*FlushCommitRequest) String 

func (m *FlushCommitRequest) String() string

func (*FlushCommitRequest) Unmarshal 

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

func (*FlushCommitRequest) XXX_DiscardUnknown 

func (m *FlushCommitRequest) XXX_DiscardUnknown()

func (*FlushCommitRequest) XXX_Marshal 

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

func (*FlushCommitRequest) XXX_Merge 

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

func (*FlushCommitRequest) XXX_Size 

func (m *FlushCommitRequest) XXX_Size() int

func (*FlushCommitRequest) XXX_Unmarshal 

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

type GetFileRequest 

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

func (*GetFileRequest) Descriptor 

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

func (*GetFileRequest) GetFile 

func (m *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetOffsetBytes 

func (m *GetFileRequest) GetOffsetBytes() int64

func (*GetFileRequest) GetSizeBytes 

func (m *GetFileRequest) GetSizeBytes() int64

func (*GetFileRequest) Marshal 

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

func (*GetFileRequest) MarshalTo 

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

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) Reset 

func (m *GetFileRequest) Reset()

func (*GetFileRequest) Size 

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

func (*GetFileRequest) String 

func (m *GetFileRequest) String() string

func (*GetFileRequest) Unmarshal 

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

func (*GetFileRequest) XXX_DiscardUnknown 

func (m *GetFileRequest) XXX_DiscardUnknown()

func (*GetFileRequest) XXX_Marshal 

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

func (*GetFileRequest) XXX_Merge 

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

func (*GetFileRequest) XXX_Size 

func (m *GetFileRequest) XXX_Size() int

func (*GetFileRequest) XXX_Unmarshal 

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

type GetObjectsRequest 

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

func (*GetObjectsRequest) Descriptor 

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

func (*GetObjectsRequest) GetObjects 

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

func (*GetObjectsRequest) GetOffsetBytes 

func (m *GetObjectsRequest) GetOffsetBytes() uint64

func (*GetObjectsRequest) GetSizeBytes 

func (m *GetObjectsRequest) GetSizeBytes() uint64

func (*GetObjectsRequest) GetTotalSize 

func (m *GetObjectsRequest) GetTotalSize() uint64

func (*GetObjectsRequest) Marshal 

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

func (*GetObjectsRequest) MarshalTo 

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

func (*GetObjectsRequest) ProtoMessage 

func (*GetObjectsRequest) ProtoMessage()

func (*GetObjectsRequest) Reset 

func (m *GetObjectsRequest) Reset()

func (*GetObjectsRequest) Size 

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

func (*GetObjectsRequest) String 

func (m *GetObjectsRequest) String() string

func (*GetObjectsRequest) Unmarshal 

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

func (*GetObjectsRequest) XXX_DiscardUnknown 

func (m *GetObjectsRequest) XXX_DiscardUnknown()

func (*GetObjectsRequest) XXX_Marshal 

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

func (*GetObjectsRequest) XXX_Merge 

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

func (*GetObjectsRequest) XXX_Size 

func (m *GetObjectsRequest) XXX_Size() int

func (*GetObjectsRequest) XXX_Unmarshal 

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

type GlobFileRequest 

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 

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

func (*GlobFileRequest) GetCommit 

func (m *GlobFileRequest) GetCommit() *Commit

func (*GlobFileRequest) GetPattern 

func (m *GlobFileRequest) GetPattern() string

func (*GlobFileRequest) Marshal 

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

func (*GlobFileRequest) MarshalTo 

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

func (*GlobFileRequest) ProtoMessage 

func (*GlobFileRequest) ProtoMessage()

func (*GlobFileRequest) Reset 

func (m *GlobFileRequest) Reset()

func (*GlobFileRequest) Size 

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

func (*GlobFileRequest) String 

func (m *GlobFileRequest) String() string

func (*GlobFileRequest) Unmarshal 

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

func (*GlobFileRequest) XXX_DiscardUnknown 

func (m *GlobFileRequest) XXX_DiscardUnknown()

func (*GlobFileRequest) XXX_Marshal 

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

func (*GlobFileRequest) XXX_Merge 

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

func (*GlobFileRequest) XXX_Size 

func (m *GlobFileRequest) XXX_Size() int

func (*GlobFileRequest) XXX_Unmarshal 

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

type InspectBranchRequest 

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 

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

func (*InspectBranchRequest) GetBranch 

func (m *InspectBranchRequest) GetBranch() *Branch

func (*InspectBranchRequest) Marshal 

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

func (*InspectBranchRequest) MarshalTo 

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

func (*InspectBranchRequest) ProtoMessage 

func (*InspectBranchRequest) ProtoMessage()

func (*InspectBranchRequest) Reset 

func (m *InspectBranchRequest) Reset()

func (*InspectBranchRequest) Size 

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

func (*InspectBranchRequest) String 

func (m *InspectBranchRequest) String() string

func (*InspectBranchRequest) Unmarshal 

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

func (*InspectBranchRequest) XXX_DiscardUnknown 

func (m *InspectBranchRequest) XXX_DiscardUnknown()

func (*InspectBranchRequest) XXX_Marshal 

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

func (*InspectBranchRequest) XXX_Merge 

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

func (*InspectBranchRequest) XXX_Size 

func (m *InspectBranchRequest) XXX_Size() int

func (*InspectBranchRequest) XXX_Unmarshal 

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_1_7.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 

func (m *InspectCommitRequest) GetBlockState() CommitState

func (*InspectCommitRequest) GetCommit 

func (m *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) Marshal 

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

func (*InspectCommitRequest) MarshalTo 

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

func (*InspectCommitRequest) ProtoMessage 

func (*InspectCommitRequest) ProtoMessage()

func (*InspectCommitRequest) Reset 

func (m *InspectCommitRequest) Reset()

func (*InspectCommitRequest) Size 

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

func (*InspectCommitRequest) String 

func (m *InspectCommitRequest) String() string

func (*InspectCommitRequest) Unmarshal 

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

func (*InspectCommitRequest) XXX_DiscardUnknown 

func (m *InspectCommitRequest) XXX_DiscardUnknown()

func (*InspectCommitRequest) XXX_Marshal 

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

func (*InspectCommitRequest) XXX_Merge 

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

func (*InspectCommitRequest) XXX_Size 

func (m *InspectCommitRequest) XXX_Size() int

func (*InspectCommitRequest) XXX_Unmarshal 

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 

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

func (*InspectFileRequest) MarshalTo 

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

func (*InspectFileRequest) ProtoMessage 

func (*InspectFileRequest) ProtoMessage()

func (*InspectFileRequest) Reset 

func (m *InspectFileRequest) Reset()

func (*InspectFileRequest) Size 

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

func (*InspectFileRequest) String 

func (m *InspectFileRequest) String() string

func (*InspectFileRequest) Unmarshal 

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

func (*InspectFileRequest) XXX_DiscardUnknown 

func (m *InspectFileRequest) XXX_DiscardUnknown()

func (*InspectFileRequest) XXX_Marshal 

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

func (*InspectFileRequest) XXX_Merge 

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

func (*InspectFileRequest) XXX_Size 

func (m *InspectFileRequest) XXX_Size() int

func (*InspectFileRequest) XXX_Unmarshal 

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 

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

func (*InspectRepoRequest) MarshalTo 

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

func (*InspectRepoRequest) ProtoMessage 

func (*InspectRepoRequest) ProtoMessage()

func (*InspectRepoRequest) Reset 

func (m *InspectRepoRequest) Reset()

func (*InspectRepoRequest) Size 

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

func (*InspectRepoRequest) String 

func (m *InspectRepoRequest) String() string

func (*InspectRepoRequest) Unmarshal 

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

func (*InspectRepoRequest) XXX_DiscardUnknown 

func (m *InspectRepoRequest) XXX_DiscardUnknown()

func (*InspectRepoRequest) XXX_Marshal 

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

func (*InspectRepoRequest) XXX_Merge 

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

func (*InspectRepoRequest) XXX_Size 

func (m *InspectRepoRequest) XXX_Size() int

func (*InspectRepoRequest) XXX_Unmarshal 

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 

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

func (*ListBranchRequest) MarshalTo 

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

func (*ListBranchRequest) ProtoMessage 

func (*ListBranchRequest) ProtoMessage()

func (*ListBranchRequest) Reset 

func (m *ListBranchRequest) Reset()

func (*ListBranchRequest) Size 

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

func (*ListBranchRequest) String 

func (m *ListBranchRequest) String() string

func (*ListBranchRequest) Unmarshal 

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

func (*ListBranchRequest) XXX_DiscardUnknown 

func (m *ListBranchRequest) XXX_DiscardUnknown()

func (*ListBranchRequest) XXX_Marshal 

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

func (*ListBranchRequest) XXX_Merge 

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

func (*ListBranchRequest) XXX_Size 

func (m *ListBranchRequest) XXX_Size() int

func (*ListBranchRequest) XXX_Unmarshal 

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 

func (m *ListCommitRequest) GetFrom() *Commit

func (*ListCommitRequest) GetNumber 

func (m *ListCommitRequest) GetNumber() uint64

func (*ListCommitRequest) GetRepo 

func (m *ListCommitRequest) GetRepo() *Repo

func (*ListCommitRequest) GetTo 

func (m *ListCommitRequest) GetTo() *Commit

func (*ListCommitRequest) Marshal 

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

func (*ListCommitRequest) MarshalTo 

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

func (*ListCommitRequest) ProtoMessage 

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) Reset 

func (m *ListCommitRequest) Reset()

func (*ListCommitRequest) Size 

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

func (*ListCommitRequest) String 

func (m *ListCommitRequest) String() string

func (*ListCommitRequest) Unmarshal 

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

func (*ListCommitRequest) XXX_DiscardUnknown 

func (m *ListCommitRequest) XXX_DiscardUnknown()

func (*ListCommitRequest) XXX_Marshal 

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

func (*ListCommitRequest) XXX_Merge 

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

func (*ListCommitRequest) XXX_Size 

func (m *ListCommitRequest) XXX_Size() int

func (*ListCommitRequest) XXX_Unmarshal 

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

type ListFileRequest 

type ListFileRequest struct {
	// File is the parent directory of the files we want to list. This fixes the
	// repo, the commit/branch, and path prefix of files we're interested it
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// Full indicates whether the result should include file contents, which may
	// be large (i.e. the list of children for directories, and the list of object
	// references for regular files)
	Full                 bool     `protobuf:"varint,2,opt,name=full,proto3" json:"full,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListFileRequest) Descriptor 

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

func (*ListFileRequest) GetFile 

func (m *ListFileRequest) GetFile() *File

func (*ListFileRequest) GetFull 

func (m *ListFileRequest) GetFull() bool

func (*ListFileRequest) Marshal 

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

func (*ListFileRequest) MarshalTo 

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

func (*ListFileRequest) ProtoMessage 

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) Reset 

func (m *ListFileRequest) Reset()

func (*ListFileRequest) Size 

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

func (*ListFileRequest) String 

func (m *ListFileRequest) String() string

func (*ListFileRequest) Unmarshal 

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

func (*ListFileRequest) XXX_DiscardUnknown 

func (m *ListFileRequest) XXX_DiscardUnknown()

func (*ListFileRequest) XXX_Marshal 

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

func (*ListFileRequest) XXX_Merge 

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

func (*ListFileRequest) XXX_Size 

func (m *ListFileRequest) XXX_Size() int

func (*ListFileRequest) XXX_Unmarshal 

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

type ListObjectsRequest 

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

func (*ListObjectsRequest) Descriptor 

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

func (*ListObjectsRequest) Marshal 

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

func (*ListObjectsRequest) MarshalTo 

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

func (*ListObjectsRequest) ProtoMessage 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset 

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) Size 

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

func (*ListObjectsRequest) String 

func (m *ListObjectsRequest) String() string

func (*ListObjectsRequest) Unmarshal 

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

func (*ListObjectsRequest) XXX_DiscardUnknown 

func (m *ListObjectsRequest) XXX_DiscardUnknown()

func (*ListObjectsRequest) XXX_Marshal 

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

func (*ListObjectsRequest) XXX_Merge 

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

func (*ListObjectsRequest) XXX_Size 

func (m *ListObjectsRequest) XXX_Size() int

func (*ListObjectsRequest) XXX_Unmarshal 

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 

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

func (*ListRepoRequest) MarshalTo 

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

func (*ListRepoRequest) ProtoMessage 

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset 

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) Size 

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

func (*ListRepoRequest) String 

func (m *ListRepoRequest) String() string

func (*ListRepoRequest) Unmarshal 

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

func (*ListRepoRequest) XXX_DiscardUnknown 

func (m *ListRepoRequest) XXX_DiscardUnknown()

func (*ListRepoRequest) XXX_Marshal 

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

func (*ListRepoRequest) XXX_Merge 

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

func (*ListRepoRequest) XXX_Size 

func (m *ListRepoRequest) XXX_Size() int

func (*ListRepoRequest) XXX_Unmarshal 

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

type ListRepoResponse 

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 

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

func (*ListRepoResponse) GetRepoInfo 

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

func (*ListRepoResponse) Marshal 

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

func (*ListRepoResponse) MarshalTo 

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

func (*ListRepoResponse) ProtoMessage 

func (*ListRepoResponse) ProtoMessage()

func (*ListRepoResponse) Reset 

func (m *ListRepoResponse) Reset()

func (*ListRepoResponse) Size 

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

func (*ListRepoResponse) String 

func (m *ListRepoResponse) String() string

func (*ListRepoResponse) Unmarshal 

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

func (*ListRepoResponse) XXX_DiscardUnknown 

func (m *ListRepoResponse) XXX_DiscardUnknown()

func (*ListRepoResponse) XXX_Marshal 

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

func (*ListRepoResponse) XXX_Merge 

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

func (*ListRepoResponse) XXX_Size 

func (m *ListRepoResponse) XXX_Size() int

func (*ListRepoResponse) XXX_Unmarshal 

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

type ListTagsRequest 

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 

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

func (*ListTagsRequest) GetIncludeObject 

func (m *ListTagsRequest) GetIncludeObject() bool

func (*ListTagsRequest) GetPrefix 

func (m *ListTagsRequest) GetPrefix() string

func (*ListTagsRequest) Marshal 

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

func (*ListTagsRequest) MarshalTo 

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

func (*ListTagsRequest) ProtoMessage 

func (*ListTagsRequest) ProtoMessage()

func (*ListTagsRequest) Reset 

func (m *ListTagsRequest) Reset()

func (*ListTagsRequest) Size 

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

func (*ListTagsRequest) String 

func (m *ListTagsRequest) String() string

func (*ListTagsRequest) Unmarshal 

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

func (*ListTagsRequest) XXX_DiscardUnknown 

func (m *ListTagsRequest) XXX_DiscardUnknown()

func (*ListTagsRequest) XXX_Marshal 

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

func (*ListTagsRequest) XXX_Merge 

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

func (*ListTagsRequest) XXX_Size 

func (m *ListTagsRequest) XXX_Size() int

func (*ListTagsRequest) XXX_Unmarshal 

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

type ListTagsResponse 

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 

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

func (*ListTagsResponse) GetObject 

func (m *ListTagsResponse) GetObject() *Object

func (*ListTagsResponse) GetTag 

func (m *ListTagsResponse) GetTag() *Tag

func (*ListTagsResponse) Marshal 

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

func (*ListTagsResponse) MarshalTo 

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

func (*ListTagsResponse) ProtoMessage 

func (*ListTagsResponse) ProtoMessage()

func (*ListTagsResponse) Reset 

func (m *ListTagsResponse) Reset()

func (*ListTagsResponse) Size 

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

func (*ListTagsResponse) String 

func (m *ListTagsResponse) String() string

func (*ListTagsResponse) Unmarshal 

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

func (*ListTagsResponse) XXX_DiscardUnknown 

func (m *ListTagsResponse) XXX_DiscardUnknown()

func (*ListTagsResponse) XXX_Marshal 

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

func (*ListTagsResponse) XXX_Merge 

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

func (*ListTagsResponse) XXX_Size 

func (m *ListTagsResponse) XXX_Size() int

func (*ListTagsResponse) XXX_Unmarshal 

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

type Metadata 

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

Metadata struct allows us to distinguish between cases where header/footer are not specified vs explicitly empty

func (*Metadata) Descriptor 

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

func (*Metadata) GetValue 

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

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

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

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type Object 

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 

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

func (*Object) GetHash 

func (m *Object) GetHash() string

func (*Object) Marshal 

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

func (*Object) MarshalTo 

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

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) Size 

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

func (*Object) String 

func (m *Object) String() string

func (*Object) Unmarshal 

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

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

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

func (*Object) XXX_Merge 

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

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

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

type ObjectAPIClient 

type ObjectAPIClient interface {
	PutObject(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectClient, error)
	PutObjectSplit(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectSplitClient, error)
	GetObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (ObjectAPI_GetObjectClient, error)
	GetObjects(ctx context.Context, in *GetObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_GetObjectsClient, error)
	TagObject(ctx context.Context, in *TagObjectRequest, opts ...grpc.CallOption) (*types.Empty, error)
	InspectObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (*ObjectInfo, error)
	// CheckObject checks if an object exists in the blob store without
	// actually reading the object.
	CheckObject(ctx context.Context, in *CheckObjectRequest, opts ...grpc.CallOption) (*CheckObjectResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_ListObjectsClient, error)
	DeleteObjects(ctx context.Context, in *DeleteObjectsRequest, opts ...grpc.CallOption) (*DeleteObjectsResponse, error)
	GetTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (ObjectAPI_GetTagClient, error)
	InspectTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (*ObjectInfo, error)
	ListTags(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (ObjectAPI_ListTagsClient, error)
	DeleteTags(ctx context.Context, in *DeleteTagsRequest, opts ...grpc.CallOption) (*DeleteTagsResponse, error)
	Compact(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)
}

ObjectAPIClient is the client API for ObjectAPI service.

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

func NewObjectAPIClient 

func NewObjectAPIClient(cc *grpc.ClientConn) ObjectAPIClient

type ObjectAPIServer 

type ObjectAPIServer interface {
	PutObject(ObjectAPI_PutObjectServer) error
	PutObjectSplit(ObjectAPI_PutObjectSplitServer) error
	GetObject(*Object, ObjectAPI_GetObjectServer) error
	GetObjects(*GetObjectsRequest, ObjectAPI_GetObjectsServer) error
	TagObject(context.Context, *TagObjectRequest) (*types.Empty, error)
	InspectObject(context.Context, *Object) (*ObjectInfo, error)
	// CheckObject checks if an object exists in the blob store without
	// actually reading the object.
	CheckObject(context.Context, *CheckObjectRequest) (*CheckObjectResponse, error)
	ListObjects(*ListObjectsRequest, ObjectAPI_ListObjectsServer) error
	DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)
	GetTag(*Tag, ObjectAPI_GetTagServer) error
	InspectTag(context.Context, *Tag) (*ObjectInfo, error)
	ListTags(*ListTagsRequest, ObjectAPI_ListTagsServer) error
	DeleteTags(context.Context, *DeleteTagsRequest) (*DeleteTagsResponse, error)
	Compact(context.Context, *types.Empty) (*types.Empty, error)
}

ObjectAPIServer is the server API for ObjectAPI service.

type ObjectAPI_GetObjectClient 

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

type ObjectAPI_GetObjectServer 

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

type ObjectAPI_GetObjectsClient 

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

type ObjectAPI_GetObjectsServer 

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

type ObjectAPI_GetTagClient 

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

type ObjectAPI_GetTagServer 

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

type ObjectAPI_ListObjectsClient 

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

type ObjectAPI_ListObjectsServer 

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

type ObjectAPI_ListTagsClient 

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

type ObjectAPI_ListTagsServer 

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

type ObjectAPI_PutObjectClient 

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

type ObjectAPI_PutObjectServer 

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

type ObjectAPI_PutObjectSplitClient 

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

type ObjectAPI_PutObjectSplitServer 

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

type ObjectIndex 

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 

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

func (*ObjectIndex) GetObjects 

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

func (*ObjectIndex) GetTags 

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

func (*ObjectIndex) Marshal 

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

func (*ObjectIndex) MarshalTo 

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

func (*ObjectIndex) ProtoMessage 

func (*ObjectIndex) ProtoMessage()

func (*ObjectIndex) Reset 

func (m *ObjectIndex) Reset()

func (*ObjectIndex) Size 

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

func (*ObjectIndex) String 

func (m *ObjectIndex) String() string

func (*ObjectIndex) Unmarshal 

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

func (*ObjectIndex) XXX_DiscardUnknown 

func (m *ObjectIndex) XXX_DiscardUnknown()

func (*ObjectIndex) XXX_Marshal 

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

func (*ObjectIndex) XXX_Merge 

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

func (*ObjectIndex) XXX_Size 

func (m *ObjectIndex) XXX_Size() int

func (*ObjectIndex) XXX_Unmarshal 

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

type ObjectInfo 

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 

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

func (*ObjectInfo) GetBlockRef 

func (m *ObjectInfo) GetBlockRef() *BlockRef

func (*ObjectInfo) GetObject 

func (m *ObjectInfo) GetObject() *Object

func (*ObjectInfo) Marshal 

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

func (*ObjectInfo) MarshalTo 

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

func (*ObjectInfo) ProtoMessage 

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) Reset 

func (m *ObjectInfo) Reset()

func (*ObjectInfo) Size 

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

func (*ObjectInfo) String 

func (m *ObjectInfo) String() string

func (*ObjectInfo) Unmarshal 

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

func (*ObjectInfo) XXX_DiscardUnknown 

func (m *ObjectInfo) XXX_DiscardUnknown()

func (*ObjectInfo) XXX_Marshal 

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

func (*ObjectInfo) XXX_Merge 

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

func (*ObjectInfo) XXX_Size 

func (m *ObjectInfo) XXX_Size() int

func (*ObjectInfo) XXX_Unmarshal 

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

type Objects 

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 

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

func (*Objects) GetObjects 

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

func (*Objects) Marshal 

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

func (*Objects) MarshalTo 

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

func (*Objects) ProtoMessage 

func (*Objects) ProtoMessage()

func (*Objects) Reset 

func (m *Objects) Reset()

func (*Objects) Size 

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

func (*Objects) String 

func (m *Objects) String() string

func (*Objects) Unmarshal 

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

func (*Objects) XXX_DiscardUnknown 

func (m *Objects) XXX_DiscardUnknown()

func (*Objects) XXX_Marshal 

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

func (*Objects) XXX_Merge 

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

func (*Objects) XXX_Size 

func (m *Objects) XXX_Size() int

func (*Objects) XXX_Unmarshal 

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

type OverwriteIndex 

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 

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

func (*OverwriteIndex) GetIndex 

func (m *OverwriteIndex) GetIndex() int64

func (*OverwriteIndex) Marshal 

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

func (*OverwriteIndex) MarshalTo 

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

func (*OverwriteIndex) ProtoMessage 

func (*OverwriteIndex) ProtoMessage()

func (*OverwriteIndex) Reset 

func (m *OverwriteIndex) Reset()

func (*OverwriteIndex) Size 

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

func (*OverwriteIndex) String 

func (m *OverwriteIndex) String() string

func (*OverwriteIndex) Unmarshal 

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

func (*OverwriteIndex) XXX_DiscardUnknown 

func (m *OverwriteIndex) XXX_DiscardUnknown()

func (*OverwriteIndex) XXX_Marshal 

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

func (*OverwriteIndex) XXX_Merge 

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

func (*OverwriteIndex) XXX_Size 

func (m *OverwriteIndex) XXX_Size() int

func (*OverwriteIndex) XXX_Unmarshal 

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

type PutFileRecord 

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 

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

func (*PutFileRecord) GetObjectHash 

func (m *PutFileRecord) GetObjectHash() string

func (*PutFileRecord) GetOverwriteIndex 

func (m *PutFileRecord) GetOverwriteIndex() *OverwriteIndex

func (*PutFileRecord) GetSizeBytes 

func (m *PutFileRecord) GetSizeBytes() int64

func (*PutFileRecord) Marshal 

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

func (*PutFileRecord) MarshalTo 

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

func (*PutFileRecord) ProtoMessage 

func (*PutFileRecord) ProtoMessage()

func (*PutFileRecord) Reset 

func (m *PutFileRecord) Reset()

func (*PutFileRecord) Size 

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

func (*PutFileRecord) String 

func (m *PutFileRecord) String() string

func (*PutFileRecord) Unmarshal 

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

func (*PutFileRecord) XXX_DiscardUnknown 

func (m *PutFileRecord) XXX_DiscardUnknown()

func (*PutFileRecord) XXX_Marshal 

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

func (*PutFileRecord) XXX_Merge 

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

func (*PutFileRecord) XXX_Size 

func (m *PutFileRecord) XXX_Size() int

func (*PutFileRecord) XXX_Unmarshal 

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

type PutFileRecords 

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 

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

func (*PutFileRecords) GetFooter 

func (m *PutFileRecords) GetFooter() *PutFileRecord

func (*PutFileRecords) GetHeader 

func (m *PutFileRecords) GetHeader() *PutFileRecord

func (*PutFileRecords) GetRecords 

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

func (*PutFileRecords) GetSplit 

func (m *PutFileRecords) GetSplit() bool

func (*PutFileRecords) GetTombstone 

func (m *PutFileRecords) GetTombstone() bool

func (*PutFileRecords) Marshal 

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

func (*PutFileRecords) MarshalTo 

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

func (*PutFileRecords) ProtoMessage 

func (*PutFileRecords) ProtoMessage()

func (*PutFileRecords) Reset 

func (m *PutFileRecords) Reset()

func (*PutFileRecords) Size 

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

func (*PutFileRecords) String 

func (m *PutFileRecords) String() string

func (*PutFileRecords) Unmarshal 

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

func (*PutFileRecords) XXX_DiscardUnknown 

func (m *PutFileRecords) XXX_DiscardUnknown()

func (*PutFileRecords) XXX_Marshal 

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

func (*PutFileRecords) XXX_Merge 

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

func (*PutFileRecords) XXX_Size 

func (m *PutFileRecords) XXX_Size() int

func (*PutFileRecords) XXX_Unmarshal 

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_1_7.Delimiter" json:"delimiter,omitempty"`
	// TargetFileDatums specifies the target number of datums in each written
	// file it may be lower if data does not split evenly, but will never be
	// higher, unless the value is 0.
	TargetFileDatums int64 `protobuf:"varint,8,opt,name=target_file_datums,json=targetFileDatums,proto3" json:"target_file_datums,omitempty"`
	// TargetFileBytes specifies the target number of bytes in each written
	// file, files may have more or fewer bytes than the target.
	TargetFileBytes int64 `protobuf:"varint,9,opt,name=target_file_bytes,json=targetFileBytes,proto3" json:"target_file_bytes,omitempty"`
	// overwrite_index is the object index where the write starts from.  All
	// existing objects starting from the index are deleted.
	OverwriteIndex       *OverwriteIndex `protobuf:"bytes,10,opt,name=overwrite_index,json=overwriteIndex,proto3" json:"overwrite_index,omitempty"`
	Header               *Metadata       `protobuf:"bytes,11,opt,name=header,proto3" json:"header,omitempty"`
	Footer               *Metadata       `protobuf:"bytes,12,opt,name=footer,proto3" json:"footer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PutFileRequest) Descriptor 

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

func (*PutFileRequest) GetDelimiter 

func (m *PutFileRequest) GetDelimiter() Delimiter

func (*PutFileRequest) GetFile 

func (m *PutFileRequest) GetFile() *File

func (*PutFileRequest) GetFooter 

func (m *PutFileRequest) GetFooter() *Metadata

func (*PutFileRequest) GetHeader 

func (m *PutFileRequest) GetHeader() *Metadata

func (*PutFileRequest) GetOverwriteIndex 

func (m *PutFileRequest) GetOverwriteIndex() *OverwriteIndex

func (*PutFileRequest) GetRecursive 

func (m *PutFileRequest) GetRecursive() bool

func (*PutFileRequest) GetTargetFileBytes 

func (m *PutFileRequest) GetTargetFileBytes() int64

func (*PutFileRequest) GetTargetFileDatums 

func (m *PutFileRequest) GetTargetFileDatums() int64

func (*PutFileRequest) GetUrl 

func (m *PutFileRequest) GetUrl() string

func (*PutFileRequest) GetValue 

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

func (*PutFileRequest) Marshal 

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

func (*PutFileRequest) MarshalTo 

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

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) Reset 

func (m *PutFileRequest) Reset()

func (*PutFileRequest) Size 

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

func (*PutFileRequest) String 

func (m *PutFileRequest) String() string

func (*PutFileRequest) Unmarshal 

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

func (*PutFileRequest) XXX_DiscardUnknown 

func (m *PutFileRequest) XXX_DiscardUnknown()

func (*PutFileRequest) XXX_Marshal 

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

func (*PutFileRequest) XXX_Merge 

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

func (*PutFileRequest) XXX_Size 

func (m *PutFileRequest) XXX_Size() int

func (*PutFileRequest) XXX_Unmarshal 

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

type PutObjectRequest 

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

func (*PutObjectRequest) Descriptor 

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

func (*PutObjectRequest) GetTags 

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

func (*PutObjectRequest) GetValue 

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

func (*PutObjectRequest) Marshal 

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

func (*PutObjectRequest) MarshalTo 

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

func (*PutObjectRequest) ProtoMessage 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) Reset 

func (m *PutObjectRequest) Reset()

func (*PutObjectRequest) Size 

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

func (*PutObjectRequest) String 

func (m *PutObjectRequest) String() string

func (*PutObjectRequest) Unmarshal 

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

func (*PutObjectRequest) XXX_DiscardUnknown 

func (m *PutObjectRequest) XXX_DiscardUnknown()

func (*PutObjectRequest) XXX_Marshal 

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

func (*PutObjectRequest) XXX_Merge 

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

func (*PutObjectRequest) XXX_Size 

func (m *PutObjectRequest) XXX_Size() int

func (*PutObjectRequest) XXX_Unmarshal 

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 

func (m *Repo) GetName() string

func (*Repo) Marshal 

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

func (*Repo) MarshalTo 

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

func (*Repo) ProtoMessage 

func (*Repo) ProtoMessage()

func (*Repo) Reset 

func (m *Repo) Reset()

func (*Repo) Size 

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

func (*Repo) String 

func (m *Repo) String() string

func (*Repo) Unmarshal 

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

func (*Repo) XXX_DiscardUnknown 

func (m *Repo) XXX_DiscardUnknown()

func (*Repo) XXX_Marshal 

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

func (*Repo) XXX_Merge 

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

func (*Repo) XXX_Size 

func (m *Repo) XXX_Size() int

func (*Repo) XXX_Unmarshal 

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

type RepoAuthInfo 

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_1_7.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/admin/1_7/auth/auth.proto)

func (*RepoAuthInfo) Descriptor 

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

func (*RepoAuthInfo) GetAccessLevel 

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

func (*RepoAuthInfo) Marshal 

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

func (*RepoAuthInfo) MarshalTo 

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

func (*RepoAuthInfo) ProtoMessage 

func (*RepoAuthInfo) ProtoMessage()

func (*RepoAuthInfo) Reset 

func (m *RepoAuthInfo) Reset()

func (*RepoAuthInfo) Size 

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

func (*RepoAuthInfo) String 

func (m *RepoAuthInfo) String() string

func (*RepoAuthInfo) Unmarshal 

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

func (*RepoAuthInfo) XXX_DiscardUnknown 

func (m *RepoAuthInfo) XXX_DiscardUnknown()

func (*RepoAuthInfo) XXX_Marshal 

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

func (*RepoAuthInfo) XXX_Merge 

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

func (*RepoAuthInfo) XXX_Size 

func (m *RepoAuthInfo) XXX_Size() int

func (*RepoAuthInfo) XXX_Unmarshal 

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/admin/1_7/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 

func (m *RepoInfo) GetAuthInfo() *RepoAuthInfo

func (*RepoInfo) GetBranches 

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

func (*RepoInfo) GetCreated 

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

func (*RepoInfo) GetDescription 

func (m *RepoInfo) GetDescription() string

func (*RepoInfo) GetRepo 

func (m *RepoInfo) GetRepo() *Repo

func (*RepoInfo) GetSizeBytes 

func (m *RepoInfo) GetSizeBytes() uint64

func (*RepoInfo) Marshal 

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

func (*RepoInfo) MarshalTo 

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

func (*RepoInfo) ProtoMessage 

func (*RepoInfo) ProtoMessage()

func (*RepoInfo) Reset 

func (m *RepoInfo) Reset()

func (*RepoInfo) Size 

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

func (*RepoInfo) String 

func (m *RepoInfo) String() string

func (*RepoInfo) Unmarshal 

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

func (*RepoInfo) XXX_DiscardUnknown 

func (m *RepoInfo) XXX_DiscardUnknown()

func (*RepoInfo) XXX_Marshal 

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

func (*RepoInfo) XXX_Merge 

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

func (*RepoInfo) XXX_Size 

func (m *RepoInfo) XXX_Size() int

func (*RepoInfo) XXX_Unmarshal 

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 

func (m *StartCommitRequest) GetBranch() string

func (*StartCommitRequest) GetDescription 

func (m *StartCommitRequest) GetDescription() string

func (*StartCommitRequest) GetParent 

func (m *StartCommitRequest) GetParent() *Commit

func (*StartCommitRequest) GetProvenance 

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

func (*StartCommitRequest) Marshal 

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

func (*StartCommitRequest) MarshalTo 

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

func (*StartCommitRequest) ProtoMessage 

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) Reset 

func (m *StartCommitRequest) Reset()

func (*StartCommitRequest) Size 

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

func (*StartCommitRequest) String 

func (m *StartCommitRequest) String() string

func (*StartCommitRequest) Unmarshal 

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

func (*StartCommitRequest) XXX_DiscardUnknown 

func (m *StartCommitRequest) XXX_DiscardUnknown()

func (*StartCommitRequest) XXX_Marshal 

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

func (*StartCommitRequest) XXX_Merge 

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

func (*StartCommitRequest) XXX_Size 

func (m *StartCommitRequest) XXX_Size() int

func (*StartCommitRequest) XXX_Unmarshal 

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

type SubscribeCommitRequest 

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_1_7.CommitState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SubscribeCommitRequest) Descriptor 

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

func (*SubscribeCommitRequest) GetBranch 

func (m *SubscribeCommitRequest) GetBranch() string

func (*SubscribeCommitRequest) GetFrom 

func (m *SubscribeCommitRequest) GetFrom() *Commit

func (*SubscribeCommitRequest) GetRepo 

func (m *SubscribeCommitRequest) GetRepo() *Repo

func (*SubscribeCommitRequest) GetState 

func (m *SubscribeCommitRequest) GetState() CommitState

func (*SubscribeCommitRequest) Marshal 

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

func (*SubscribeCommitRequest) MarshalTo 

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

func (*SubscribeCommitRequest) ProtoMessage 

func (*SubscribeCommitRequest) ProtoMessage()

func (*SubscribeCommitRequest) Reset 

func (m *SubscribeCommitRequest) Reset()

func (*SubscribeCommitRequest) Size 

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

func (*SubscribeCommitRequest) String 

func (m *SubscribeCommitRequest) String() string

func (*SubscribeCommitRequest) Unmarshal 

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

func (*SubscribeCommitRequest) XXX_DiscardUnknown 

func (m *SubscribeCommitRequest) XXX_DiscardUnknown()

func (*SubscribeCommitRequest) XXX_Marshal 

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

func (*SubscribeCommitRequest) XXX_Merge 

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

func (*SubscribeCommitRequest) XXX_Size 

func (m *SubscribeCommitRequest) XXX_Size() int

func (*SubscribeCommitRequest) XXX_Unmarshal 

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

type Tag 

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 

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

func (*Tag) GetName 

func (m *Tag) GetName() string

func (*Tag) Marshal 

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

func (*Tag) MarshalTo 

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

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) Reset 

func (m *Tag) Reset()

func (*Tag) Size 

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

func (*Tag) String 

func (m *Tag) String() string

func (*Tag) Unmarshal 

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

func (*Tag) XXX_DiscardUnknown 

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal 

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

func (*Tag) XXX_Merge 

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

func (*Tag) XXX_Size 

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal 

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

type TagObjectRequest 

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 

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

func (*TagObjectRequest) GetObject 

func (m *TagObjectRequest) GetObject() *Object

func (*TagObjectRequest) GetTags 

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

func (*TagObjectRequest) Marshal 

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

func (*TagObjectRequest) MarshalTo 

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

func (*TagObjectRequest) ProtoMessage 

func (*TagObjectRequest) ProtoMessage()

func (*TagObjectRequest) Reset 

func (m *TagObjectRequest) Reset()

func (*TagObjectRequest) Size 

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

func (*TagObjectRequest) String 

func (m *TagObjectRequest) String() string

func (*TagObjectRequest) Unmarshal 

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

func (*TagObjectRequest) XXX_DiscardUnknown 

func (m *TagObjectRequest) XXX_DiscardUnknown()

func (*TagObjectRequest) XXX_Marshal 

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

func (*TagObjectRequest) XXX_Merge 

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

func (*TagObjectRequest) XXX_Size 

func (m *TagObjectRequest) XXX_Size() int

func (*TagObjectRequest) XXX_Unmarshal 

func (m *TagObjectRequest) 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.