pfs

package
v1.9.0 Latest Latest
Warning

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

Go to latest
Published: Jun 12, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthPfs = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPfs   = fmt.Errorf("proto: integer overflow")
)
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 (m *Block) XXX_Merge(src proto.Message)

func (*Block) XXX_Size

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal

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

type BlockRef

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

func (*BlockRef) Descriptor

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

func (*BlockRef) GetBlock

func (m *BlockRef) GetBlock() *Block

func (*BlockRef) GetRange

func (m *BlockRef) GetRange() *ByteRange

func (*BlockRef) Marshal

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

func (*BlockRef) MarshalTo

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

func (*BlockRef) ProtoMessage

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset

func (m *BlockRef) Reset()

func (*BlockRef) Size

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

func (*BlockRef) String

func (m *BlockRef) String() string

func (*BlockRef) Unmarshal

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

func (*BlockRef) XXX_DiscardUnknown

func (m *BlockRef) XXX_DiscardUnknown()

func (*BlockRef) XXX_Marshal

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

func (*BlockRef) XXX_Merge

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

func (*BlockRef) XXX_Size

func (m *BlockRef) XXX_Size() int

func (*BlockRef) XXX_Unmarshal

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

type Branch

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

func (*Branch) Descriptor

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

func (*Branch) GetName

func (m *Branch) GetName() string

func (*Branch) GetRepo

func (m *Branch) GetRepo() *Repo

func (*Branch) Marshal

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

func (*Branch) MarshalTo

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

func (*Branch) ProtoMessage

func (*Branch) ProtoMessage()

func (*Branch) Reset

func (m *Branch) Reset()

func (*Branch) Size

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

func (*Branch) String

func (m *Branch) String() string

func (*Branch) Unmarshal

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

func (*Branch) XXX_DiscardUnknown

func (m *Branch) XXX_DiscardUnknown()

func (*Branch) XXX_Marshal

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

func (*Branch) XXX_Merge

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

func (*Branch) XXX_Size

func (m *Branch) XXX_Size() int

func (*Branch) XXX_Unmarshal

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

type BranchInfo

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

func (*BranchInfo) Descriptor

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

func (*BranchInfo) GetBranch

func (m *BranchInfo) GetBranch() *Branch

func (*BranchInfo) GetDirectProvenance

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

func (*BranchInfo) GetHead

func (m *BranchInfo) GetHead() *Commit

func (*BranchInfo) GetName

func (m *BranchInfo) GetName() string

func (*BranchInfo) GetProvenance

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

func (*BranchInfo) GetSubvenance

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

func (*BranchInfo) Marshal

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

func (*BranchInfo) MarshalTo

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

func (*BranchInfo) ProtoMessage

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) Reset

func (m *BranchInfo) Reset()

func (*BranchInfo) Size

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

func (*BranchInfo) String

func (m *BranchInfo) String() string

func (*BranchInfo) Unmarshal

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

func (*BranchInfo) XXX_DiscardUnknown

func (m *BranchInfo) XXX_DiscardUnknown()

func (*BranchInfo) XXX_Marshal

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

func (*BranchInfo) XXX_Merge

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

func (*BranchInfo) XXX_Size

func (m *BranchInfo) XXX_Size() int

func (*BranchInfo) XXX_Unmarshal

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

type BranchInfos

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

func (*BranchInfos) Descriptor

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

func (*BranchInfos) GetBranchInfo

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

func (*BranchInfos) Marshal

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

func (*BranchInfos) MarshalTo

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

func (*BranchInfos) ProtoMessage

func (*BranchInfos) ProtoMessage()

func (*BranchInfos) Reset

func (m *BranchInfos) Reset()

func (*BranchInfos) Size

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

func (*BranchInfos) String

func (m *BranchInfos) String() string

func (*BranchInfos) Unmarshal

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

func (*BranchInfos) XXX_DiscardUnknown

func (m *BranchInfos) XXX_DiscardUnknown()

func (*BranchInfos) XXX_Marshal

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

func (*BranchInfos) XXX_Merge

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

func (*BranchInfos) XXX_Size

func (m *BranchInfos) XXX_Size() int

func (*BranchInfos) XXX_Unmarshal

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

type BuildCommitRequest

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

func (*BuildCommitRequest) XXX_Size

func (m *BuildCommitRequest) XXX_Size() int

func (*BuildCommitRequest) XXX_Unmarshal

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

type ByteRange

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

func (*ByteRange) Descriptor

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

func (*ByteRange) GetLower

func (m *ByteRange) GetLower() uint64

func (*ByteRange) GetUpper

func (m *ByteRange) GetUpper() uint64

func (*ByteRange) Marshal

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

func (*ByteRange) MarshalTo

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

func (*ByteRange) ProtoMessage

func (*ByteRange) ProtoMessage()

func (*ByteRange) Reset

func (m *ByteRange) Reset()

func (*ByteRange) Size

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

func (*ByteRange) String

func (m *ByteRange) String() string

func (*ByteRange) Unmarshal

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

func (*ByteRange) XXX_DiscardUnknown

func (m *ByteRange) XXX_DiscardUnknown()

func (*ByteRange) XXX_Marshal

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

func (*ByteRange) XXX_Merge

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

func (*ByteRange) XXX_Size

func (m *ByteRange) XXX_Size() int

func (*ByteRange) XXX_Unmarshal

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

type CheckObjectRequest

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

func (*CheckObjectRequest) Descriptor

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

func (*CheckObjectRequest) GetObject

func (m *CheckObjectRequest) GetObject() *Object

func (*CheckObjectRequest) Marshal

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

func (*CheckObjectRequest) MarshalTo

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

func (*CheckObjectRequest) ProtoMessage

func (*CheckObjectRequest) ProtoMessage()

func (*CheckObjectRequest) Reset

func (m *CheckObjectRequest) Reset()

func (*CheckObjectRequest) Size

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

func (*CheckObjectRequest) String

func (m *CheckObjectRequest) String() string

func (*CheckObjectRequest) Unmarshal

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

func (*CheckObjectRequest) XXX_DiscardUnknown

func (m *CheckObjectRequest) XXX_DiscardUnknown()

func (*CheckObjectRequest) XXX_Marshal

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

func (*CheckObjectRequest) XXX_Merge

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

func (*CheckObjectRequest) XXX_Size

func (m *CheckObjectRequest) XXX_Size() int

func (*CheckObjectRequest) XXX_Unmarshal

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

type CheckObjectResponse

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

func (*CheckObjectResponse) Descriptor

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

func (*CheckObjectResponse) GetExists

func (m *CheckObjectResponse) GetExists() bool

func (*CheckObjectResponse) Marshal

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

func (*CheckObjectResponse) MarshalTo

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

func (*CheckObjectResponse) ProtoMessage

func (*CheckObjectResponse) ProtoMessage()

func (*CheckObjectResponse) Reset

func (m *CheckObjectResponse) Reset()

func (*CheckObjectResponse) Size

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

func (*CheckObjectResponse) String

func (m *CheckObjectResponse) String() string

func (*CheckObjectResponse) Unmarshal

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

func (*CheckObjectResponse) XXX_DiscardUnknown

func (m *CheckObjectResponse) XXX_DiscardUnknown()

func (*CheckObjectResponse) XXX_Marshal

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

func (*CheckObjectResponse) XXX_Merge

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

func (*CheckObjectResponse) XXX_Size

func (m *CheckObjectResponse) XXX_Size() int

func (*CheckObjectResponse) XXX_Unmarshal

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

type Commit

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

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

func (*Commit) Descriptor

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

func (*Commit) GetID

func (m *Commit) GetID() string

func (*Commit) GetRepo

func (m *Commit) GetRepo() *Repo

func (*Commit) Marshal

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

func (*Commit) MarshalTo

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

func (*Commit) ProtoMessage

func (*Commit) ProtoMessage()

func (*Commit) Reset

func (m *Commit) Reset()

func (*Commit) Size

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

func (*Commit) String

func (m *Commit) String() string

func (*Commit) Unmarshal

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

func (*Commit) XXX_DiscardUnknown

func (m *Commit) XXX_DiscardUnknown()

func (*Commit) XXX_Marshal

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

func (*Commit) XXX_Merge

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

func (*Commit) XXX_Size

func (m *Commit) XXX_Size() int

func (*Commit) XXX_Unmarshal

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

type CommitInfo

type CommitInfo struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// 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 (m *CommitInfo) XXX_Merge(src proto.Message)

func (*CommitInfo) XXX_Size

func (m *CommitInfo) XXX_Size() int

func (*CommitInfo) XXX_Unmarshal

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

type CommitInfos

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

func (*CommitInfos) Descriptor

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

func (*CommitInfos) GetCommitInfo

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

func (*CommitInfos) Marshal

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

func (*CommitInfos) MarshalTo

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

func (*CommitInfos) ProtoMessage

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset

func (m *CommitInfos) Reset()

func (*CommitInfos) Size

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

func (*CommitInfos) String

func (m *CommitInfos) String() string

func (*CommitInfos) Unmarshal

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

func (*CommitInfos) XXX_DiscardUnknown

func (m *CommitInfos) XXX_DiscardUnknown()

func (*CommitInfos) XXX_Marshal

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

func (*CommitInfos) XXX_Merge

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

func (*CommitInfos) XXX_Size

func (m *CommitInfos) XXX_Size() int

func (*CommitInfos) XXX_Unmarshal

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

type 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 (m *CommitRange) XXX_Merge(src proto.Message)

func (*CommitRange) XXX_Size

func (m *CommitRange) XXX_Size() int

func (*CommitRange) XXX_Unmarshal

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

type CommitState

type CommitState int32

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

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

func (CommitState) EnumDescriptor

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

func (CommitState) String

func (x CommitState) String() string

type CopyFileRequest

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

func (*CopyFileRequest) Descriptor

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

func (*CopyFileRequest) GetDst

func (m *CopyFileRequest) GetDst() *File

func (*CopyFileRequest) GetOverwrite

func (m *CopyFileRequest) GetOverwrite() bool

func (*CopyFileRequest) GetSrc

func (m *CopyFileRequest) GetSrc() *File

func (*CopyFileRequest) Marshal

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

func (*CopyFileRequest) MarshalTo

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

func (*CopyFileRequest) ProtoMessage

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) Size

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

func (*CopyFileRequest) String

func (m *CopyFileRequest) String() string

func (*CopyFileRequest) Unmarshal

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

func (*CopyFileRequest) XXX_DiscardUnknown

func (m *CopyFileRequest) XXX_DiscardUnknown()

func (*CopyFileRequest) XXX_Marshal

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

func (*CopyFileRequest) XXX_Merge

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

func (*CopyFileRequest) XXX_Size

func (m *CopyFileRequest) XXX_Size() int

func (*CopyFileRequest) XXX_Unmarshal

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

type CreateBranchRequest

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

func (*CreateBranchRequest) Descriptor

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

func (*CreateBranchRequest) GetBranch

func (m *CreateBranchRequest) GetBranch() *Branch

func (*CreateBranchRequest) GetHead

func (m *CreateBranchRequest) GetHead() *Commit

func (*CreateBranchRequest) GetProvenance

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

func (*CreateBranchRequest) GetSBranch

func (m *CreateBranchRequest) GetSBranch() string

func (*CreateBranchRequest) Marshal

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

func (*CreateBranchRequest) MarshalTo

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

func (*CreateBranchRequest) ProtoMessage

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) Reset

func (m *CreateBranchRequest) Reset()

func (*CreateBranchRequest) Size

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

func (*CreateBranchRequest) String

func (m *CreateBranchRequest) String() string

func (*CreateBranchRequest) Unmarshal

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

func (*CreateBranchRequest) XXX_DiscardUnknown

func (m *CreateBranchRequest) XXX_DiscardUnknown()

func (*CreateBranchRequest) XXX_Marshal

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

func (*CreateBranchRequest) XXX_Merge

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

func (*CreateBranchRequest) XXX_Size

func (m *CreateBranchRequest) XXX_Size() int

func (*CreateBranchRequest) XXX_Unmarshal

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

type 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 (m *CreateRepoRequest) XXX_Merge(src proto.Message)

func (*CreateRepoRequest) XXX_Size

func (m *CreateRepoRequest) XXX_Size() int

func (*CreateRepoRequest) XXX_Unmarshal

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

type DeleteBranchRequest

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

func (*DeleteBranchRequest) Descriptor

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

func (*DeleteBranchRequest) GetBranch

func (m *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) GetForce

func (m *DeleteBranchRequest) GetForce() bool

func (*DeleteBranchRequest) Marshal

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

func (*DeleteBranchRequest) MarshalTo

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

func (*DeleteBranchRequest) ProtoMessage

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) Size

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

func (*DeleteBranchRequest) String

func (m *DeleteBranchRequest) String() string

func (*DeleteBranchRequest) Unmarshal

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

func (*DeleteBranchRequest) XXX_DiscardUnknown

func (m *DeleteBranchRequest) XXX_DiscardUnknown()

func (*DeleteBranchRequest) XXX_Marshal

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

func (*DeleteBranchRequest) XXX_Merge

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

func (*DeleteBranchRequest) XXX_Size

func (m *DeleteBranchRequest) XXX_Size() int

func (*DeleteBranchRequest) XXX_Unmarshal

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

type DeleteCommitRequest

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

func (*DeleteCommitRequest) Descriptor

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

func (*DeleteCommitRequest) GetCommit

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) Marshal

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

func (*DeleteCommitRequest) MarshalTo

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

func (*DeleteCommitRequest) ProtoMessage

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) Size

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

func (*DeleteCommitRequest) String

func (m *DeleteCommitRequest) String() string

func (*DeleteCommitRequest) Unmarshal

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

func (*DeleteCommitRequest) XXX_DiscardUnknown

func (m *DeleteCommitRequest) XXX_DiscardUnknown()

func (*DeleteCommitRequest) XXX_Marshal

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

func (*DeleteCommitRequest) XXX_Merge

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

func (*DeleteCommitRequest) XXX_Size

func (m *DeleteCommitRequest) XXX_Size() int

func (*DeleteCommitRequest) XXX_Unmarshal

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

type DeleteFileRequest

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

func (*DeleteFileRequest) Descriptor

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

func (*DeleteFileRequest) GetFile

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) Marshal

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

func (*DeleteFileRequest) MarshalTo

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

func (*DeleteFileRequest) ProtoMessage

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) Size

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

func (*DeleteFileRequest) String

func (m *DeleteFileRequest) String() string

func (*DeleteFileRequest) Unmarshal

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

func (*DeleteFileRequest) XXX_DiscardUnknown

func (m *DeleteFileRequest) XXX_DiscardUnknown()

func (*DeleteFileRequest) XXX_Marshal

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

func (*DeleteFileRequest) XXX_Merge

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

func (*DeleteFileRequest) XXX_Size

func (m *DeleteFileRequest) XXX_Size() int

func (*DeleteFileRequest) XXX_Unmarshal

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

type DeleteObjectsRequest

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

func (*DeleteObjectsRequest) Descriptor

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

func (*DeleteObjectsRequest) GetObjects

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

func (*DeleteObjectsRequest) Marshal

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

func (*DeleteObjectsRequest) MarshalTo

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

func (*DeleteObjectsRequest) ProtoMessage

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) Reset

func (m *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) Size

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

func (*DeleteObjectsRequest) String

func (m *DeleteObjectsRequest) String() string

func (*DeleteObjectsRequest) Unmarshal

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

func (*DeleteObjectsRequest) XXX_DiscardUnknown

func (m *DeleteObjectsRequest) XXX_DiscardUnknown()

func (*DeleteObjectsRequest) XXX_Marshal

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

func (*DeleteObjectsRequest) XXX_Merge

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

func (*DeleteObjectsRequest) XXX_Size

func (m *DeleteObjectsRequest) XXX_Size() int

func (*DeleteObjectsRequest) XXX_Unmarshal

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

type DeleteObjectsResponse

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

func (*DeleteObjectsResponse) Descriptor

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

func (*DeleteObjectsResponse) Marshal

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

func (*DeleteObjectsResponse) MarshalTo

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

func (*DeleteObjectsResponse) ProtoMessage

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) Reset

func (m *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) Size

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

func (*DeleteObjectsResponse) String

func (m *DeleteObjectsResponse) String() string

func (*DeleteObjectsResponse) Unmarshal

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

func (*DeleteObjectsResponse) XXX_DiscardUnknown

func (m *DeleteObjectsResponse) XXX_DiscardUnknown()

func (*DeleteObjectsResponse) XXX_Marshal

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

func (*DeleteObjectsResponse) XXX_Merge

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

func (*DeleteObjectsResponse) XXX_Size

func (m *DeleteObjectsResponse) XXX_Size() int

func (*DeleteObjectsResponse) XXX_Unmarshal

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

type DeleteRepoRequest

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

func (*DeleteRepoRequest) Descriptor

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

func (*DeleteRepoRequest) GetAll

func (m *DeleteRepoRequest) GetAll() bool

func (*DeleteRepoRequest) GetForce

func (m *DeleteRepoRequest) GetForce() bool

func (*DeleteRepoRequest) GetRepo

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) Marshal

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

func (*DeleteRepoRequest) MarshalTo

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

func (*DeleteRepoRequest) ProtoMessage

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) Size

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

func (*DeleteRepoRequest) String

func (m *DeleteRepoRequest) String() string

func (*DeleteRepoRequest) Unmarshal

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

func (*DeleteRepoRequest) XXX_DiscardUnknown

func (m *DeleteRepoRequest) XXX_DiscardUnknown()

func (*DeleteRepoRequest) XXX_Marshal

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

func (*DeleteRepoRequest) XXX_Merge

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

func (*DeleteRepoRequest) XXX_Size

func (m *DeleteRepoRequest) XXX_Size() int

func (*DeleteRepoRequest) XXX_Unmarshal

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

type DeleteTagsRequest

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

func (*DeleteTagsRequest) Descriptor

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

func (*DeleteTagsRequest) GetTags

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

func (*DeleteTagsRequest) Marshal

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

func (*DeleteTagsRequest) MarshalTo

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

func (*DeleteTagsRequest) ProtoMessage

func (*DeleteTagsRequest) ProtoMessage()

func (*DeleteTagsRequest) Reset

func (m *DeleteTagsRequest) Reset()

func (*DeleteTagsRequest) Size

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

func (*DeleteTagsRequest) String

func (m *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Unmarshal

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

func (*DeleteTagsRequest) XXX_DiscardUnknown

func (m *DeleteTagsRequest) XXX_DiscardUnknown()

func (*DeleteTagsRequest) XXX_Marshal

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

func (*DeleteTagsRequest) XXX_Merge

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

func (*DeleteTagsRequest) XXX_Size

func (m *DeleteTagsRequest) XXX_Size() int

func (*DeleteTagsRequest) XXX_Unmarshal

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

type DeleteTagsResponse

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

func (*DeleteTagsResponse) Descriptor

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

func (*DeleteTagsResponse) Marshal

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

func (*DeleteTagsResponse) MarshalTo

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

func (*DeleteTagsResponse) ProtoMessage

func (*DeleteTagsResponse) ProtoMessage()

func (*DeleteTagsResponse) Reset

func (m *DeleteTagsResponse) Reset()

func (*DeleteTagsResponse) Size

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

func (*DeleteTagsResponse) String

func (m *DeleteTagsResponse) String() string

func (*DeleteTagsResponse) Unmarshal

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

func (*DeleteTagsResponse) XXX_DiscardUnknown

func (m *DeleteTagsResponse) XXX_DiscardUnknown()

func (*DeleteTagsResponse) XXX_Marshal

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

func (*DeleteTagsResponse) XXX_Merge

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

func (*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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *InspectRepoRequest) XXX_Merge(src proto.Message)

func (*InspectRepoRequest)