pfs

package
v2.7.0-alpha.1 Latest Latest
Warning

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

 Go to latest Published: May 25, 2023 License: Apache-2.0 Imports: 21 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	// ChunkSize is the size of file chunks when resumable upload is used
	ChunkSize = int64(512 * 1024 * 1024) // 512 MB

	// default system repo types
	UserRepoType = "user"
	MetaRepoType = "meta"
	SpecRepoType = "spec"

	DefaultProjectName = "default"
)

Variables

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

Functions

func DecodeHash 

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

DecodeHash decodes a hash into bytes.

func EncodeHash 

func EncodeHash(bytes []byte) string

EncodeHash encodes a hash into a readable format.

func NewHash 

func NewHash() hash.Hash

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

func RegisterAPIServer 

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

Types

type APIClient 

type APIClient interface {
	// CreateRepo creates a new repo.
	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) (API_ListRepoClient, error)
	// DeleteRepo deletes a repo.
	DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// DeleteRepos deletes more than one repo at once.  It attempts to
	// delete every repo matching the DeleteReposRequest.  When deleting
	// all repos matching a project, any repos not deletable by the
	// caller will remain, and the project will not be empty; this is
	// not an error.  The returned DeleteReposResponse will contain a
	// list of all actually-deleted repos.
	DeleteRepos(ctx context.Context, in *DeleteReposRequest, opts ...grpc.CallOption) (*DeleteReposResponse, error)
	// 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)
	// ClearCommit removes all data from the commit.
	ClearCommit(ctx context.Context, in *ClearCommitRequest, 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.
	ListCommit(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (API_ListCommitClient, error)
	// SubscribeCommit subscribes for new commits on a given branch.
	SubscribeCommit(ctx context.Context, in *SubscribeCommitRequest, opts ...grpc.CallOption) (API_SubscribeCommitClient, error)
	// InspectCommitSet returns the info about a CommitSet.
	InspectCommitSet(ctx context.Context, in *InspectCommitSetRequest, opts ...grpc.CallOption) (API_InspectCommitSetClient, error)
	// ListCommitSet returns info about all CommitSets.
	ListCommitSet(ctx context.Context, in *ListCommitSetRequest, opts ...grpc.CallOption) (API_ListCommitSetClient, error)
	// SquashCommitSet squashes the commits of a CommitSet into their children.
	SquashCommitSet(ctx context.Context, in *SquashCommitSetRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// DropCommitSet drops the commits of a CommitSet and all data included in the commits.
	DropCommitSet(ctx context.Context, in *DropCommitSetRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// FindCommits searches for commits that reference a supplied file being modified in a branch.
	FindCommits(ctx context.Context, in *FindCommitsRequest, opts ...grpc.CallOption) (API_FindCommitsClient, 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) (API_ListBranchClient, error)
	// DeleteBranch deletes a branch; note that the commits still exist.
	DeleteBranch(ctx context.Context, in *DeleteBranchRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// ModifyFile performs modifications on a set of files.
	ModifyFile(ctx context.Context, opts ...grpc.CallOption) (API_ModifyFileClient, error)
	// GetFile returns the contents of a single file
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (API_GetFileClient, error)
	// GetFileTAR returns a TAR stream of the contents matched by the request
	GetFileTAR(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (API_GetFileTARClient, error)
	// InspectFile returns info about a file.
	InspectFile(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error)
	// ListFile returns info about all files.
	ListFile(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (API_ListFileClient, error)
	// WalkFile walks over all the files under a directory, including children of children.
	WalkFile(ctx context.Context, in *WalkFileRequest, opts ...grpc.CallOption) (API_WalkFileClient, error)
	// GlobFile returns info about all files.
	GlobFile(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (API_GlobFileClient, error)
	// DiffFile returns the differences between 2 paths at 2 commits.
	DiffFile(ctx context.Context, in *DiffFileRequest, opts ...grpc.CallOption) (API_DiffFileClient, error)
	// ActivateAuth creates a role binding for all existing repos
	ActivateAuth(ctx context.Context, in *ActivateAuthRequest, opts ...grpc.CallOption) (*ActivateAuthResponse, error)
	// DeleteAll deletes everything.
	DeleteAll(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)
	// Fsck does a file system consistency check for pfs.
	Fsck(ctx context.Context, in *FsckRequest, opts ...grpc.CallOption) (API_FsckClient, error)
	// FileSet API
	// CreateFileSet creates a new file set.
	CreateFileSet(ctx context.Context, opts ...grpc.CallOption) (API_CreateFileSetClient, error)
	// GetFileSet returns a file set with the data from a commit
	GetFileSet(ctx context.Context, in *GetFileSetRequest, opts ...grpc.CallOption) (*CreateFileSetResponse, error)
	// AddFileSet associates a file set with a commit
	AddFileSet(ctx context.Context, in *AddFileSetRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// RenewFileSet prevents a file set from being deleted for a set amount of time.
	RenewFileSet(ctx context.Context, in *RenewFileSetRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// ComposeFileSet composes a file set from a list of file sets.
	ComposeFileSet(ctx context.Context, in *ComposeFileSetRequest, opts ...grpc.CallOption) (*CreateFileSetResponse, error)
	ShardFileSet(ctx context.Context, in *ShardFileSetRequest, opts ...grpc.CallOption) (*ShardFileSetResponse, error)
	// CheckStorage runs integrity checks for the storage layer.
	CheckStorage(ctx context.Context, in *CheckStorageRequest, opts ...grpc.CallOption) (*CheckStorageResponse, error)
	PutCache(ctx context.Context, in *PutCacheRequest, opts ...grpc.CallOption) (*types.Empty, error)
	GetCache(ctx context.Context, in *GetCacheRequest, opts ...grpc.CallOption) (*GetCacheResponse, error)
	ClearCache(ctx context.Context, in *ClearCacheRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// RunLoadTest runs a load test.
	RunLoadTest(ctx context.Context, in *RunLoadTestRequest, opts ...grpc.CallOption) (*RunLoadTestResponse, error)
	// RunLoadTestDefault runs the default load tests.
	RunLoadTestDefault(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*RunLoadTestResponse, error)
	// ListTask lists PFS tasks
	ListTask(ctx context.Context, in *task.ListTaskRequest, opts ...grpc.CallOption) (API_ListTaskClient, error)
	// Egress writes data from a commit to an external system
	Egress(ctx context.Context, in *EgressRequest, opts ...grpc.CallOption) (*EgressResponse, error)
	// Project API
	// CreateProject creates a new project.
	CreateProject(ctx context.Context, in *CreateProjectRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// InspectProject returns info about a project.
	InspectProject(ctx context.Context, in *InspectProjectRequest, opts ...grpc.CallOption) (*ProjectInfo, error)
	// ListProject returns info about all projects.
	ListProject(ctx context.Context, in *ListProjectRequest, opts ...grpc.CallOption) (API_ListProjectClient, error)
	// DeleteProject deletes a project.
	DeleteProject(ctx context.Context, in *DeleteProjectRequest, 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 {
	// CreateRepo creates a new repo.
	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(*ListRepoRequest, API_ListRepoServer) error
	// DeleteRepo deletes a repo.
	DeleteRepo(context.Context, *DeleteRepoRequest) (*types.Empty, error)
	// DeleteRepos deletes more than one repo at once.  It attempts to
	// delete every repo matching the DeleteReposRequest.  When deleting
	// all repos matching a project, any repos not deletable by the
	// caller will remain, and the project will not be empty; this is
	// not an error.  The returned DeleteReposResponse will contain a
	// list of all actually-deleted repos.
	DeleteRepos(context.Context, *DeleteReposRequest) (*DeleteReposResponse, error)
	// 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)
	// ClearCommit removes all data from the commit.
	ClearCommit(context.Context, *ClearCommitRequest) (*types.Empty, error)
	// InspectCommit returns the info about a commit.
	InspectCommit(context.Context, *InspectCommitRequest) (*CommitInfo, error)
	// ListCommit returns info about all commits.
	ListCommit(*ListCommitRequest, API_ListCommitServer) error
	// SubscribeCommit subscribes for new commits on a given branch.
	SubscribeCommit(*SubscribeCommitRequest, API_SubscribeCommitServer) error
	// InspectCommitSet returns the info about a CommitSet.
	InspectCommitSet(*InspectCommitSetRequest, API_InspectCommitSetServer) error
	// ListCommitSet returns info about all CommitSets.
	ListCommitSet(*ListCommitSetRequest, API_ListCommitSetServer) error
	// SquashCommitSet squashes the commits of a CommitSet into their children.
	SquashCommitSet(context.Context, *SquashCommitSetRequest) (*types.Empty, error)
	// DropCommitSet drops the commits of a CommitSet and all data included in the commits.
	DropCommitSet(context.Context, *DropCommitSetRequest) (*types.Empty, error)
	// FindCommits searches for commits that reference a supplied file being modified in a branch.
	FindCommits(*FindCommitsRequest, API_FindCommitsServer) 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(*ListBranchRequest, API_ListBranchServer) error
	// DeleteBranch deletes a branch; note that the commits still exist.
	DeleteBranch(context.Context, *DeleteBranchRequest) (*types.Empty, error)
	// ModifyFile performs modifications on a set of files.
	ModifyFile(API_ModifyFileServer) error
	// GetFile returns the contents of a single file
	GetFile(*GetFileRequest, API_GetFileServer) error
	// GetFileTAR returns a TAR stream of the contents matched by the request
	GetFileTAR(*GetFileRequest, API_GetFileTARServer) error
	// InspectFile returns info about a file.
	InspectFile(context.Context, *InspectFileRequest) (*FileInfo, error)
	// ListFile returns info about all files.
	ListFile(*ListFileRequest, API_ListFileServer) error
	// WalkFile walks over all the files under a directory, including children of children.
	WalkFile(*WalkFileRequest, API_WalkFileServer) error
	// GlobFile returns info about all files.
	GlobFile(*GlobFileRequest, API_GlobFileServer) error
	// DiffFile returns the differences between 2 paths at 2 commits.
	DiffFile(*DiffFileRequest, API_DiffFileServer) error
	// ActivateAuth creates a role binding for all existing repos
	ActivateAuth(context.Context, *ActivateAuthRequest) (*ActivateAuthResponse, error)
	// DeleteAll deletes everything.
	DeleteAll(context.Context, *types.Empty) (*types.Empty, error)
	// Fsck does a file system consistency check for pfs.
	Fsck(*FsckRequest, API_FsckServer) error
	// FileSet API
	// CreateFileSet creates a new file set.
	CreateFileSet(API_CreateFileSetServer) error
	// GetFileSet returns a file set with the data from a commit
	GetFileSet(context.Context, *GetFileSetRequest) (*CreateFileSetResponse, error)
	// AddFileSet associates a file set with a commit
	AddFileSet(context.Context, *AddFileSetRequest) (*types.Empty, error)
	// RenewFileSet prevents a file set from being deleted for a set amount of time.
	RenewFileSet(context.Context, *RenewFileSetRequest) (*types.Empty, error)
	// ComposeFileSet composes a file set from a list of file sets.
	ComposeFileSet(context.Context, *ComposeFileSetRequest) (*CreateFileSetResponse, error)
	ShardFileSet(context.Context, *ShardFileSetRequest) (*ShardFileSetResponse, error)
	// CheckStorage runs integrity checks for the storage layer.
	CheckStorage(context.Context, *CheckStorageRequest) (*CheckStorageResponse, error)
	PutCache(context.Context, *PutCacheRequest) (*types.Empty, error)
	GetCache(context.Context, *GetCacheRequest) (*GetCacheResponse, error)
	ClearCache(context.Context, *ClearCacheRequest) (*types.Empty, error)
	// RunLoadTest runs a load test.
	RunLoadTest(context.Context, *RunLoadTestRequest) (*RunLoadTestResponse, error)
	// RunLoadTestDefault runs the default load tests.
	RunLoadTestDefault(context.Context, *types.Empty) (*RunLoadTestResponse, error)
	// ListTask lists PFS tasks
	ListTask(*task.ListTaskRequest, API_ListTaskServer) error
	// Egress writes data from a commit to an external system
	Egress(context.Context, *EgressRequest) (*EgressResponse, error)
	// Project API
	// CreateProject creates a new project.
	CreateProject(context.Context, *CreateProjectRequest) (*types.Empty, error)
	// InspectProject returns info about a project.
	InspectProject(context.Context, *InspectProjectRequest) (*ProjectInfo, error)
	// ListProject returns info about all projects.
	ListProject(*ListProjectRequest, API_ListProjectServer) error
	// DeleteProject deletes a project.
	DeleteProject(context.Context, *DeleteProjectRequest) (*types.Empty, error)
}

APIServer is the server API for API service.

type API_CreateFileSetClient 

type API_CreateFileSetClient interface {
	Send(*ModifyFileRequest) error
	CloseAndRecv() (*CreateFileSetResponse, error)
	grpc.ClientStream
}

type API_CreateFileSetServer 

type API_CreateFileSetServer interface {
	SendAndClose(*CreateFileSetResponse) error
	Recv() (*ModifyFileRequest, error)
	grpc.ServerStream
}

type API_DiffFileClient 

type API_DiffFileClient interface {
	Recv() (*DiffFileResponse, error)
	grpc.ClientStream
}

type API_DiffFileServer 

type API_DiffFileServer interface {
	Send(*DiffFileResponse) error
	grpc.ServerStream
}

type API_FindCommitsClient 

type API_FindCommitsClient interface {
	Recv() (*FindCommitsResponse, error)
	grpc.ClientStream
}

type API_FindCommitsServer 

type API_FindCommitsServer interface {
	Send(*FindCommitsResponse) error
	grpc.ServerStream
}

type API_FsckClient 

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

type API_FsckServer 

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

type API_GetFileClient 

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

type API_GetFileServer 

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

type API_GetFileTARClient 

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

type API_GetFileTARServer 

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

type API_GlobFileClient 

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

type API_GlobFileServer 

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

type API_InspectCommitSetClient 

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

type API_InspectCommitSetServer 

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

type API_ListBranchClient 

type API_ListBranchClient interface {
	Recv() (*BranchInfo, error)
	grpc.ClientStream
}

type API_ListBranchServer 

type API_ListBranchServer interface {
	Send(*BranchInfo) error
	grpc.ServerStream
}

type API_ListCommitClient 

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

type API_ListCommitServer 

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

type API_ListCommitSetClient 

type API_ListCommitSetClient interface {
	Recv() (*CommitSetInfo, error)
	grpc.ClientStream
}

type API_ListCommitSetServer 

type API_ListCommitSetServer interface {
	Send(*CommitSetInfo) error
	grpc.ServerStream
}

type API_ListFileClient 

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

type API_ListFileServer 

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

type API_ListProjectClient 

type API_ListProjectClient interface {
	Recv() (*ProjectInfo, error)
	grpc.ClientStream
}

type API_ListProjectServer 

type API_ListProjectServer interface {
	Send(*ProjectInfo) error
	grpc.ServerStream
}

type API_ListRepoClient 

type API_ListRepoClient interface {
	Recv() (*RepoInfo, error)
	grpc.ClientStream
}

type API_ListRepoServer 

type API_ListRepoServer interface {
	Send(*RepoInfo) error
	grpc.ServerStream
}

type API_ListTaskClient 

type API_ListTaskClient interface {
	Recv() (*task.TaskInfo, error)
	grpc.ClientStream
}

type API_ListTaskServer 

type API_ListTaskServer interface {
	Send(*task.TaskInfo) error
	grpc.ServerStream
}

type API_ModifyFileClient 

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

type API_ModifyFileServer 

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

type API_SubscribeCommitClient 

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

type API_SubscribeCommitServer 

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

type API_WalkFileClient 

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

type API_WalkFileServer 

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

type ActivateAuthRequest 

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

func (*ActivateAuthRequest) Descriptor 

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

func (*ActivateAuthRequest) Marshal 

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

func (*ActivateAuthRequest) MarshalLogObject 

func (x *ActivateAuthRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ActivateAuthRequest) MarshalTo 

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

func (*ActivateAuthRequest) MarshalToSizedBuffer 

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

func (*ActivateAuthRequest) ProtoMessage 

func (*ActivateAuthRequest) ProtoMessage()

func (*ActivateAuthRequest) Reset 

func (m *ActivateAuthRequest) Reset()

func (*ActivateAuthRequest) Size 

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

func (*ActivateAuthRequest) String 

func (m *ActivateAuthRequest) String() string

func (*ActivateAuthRequest) Unmarshal 

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

func (*ActivateAuthRequest) XXX_DiscardUnknown 

func (m *ActivateAuthRequest) XXX_DiscardUnknown()

func (*ActivateAuthRequest) XXX_Marshal 

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

func (*ActivateAuthRequest) XXX_Merge 

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

func (*ActivateAuthRequest) XXX_Size 

func (m *ActivateAuthRequest) XXX_Size() int

func (*ActivateAuthRequest) XXX_Unmarshal 

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

type ActivateAuthResponse 

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

func (*ActivateAuthResponse) Descriptor 

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

func (*ActivateAuthResponse) Marshal 

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

func (*ActivateAuthResponse) MarshalLogObject 

func (x *ActivateAuthResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ActivateAuthResponse) MarshalTo 

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

func (*ActivateAuthResponse) MarshalToSizedBuffer 

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

func (*ActivateAuthResponse) ProtoMessage 

func (*ActivateAuthResponse) ProtoMessage()

func (*ActivateAuthResponse) Reset 

func (m *ActivateAuthResponse) Reset()

func (*ActivateAuthResponse) Size 

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

func (*ActivateAuthResponse) String 

func (m *ActivateAuthResponse) String() string

func (*ActivateAuthResponse) Unmarshal 

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

func (*ActivateAuthResponse) XXX_DiscardUnknown 

func (m *ActivateAuthResponse) XXX_DiscardUnknown()

func (*ActivateAuthResponse) XXX_Marshal 

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

func (*ActivateAuthResponse) XXX_Merge 

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

func (*ActivateAuthResponse) XXX_Size 

func (m *ActivateAuthResponse) XXX_Size() int

func (*ActivateAuthResponse) XXX_Unmarshal 

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

type AddFile 

type AddFile struct {
	Path  string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Datum string `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"`
	// Types that are valid to be assigned to Source:
	//
	//	*AddFile_Raw
	//	*AddFile_Url
	Source               isAddFile_Source `protobuf_oneof:"source"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*AddFile) Descriptor 

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

func (*AddFile) GetDatum 

func (m *AddFile) GetDatum() string

func (*AddFile) GetPath 

func (m *AddFile) GetPath() string

func (*AddFile) GetRaw 

func (m *AddFile) GetRaw() *types.BytesValue

func (*AddFile) GetSource 

func (m *AddFile) GetSource() isAddFile_Source

func (*AddFile) GetUrl 

func (m *AddFile) GetUrl() *AddFile_URLSource

func (*AddFile) Marshal 

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

func (*AddFile) MarshalLogObject 

func (x *AddFile) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AddFile) MarshalTo 

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

func (*AddFile) MarshalToSizedBuffer 

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

func (*AddFile) ProtoMessage 

func (*AddFile) ProtoMessage()

func (*AddFile) Reset 

func (m *AddFile) Reset()

func (*AddFile) Size 

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

func (*AddFile) String 

func (m *AddFile) String() string

func (*AddFile) Unmarshal 

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

func (*AddFile) XXX_DiscardUnknown 

func (m *AddFile) XXX_DiscardUnknown()

func (*AddFile) XXX_Marshal 

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

func (*AddFile) XXX_Merge 

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

func (*AddFile) XXX_OneofWrappers 

func (*AddFile) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AddFile) XXX_Size 

func (m *AddFile) XXX_Size() int

func (*AddFile) XXX_Unmarshal 

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

type AddFileSetRequest 

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

func (*AddFileSetRequest) Descriptor 

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

func (*AddFileSetRequest) GetCommit 

func (m *AddFileSetRequest) GetCommit() *Commit

func (*AddFileSetRequest) GetFileSetId 

func (m *AddFileSetRequest) GetFileSetId() string

func (*AddFileSetRequest) Marshal 

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

func (*AddFileSetRequest) MarshalLogObject 

func (x *AddFileSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AddFileSetRequest) MarshalTo 

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

func (*AddFileSetRequest) MarshalToSizedBuffer 

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

func (*AddFileSetRequest) ProtoMessage 

func (*AddFileSetRequest) ProtoMessage()

func (*AddFileSetRequest) Reset 

func (m *AddFileSetRequest) Reset()

func (*AddFileSetRequest) Size 

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

func (*AddFileSetRequest) String 

func (m *AddFileSetRequest) String() string

func (*AddFileSetRequest) Unmarshal 

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

func (*AddFileSetRequest) XXX_DiscardUnknown 

func (m *AddFileSetRequest) XXX_DiscardUnknown()

func (*AddFileSetRequest) XXX_Marshal 

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

func (*AddFileSetRequest) XXX_Merge 

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

func (*AddFileSetRequest) XXX_Size 

func (m *AddFileSetRequest) XXX_Size() int

func (*AddFileSetRequest) XXX_Unmarshal 

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

type AddFile_Raw 

type AddFile_Raw struct {
	Raw *types.BytesValue `protobuf:"bytes,3,opt,name=raw,proto3,oneof" json:"raw,omitempty"`
}

func (*AddFile_Raw) MarshalTo 

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

func (*AddFile_Raw) MarshalToSizedBuffer 

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

func (*AddFile_Raw) Size 

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

type AddFile_URLSource 

type AddFile_URLSource struct {
	URL                  string   `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
	Recursive            bool     `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	Concurrency          uint32   `protobuf:"varint,3,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddFile_URLSource) Descriptor 

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

func (*AddFile_URLSource) GetConcurrency 

func (m *AddFile_URLSource) GetConcurrency() uint32

func (*AddFile_URLSource) GetRecursive 

func (m *AddFile_URLSource) GetRecursive() bool

func (*AddFile_URLSource) GetURL 

func (m *AddFile_URLSource) GetURL() string

func (*AddFile_URLSource) Marshal 

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

func (*AddFile_URLSource) MarshalLogObject 

func (x *AddFile_URLSource) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AddFile_URLSource) MarshalTo 

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

func (*AddFile_URLSource) MarshalToSizedBuffer 

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

func (*AddFile_URLSource) ProtoMessage 

func (*AddFile_URLSource) ProtoMessage()

func (*AddFile_URLSource) Reset 

func (m *AddFile_URLSource) Reset()

func (*AddFile_URLSource) Size 

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

func (*AddFile_URLSource) String 

func (m *AddFile_URLSource) String() string

func (*AddFile_URLSource) Unmarshal 

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

func (*AddFile_URLSource) XXX_DiscardUnknown 

func (m *AddFile_URLSource) XXX_DiscardUnknown()

func (*AddFile_URLSource) XXX_Marshal 

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

func (*AddFile_URLSource) XXX_Merge 

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

func (*AddFile_URLSource) XXX_Size 

func (m *AddFile_URLSource) XXX_Size() int

func (*AddFile_URLSource) XXX_Unmarshal 

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

type AddFile_Url 

type AddFile_Url struct {
	Url *AddFile_URLSource `protobuf:"bytes,4,opt,name=url,proto3,oneof" json:"url,omitempty"`
}

func (*AddFile_Url) MarshalTo 

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

func (*AddFile_Url) MarshalToSizedBuffer 

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

func (*AddFile_Url) Size 

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

type AuthInfo 

type AuthInfo struct {
	// The callers access level to the relevant resource. These are very granular
	// permissions - for the end user it makes sense to show them the roles
	// they have instead.
	Permissions []auth.Permission `protobuf:"varint,1,rep,packed,name=permissions,proto3,enum=auth_v2.Permission" json:"permissions,omitempty"`
	// The caller's roles on the relevant resource. This includes inherited
	// roles from the cluster, project, group membership, etc.
	Roles                []string `protobuf:"bytes,2,rep,name=roles,proto3" json:"roles,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*AuthInfo) Descriptor 

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

func (*AuthInfo) GetPermissions 

func (m *AuthInfo) GetPermissions() []auth.Permission

func (*AuthInfo) GetRoles 

func (m *AuthInfo) GetRoles() []string

func (*AuthInfo) Marshal 

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

func (*AuthInfo) MarshalLogObject 

func (x *AuthInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AuthInfo) MarshalTo 

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

func (*AuthInfo) MarshalToSizedBuffer 

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

func (*AuthInfo) ProtoMessage 

func (*AuthInfo) ProtoMessage()

func (*AuthInfo) Reset 

func (m *AuthInfo) Reset()

func (*AuthInfo) Size 

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

func (*AuthInfo) String 

func (m *AuthInfo) String() string

func (*AuthInfo) Unmarshal 

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

func (*AuthInfo) XXX_DiscardUnknown 

func (m *AuthInfo) XXX_DiscardUnknown()

func (*AuthInfo) XXX_Marshal 

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

func (*AuthInfo) XXX_Merge 

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

func (*AuthInfo) XXX_Size 

func (m *AuthInfo) XXX_Size() int

func (*AuthInfo) XXX_Unmarshal 

func (m *AuthInfo) 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) MarshalLogObject 

func (x *Branch) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Branch) MarshalTo 

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

func (*Branch) MarshalToSizedBuffer 

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

func (*Branch) NewCommit 

func (b *Branch) NewCommit(id string) *Commit

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 (b *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,1,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,4,rep,name=subvenance,proto3" json:"subvenance,omitempty"`
	DirectProvenance     []*Branch `protobuf:"bytes,5,rep,name=direct_provenance,json=directProvenance,proto3" json:"direct_provenance,omitempty"`
	Trigger              *Trigger  `protobuf:"bytes,6,opt,name=trigger,proto3" json:"trigger,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) GetProvenance 

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

func (*BranchInfo) GetSubvenance 

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

func (*BranchInfo) GetTrigger 

func (m *BranchInfo) GetTrigger() *Trigger

func (*BranchInfo) Marshal 

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

func (*BranchInfo) MarshalLogObject 

func (x *BranchInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*BranchInfo) MarshalTo 

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

func (*BranchInfo) MarshalToSizedBuffer 

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

func (*BranchInfo) ProtoMessage 

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) Reset 

func (m *BranchInfo) Reset()

func (*BranchInfo) Size 

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

func (*BranchInfo) String 

func (m *BranchInfo) String() string

func (*BranchInfo) Unmarshal 

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

func (*BranchInfo) XXX_DiscardUnknown 

func (m *BranchInfo) XXX_DiscardUnknown()

func (*BranchInfo) XXX_Marshal 

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

func (*BranchInfo) XXX_Merge 

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

func (*BranchInfo) XXX_Size 

func (m *BranchInfo) XXX_Size() int

func (*BranchInfo) XXX_Unmarshal 

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

type CheckStorageRequest 

type CheckStorageRequest struct {
	ReadChunkData        bool     `protobuf:"varint,1,opt,name=read_chunk_data,json=readChunkData,proto3" json:"read_chunk_data,omitempty"`
	ChunkBegin           []byte   `protobuf:"bytes,2,opt,name=chunk_begin,json=chunkBegin,proto3" json:"chunk_begin,omitempty"`
	ChunkEnd             []byte   `protobuf:"bytes,3,opt,name=chunk_end,json=chunkEnd,proto3" json:"chunk_end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckStorageRequest) Descriptor 

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

func (*CheckStorageRequest) GetChunkBegin 

func (m *CheckStorageRequest) GetChunkBegin() []byte

func (*CheckStorageRequest) GetChunkEnd 

func (m *CheckStorageRequest) GetChunkEnd() []byte

func (*CheckStorageRequest) GetReadChunkData 

func (m *CheckStorageRequest) GetReadChunkData() bool

func (*CheckStorageRequest) Marshal 

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

func (*CheckStorageRequest) MarshalLogObject 

func (x *CheckStorageRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CheckStorageRequest) MarshalTo 

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

func (*CheckStorageRequest) MarshalToSizedBuffer 

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

func (*CheckStorageRequest) ProtoMessage 

func (*CheckStorageRequest) ProtoMessage()

func (*CheckStorageRequest) Reset 

func (m *CheckStorageRequest) Reset()

func (*CheckStorageRequest) Size 

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

func (*CheckStorageRequest) String 

func (m *CheckStorageRequest) String() string

func (*CheckStorageRequest) Unmarshal 

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

func (*CheckStorageRequest) XXX_DiscardUnknown 

func (m *CheckStorageRequest) XXX_DiscardUnknown()

func (*CheckStorageRequest) XXX_Marshal 

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

func (*CheckStorageRequest) XXX_Merge 

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

func (*CheckStorageRequest) XXX_Size 

func (m *CheckStorageRequest) XXX_Size() int

func (*CheckStorageRequest) XXX_Unmarshal 

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

type CheckStorageResponse 

type CheckStorageResponse struct {
	ChunkObjectCount     int64    `protobuf:"varint,1,opt,name=chunk_object_count,json=chunkObjectCount,proto3" json:"chunk_object_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckStorageResponse) Descriptor 

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

func (*CheckStorageResponse) GetChunkObjectCount 

func (m *CheckStorageResponse) GetChunkObjectCount() int64

func (*CheckStorageResponse) Marshal 

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

func (*CheckStorageResponse) MarshalLogObject 

func (x *CheckStorageResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CheckStorageResponse) MarshalTo 

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

func (*CheckStorageResponse) MarshalToSizedBuffer 

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

func (*CheckStorageResponse) ProtoMessage 

func (*CheckStorageResponse) ProtoMessage()

func (*CheckStorageResponse) Reset 

func (m *CheckStorageResponse) Reset()

func (*CheckStorageResponse) Size 

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

func (*CheckStorageResponse) String 

func (m *CheckStorageResponse) String() string

func (*CheckStorageResponse) Unmarshal 

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

func (*CheckStorageResponse) XXX_DiscardUnknown 

func (m *CheckStorageResponse) XXX_DiscardUnknown()

func (*CheckStorageResponse) XXX_Marshal 

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

func (*CheckStorageResponse) XXX_Merge 

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

func (*CheckStorageResponse) XXX_Size 

func (m *CheckStorageResponse) XXX_Size() int

func (*CheckStorageResponse) XXX_Unmarshal 

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

type ClearCacheRequest 

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

func (*ClearCacheRequest) Descriptor 

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

func (*ClearCacheRequest) GetTagPrefix 

func (m *ClearCacheRequest) GetTagPrefix() string

func (*ClearCacheRequest) Marshal 

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

func (*ClearCacheRequest) MarshalLogObject 

func (x *ClearCacheRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ClearCacheRequest) MarshalTo 

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

func (*ClearCacheRequest) MarshalToSizedBuffer 

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

func (*ClearCacheRequest) ProtoMessage 

func (*ClearCacheRequest) ProtoMessage()

func (*ClearCacheRequest) Reset 

func (m *ClearCacheRequest) Reset()

func (*ClearCacheRequest) Size 

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

func (*ClearCacheRequest) String 

func (m *ClearCacheRequest) String() string

func (*ClearCacheRequest) Unmarshal 

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

func (*ClearCacheRequest) XXX_DiscardUnknown 

func (m *ClearCacheRequest) XXX_DiscardUnknown()

func (*ClearCacheRequest) XXX_Marshal 

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

func (*ClearCacheRequest) XXX_Merge 

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

func (*ClearCacheRequest) XXX_Size 

func (m *ClearCacheRequest) XXX_Size() int

func (*ClearCacheRequest) XXX_Unmarshal 

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

type ClearCommitRequest 

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

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

func (*ClearCommitRequest) GetCommit 

func (m *ClearCommitRequest) GetCommit() *Commit

func (*ClearCommitRequest) Marshal 

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

func (*ClearCommitRequest) MarshalLogObject 

func (x *ClearCommitRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ClearCommitRequest) MarshalTo 

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

func (*ClearCommitRequest) MarshalToSizedBuffer 

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

func (*ClearCommitRequest) ProtoMessage 

func (*ClearCommitRequest) ProtoMessage()

func (*ClearCommitRequest) Reset 

func (m *ClearCommitRequest) Reset()

func (*ClearCommitRequest) Size 

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

func (*ClearCommitRequest) String 

func (m *ClearCommitRequest) String() string

func (*ClearCommitRequest) Unmarshal 

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

func (*ClearCommitRequest) XXX_DiscardUnknown 

func (m *ClearCommitRequest) XXX_DiscardUnknown()

func (*ClearCommitRequest) XXX_Marshal 

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

func (*ClearCommitRequest) XXX_Merge 

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

func (*ClearCommitRequest) XXX_Size 

func (m *ClearCommitRequest) XXX_Size() int

func (*ClearCommitRequest) XXX_Unmarshal 

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

type Commit 

type Commit struct {
	Repo *Repo  `protobuf:"bytes,3,opt,name=repo,proto3" json:"repo,omitempty"`
	ID   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// only used by the client
	Branch               *Branch  `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,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) AccessRepo 

func (c *Commit) AccessRepo() *Repo

TODO(provenance): there's a concern client code will unknowningly call GetRepo() when it shouldn't

func (*Commit) Descriptor 

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

func (*Commit) GetBranch 

func (m *Commit) GetBranch() *Branch

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) MarshalLogObject 

func (x *Commit) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Commit) MarshalTo 

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

func (*Commit) MarshalToSizedBuffer 

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

func (*Commit) NewFile 

func (c *Commit) NewFile(path string) *File

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 (c *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"`
	Origin *CommitOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// description is a user-provided script describing this commit
	Description          string              `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	ParentCommit         *Commit             `protobuf:"bytes,4,opt,name=parent_commit,json=parentCommit,proto3" json:"parent_commit,omitempty"`
	ChildCommits         []*Commit           `protobuf:"bytes,5,rep,name=child_commits,json=childCommits,proto3" json:"child_commits,omitempty"`
	Started              *types.Timestamp    `protobuf:"bytes,6,opt,name=started,proto3" json:"started,omitempty"`
	Finishing            *types.Timestamp    `protobuf:"bytes,7,opt,name=finishing,proto3" json:"finishing,omitempty"`
	Finished             *types.Timestamp    `protobuf:"bytes,8,opt,name=finished,proto3" json:"finished,omitempty"`
	DirectProvenance     []*Commit           `protobuf:"bytes,13,rep,name=direct_provenance,json=directProvenance,proto3" json:"direct_provenance,omitempty"`
	Error                string              `protobuf:"bytes,10,opt,name=error,proto3" json:"error,omitempty"`
	SizeBytesUpperBound  int64               `protobuf:"varint,11,opt,name=size_bytes_upper_bound,json=sizeBytesUpperBound,proto3" json:"size_bytes_upper_bound,omitempty"`
	Details              *CommitInfo_Details `protobuf:"bytes,12,opt,name=details,proto3" json:"details,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) GetChildCommits 

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

func (*CommitInfo) GetCommit 

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetDescription 

func (m *CommitInfo) GetDescription() string

func (*CommitInfo) GetDetails 

func (m *CommitInfo) GetDetails() *CommitInfo_Details

func (*CommitInfo) GetDirectProvenance 

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

func (*CommitInfo) GetError 

func (m *CommitInfo) GetError() string

func (*CommitInfo) GetFinished 

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

func (*CommitInfo) GetFinishing 

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

func (*CommitInfo) GetOrigin 

func (m *CommitInfo) GetOrigin() *CommitOrigin

func (*CommitInfo) GetParentCommit 

func (m *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetSizeBytesUpperBound 

func (m *CommitInfo) GetSizeBytesUpperBound() int64

func (*CommitInfo) GetStarted 

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

func (*CommitInfo) Marshal 

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

func (*CommitInfo) MarshalLogObject 

func (x *CommitInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CommitInfo) MarshalTo 

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

func (*CommitInfo) MarshalToSizedBuffer 

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

func (*CommitInfo) ProtoMessage 

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset 

func (m *CommitInfo) Reset()

func (*CommitInfo) Size 

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

func (*CommitInfo) String 

func (m *CommitInfo) String() string

func (*CommitInfo) Unmarshal 

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

func (*CommitInfo) XXX_DiscardUnknown 

func (m *CommitInfo) XXX_DiscardUnknown()

func (*CommitInfo) XXX_Marshal 

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

func (*CommitInfo) XXX_Merge 

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

func (*CommitInfo) XXX_Size 

func (m *CommitInfo) XXX_Size() int

func (*CommitInfo) XXX_Unmarshal 

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

type CommitInfo_Details 

type CommitInfo_Details struct {
	SizeBytes            int64           `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	CompactingTime       *types.Duration `protobuf:"bytes,2,opt,name=compacting_time,json=compactingTime,proto3" json:"compacting_time,omitempty"`
	ValidatingTime       *types.Duration `protobuf:"bytes,3,opt,name=validating_time,json=validatingTime,proto3" json:"validating_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Details are only provided when explicitly requested

func (*CommitInfo_Details) Descriptor 

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

func (*CommitInfo_Details) GetCompactingTime 

func (m *CommitInfo_Details) GetCompactingTime() *types.Duration

func (*CommitInfo_Details) GetSizeBytes 

func (m *CommitInfo_Details) GetSizeBytes() int64

func (*CommitInfo_Details) GetValidatingTime 

func (m *CommitInfo_Details) GetValidatingTime() *types.Duration

func (*CommitInfo_Details) Marshal 

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

func (*CommitInfo_Details) MarshalLogObject 

func (x *CommitInfo_Details) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CommitInfo_Details) MarshalTo 

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

func (*CommitInfo_Details) MarshalToSizedBuffer 

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

func (*CommitInfo_Details) ProtoMessage 

func (*CommitInfo_Details) ProtoMessage()

func (*CommitInfo_Details) Reset 

func (m *CommitInfo_Details) Reset()

func (*CommitInfo_Details) Size 

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

func (*CommitInfo_Details) String 

func (m *CommitInfo_Details) String() string

func (*CommitInfo_Details) Unmarshal 

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

func (*CommitInfo_Details) XXX_DiscardUnknown 

func (m *CommitInfo_Details) XXX_DiscardUnknown()

func (*CommitInfo_Details) XXX_Marshal 

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

func (*CommitInfo_Details) XXX_Merge 

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

func (*CommitInfo_Details) XXX_Size 

func (m *CommitInfo_Details) XXX_Size() int

func (*CommitInfo_Details) XXX_Unmarshal 

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

type CommitOrigin 

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

func (*CommitOrigin) Descriptor 

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

func (*CommitOrigin) GetKind 

func (m *CommitOrigin) GetKind() OriginKind

func (*CommitOrigin) Marshal 

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

func (*CommitOrigin) MarshalLogObject 

func (x *CommitOrigin) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CommitOrigin) MarshalTo 

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

func (*CommitOrigin) MarshalToSizedBuffer 

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

func (*CommitOrigin) ProtoMessage 

func (*CommitOrigin) ProtoMessage()

func (*CommitOrigin) Reset 

func (m *CommitOrigin) Reset()

func (*CommitOrigin) Size 

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

func (*CommitOrigin) String 

func (m *CommitOrigin) String() string

func (*CommitOrigin) Unmarshal 

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

func (*CommitOrigin) XXX_DiscardUnknown 

func (m *CommitOrigin) XXX_DiscardUnknown()

func (*CommitOrigin) XXX_Marshal 

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

func (*CommitOrigin) XXX_Merge 

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

func (*CommitOrigin) XXX_Size 

func (m *CommitOrigin) XXX_Size() int

func (*CommitOrigin) XXX_Unmarshal 

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

type CommitSet 

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

func (*CommitSet) Descriptor 

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

func (*CommitSet) GetID 

func (m *CommitSet) GetID() string

func (*CommitSet) Marshal 

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

func (*CommitSet) MarshalLogObject 

func (x *CommitSet) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CommitSet) MarshalTo 

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

func (*CommitSet) MarshalToSizedBuffer 

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

func (*CommitSet) ProtoMessage 

func (*CommitSet) ProtoMessage()

func (*CommitSet) Reset 

func (m *CommitSet) Reset()

func (*CommitSet) Size 

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

func (*CommitSet) String 

func (m *CommitSet) String() string

func (*CommitSet) Unmarshal 

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

func (*CommitSet) XXX_DiscardUnknown 

func (m *CommitSet) XXX_DiscardUnknown()

func (*CommitSet) XXX_Marshal 

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

func (*CommitSet) XXX_Merge 

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

func (*CommitSet) XXX_Size 

func (m *CommitSet) XXX_Size() int

func (*CommitSet) XXX_Unmarshal 

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

type CommitSetInfo 

type CommitSetInfo struct {
	CommitSet            *CommitSet    `protobuf:"bytes,1,opt,name=commit_set,json=commitSet,proto3" json:"commit_set,omitempty"`
	Commits              []*CommitInfo `protobuf:"bytes,2,rep,name=commits,proto3" json:"commits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CommitSetInfo) Descriptor 

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

func (*CommitSetInfo) GetCommitSet 

func (m *CommitSetInfo) GetCommitSet() *CommitSet

func (*CommitSetInfo) GetCommits 

func (m *CommitSetInfo) GetCommits() []*CommitInfo

func (*CommitSetInfo) Marshal 

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

func (*CommitSetInfo) MarshalLogObject 

func (x *CommitSetInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CommitSetInfo) MarshalTo 

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

func (*CommitSetInfo) MarshalToSizedBuffer 

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

func (*CommitSetInfo) ProtoMessage 

func (*CommitSetInfo) ProtoMessage()

func (*CommitSetInfo) Reset 

func (m *CommitSetInfo) Reset()

func (*CommitSetInfo) Size 

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

func (*CommitSetInfo) String 

func (m *CommitSetInfo) String() string

func (*CommitSetInfo) Unmarshal 

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

func (*CommitSetInfo) XXX_DiscardUnknown 

func (m *CommitSetInfo) XXX_DiscardUnknown()

func (*CommitSetInfo) XXX_Marshal 

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

func (*CommitSetInfo) XXX_Merge 

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

func (*CommitSetInfo) XXX_Size 

func (m *CommitSetInfo) XXX_Size() int

func (*CommitSetInfo) XXX_Unmarshal 

func (m *CommitSetInfo) 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_COMMIT_STATE_UNKNOWN CommitState = 0
	CommitState_STARTED              CommitState = 1
	CommitState_READY                CommitState = 2
	CommitState_FINISHING            CommitState = 3
	CommitState_FINISHED             CommitState = 4
)

func (CommitState) EnumDescriptor 

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

func (CommitState) String 

func (x CommitState) String() string

type ComposeFileSetRequest 

type ComposeFileSetRequest struct {
	FileSetIds           []string `protobuf:"bytes,1,rep,name=file_set_ids,json=fileSetIds,proto3" json:"file_set_ids,omitempty"`
	TtlSeconds           int64    `protobuf:"varint,2,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`
	Compact              bool     `protobuf:"varint,3,opt,name=compact,proto3" json:"compact,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ComposeFileSetRequest) Descriptor 

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

func (*ComposeFileSetRequest) GetCompact 

func (m *ComposeFileSetRequest) GetCompact() bool

func (*ComposeFileSetRequest) GetFileSetIds 

func (m *ComposeFileSetRequest) GetFileSetIds() []string

func (*ComposeFileSetRequest) GetTtlSeconds 

func (m *ComposeFileSetRequest) GetTtlSeconds() int64

func (*ComposeFileSetRequest) Marshal 

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

func (*ComposeFileSetRequest) MarshalLogObject 

func (x *ComposeFileSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ComposeFileSetRequest) MarshalTo 

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

func (*ComposeFileSetRequest) MarshalToSizedBuffer 

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

func (*ComposeFileSetRequest) ProtoMessage 

func (*ComposeFileSetRequest) ProtoMessage()

func (*ComposeFileSetRequest) Reset 

func (m *ComposeFileSetRequest) Reset()

func (*ComposeFileSetRequest) Size 

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

func (*ComposeFileSetRequest) String 

func (m *ComposeFileSetRequest) String() string

func (*ComposeFileSetRequest) Unmarshal 

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

func (*ComposeFileSetRequest) XXX_DiscardUnknown 

func (m *ComposeFileSetRequest) XXX_DiscardUnknown()

func (*ComposeFileSetRequest) XXX_Marshal 

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

func (*ComposeFileSetRequest) XXX_Merge 

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

func (*ComposeFileSetRequest) XXX_Size 

func (m *ComposeFileSetRequest) XXX_Size() int

func (*ComposeFileSetRequest) XXX_Unmarshal 

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

type CopyFile 

type CopyFile struct {
	Dst                  string   `protobuf:"bytes,1,opt,name=dst,proto3" json:"dst,omitempty"`
	Datum                string   `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"`
	Src                  *File    `protobuf:"bytes,3,opt,name=src,proto3" json:"src,omitempty"`
	Append               bool     `protobuf:"varint,4,opt,name=append,proto3" json:"append,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CopyFile) Descriptor 

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

func (*CopyFile) GetAppend 

func (m *CopyFile) GetAppend() bool

func (*CopyFile) GetDatum 

func (m *CopyFile) GetDatum() string

func (*CopyFile) GetDst 

func (m *CopyFile) GetDst() string

func (*CopyFile) GetSrc 

func (m *CopyFile) GetSrc() *File

func (*CopyFile) Marshal 

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

func (*CopyFile) MarshalLogObject 

func (x *CopyFile) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CopyFile) MarshalTo 

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

func (*CopyFile) MarshalToSizedBuffer 

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

func (*CopyFile) ProtoMessage 

func (*CopyFile) ProtoMessage()

func (*CopyFile) Reset 

func (m *CopyFile) Reset()

func (*CopyFile) Size 

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

func (*CopyFile) String 

func (m *CopyFile) String() string

func (*CopyFile) Unmarshal 

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

func (*CopyFile) XXX_DiscardUnknown 

func (m *CopyFile) XXX_DiscardUnknown()

func (*CopyFile) XXX_Marshal 

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

func (*CopyFile) XXX_Merge 

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

func (*CopyFile) XXX_Size 

func (m *CopyFile) XXX_Size() int

func (*CopyFile) XXX_Unmarshal 

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

type CreateBranchRequest 

type CreateBranchRequest struct {
	Head                 *Commit   `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Branch               *Branch   `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance           []*Branch `protobuf:"bytes,3,rep,name=provenance,proto3" json:"provenance,omitempty"`
	Trigger              *Trigger  `protobuf:"bytes,4,opt,name=trigger,proto3" json:"trigger,omitempty"`
	NewCommitSet         bool      `protobuf:"varint,5,opt,name=new_commit_set,json=newCommitSet,proto3" json:"new_commit_set,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) GetNewCommitSet 

func (m *CreateBranchRequest) GetNewCommitSet() bool

func (*CreateBranchRequest) GetProvenance 

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

func (*CreateBranchRequest) GetTrigger 

func (m *CreateBranchRequest) GetTrigger() *Trigger

func (*CreateBranchRequest) Marshal 

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

func (*CreateBranchRequest) MarshalLogObject 

func (x *CreateBranchRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CreateBranchRequest) MarshalTo 

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

func (*CreateBranchRequest) MarshalToSizedBuffer 

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

func (*CreateBranchRequest) ProtoMessage 

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) Reset 

func (m *CreateBranchRequest) Reset()

func (*CreateBranchRequest) Size 

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

func (*CreateBranchRequest) String 

func (m *CreateBranchRequest) String() string

func (*CreateBranchRequest) Unmarshal 

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

func (*CreateBranchRequest) XXX_DiscardUnknown 

func (m *CreateBranchRequest) XXX_DiscardUnknown()

func (*CreateBranchRequest) XXX_Marshal 

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

func (*CreateBranchRequest) XXX_Merge 

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

func (*CreateBranchRequest) XXX_Size 

func (m *CreateBranchRequest) XXX_Size() int

func (*CreateBranchRequest) XXX_Unmarshal 

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

type CreateFileSetResponse 

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

func (*CreateFileSetResponse) Descriptor 

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

func (*CreateFileSetResponse) GetFileSetId 

func (m *CreateFileSetResponse) GetFileSetId() string

func (*CreateFileSetResponse) Marshal 

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

func (*CreateFileSetResponse) MarshalLogObject 

func (x *CreateFileSetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CreateFileSetResponse) MarshalTo 

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

func (*CreateFileSetResponse) MarshalToSizedBuffer 

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

func (*CreateFileSetResponse) ProtoMessage 

func (*CreateFileSetResponse) ProtoMessage()

func (*CreateFileSetResponse) Reset 

func (m *CreateFileSetResponse) Reset()

func (*CreateFileSetResponse) Size 

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

func (*CreateFileSetResponse) String 

func (m *CreateFileSetResponse) String() string

func (*CreateFileSetResponse) Unmarshal 

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

func (*CreateFileSetResponse) XXX_DiscardUnknown 

func (m *CreateFileSetResponse) XXX_DiscardUnknown()

func (*CreateFileSetResponse) XXX_Marshal 

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

func (*CreateFileSetResponse) XXX_Merge 

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

func (*CreateFileSetResponse) XXX_Size 

func (m *CreateFileSetResponse) XXX_Size() int

func (*CreateFileSetResponse) XXX_Unmarshal 

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

type CreateProjectRequest 

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

func (*CreateProjectRequest) Descriptor 

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

func (*CreateProjectRequest) GetDescription 

func (m *CreateProjectRequest) GetDescription() string

func (*CreateProjectRequest) GetProject 

func (m *CreateProjectRequest) GetProject() *Project

func (*CreateProjectRequest) GetUpdate 

func (m *CreateProjectRequest) GetUpdate() bool

func (*CreateProjectRequest) Marshal 

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

func (*CreateProjectRequest) MarshalLogObject 

func (x *CreateProjectRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CreateProjectRequest) MarshalTo 

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

func (*CreateProjectRequest) MarshalToSizedBuffer 

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

func (*CreateProjectRequest) ProtoMessage 

func (*CreateProjectRequest) ProtoMessage()

func (*CreateProjectRequest) Reset 

func (m *CreateProjectRequest) Reset()

func (*CreateProjectRequest) Size 

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

func (*CreateProjectRequest) String 

func (m *CreateProjectRequest) String() string

func (*CreateProjectRequest) Unmarshal 

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

func (*CreateProjectRequest) XXX_DiscardUnknown 

func (m *CreateProjectRequest) XXX_DiscardUnknown()

func (*CreateProjectRequest) XXX_Marshal 

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

func (*CreateProjectRequest) XXX_Merge 

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

func (*CreateProjectRequest) XXX_Size 

func (m *CreateProjectRequest) XXX_Size() int

func (*CreateProjectRequest) XXX_Unmarshal 

func (m *CreateProjectRequest) 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,2,opt,name=description,proto3" json:"description,omitempty"`
	Update               bool     `protobuf:"varint,3,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) MarshalLogObject 

func (x *CreateRepoRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CreateRepoRequest) MarshalTo 

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

func (*CreateRepoRequest) MarshalToSizedBuffer 

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

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset 

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) Size 

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

func (*CreateRepoRequest) String 

func (m *CreateRepoRequest) String() string

func (*CreateRepoRequest) Unmarshal 

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

func (*CreateRepoRequest) XXX_DiscardUnknown 

func (m *CreateRepoRequest) XXX_DiscardUnknown()

func (*CreateRepoRequest) XXX_Marshal 

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

func (*CreateRepoRequest) XXX_Merge 

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

func (*CreateRepoRequest) XXX_Size 

func (m *CreateRepoRequest) XXX_Size() int

func (*CreateRepoRequest) XXX_Unmarshal 

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

type DeleteBranchRequest 

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

func (*DeleteBranchRequest) Descriptor 

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

func (*DeleteBranchRequest) GetBranch 

func (m *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) GetForce 

func (m *DeleteBranchRequest) GetForce() bool

func (*DeleteBranchRequest) Marshal 

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

func (*DeleteBranchRequest) MarshalLogObject 

func (x *DeleteBranchRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteBranchRequest) MarshalTo 

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

func (*DeleteBranchRequest) MarshalToSizedBuffer 

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

func (*DeleteBranchRequest) ProtoMessage 

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset 

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) Size 

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

func (*DeleteBranchRequest) String 

func (m *DeleteBranchRequest) String() string

func (*DeleteBranchRequest) Unmarshal 

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

func (*DeleteBranchRequest) XXX_DiscardUnknown 

func (m *DeleteBranchRequest) XXX_DiscardUnknown()

func (*DeleteBranchRequest) XXX_Marshal 

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

func (*DeleteBranchRequest) XXX_Merge 

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

func (*DeleteBranchRequest) XXX_Size 

func (m *DeleteBranchRequest) XXX_Size() int

func (*DeleteBranchRequest) XXX_Unmarshal 

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

type DeleteFile 

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

func (*DeleteFile) Descriptor 

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

func (*DeleteFile) GetDatum 

func (m *DeleteFile) GetDatum() string

func (*DeleteFile) GetPath 

func (m *DeleteFile) GetPath() string

func (*DeleteFile) Marshal 

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

func (*DeleteFile) MarshalLogObject 

func (x *DeleteFile) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteFile) MarshalTo 

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

func (*DeleteFile) MarshalToSizedBuffer 

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

func (*DeleteFile) ProtoMessage 

func (*DeleteFile) ProtoMessage()

func (*DeleteFile) Reset 

func (m *DeleteFile) Reset()

func (*DeleteFile) Size 

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

func (*DeleteFile) String 

func (m *DeleteFile) String() string

func (*DeleteFile) Unmarshal 

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

func (*DeleteFile) XXX_DiscardUnknown 

func (m *DeleteFile) XXX_DiscardUnknown()

func (*DeleteFile) XXX_Marshal 

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

func (*DeleteFile) XXX_Merge 

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

func (*DeleteFile) XXX_Size 

func (m *DeleteFile) XXX_Size() int

func (*DeleteFile) XXX_Unmarshal 

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

type DeleteProjectRequest 

type DeleteProjectRequest struct {
	Project              *Project `protobuf:"bytes,1,opt,name=project,proto3" json:"project,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 (*DeleteProjectRequest) Descriptor 

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

func (*DeleteProjectRequest) GetForce 

func (m *DeleteProjectRequest) GetForce() bool

func (*DeleteProjectRequest) GetProject 

func (m *DeleteProjectRequest) GetProject() *Project

func (*DeleteProjectRequest) Marshal 

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

func (*DeleteProjectRequest) MarshalLogObject 

func (x *DeleteProjectRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteProjectRequest) MarshalTo 

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

func (*DeleteProjectRequest) MarshalToSizedBuffer 

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

func (*DeleteProjectRequest) ProtoMessage 

func (*DeleteProjectRequest) ProtoMessage()

func (*DeleteProjectRequest) Reset 

func (m *DeleteProjectRequest) Reset()

func (*DeleteProjectRequest) Size 

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

func (*DeleteProjectRequest) String 

func (m *DeleteProjectRequest) String() string

func (*DeleteProjectRequest) Unmarshal 

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

func (*DeleteProjectRequest) XXX_DiscardUnknown 

func (m *DeleteProjectRequest) XXX_DiscardUnknown()

func (*DeleteProjectRequest) XXX_Marshal 

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

func (*DeleteProjectRequest) XXX_Merge 

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

func (*DeleteProjectRequest) XXX_Size 

func (m *DeleteProjectRequest) XXX_Size() int

func (*DeleteProjectRequest) XXX_Unmarshal 

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

func (*DeleteRepoRequest) Descriptor 

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

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) MarshalLogObject 

func (x *DeleteRepoRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteRepoRequest) MarshalTo 

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

func (*DeleteRepoRequest) MarshalToSizedBuffer 

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

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset 

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) Size 

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

func (*DeleteRepoRequest) String 

func (m *DeleteRepoRequest) String() string

func (*DeleteRepoRequest) Unmarshal 

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

func (*DeleteRepoRequest) XXX_DiscardUnknown 

func (m *DeleteRepoRequest) XXX_DiscardUnknown()

func (*DeleteRepoRequest) XXX_Marshal 

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

func (*DeleteRepoRequest) XXX_Merge 

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

func (*DeleteRepoRequest) XXX_Size 

func (m *DeleteRepoRequest) XXX_Size() int

func (*DeleteRepoRequest) XXX_Unmarshal 

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

type DeleteReposRequest 

type DeleteReposRequest struct {
	// All repos in each project will be deleted if the caller has
	// permission.
	Projects []*Project `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	Force    bool       `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// If all is set, then all repos in all projects will be deleted if the caller
	// has permission.
	All                  bool     `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeleteReposRequest is used to delete more than one repo at once.

func (*DeleteReposRequest) Descriptor 

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

func (*DeleteReposRequest) GetAll 

func (m *DeleteReposRequest) GetAll() bool

func (*DeleteReposRequest) GetForce 

func (m *DeleteReposRequest) GetForce() bool

func (*DeleteReposRequest) GetProjects 

func (m *DeleteReposRequest) GetProjects() []*Project

func (*DeleteReposRequest) Marshal 

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

func (*DeleteReposRequest) MarshalLogObject 

func (x *DeleteReposRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteReposRequest) MarshalTo 

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

func (*DeleteReposRequest) MarshalToSizedBuffer 

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

func (*DeleteReposRequest) ProtoMessage 

func (*DeleteReposRequest) ProtoMessage()

func (*DeleteReposRequest) Reset 

func (m *DeleteReposRequest) Reset()

func (*DeleteReposRequest) Size 

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

func (*DeleteReposRequest) String 

func (m *DeleteReposRequest) String() string

func (*DeleteReposRequest) Unmarshal 

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

func (*DeleteReposRequest) XXX_DiscardUnknown 

func (m *DeleteReposRequest) XXX_DiscardUnknown()

func (*DeleteReposRequest) XXX_Marshal 

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

func (*DeleteReposRequest) XXX_Merge 

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

func (*DeleteReposRequest) XXX_Size 

func (m *DeleteReposRequest) XXX_Size() int

func (*DeleteReposRequest) XXX_Unmarshal 

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

type DeleteReposResponse 

type DeleteReposResponse struct {
	Repos                []*Repo  `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteReposResponse) Descriptor 

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

func (*DeleteReposResponse) GetRepos 

func (m *DeleteReposResponse) GetRepos() []*Repo

func (*DeleteReposResponse) Marshal 

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

func (*DeleteReposResponse) MarshalLogObject 

func (x *DeleteReposResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteReposResponse) MarshalTo 

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

func (*DeleteReposResponse) MarshalToSizedBuffer 

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

func (*DeleteReposResponse) ProtoMessage 

func (*DeleteReposResponse) ProtoMessage()

func (*DeleteReposResponse) Reset 

func (m *DeleteReposResponse) Reset()

func (*DeleteReposResponse) Size 

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

func (*DeleteReposResponse) String 

func (m *DeleteReposResponse) String() string

func (*DeleteReposResponse) Unmarshal 

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

func (*DeleteReposResponse) XXX_DiscardUnknown 

func (m *DeleteReposResponse) XXX_DiscardUnknown()

func (*DeleteReposResponse) XXX_Marshal 

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

func (*DeleteReposResponse) XXX_Merge 

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

func (*DeleteReposResponse) XXX_Size 

func (m *DeleteReposResponse) XXX_Size() int

func (*DeleteReposResponse) XXX_Unmarshal 

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

type Delimiter 

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

func (Delimiter) EnumDescriptor 

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

func (Delimiter) String 

func (x Delimiter) String() string

type DiffFileRequest 

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) MarshalLogObject 

func (x *DiffFileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DiffFileRequest) MarshalTo 

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

func (*DiffFileRequest) MarshalToSizedBuffer 

func (m *DiffFileRequest) MarshalToSizedBuffer(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 {
	NewFile              *FileInfo `protobuf:"bytes,1,opt,name=new_file,json=newFile,proto3" json:"new_file,omitempty"`
	OldFile              *FileInfo `protobuf:"bytes,2,opt,name=old_file,json=oldFile,proto3" json:"old_file,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DiffFileResponse) Descriptor 

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

func (*DiffFileResponse) GetNewFile 

func (m *DiffFileResponse) GetNewFile() *FileInfo

func (*DiffFileResponse) GetOldFile 

func (m *DiffFileResponse) GetOldFile() *FileInfo

func (*DiffFileResponse) Marshal 

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

func (*DiffFileResponse) MarshalLogObject 

func (x *DiffFileResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DiffFileResponse) MarshalTo 

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

func (*DiffFileResponse) MarshalToSizedBuffer 

func (m *DiffFileResponse) MarshalToSizedBuffer(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 DropCommitSetRequest 

type DropCommitSetRequest struct {
	CommitSet            *CommitSet `protobuf:"bytes,1,opt,name=commit_set,json=commitSet,proto3" json:"commit_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DropCommitSetRequest) Descriptor 

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

func (*DropCommitSetRequest) GetCommitSet 

func (m *DropCommitSetRequest) GetCommitSet() *CommitSet

func (*DropCommitSetRequest) Marshal 

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

func (*DropCommitSetRequest) MarshalLogObject 

func (x *DropCommitSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DropCommitSetRequest) MarshalTo 

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

func (*DropCommitSetRequest) MarshalToSizedBuffer 

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

func (*DropCommitSetRequest) ProtoMessage 

func (*DropCommitSetRequest) ProtoMessage()

func (*DropCommitSetRequest) Reset 

func (m *DropCommitSetRequest) Reset()

func (*DropCommitSetRequest) Size 

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

func (*DropCommitSetRequest) String 

func (m *DropCommitSetRequest) String() string

func (*DropCommitSetRequest) Unmarshal 

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

func (*DropCommitSetRequest) XXX_DiscardUnknown 

func (m *DropCommitSetRequest) XXX_DiscardUnknown()

func (*DropCommitSetRequest) XXX_Marshal 

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

func (*DropCommitSetRequest) XXX_Merge 

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

func (*DropCommitSetRequest) XXX_Size 

func (m *DropCommitSetRequest) XXX_Size() int

func (*DropCommitSetRequest) XXX_Unmarshal 

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

type EgressRequest 

type EgressRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// Types that are valid to be assigned to Target:
	//
	//	*EgressRequest_ObjectStorage
	//	*EgressRequest_SqlDatabase
	Target               isEgressRequest_Target `protobuf_oneof:"target"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*EgressRequest) Descriptor 

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

func (*EgressRequest) GetCommit 

func (m *EgressRequest) GetCommit() *Commit

func (*EgressRequest) GetObjectStorage 

func (m *EgressRequest) GetObjectStorage() *ObjectStorageEgress

func (*EgressRequest) GetSqlDatabase 

func (m *EgressRequest) GetSqlDatabase() *SQLDatabaseEgress

func (*EgressRequest) GetTarget 

func (m *EgressRequest) GetTarget() isEgressRequest_Target

func (*EgressRequest) Marshal 

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

func (*EgressRequest) MarshalLogObject 

func (x *EgressRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*EgressRequest) MarshalTo 

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

func (*EgressRequest) MarshalToSizedBuffer 

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

func (*EgressRequest) ProtoMessage 

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) Reset 

func (m *EgressRequest) Reset()

func (*EgressRequest) Size 

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

func (*EgressRequest) String 

func (m *EgressRequest) String() string

func (*EgressRequest) Unmarshal 

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

func (*EgressRequest) XXX_DiscardUnknown 

func (m *EgressRequest) XXX_DiscardUnknown()

func (*EgressRequest) XXX_Marshal 

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

func (*EgressRequest) XXX_Merge 

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

func (*EgressRequest) XXX_OneofWrappers 

func (*EgressRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EgressRequest) XXX_Size 

func (m *EgressRequest) XXX_Size() int

func (*EgressRequest) XXX_Unmarshal 

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

type EgressRequest_ObjectStorage 

type EgressRequest_ObjectStorage struct {
	ObjectStorage *ObjectStorageEgress `protobuf:"bytes,2,opt,name=object_storage,json=objectStorage,proto3,oneof" json:"object_storage,omitempty"`
}

func (*EgressRequest_ObjectStorage) MarshalTo 

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

func (*EgressRequest_ObjectStorage) MarshalToSizedBuffer 

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

func (*EgressRequest_ObjectStorage) Size 

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

type EgressRequest_SqlDatabase 

type EgressRequest_SqlDatabase struct {
	SqlDatabase *SQLDatabaseEgress `protobuf:"bytes,3,opt,name=sql_database,json=sqlDatabase,proto3,oneof" json:"sql_database,omitempty"`
}

func (*EgressRequest_SqlDatabase) MarshalTo 

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

func (*EgressRequest_SqlDatabase) MarshalToSizedBuffer 

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

func (*EgressRequest_SqlDatabase) Size 

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

type EgressResponse 

type EgressResponse struct {
	// Types that are valid to be assigned to Result:
	//
	//	*EgressResponse_ObjectStorage
	//	*EgressResponse_SqlDatabase
	Result               isEgressResponse_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*EgressResponse) Descriptor 

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

func (*EgressResponse) GetObjectStorage 

func (m *EgressResponse) GetObjectStorage() *EgressResponse_ObjectStorageResult

func (*EgressResponse) GetResult 

func (m *EgressResponse) GetResult() isEgressResponse_Result

func (*EgressResponse) GetSqlDatabase 

func (m *EgressResponse) GetSqlDatabase() *EgressResponse_SQLDatabaseResult

func (*EgressResponse) Marshal 

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

func (*EgressResponse) MarshalLogObject 

func (x *EgressResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*EgressResponse) MarshalTo 

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

func (*EgressResponse) MarshalToSizedBuffer 

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

func (*EgressResponse) ProtoMessage 

func (*EgressResponse) ProtoMessage()

func (*EgressResponse) Reset 

func (m *EgressResponse) Reset()

func (*EgressResponse) Size 

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

func (*EgressResponse) String 

func (m *EgressResponse) String() string

func (*EgressResponse) Unmarshal 

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

func (*EgressResponse) XXX_DiscardUnknown 

func (m *EgressResponse) XXX_DiscardUnknown()

func (*EgressResponse) XXX_Marshal 

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

func (*EgressResponse) XXX_Merge 

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

func (*EgressResponse) XXX_OneofWrappers 

func (*EgressResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EgressResponse) XXX_Size 

func (m *EgressResponse) XXX_Size() int

func (*EgressResponse) XXX_Unmarshal 

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

type EgressResponse_ObjectStorage 

type EgressResponse_ObjectStorage struct {
	ObjectStorage *EgressResponse_ObjectStorageResult `protobuf:"bytes,1,opt,name=object_storage,json=objectStorage,proto3,oneof" json:"object_storage,omitempty"`
}

func (*EgressResponse_ObjectStorage) MarshalTo 

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

func (*EgressResponse_ObjectStorage) MarshalToSizedBuffer 

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

func (*EgressResponse_ObjectStorage) Size 

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

type EgressResponse_ObjectStorageResult 

type EgressResponse_ObjectStorageResult struct {
	BytesWritten         int64    `protobuf:"varint,1,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EgressResponse_ObjectStorageResult) Descriptor 

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

func (*EgressResponse_ObjectStorageResult) GetBytesWritten 

func (m *EgressResponse_ObjectStorageResult) GetBytesWritten() int64

func (*EgressResponse_ObjectStorageResult) Marshal 

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

func (*EgressResponse_ObjectStorageResult) MarshalLogObject 

func (x *EgressResponse_ObjectStorageResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*EgressResponse_ObjectStorageResult) MarshalTo 

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

func (*EgressResponse_ObjectStorageResult) MarshalToSizedBuffer 

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

func (*EgressResponse_ObjectStorageResult) ProtoMessage 

func (*EgressResponse_ObjectStorageResult) ProtoMessage()

func (*EgressResponse_ObjectStorageResult) Reset 

func (m *EgressResponse_ObjectStorageResult) Reset()

func (*EgressResponse_ObjectStorageResult) Size 

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

func (*EgressResponse_ObjectStorageResult) String 

func (m *EgressResponse_ObjectStorageResult) String() string

func (*EgressResponse_ObjectStorageResult) Unmarshal 

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

func (*EgressResponse_ObjectStorageResult) XXX_DiscardUnknown 

func (m *EgressResponse_ObjectStorageResult) XXX_DiscardUnknown()

func (*EgressResponse_ObjectStorageResult) XXX_Marshal 

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

func (*EgressResponse_ObjectStorageResult) XXX_Merge 

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

func (*EgressResponse_ObjectStorageResult) XXX_Size 

func (m *EgressResponse_ObjectStorageResult) XXX_Size() int

func (*EgressResponse_ObjectStorageResult) XXX_Unmarshal 

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

type EgressResponse_SQLDatabaseResult 

type EgressResponse_SQLDatabaseResult struct {
	RowsWritten          map[string]int64 `` /* 183-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*EgressResponse_SQLDatabaseResult) Descriptor 

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

func (*EgressResponse_SQLDatabaseResult) GetRowsWritten 

func (m *EgressResponse_SQLDatabaseResult) GetRowsWritten() map[string]int64

func (*EgressResponse_SQLDatabaseResult) Marshal 

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

func (*EgressResponse_SQLDatabaseResult) MarshalLogObject 

func (x *EgressResponse_SQLDatabaseResult) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*EgressResponse_SQLDatabaseResult) MarshalTo 

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

func (*EgressResponse_SQLDatabaseResult) MarshalToSizedBuffer 

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

func (*EgressResponse_SQLDatabaseResult) ProtoMessage 

func (*EgressResponse_SQLDatabaseResult) ProtoMessage()

func (*EgressResponse_SQLDatabaseResult) Reset 

func (m *EgressResponse_SQLDatabaseResult) Reset()

func (*EgressResponse_SQLDatabaseResult) Size 

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

func (*EgressResponse_SQLDatabaseResult) String 

func (m *EgressResponse_SQLDatabaseResult) String() string

func (*EgressResponse_SQLDatabaseResult) Unmarshal 

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

func (*EgressResponse_SQLDatabaseResult) XXX_DiscardUnknown 

func (m *EgressResponse_SQLDatabaseResult) XXX_DiscardUnknown()

func (*EgressResponse_SQLDatabaseResult) XXX_Marshal 

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

func (*EgressResponse_SQLDatabaseResult) XXX_Merge 

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

func (*EgressResponse_SQLDatabaseResult) XXX_Size 

func (m *EgressResponse_SQLDatabaseResult) XXX_Size() int

func (*EgressResponse_SQLDatabaseResult) XXX_Unmarshal 

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

type EgressResponse_SqlDatabase 

type EgressResponse_SqlDatabase struct {
	SqlDatabase *EgressResponse_SQLDatabaseResult `protobuf:"bytes,2,opt,name=sql_database,json=sqlDatabase,proto3,oneof" json:"sql_database,omitempty"`
}

func (*EgressResponse_SqlDatabase) MarshalTo 

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

func (*EgressResponse_SqlDatabase) MarshalToSizedBuffer 

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

func (*EgressResponse_SqlDatabase) Size 

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

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"`
	Datum                string   `protobuf:"bytes,3,opt,name=datum,proto3" json:"datum,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) GetDatum 

func (m *File) GetDatum() string

func (*File) GetPath 

func (m *File) GetPath() string

func (*File) Marshal 

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

func (*File) MarshalLogObject 

func (x *File) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*File) MarshalTo 

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

func (*File) MarshalToSizedBuffer 

func (m *File) MarshalToSizedBuffer(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_v2.FileType" json:"file_type,omitempty"`
	Committed            *types.Timestamp `protobuf:"bytes,3,opt,name=committed,proto3" json:"committed,omitempty"`
	SizeBytes            int64            `protobuf:"varint,4,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Hash                 []byte           `protobuf:"bytes,5,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) GetCommitted 

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

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) GetSizeBytes 

func (m *FileInfo) GetSizeBytes() int64

func (*FileInfo) Marshal 

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

func (*FileInfo) MarshalLogObject 

func (x *FileInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*FileInfo) MarshalTo 

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

func (*FileInfo) MarshalToSizedBuffer 

func (m *FileInfo) MarshalToSizedBuffer(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 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 FindCommitsRequest 

type FindCommitsRequest struct {
	Start                *Commit  `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	FilePath             string   `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	Limit                uint32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindCommitsRequest) Descriptor 

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

func (*FindCommitsRequest) GetFilePath 

func (m *FindCommitsRequest) GetFilePath() string

func (*FindCommitsRequest) GetLimit 

func (m *FindCommitsRequest) GetLimit() uint32

func (*FindCommitsRequest) GetStart 

func (m *FindCommitsRequest) GetStart() *Commit

func (*FindCommitsRequest) Marshal 

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

func (*FindCommitsRequest) MarshalLogObject 

func (x *FindCommitsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*FindCommitsRequest) MarshalTo 

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

func (*FindCommitsRequest) MarshalToSizedBuffer 

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

func (*FindCommitsRequest) ProtoMessage 

func (*FindCommitsRequest) ProtoMessage()

func (*FindCommitsRequest) Reset 

func (m *FindCommitsRequest) Reset()

func (*FindCommitsRequest) Size 

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

func (*FindCommitsRequest) String 

func (m *FindCommitsRequest) String() string

func (*FindCommitsRequest) Unmarshal 

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

func (*FindCommitsRequest) XXX_DiscardUnknown 

func (m *FindCommitsRequest) XXX_DiscardUnknown()

func (*FindCommitsRequest) XXX_Marshal 

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

func (*FindCommitsRequest) XXX_Merge 

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

func (*FindCommitsRequest) XXX_Size 

func (m *FindCommitsRequest) XXX_Size() int

func (*FindCommitsRequest) XXX_Unmarshal 

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

type FindCommitsResponse 

type FindCommitsResponse struct {
	// Types that are valid to be assigned to Result:
	//
	//	*FindCommitsResponse_FoundCommit
	//	*FindCommitsResponse_LastSearchedCommit
	Result               isFindCommitsResponse_Result `protobuf_oneof:"result"`
	CommitsSearched      uint32                       `protobuf:"varint,3,opt,name=commits_searched,json=commitsSearched,proto3" json:"commits_searched,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*FindCommitsResponse) Descriptor 

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

func (*FindCommitsResponse) GetCommitsSearched 

func (m *FindCommitsResponse) GetCommitsSearched() uint32

func (*FindCommitsResponse) GetFoundCommit 

func (m *FindCommitsResponse) GetFoundCommit() *Commit

func (*FindCommitsResponse) GetLastSearchedCommit 

func (m *FindCommitsResponse) GetLastSearchedCommit() *Commit

func (*FindCommitsResponse) GetResult 

func (m *FindCommitsResponse) GetResult() isFindCommitsResponse_Result

func (*FindCommitsResponse) Marshal 

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

func (*FindCommitsResponse) MarshalLogObject 

func (x *FindCommitsResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*FindCommitsResponse) MarshalTo 

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

func (*FindCommitsResponse) MarshalToSizedBuffer 

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

func (*FindCommitsResponse) ProtoMessage 

func (*FindCommitsResponse) ProtoMessage()

func (*FindCommitsResponse) Reset 

func (m *FindCommitsResponse) Reset()

func (*FindCommitsResponse) Size 

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

func (*FindCommitsResponse) String 

func (m *FindCommitsResponse) String() string

func (*FindCommitsResponse) Unmarshal 

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

func (*FindCommitsResponse) XXX_DiscardUnknown 

func (m *FindCommitsResponse) XXX_DiscardUnknown()

func (*FindCommitsResponse) XXX_Marshal 

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

func (*FindCommitsResponse) XXX_Merge 

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

func (*FindCommitsResponse) XXX_OneofWrappers 

func (*FindCommitsResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*FindCommitsResponse) XXX_Size 

func (m *FindCommitsResponse) XXX_Size() int

func (*FindCommitsResponse) XXX_Unmarshal 

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

type FindCommitsResponse_FoundCommit 

type FindCommitsResponse_FoundCommit struct {
	FoundCommit *Commit `protobuf:"bytes,1,opt,name=found_commit,json=foundCommit,proto3,oneof" json:"found_commit,omitempty"`
}

func (*FindCommitsResponse_FoundCommit) MarshalTo 

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

func (*FindCommitsResponse_FoundCommit) MarshalToSizedBuffer 

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

func (*FindCommitsResponse_FoundCommit) Size 

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

type FindCommitsResponse_LastSearchedCommit 

type FindCommitsResponse_LastSearchedCommit struct {
	LastSearchedCommit *Commit `protobuf:"bytes,2,opt,name=last_searched_commit,json=lastSearchedCommit,proto3,oneof" json:"last_searched_commit,omitempty"`
}

func (*FindCommitsResponse_LastSearchedCommit) MarshalTo 

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

func (*FindCommitsResponse_LastSearchedCommit) MarshalToSizedBuffer 

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

func (*FindCommitsResponse_LastSearchedCommit) Size 

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

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"`
	Error                string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Force                bool     `protobuf:"varint,4,opt,name=force,proto3" json:"force,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) GetError 

func (m *FinishCommitRequest) GetError() string

func (*FinishCommitRequest) GetForce 

func (m *FinishCommitRequest) GetForce() bool

func (*FinishCommitRequest) Marshal 

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

func (*FinishCommitRequest) MarshalLogObject 

func (x *FinishCommitRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*FinishCommitRequest) MarshalTo 

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

func (*FinishCommitRequest) MarshalToSizedBuffer 

func (m *FinishCommitRequest) MarshalToSizedBuffer(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 FsckRequest 

type FsckRequest struct {
	Fix bool `protobuf:"varint,1,opt,name=fix,proto3" json:"fix,omitempty"`
	// Types that are valid to be assigned to ZombieCheck:
	//
	//	*FsckRequest_ZombieTarget
	//	*FsckRequest_ZombieAll
	ZombieCheck          isFsckRequest_ZombieCheck `protobuf_oneof:"zombie_check"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*FsckRequest) Descriptor 

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

func (*FsckRequest) GetFix 

func (m *FsckRequest) GetFix() bool

func (*FsckRequest) GetZombieAll 

func (m *FsckRequest) GetZombieAll() bool

func (*FsckRequest) GetZombieCheck 

func (m *FsckRequest) GetZombieCheck() isFsckRequest_ZombieCheck

func (*FsckRequest) GetZombieTarget 

func (m *FsckRequest) GetZombieTarget() *Commit

func (*FsckRequest) Marshal 

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

func (*FsckRequest) MarshalLogObject 

func (x *FsckRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*FsckRequest) MarshalTo 

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

func (*FsckRequest) MarshalToSizedBuffer 

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

func (*FsckRequest) ProtoMessage 

func (*FsckRequest) ProtoMessage()

func (*FsckRequest) Reset 

func (m *FsckRequest) Reset()

func (*FsckRequest) Size 

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

func (*FsckRequest) String 

func (m *FsckRequest) String() string

func (*FsckRequest) Unmarshal 

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

func (*FsckRequest) XXX_DiscardUnknown 

func (m *FsckRequest) XXX_DiscardUnknown()

func (*FsckRequest) XXX_Marshal 

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

func (*FsckRequest) XXX_Merge 

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

func (*FsckRequest) XXX_OneofWrappers 

func (*FsckRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*FsckRequest) XXX_Size 

func (m *FsckRequest) XXX_Size() int

func (*FsckRequest) XXX_Unmarshal 

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

type FsckRequest_ZombieAll 

type FsckRequest_ZombieAll struct {
	ZombieAll bool `protobuf:"varint,3,opt,name=zombie_all,json=zombieAll,proto3,oneof" json:"zombie_all,omitempty"`
}

func (*FsckRequest_ZombieAll) MarshalTo 

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

func (*FsckRequest_ZombieAll) MarshalToSizedBuffer 

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

func (*FsckRequest_ZombieAll) Size 

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

type FsckRequest_ZombieTarget 

type FsckRequest_ZombieTarget struct {
	ZombieTarget *Commit `protobuf:"bytes,2,opt,name=zombie_target,json=zombieTarget,proto3,oneof" json:"zombie_target,omitempty"`
}

func (*FsckRequest_ZombieTarget) MarshalTo 

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

func (*FsckRequest_ZombieTarget) MarshalToSizedBuffer 

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

func (*FsckRequest_ZombieTarget) Size 

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

type FsckResponse 

type FsckResponse struct {
	Fix                  string   `protobuf:"bytes,1,opt,name=fix,proto3" json:"fix,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FsckResponse) Descriptor 

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

func (*FsckResponse) GetError 

func (m *FsckResponse) GetError() string

func (*FsckResponse) GetFix 

func (m *FsckResponse) GetFix() string

func (*FsckResponse) Marshal 

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

func (*FsckResponse) MarshalLogObject 

func (x *FsckResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*FsckResponse) MarshalTo 

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

func (*FsckResponse) MarshalToSizedBuffer 

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

func (*FsckResponse) ProtoMessage 

func (*FsckResponse) ProtoMessage()

func (*FsckResponse) Reset 

func (m *FsckResponse) Reset()

func (*FsckResponse) Size 

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

func (*FsckResponse) String 

func (m *FsckResponse) String() string

func (*FsckResponse) Unmarshal 

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

func (*FsckResponse) XXX_DiscardUnknown 

func (m *FsckResponse) XXX_DiscardUnknown()

func (*FsckResponse) XXX_Marshal 

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

func (*FsckResponse) XXX_Merge 

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

func (*FsckResponse) XXX_Size 

func (m *FsckResponse) XXX_Size() int

func (*FsckResponse) XXX_Unmarshal 

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

type GetCacheRequest 

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

func (*GetCacheRequest) Descriptor 

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

func (*GetCacheRequest) GetKey 

func (m *GetCacheRequest) GetKey() string

func (*GetCacheRequest) Marshal 

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

func (*GetCacheRequest) MarshalLogObject 

func (x *GetCacheRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetCacheRequest) MarshalTo 

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

func (*GetCacheRequest) MarshalToSizedBuffer 

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

func (*GetCacheRequest) ProtoMessage 

func (*GetCacheRequest) ProtoMessage()

func (*GetCacheRequest) Reset 

func (m *GetCacheRequest) Reset()

func (*GetCacheRequest) Size 

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

func (*GetCacheRequest) String 

func (m *GetCacheRequest) String() string

func (*GetCacheRequest) Unmarshal 

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

func (*GetCacheRequest) XXX_DiscardUnknown 

func (m *GetCacheRequest) XXX_DiscardUnknown()

func (*GetCacheRequest) XXX_Marshal 

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

func (*GetCacheRequest) XXX_Merge 

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

func (*GetCacheRequest) XXX_Size 

func (m *GetCacheRequest) XXX_Size() int

func (*GetCacheRequest) XXX_Unmarshal 

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

type GetCacheResponse 

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

func (*GetCacheResponse) Descriptor 

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

func (*GetCacheResponse) GetValue 

func (m *GetCacheResponse) GetValue() *types.Any

func (*GetCacheResponse) Marshal 

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

func (*GetCacheResponse) MarshalLogObject 

func (x *GetCacheResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetCacheResponse) MarshalTo 

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

func (*GetCacheResponse) MarshalToSizedBuffer 

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

func (*GetCacheResponse) ProtoMessage 

func (*GetCacheResponse) ProtoMessage()

func (*GetCacheResponse) Reset 

func (m *GetCacheResponse) Reset()

func (*GetCacheResponse) Size 

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

func (*GetCacheResponse) String 

func (m *GetCacheResponse) String() string

func (*GetCacheResponse) Unmarshal 

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

func (*GetCacheResponse) XXX_DiscardUnknown 

func (m *GetCacheResponse) XXX_DiscardUnknown()

func (*GetCacheResponse) XXX_Marshal 

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

func (*GetCacheResponse) XXX_Merge 

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

func (*GetCacheResponse) XXX_Size 

func (m *GetCacheResponse) XXX_Size() int

func (*GetCacheResponse) XXX_Unmarshal 

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

type GetFileRequest 

type GetFileRequest struct {
	File                 *File      `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	URL                  string     `protobuf:"bytes,2,opt,name=URL,proto3" json:"URL,omitempty"`
	Offset               int64      `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	PathRange            *PathRange `protobuf:"bytes,4,opt,name=path_range,json=pathRange,proto3" json:"path_range,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) GetOffset 

func (m *GetFileRequest) GetOffset() int64

func (*GetFileRequest) GetPathRange 

func (m *GetFileRequest) GetPathRange() *PathRange

func (*GetFileRequest) GetURL 

func (m *GetFileRequest) GetURL() string

func (*GetFileRequest) Marshal 

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

func (*GetFileRequest) MarshalLogObject 

func (x *GetFileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetFileRequest) MarshalTo 

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

func (*GetFileRequest) MarshalToSizedBuffer 

func (m *GetFileRequest) MarshalToSizedBuffer(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 GetFileSetRequest 

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

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

func (*GetFileSetRequest) GetCommit 

func (m *GetFileSetRequest) GetCommit() *Commit

func (*GetFileSetRequest) Marshal 

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

func (*GetFileSetRequest) MarshalLogObject 

func (x *GetFileSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetFileSetRequest) MarshalTo 

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

func (*GetFileSetRequest) MarshalToSizedBuffer 

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

func (*GetFileSetRequest) ProtoMessage 

func (*GetFileSetRequest) ProtoMessage()

func (*GetFileSetRequest) Reset 

func (m *GetFileSetRequest) Reset()

func (*GetFileSetRequest) Size 

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

func (*GetFileSetRequest) String 

func (m *GetFileSetRequest) String() string

func (*GetFileSetRequest) Unmarshal 

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

func (*GetFileSetRequest) XXX_DiscardUnknown 

func (m *GetFileSetRequest) XXX_DiscardUnknown()

func (*GetFileSetRequest) XXX_Marshal 

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

func (*GetFileSetRequest) XXX_Merge 

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

func (*GetFileSetRequest) XXX_Size 

func (m *GetFileSetRequest) XXX_Size() int

func (*GetFileSetRequest) XXX_Unmarshal 

func (m *GetFileSetRequest) 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"`
	PathRange            *PathRange `protobuf:"bytes,3,opt,name=path_range,json=pathRange,proto3" json:"path_range,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) GetPathRange 

func (m *GlobFileRequest) GetPathRange() *PathRange

func (*GlobFileRequest) GetPattern 

func (m *GlobFileRequest) GetPattern() string

func (*GlobFileRequest) Marshal 

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

func (*GlobFileRequest) MarshalLogObject 

func (x *GlobFileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GlobFileRequest) MarshalTo 

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

func (*GlobFileRequest) MarshalToSizedBuffer 

func (m *GlobFileRequest) MarshalToSizedBuffer(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) MarshalLogObject 

func (x *InspectBranchRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectBranchRequest) MarshalTo 

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

func (*InspectBranchRequest) MarshalToSizedBuffer 

func (m *InspectBranchRequest) MarshalToSizedBuffer(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"`
	// Wait causes inspect commit to wait until the commit is in the desired state.
	Wait                 CommitState `protobuf:"varint,2,opt,name=wait,proto3,enum=pfs_v2.CommitState" json:"wait,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*InspectCommitRequest) Descriptor 

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

func (*InspectCommitRequest) GetCommit 

func (m *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) GetWait 

func (m *InspectCommitRequest) GetWait() CommitState

func (*InspectCommitRequest) Marshal 

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

func (*InspectCommitRequest) MarshalLogObject 

func (x *InspectCommitRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectCommitRequest) MarshalTo 

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

func (*InspectCommitRequest) MarshalToSizedBuffer 

func (m *InspectCommitRequest) MarshalToSizedBuffer(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 InspectCommitSetRequest 

type InspectCommitSetRequest struct {
	CommitSet            *CommitSet `protobuf:"bytes,1,opt,name=commit_set,json=commitSet,proto3" json:"commit_set,omitempty"`
	Wait                 bool       `protobuf:"varint,2,opt,name=wait,proto3" json:"wait,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*InspectCommitSetRequest) Descriptor 

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

func (*InspectCommitSetRequest) GetCommitSet 

func (m *InspectCommitSetRequest) GetCommitSet() *CommitSet

func (*InspectCommitSetRequest) GetWait 

func (m *InspectCommitSetRequest) GetWait() bool

func (*InspectCommitSetRequest) Marshal 

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

func (*InspectCommitSetRequest) MarshalLogObject 

func (x *InspectCommitSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectCommitSetRequest) MarshalTo 

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

func (*InspectCommitSetRequest) MarshalToSizedBuffer 

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

func (*InspectCommitSetRequest) ProtoMessage 

func (*InspectCommitSetRequest) ProtoMessage()

func (*InspectCommitSetRequest) Reset 

func (m *InspectCommitSetRequest) Reset()

func (*InspectCommitSetRequest) Size 

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

func (*InspectCommitSetRequest) String 

func (m *InspectCommitSetRequest) String() string

func (*InspectCommitSetRequest) Unmarshal 

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

func (*InspectCommitSetRequest) XXX_DiscardUnknown 

func (m *InspectCommitSetRequest) XXX_DiscardUnknown()

func (*InspectCommitSetRequest) XXX_Marshal 

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

func (*InspectCommitSetRequest) XXX_Merge 

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

func (*InspectCommitSetRequest) XXX_Size 

func (m *InspectCommitSetRequest) XXX_Size() int

func (*InspectCommitSetRequest) XXX_Unmarshal 

func (m *InspectCommitSetRequest) 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) MarshalLogObject 

func (x *InspectFileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectFileRequest) MarshalTo 

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

func (*InspectFileRequest) MarshalToSizedBuffer 

func (m *InspectFileRequest) MarshalToSizedBuffer(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 InspectProjectRequest 

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

func (*InspectProjectRequest) Descriptor 

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

func (*InspectProjectRequest) GetProject 

func (m *InspectProjectRequest) GetProject() *Project

func (*InspectProjectRequest) Marshal 

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

func (*InspectProjectRequest) MarshalLogObject 

func (x *InspectProjectRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectProjectRequest) MarshalTo 

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

func (*InspectProjectRequest) MarshalToSizedBuffer 

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

func (*InspectProjectRequest) ProtoMessage 

func (*InspectProjectRequest) ProtoMessage()

func (*InspectProjectRequest) Reset 

func (m *InspectProjectRequest) Reset()

func (*InspectProjectRequest) Size 

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

func (*InspectProjectRequest) String 

func (m *InspectProjectRequest) String() string

func (*InspectProjectRequest) Unmarshal 

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

func (*InspectProjectRequest) XXX_DiscardUnknown 

func (m *InspectProjectRequest) XXX_DiscardUnknown()

func (*InspectProjectRequest) XXX_Marshal 

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

func (*InspectProjectRequest) XXX_Merge 

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

func (*InspectProjectRequest) XXX_Size 

func (m *InspectProjectRequest) XXX_Size() int

func (*InspectProjectRequest) XXX_Unmarshal 

func (m *InspectProjectRequest) 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) MarshalLogObject 

func (x *InspectRepoRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectRepoRequest) MarshalTo 

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

func (*InspectRepoRequest) MarshalToSizedBuffer 

func (m *InspectRepoRequest) MarshalToSizedBuffer(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) 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"`
	Reverse              bool     `protobuf:"varint,2,opt,name=reverse,proto3" json:"reverse,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) GetReverse 

func (m *ListBranchRequest) GetReverse() bool

func (*ListBranchRequest) Marshal 

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

func (*ListBranchRequest) MarshalLogObject 

func (x *ListBranchRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListBranchRequest) MarshalTo 

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

func (*ListBranchRequest) MarshalToSizedBuffer 

func (m *ListBranchRequest) MarshalToSizedBuffer(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 (m *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               int64            `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	Reverse              bool             `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
	All                  bool             `protobuf:"varint,6,opt,name=all,proto3" json:"all,omitempty"`
	OriginKind           OriginKind       `protobuf:"varint,7,opt,name=origin_kind,json=originKind,proto3,enum=pfs_v2.OriginKind" json:"origin_kind,omitempty"`
	StartedTime          *types.Timestamp `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ListCommitRequest) Descriptor 

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

func (*ListCommitRequest) GetAll 

func (m *ListCommitRequest) GetAll() bool

func (*ListCommitRequest) GetFrom 

func (m *ListCommitRequest) GetFrom() *Commit

func (*ListCommitRequest) GetNumber 

func (m *ListCommitRequest) GetNumber() int64

func (*ListCommitRequest) GetOriginKind 

func (m *ListCommitRequest) GetOriginKind() OriginKind

func (*ListCommitRequest) GetRepo 

func (m *ListCommitRequest) GetRepo() *Repo

func (*ListCommitRequest) GetReverse 

func (m *ListCommitRequest) GetReverse() bool

func (*ListCommitRequest) GetStartedTime 

func (m *ListCommitRequest) GetStartedTime() *types.Timestamp

func (*ListCommitRequest) GetTo 

func (m *ListCommitRequest) GetTo() *Commit

func (*ListCommitRequest) Marshal 

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

func (*ListCommitRequest) MarshalLogObject 

func (x *ListCommitRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListCommitRequest) MarshalTo 

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

func (*ListCommitRequest) MarshalToSizedBuffer 

func (m *ListCommitRequest) MarshalToSizedBuffer(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 (m *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 ListCommitSetRequest 

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

func (*ListCommitSetRequest) Descriptor 

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

func (*ListCommitSetRequest) GetProject 

func (m *ListCommitSetRequest) GetProject() *Project

func (*ListCommitSetRequest) Marshal 

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

func (*ListCommitSetRequest) MarshalLogObject 

func (x *ListCommitSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListCommitSetRequest) MarshalTo 

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

func (*ListCommitSetRequest) MarshalToSizedBuffer 

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

func (*ListCommitSetRequest) ProtoMessage 

func (*ListCommitSetRequest) ProtoMessage()

func (*ListCommitSetRequest) Reset 

func (m *ListCommitSetRequest) Reset()

func (*ListCommitSetRequest) Size 

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

func (*ListCommitSetRequest) String 

func (m *ListCommitSetRequest) String() string

func (*ListCommitSetRequest) Unmarshal 

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

func (*ListCommitSetRequest) XXX_DiscardUnknown 

func (m *ListCommitSetRequest) XXX_DiscardUnknown()

func (*ListCommitSetRequest) XXX_Marshal 

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

func (*ListCommitSetRequest) XXX_Merge 

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

func (*ListCommitSetRequest) XXX_Size 

func (m *ListCommitSetRequest) XXX_Size() int

func (*ListCommitSetRequest) XXX_Unmarshal 

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

type ListFileRequest 

type ListFileRequest struct {
	// File is the parent directory of the files we want to list. This sets the
	// repo, the commit/branch, and path prefix of files we're interested in
	// If the "path" field is omitted, a list of files at the top level of the repo
	// is returned
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// Marker for pagination. If set, the files that come after the marker in
	// lexicographical order will be returned. If reverse is also set, the files
	// that come before the marker in lexicographical order will be returned.
	PaginationMarker *File `protobuf:"bytes,3,opt,name=paginationMarker,proto3" json:"paginationMarker,omitempty"`
	// Number of files to return
	Number int64 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	// If true, return files in reverse order
	Reverse              bool     `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,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) GetNumber 

func (m *ListFileRequest) GetNumber() int64

func (*ListFileRequest) GetPaginationMarker 

func (m *ListFileRequest) GetPaginationMarker() *File

func (*ListFileRequest) GetReverse 

func (m *ListFileRequest) GetReverse() bool

func (*ListFileRequest) Marshal 

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

func (*ListFileRequest) MarshalLogObject 

func (x *ListFileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListFileRequest) MarshalTo 

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

func (*ListFileRequest) MarshalToSizedBuffer 

func (m *ListFileRequest) MarshalToSizedBuffer(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 (m *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 ListProjectRequest 

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

func (*ListProjectRequest) Descriptor 

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

func (*ListProjectRequest) Marshal 

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

func (*ListProjectRequest) MarshalLogObject 

func (x *ListProjectRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListProjectRequest) MarshalTo 

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

func (*ListProjectRequest) MarshalToSizedBuffer 

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

func (*ListProjectRequest) ProtoMessage 

func (*ListProjectRequest) ProtoMessage()

func (*ListProjectRequest) Reset 

func (m *ListProjectRequest) Reset()

func (*ListProjectRequest) Size 

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

func (*ListProjectRequest) String 

func (m *ListProjectRequest) String() string

func (*ListProjectRequest) Unmarshal 

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

func (*ListProjectRequest) XXX_DiscardUnknown 

func (m *ListProjectRequest) XXX_DiscardUnknown()

func (*ListProjectRequest) XXX_Marshal 

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

func (*ListProjectRequest) XXX_Merge 

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

func (*ListProjectRequest) XXX_Size 

func (m *ListProjectRequest) XXX_Size() int

func (*ListProjectRequest) XXX_Unmarshal 

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

type ListRepoRequest 

type ListRepoRequest struct {
	// type is the type of (system) repos that should be returned
	// an empty string requests all repos
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// projects filters out repos that do not belong in the list, while no projects means list all repos.
	Projects             []*Project `protobuf:"bytes,2,rep,name=projects,proto3" json:"projects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ListRepoRequest) Descriptor 

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

func (*ListRepoRequest) GetProjects 

func (m *ListRepoRequest) GetProjects() []*Project

func (*ListRepoRequest) GetType 

func (m *ListRepoRequest) GetType() string

func (*ListRepoRequest) Marshal 

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

func (*ListRepoRequest) MarshalLogObject 

func (x *ListRepoRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListRepoRequest) MarshalTo 

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

func (*ListRepoRequest) MarshalToSizedBuffer 

func (m *ListRepoRequest) MarshalToSizedBuffer(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 (m *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 ModifyFileRequest 

type ModifyFileRequest struct {
	// Types that are valid to be assigned to Body:
	//
	//	*ModifyFileRequest_SetCommit
	//	*ModifyFileRequest_AddFile
	//	*ModifyFileRequest_DeleteFile
	//	*ModifyFileRequest_CopyFile
	Body                 isModifyFileRequest_Body `protobuf_oneof:"body"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ModifyFileRequest) Descriptor 

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

func (*ModifyFileRequest) GetAddFile 

func (m *ModifyFileRequest) GetAddFile() *AddFile

func (*ModifyFileRequest) GetBody 

func (m *ModifyFileRequest) GetBody() isModifyFileRequest_Body

func (*ModifyFileRequest) GetCopyFile 

func (m *ModifyFileRequest) GetCopyFile() *CopyFile

func (*ModifyFileRequest) GetDeleteFile 

func (m *ModifyFileRequest) GetDeleteFile() *DeleteFile

func (*ModifyFileRequest) GetSetCommit 

func (m *ModifyFileRequest) GetSetCommit() *Commit

func (*ModifyFileRequest) Marshal 

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

func (*ModifyFileRequest) MarshalLogObject 

func (x *ModifyFileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ModifyFileRequest) MarshalTo 

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

func (*ModifyFileRequest) MarshalToSizedBuffer 

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

func (*ModifyFileRequest) ProtoMessage 

func (*ModifyFileRequest) ProtoMessage()

func (*ModifyFileRequest) Reset 

func (m *ModifyFileRequest) Reset()

func (*ModifyFileRequest) Size 

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

func (*ModifyFileRequest) String 

func (m *ModifyFileRequest) String() string

func (*ModifyFileRequest) Unmarshal 

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

func (*ModifyFileRequest) XXX_DiscardUnknown 

func (m *ModifyFileRequest) XXX_DiscardUnknown()

func (*ModifyFileRequest) XXX_Marshal 

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

func (*ModifyFileRequest) XXX_Merge 

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

func (*ModifyFileRequest) XXX_OneofWrappers 

func (*ModifyFileRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ModifyFileRequest) XXX_Size 

func (m *ModifyFileRequest) XXX_Size() int

func (*ModifyFileRequest) XXX_Unmarshal 

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

type ModifyFileRequest_AddFile 

type ModifyFileRequest_AddFile struct {
	AddFile *AddFile `protobuf:"bytes,2,opt,name=add_file,json=addFile,proto3,oneof" json:"add_file,omitempty"`
}

func (*ModifyFileRequest_AddFile) MarshalTo 

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

func (*ModifyFileRequest_AddFile) MarshalToSizedBuffer 

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

func (*ModifyFileRequest_AddFile) Size 

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

type ModifyFileRequest_CopyFile 

type ModifyFileRequest_CopyFile struct {
	CopyFile *CopyFile `protobuf:"bytes,4,opt,name=copy_file,json=copyFile,proto3,oneof" json:"copy_file,omitempty"`
}

func (*ModifyFileRequest_CopyFile) MarshalTo 

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

func (*ModifyFileRequest_CopyFile) MarshalToSizedBuffer 

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

func (*ModifyFileRequest_CopyFile) Size 

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

type ModifyFileRequest_DeleteFile 

type ModifyFileRequest_DeleteFile struct {
	DeleteFile *DeleteFile `protobuf:"bytes,3,opt,name=delete_file,json=deleteFile,proto3,oneof" json:"delete_file,omitempty"`
}

func (*ModifyFileRequest_DeleteFile) MarshalTo 

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

func (*ModifyFileRequest_DeleteFile) MarshalToSizedBuffer 

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

func (*ModifyFileRequest_DeleteFile) Size 

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

type ModifyFileRequest_SetCommit 

type ModifyFileRequest_SetCommit struct {
	SetCommit *Commit `protobuf:"bytes,1,opt,name=set_commit,json=setCommit,proto3,oneof" json:"set_commit,omitempty"`
}

func (*ModifyFileRequest_SetCommit) MarshalTo 

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

func (*ModifyFileRequest_SetCommit) MarshalToSizedBuffer 

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

func (*ModifyFileRequest_SetCommit) Size 

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

type ObjectStorageEgress 

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

func (*ObjectStorageEgress) Descriptor 

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

func (*ObjectStorageEgress) GetUrl 

func (m *ObjectStorageEgress) GetUrl() string

func (*ObjectStorageEgress) Marshal 

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

func (*ObjectStorageEgress) MarshalLogObject 

func (x *ObjectStorageEgress) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ObjectStorageEgress) MarshalTo 

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

func (*ObjectStorageEgress) MarshalToSizedBuffer 

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

func (*ObjectStorageEgress) ProtoMessage 

func (*ObjectStorageEgress) ProtoMessage()

func (*ObjectStorageEgress) Reset 

func (m *ObjectStorageEgress) Reset()

func (*ObjectStorageEgress) Size 

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

func (*ObjectStorageEgress) String 

func (m *ObjectStorageEgress) String() string

func (*ObjectStorageEgress) Unmarshal 

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

func (*ObjectStorageEgress) XXX_DiscardUnknown 

func (m *ObjectStorageEgress) XXX_DiscardUnknown()

func (*ObjectStorageEgress) XXX_Marshal 

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

func (*ObjectStorageEgress) XXX_Merge 

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

func (*ObjectStorageEgress) XXX_Size 

func (m *ObjectStorageEgress) XXX_Size() int

func (*ObjectStorageEgress) XXX_Unmarshal 

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

type OriginKind 

type OriginKind int32

These are the different places where a commit may be originated from 

const (
	OriginKind_ORIGIN_KIND_UNKNOWN OriginKind = 0
	OriginKind_USER                OriginKind = 1
	OriginKind_AUTO                OriginKind = 2
	OriginKind_FSCK                OriginKind = 3
)

func (OriginKind) EnumDescriptor 

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

func (OriginKind) String 

func (x OriginKind) String() string

type PathRange 

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

func (*PathRange) Descriptor 

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

func (*PathRange) GetLower 

func (m *PathRange) GetLower() string

func (*PathRange) GetUpper 

func (m *PathRange) GetUpper() string

func (*PathRange) Marshal 

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

func (*PathRange) MarshalLogObject 

func (x *PathRange) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PathRange) MarshalTo 

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

func (*PathRange) MarshalToSizedBuffer 

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

func (*PathRange) ProtoMessage 

func (*PathRange) ProtoMessage()

func (*PathRange) Reset 

func (m *PathRange) Reset()

func (*PathRange) Size 

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

func (*PathRange) String 

func (m *PathRange) String() string

func (*PathRange) Unmarshal 

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

func (*PathRange) XXX_DiscardUnknown 

func (m *PathRange) XXX_DiscardUnknown()

func (*PathRange) XXX_Marshal 

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

func (*PathRange) XXX_Merge 

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

func (*PathRange) XXX_Size 

func (m *PathRange) XXX_Size() int

func (*PathRange) XXX_Unmarshal 

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

type Project 

type Project 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 (*Project) AuthResource 

func (p *Project) AuthResource() *auth.Resource

AuthResource returns the auth resource for a project.

func (*Project) Descriptor 

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

func (*Project) GetName 

func (m *Project) GetName() string

func (*Project) Marshal 

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

func (*Project) MarshalLogObject 

func (x *Project) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Project) MarshalTo 

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

func (*Project) MarshalToSizedBuffer 

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

func (*Project) ProtoMessage 

func (*Project) ProtoMessage()

func (*Project) Reset 

func (m *Project) Reset()

func (*Project) Size 

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

func (*Project) String 

func (p *Project) String() string

func (*Project) Unmarshal 

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

func (*Project) ValidateName 

func (p *Project) ValidateName() error

ValidateName returns an error if the project is nil or its name is an invalid project name. DefaultProjectName is always valid; otherwise the ancestry package is used to validate the name.

func (*Project) XXX_DiscardUnknown 

func (m *Project) XXX_DiscardUnknown()

func (*Project) XXX_Marshal 

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

func (*Project) XXX_Merge 

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

func (*Project) XXX_Size 

func (m *Project) XXX_Size() int

func (*Project) XXX_Unmarshal 

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

type ProjectInfo 

type ProjectInfo struct {
	Project              *Project         `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Description          string           `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	AuthInfo             *AuthInfo        `protobuf:"bytes,3,opt,name=auth_info,json=authInfo,proto3" json:"auth_info,omitempty"`
	CreatedAt            *types.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ProjectInfo) Descriptor 

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

func (*ProjectInfo) GetAuthInfo 

func (m *ProjectInfo) GetAuthInfo() *AuthInfo

func (*ProjectInfo) GetCreatedAt 

func (m *ProjectInfo) GetCreatedAt() *types.Timestamp

func (*ProjectInfo) GetDescription 

func (m *ProjectInfo) GetDescription() string

func (*ProjectInfo) GetProject 

func (m *ProjectInfo) GetProject() *Project

func (*ProjectInfo) Marshal 

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

func (*ProjectInfo) MarshalLogObject 

func (x *ProjectInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ProjectInfo) MarshalTo 

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

func (*ProjectInfo) MarshalToSizedBuffer 

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

func (*ProjectInfo) ProtoMessage 

func (*ProjectInfo) ProtoMessage()

func (*ProjectInfo) Reset 

func (m *ProjectInfo) Reset()

func (*ProjectInfo) Size 

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

func (*ProjectInfo) String 

func (m *ProjectInfo) String() string

func (*ProjectInfo) Unmarshal 

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

func (*ProjectInfo) XXX_DiscardUnknown 

func (m *ProjectInfo) XXX_DiscardUnknown()

func (*ProjectInfo) XXX_Marshal 

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

func (*ProjectInfo) XXX_Merge 

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

func (*ProjectInfo) XXX_Size 

func (m *ProjectInfo) XXX_Size() int

func (*ProjectInfo) XXX_Unmarshal 

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

type PutCacheRequest 

type PutCacheRequest struct {
	Key                  string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *types.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	FileSetIds           []string   `protobuf:"bytes,3,rep,name=file_set_ids,json=fileSetIds,proto3" json:"file_set_ids,omitempty"`
	Tag                  string     `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PutCacheRequest) Descriptor 

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

func (*PutCacheRequest) GetFileSetIds 

func (m *PutCacheRequest) GetFileSetIds() []string

func (*PutCacheRequest) GetKey 

func (m *PutCacheRequest) GetKey() string

func (*PutCacheRequest) GetTag 

func (m *PutCacheRequest) GetTag() string

func (*PutCacheRequest) GetValue 

func (m *PutCacheRequest) GetValue() *types.Any

func (*PutCacheRequest) Marshal 

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

func (*PutCacheRequest) MarshalLogObject 

func (x *PutCacheRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PutCacheRequest) MarshalTo 

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

func (*PutCacheRequest) MarshalToSizedBuffer 

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

func (*PutCacheRequest) ProtoMessage 

func (*PutCacheRequest) ProtoMessage()

func (*PutCacheRequest) Reset 

func (m *PutCacheRequest) Reset()

func (*PutCacheRequest) Size 

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

func (*PutCacheRequest) String 

func (m *PutCacheRequest) String() string

func (*PutCacheRequest) Unmarshal 

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

func (*PutCacheRequest) XXX_DiscardUnknown 

func (m *PutCacheRequest) XXX_DiscardUnknown()

func (*PutCacheRequest) XXX_Marshal 

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

func (*PutCacheRequest) XXX_Merge 

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

func (*PutCacheRequest) XXX_Size 

func (m *PutCacheRequest) XXX_Size() int

func (*PutCacheRequest) XXX_Unmarshal 

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

type RenewFileSetRequest 

type RenewFileSetRequest struct {
	FileSetId            string   `protobuf:"bytes,1,opt,name=file_set_id,json=fileSetId,proto3" json:"file_set_id,omitempty"`
	TtlSeconds           int64    `protobuf:"varint,2,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RenewFileSetRequest) Descriptor 

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

func (*RenewFileSetRequest) GetFileSetId 

func (m *RenewFileSetRequest) GetFileSetId() string

func (*RenewFileSetRequest) GetTtlSeconds 

func (m *RenewFileSetRequest) GetTtlSeconds() int64

func (*RenewFileSetRequest) Marshal 

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

func (*RenewFileSetRequest) MarshalLogObject 

func (x *RenewFileSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RenewFileSetRequest) MarshalTo 

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

func (*RenewFileSetRequest) MarshalToSizedBuffer 

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

func (*RenewFileSetRequest) ProtoMessage 

func (*RenewFileSetRequest) ProtoMessage()

func (*RenewFileSetRequest) Reset 

func (m *RenewFileSetRequest) Reset()

func (*RenewFileSetRequest) Size 

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

func (*RenewFileSetRequest) String 

func (m *RenewFileSetRequest) String() string

func (*RenewFileSetRequest) Unmarshal 

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

func (*RenewFileSetRequest) XXX_DiscardUnknown 

func (m *RenewFileSetRequest) XXX_DiscardUnknown()

func (*RenewFileSetRequest) XXX_Marshal 

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

func (*RenewFileSetRequest) XXX_Merge 

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

func (*RenewFileSetRequest) XXX_Size 

func (m *RenewFileSetRequest) XXX_Size() int

func (*RenewFileSetRequest) XXX_Unmarshal 

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

type Repo 

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

func (*Repo) AuthResource 

func (r *Repo) AuthResource() *auth.Resource

AuthResource returns the auth resource for a repo. The resource name is the project name and repo name separated by a slash. Notably, it does _not_ include the repo type string.

func (*Repo) Descriptor 

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

func (*Repo) EnsureProject 

func (r *Repo) EnsureProject()

EnsureProject ensures that repo.Project is set. It does nothing if repo is nil.

func (*Repo) GetName 

func (m *Repo) GetName() string

func (*Repo) GetProject 

func (m *Repo) GetProject() *Project

func (*Repo) GetType 

func (m *Repo) GetType() string

func (*Repo) Marshal 

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

func (*Repo) MarshalLogObject 

func (x *Repo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Repo) MarshalTo 

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

func (*Repo) MarshalToSizedBuffer 

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

func (*Repo) NewBranch 

func (r *Repo) NewBranch(name string) *Branch

func (*Repo) NewCommit 

func (r *Repo) NewCommit(branch, id string) *Commit

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 (r *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 (m *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 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"`
	SizeBytesUpperBound int64            `protobuf:"varint,3,opt,name=size_bytes_upper_bound,json=sizeBytesUpperBound,proto3" json:"size_bytes_upper_bound,omitempty"`
	Description         string           `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Branches            []*Branch        `protobuf:"bytes,5,rep,name=branches,proto3" json:"branches,omitempty"`
	// Set by ListRepo and InspectRepo if Pachyderm's auth system is active, but
	// not stored in etcd. To set a user's auth scope for a repo, use the
	// Pachyderm Auth API (in src/client/auth/auth.proto)
	AuthInfo             *AuthInfo         `protobuf:"bytes,6,opt,name=auth_info,json=authInfo,proto3" json:"auth_info,omitempty"`
	Details              *RepoInfo_Details `protobuf:"bytes,7,opt,name=details,proto3" json:"details,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() *AuthInfo

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) GetDetails 

func (m *RepoInfo) GetDetails() *RepoInfo_Details

func (*RepoInfo) GetRepo 

func (m *RepoInfo) GetRepo() *Repo

func (*RepoInfo) GetSizeBytesUpperBound 

func (m *RepoInfo) GetSizeBytesUpperBound() int64

func (*RepoInfo) Marshal 

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

func (*RepoInfo) MarshalLogObject 

func (x *RepoInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RepoInfo) MarshalTo 

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

func (*RepoInfo) MarshalToSizedBuffer 

func (m *RepoInfo) MarshalToSizedBuffer(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 (m *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 RepoInfo_Details 

type RepoInfo_Details struct {
	SizeBytes            int64    `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Details are only provided when explicitly requested

func (*RepoInfo_Details) Descriptor 

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

func (*RepoInfo_Details) GetSizeBytes 

func (m *RepoInfo_Details) GetSizeBytes() int64

func (*RepoInfo_Details) Marshal 

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

func (*RepoInfo_Details) MarshalLogObject 

func (x *RepoInfo_Details) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RepoInfo_Details) MarshalTo 

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

func (*RepoInfo_Details) MarshalToSizedBuffer 

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

func (*RepoInfo_Details) ProtoMessage 

func (*RepoInfo_Details) ProtoMessage()

func (*RepoInfo_Details) Reset 

func (m *RepoInfo_Details) Reset()

func (*RepoInfo_Details) Size 

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

func (*RepoInfo_Details) String 

func (m *RepoInfo_Details) String() string

func (*RepoInfo_Details) Unmarshal 

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

func (*RepoInfo_Details) XXX_DiscardUnknown 

func (m *RepoInfo_Details) XXX_DiscardUnknown()

func (*RepoInfo_Details) XXX_Marshal 

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

func (*RepoInfo_Details) XXX_Merge 

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

func (*RepoInfo_Details) XXX_Size 

func (m *RepoInfo_Details) XXX_Size() int

func (*RepoInfo_Details) XXX_Unmarshal 

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

type RunLoadTestRequest 

type RunLoadTestRequest struct {
	Spec                 string   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Branch               *Branch  `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	Seed                 int64    `protobuf:"varint,3,opt,name=seed,proto3" json:"seed,omitempty"`
	StateId              string   `protobuf:"bytes,4,opt,name=state_id,json=stateId,proto3" json:"state_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunLoadTestRequest) Descriptor 

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

func (*RunLoadTestRequest) GetBranch 

func (m *RunLoadTestRequest) GetBranch() *Branch

func (*RunLoadTestRequest) GetSeed 

func (m *RunLoadTestRequest) GetSeed() int64

func (*RunLoadTestRequest) GetSpec 

func (m *RunLoadTestRequest) GetSpec() string

func (*RunLoadTestRequest) GetStateId 

func (m *RunLoadTestRequest) GetStateId() string

func (*RunLoadTestRequest) Marshal 

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

func (*RunLoadTestRequest) MarshalLogObject 

func (x *RunLoadTestRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunLoadTestRequest) MarshalTo 

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

func (*RunLoadTestRequest) MarshalToSizedBuffer 

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

func (*RunLoadTestRequest) ProtoMessage 

func (*RunLoadTestRequest) ProtoMessage()

func (*RunLoadTestRequest) Reset 

func (m *RunLoadTestRequest) Reset()

func (*RunLoadTestRequest) Size 

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

func (*RunLoadTestRequest) String 

func (m *RunLoadTestRequest) String() string

func (*RunLoadTestRequest) Unmarshal 

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

func (*RunLoadTestRequest) XXX_DiscardUnknown 

func (m *RunLoadTestRequest) XXX_DiscardUnknown()

func (*RunLoadTestRequest) XXX_Marshal 

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

func (*RunLoadTestRequest) XXX_Merge 

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

func (*RunLoadTestRequest) XXX_Size 

func (m *RunLoadTestRequest) XXX_Size() int

func (*RunLoadTestRequest) XXX_Unmarshal 

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

type RunLoadTestResponse 

type RunLoadTestResponse struct {
	Spec                 string          `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Branch               *Branch         `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	Seed                 int64           `protobuf:"varint,3,opt,name=seed,proto3" json:"seed,omitempty"`
	Error                string          `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	Duration             *types.Duration `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"`
	StateId              string          `protobuf:"bytes,6,opt,name=state_id,json=stateId,proto3" json:"state_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RunLoadTestResponse) Descriptor 

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

func (*RunLoadTestResponse) GetBranch 

func (m *RunLoadTestResponse) GetBranch() *Branch

func (*RunLoadTestResponse) GetDuration 

func (m *RunLoadTestResponse) GetDuration() *types.Duration

func (*RunLoadTestResponse) GetError 

func (m *RunLoadTestResponse) GetError() string

func (*RunLoadTestResponse) GetSeed 

func (m *RunLoadTestResponse) GetSeed() int64

func (*RunLoadTestResponse) GetSpec 

func (m *RunLoadTestResponse) GetSpec() string

func (*RunLoadTestResponse) GetStateId 

func (m *RunLoadTestResponse) GetStateId() string

func (*RunLoadTestResponse) Marshal 

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

func (*RunLoadTestResponse) MarshalLogObject 

func (x *RunLoadTestResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunLoadTestResponse) MarshalTo 

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

func (*RunLoadTestResponse) MarshalToSizedBuffer 

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

func (*RunLoadTestResponse) ProtoMessage 

func (*RunLoadTestResponse) ProtoMessage()

func (*RunLoadTestResponse) Reset 

func (m *RunLoadTestResponse) Reset()

func (*RunLoadTestResponse) Size 

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

func (*RunLoadTestResponse) String 

func (m *RunLoadTestResponse) String() string

func (*RunLoadTestResponse) Unmarshal 

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

func (*RunLoadTestResponse) XXX_DiscardUnknown 

func (m *RunLoadTestResponse) XXX_DiscardUnknown()

func (*RunLoadTestResponse) XXX_Marshal 

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

func (*RunLoadTestResponse) XXX_Merge 

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

func (*RunLoadTestResponse) XXX_Size 

func (m *RunLoadTestResponse) XXX_Size() int

func (*RunLoadTestResponse) XXX_Unmarshal 

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

type SQLDatabaseEgress 

type SQLDatabaseEgress struct {
	Url                  string                        `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	FileFormat           *SQLDatabaseEgress_FileFormat `protobuf:"bytes,2,opt,name=file_format,json=fileFormat,proto3" json:"file_format,omitempty"`
	Secret               *SQLDatabaseEgress_Secret     `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*SQLDatabaseEgress) Descriptor 

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

func (*SQLDatabaseEgress) GetFileFormat 

func (m *SQLDatabaseEgress) GetFileFormat() *SQLDatabaseEgress_FileFormat

func (*SQLDatabaseEgress) GetSecret 

func (m *SQLDatabaseEgress) GetSecret() *SQLDatabaseEgress_Secret

func (*SQLDatabaseEgress) GetUrl 

func (m *SQLDatabaseEgress) GetUrl() string

func (*SQLDatabaseEgress) Marshal 

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

func (*SQLDatabaseEgress) MarshalLogObject 

func (x *SQLDatabaseEgress) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SQLDatabaseEgress) MarshalTo 

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

func (*SQLDatabaseEgress) MarshalToSizedBuffer 

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

func (*SQLDatabaseEgress) ProtoMessage 

func (*SQLDatabaseEgress) ProtoMessage()

func (*SQLDatabaseEgress) Reset 

func (m *SQLDatabaseEgress) Reset()

func (*SQLDatabaseEgress) Size 

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

func (*SQLDatabaseEgress) String 

func (m *SQLDatabaseEgress) String() string

func (*SQLDatabaseEgress) Unmarshal 

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

func (*SQLDatabaseEgress) XXX_DiscardUnknown 

func (m *SQLDatabaseEgress) XXX_DiscardUnknown()

func (*SQLDatabaseEgress) XXX_Marshal 

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

func (*SQLDatabaseEgress) XXX_Merge 

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

func (*SQLDatabaseEgress) XXX_Size 

func (m *SQLDatabaseEgress) XXX_Size() int

func (*SQLDatabaseEgress) XXX_Unmarshal 

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

type SQLDatabaseEgress_FileFormat 

type SQLDatabaseEgress_FileFormat struct {
	Type                 SQLDatabaseEgress_FileFormat_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pfs_v2.SQLDatabaseEgress_FileFormat_Type" json:"type,omitempty"`
	Columns              []string                          `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*SQLDatabaseEgress_FileFormat) Descriptor 

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

func (*SQLDatabaseEgress_FileFormat) GetColumns 

func (m *SQLDatabaseEgress_FileFormat) GetColumns() []string

func (*SQLDatabaseEgress_FileFormat) GetType 

func (m *SQLDatabaseEgress_FileFormat) GetType() SQLDatabaseEgress_FileFormat_Type

func (*SQLDatabaseEgress_FileFormat) Marshal 

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

func (*SQLDatabaseEgress_FileFormat) MarshalLogObject 

func (x *SQLDatabaseEgress_FileFormat) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SQLDatabaseEgress_FileFormat) MarshalTo 

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

func (*SQLDatabaseEgress_FileFormat) MarshalToSizedBuffer 

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

func (*SQLDatabaseEgress_FileFormat) ProtoMessage 

func (*SQLDatabaseEgress_FileFormat) ProtoMessage()

func (*SQLDatabaseEgress_FileFormat) Reset 

func (m *SQLDatabaseEgress_FileFormat) Reset()

func (*SQLDatabaseEgress_FileFormat) Size 

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

func (*SQLDatabaseEgress_FileFormat) String 

func (m *SQLDatabaseEgress_FileFormat) String() string

func (*SQLDatabaseEgress_FileFormat) Unmarshal 

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

func (*SQLDatabaseEgress_FileFormat) XXX_DiscardUnknown 

func (m *SQLDatabaseEgress_FileFormat) XXX_DiscardUnknown()

func (*SQLDatabaseEgress_FileFormat) XXX_Marshal 

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

func (*SQLDatabaseEgress_FileFormat) XXX_Merge 

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

func (*SQLDatabaseEgress_FileFormat) XXX_Size 

func (m *SQLDatabaseEgress_FileFormat) XXX_Size() int

func (*SQLDatabaseEgress_FileFormat) XXX_Unmarshal 

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

type SQLDatabaseEgress_FileFormat_Type 

type SQLDatabaseEgress_FileFormat_Type int32
const (
	SQLDatabaseEgress_FileFormat_UNKNOWN SQLDatabaseEgress_FileFormat_Type = 0
	SQLDatabaseEgress_FileFormat_CSV     SQLDatabaseEgress_FileFormat_Type = 1
	SQLDatabaseEgress_FileFormat_JSON    SQLDatabaseEgress_FileFormat_Type = 2
	SQLDatabaseEgress_FileFormat_PARQUET SQLDatabaseEgress_FileFormat_Type = 3
)

func (SQLDatabaseEgress_FileFormat_Type) EnumDescriptor 

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

func (SQLDatabaseEgress_FileFormat_Type) String 

func (x SQLDatabaseEgress_FileFormat_Type) String() string

type SQLDatabaseEgress_Secret 

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

func (*SQLDatabaseEgress_Secret) Descriptor 

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

func (*SQLDatabaseEgress_Secret) GetKey 

func (m *SQLDatabaseEgress_Secret) GetKey() string

func (*SQLDatabaseEgress_Secret) GetName 

func (m *SQLDatabaseEgress_Secret) GetName() string

func (*SQLDatabaseEgress_Secret) Marshal 

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

func (*SQLDatabaseEgress_Secret) MarshalLogObject 

func (x *SQLDatabaseEgress_Secret) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SQLDatabaseEgress_Secret) MarshalTo 

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

func (*SQLDatabaseEgress_Secret) MarshalToSizedBuffer 

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

func (*SQLDatabaseEgress_Secret) ProtoMessage 

func (*SQLDatabaseEgress_Secret) ProtoMessage()

func (*SQLDatabaseEgress_Secret) Reset 

func (m *SQLDatabaseEgress_Secret) Reset()

func (*SQLDatabaseEgress_Secret) Size 

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

func (*SQLDatabaseEgress_Secret) String 

func (m *SQLDatabaseEgress_Secret) String() string

func (*SQLDatabaseEgress_Secret) Unmarshal 

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

func (*SQLDatabaseEgress_Secret) XXX_DiscardUnknown 

func (m *SQLDatabaseEgress_Secret) XXX_DiscardUnknown()

func (*SQLDatabaseEgress_Secret) XXX_Marshal 

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

func (*SQLDatabaseEgress_Secret) XXX_Merge 

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

func (*SQLDatabaseEgress_Secret) XXX_Size 

func (m *SQLDatabaseEgress_Secret) XXX_Size() int

func (*SQLDatabaseEgress_Secret) XXX_Unmarshal 

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

type ShardFileSetRequest 

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

func (*ShardFileSetRequest) Descriptor 

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

func (*ShardFileSetRequest) GetFileSetId 

func (m *ShardFileSetRequest) GetFileSetId() string

func (*ShardFileSetRequest) Marshal 

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

func (*ShardFileSetRequest) MarshalLogObject 

func (x *ShardFileSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ShardFileSetRequest) MarshalTo 

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

func (*ShardFileSetRequest) MarshalToSizedBuffer 

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

func (*ShardFileSetRequest) ProtoMessage 

func (*ShardFileSetRequest) ProtoMessage()

func (*ShardFileSetRequest) Reset 

func (m *ShardFileSetRequest) Reset()

func (*ShardFileSetRequest) Size 

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

func (*ShardFileSetRequest) String 

func (m *ShardFileSetRequest) String() string

func (*ShardFileSetRequest) Unmarshal 

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

func (*ShardFileSetRequest) XXX_DiscardUnknown 

func (m *ShardFileSetRequest) XXX_DiscardUnknown()

func (*ShardFileSetRequest) XXX_Marshal 

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

func (*ShardFileSetRequest) XXX_Merge 

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

func (*ShardFileSetRequest) XXX_Size 

func (m *ShardFileSetRequest) XXX_Size() int

func (*ShardFileSetRequest) XXX_Unmarshal 

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

type ShardFileSetResponse 

type ShardFileSetResponse struct {
	Shards               []*PathRange `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ShardFileSetResponse) Descriptor 

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

func (*ShardFileSetResponse) GetShards 

func (m *ShardFileSetResponse) GetShards() []*PathRange

func (*ShardFileSetResponse) Marshal 

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

func (*ShardFileSetResponse) MarshalLogObject 

func (x *ShardFileSetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ShardFileSetResponse) MarshalTo 

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

func (*ShardFileSetResponse) MarshalToSizedBuffer 

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

func (*ShardFileSetResponse) ProtoMessage 

func (*ShardFileSetResponse) ProtoMessage()

func (*ShardFileSetResponse) Reset 

func (m *ShardFileSetResponse) Reset()

func (*ShardFileSetResponse) Size 

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

func (*ShardFileSetResponse) String 

func (m *ShardFileSetResponse) String() string

func (*ShardFileSetResponse) Unmarshal 

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

func (*ShardFileSetResponse) XXX_DiscardUnknown 

func (m *ShardFileSetResponse) XXX_DiscardUnknown()

func (*ShardFileSetResponse) XXX_Marshal 

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

func (*ShardFileSetResponse) XXX_Merge 

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

func (*ShardFileSetResponse) XXX_Size 

func (m *ShardFileSetResponse) XXX_Size() int

func (*ShardFileSetResponse) XXX_Unmarshal 

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

type SquashCommitSetRequest 

type SquashCommitSetRequest struct {
	CommitSet            *CommitSet `protobuf:"bytes,1,opt,name=commit_set,json=commitSet,proto3" json:"commit_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SquashCommitSetRequest) Descriptor 

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

func (*SquashCommitSetRequest) GetCommitSet 

func (m *SquashCommitSetRequest) GetCommitSet() *CommitSet

func (*SquashCommitSetRequest) Marshal 

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

func (*SquashCommitSetRequest) MarshalLogObject 

func (x *SquashCommitSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SquashCommitSetRequest) MarshalTo 

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

func (*SquashCommitSetRequest) MarshalToSizedBuffer 

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

func (*SquashCommitSetRequest) ProtoMessage 

func (*SquashCommitSetRequest) ProtoMessage()

func (*SquashCommitSetRequest) Reset 

func (m *SquashCommitSetRequest) Reset()

func (*SquashCommitSetRequest) Size 

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

func (*SquashCommitSetRequest) String 

func (m *SquashCommitSetRequest) String() string

func (*SquashCommitSetRequest) Unmarshal 

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

func (*SquashCommitSetRequest) XXX_DiscardUnknown 

func (m *SquashCommitSetRequest) XXX_DiscardUnknown()

func (*SquashCommitSetRequest) XXX_Marshal 

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

func (*SquashCommitSetRequest) XXX_Merge 

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

func (*SquashCommitSetRequest) XXX_Size 

func (m *SquashCommitSetRequest) XXX_Size() int

func (*SquashCommitSetRequest) XXX_Unmarshal 

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

type StartCommitRequest 

type StartCommitRequest struct {
	// parent may be empty in which case the commit that Branch points to will be used as the parent.
	// If the 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,2,opt,name=description,proto3" json:"description,omitempty"`
	Branch               *Branch  `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,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() *Branch

func (*StartCommitRequest) GetDescription 

func (m *StartCommitRequest) GetDescription() string

func (*StartCommitRequest) GetParent 

func (m *StartCommitRequest) GetParent() *Commit

func (*StartCommitRequest) Marshal 

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

func (*StartCommitRequest) MarshalLogObject 

func (x *StartCommitRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*StartCommitRequest) MarshalTo 

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

func (*StartCommitRequest) MarshalToSizedBuffer 

func (m *StartCommitRequest) MarshalToSizedBuffer(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 (m *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_v2.CommitState" json:"state,omitempty"`
	All                  bool        `protobuf:"varint,5,opt,name=all,proto3" json:"all,omitempty"`
	OriginKind           OriginKind  `protobuf:"varint,6,opt,name=origin_kind,json=originKind,proto3,enum=pfs_v2.OriginKind" json:"origin_kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SubscribeCommitRequest) Descriptor 

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

func (*SubscribeCommitRequest) GetAll 

func (m *SubscribeCommitRequest) GetAll() bool

func (*SubscribeCommitRequest) GetBranch 

func (m *SubscribeCommitRequest) GetBranch() string

func (*SubscribeCommitRequest) GetFrom 

func (m *SubscribeCommitRequest) GetFrom() *Commit

func (*SubscribeCommitRequest) GetOriginKind 

func (m *SubscribeCommitRequest) GetOriginKind() OriginKind

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) MarshalLogObject 

func (x *SubscribeCommitRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SubscribeCommitRequest) MarshalTo 

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

func (*SubscribeCommitRequest) MarshalToSizedBuffer 

func (m *SubscribeCommitRequest) MarshalToSizedBuffer(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 (m *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 Trigger 

type Trigger struct {
	// Which branch this trigger refers to
	Branch string `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
	// All indicates that all conditions must be satisfied before the trigger
	// happens, otherwise any conditions being satisfied will trigger it.
	All bool `protobuf:"varint,2,opt,name=all,proto3" json:"all,omitempty"`
	// Triggers if the cron spec has been satisfied since the last trigger and
	// there's been a new commit.
	CronSpec string `protobuf:"bytes,3,opt,name=cron_spec,json=cronSpec,proto3" json:"cron_spec,omitempty"`
	// Triggers if there's been `size` new data added since the last trigger.
	Size_ string `protobuf:"bytes,4,opt,name=size,proto3" json:"size,omitempty"`
	// Triggers if there's been `commits` new commits added since the last trigger.
	Commits              int64    `protobuf:"varint,5,opt,name=commits,proto3" json:"commits,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Trigger defines the conditions under which a head is moved, and to which branch it is moved.

func (*Trigger) Descriptor 

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

func (*Trigger) GetAll 

func (m *Trigger) GetAll() bool

func (*Trigger) GetBranch 

func (m *Trigger) GetBranch() string

func (*Trigger) GetCommits 

func (m *Trigger) GetCommits() int64

func (*Trigger) GetCronSpec 

func (m *Trigger) GetCronSpec() string

func (*Trigger) GetSize_ 

func (m *Trigger) GetSize_() string

func (*Trigger) Marshal 

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

func (*Trigger) MarshalLogObject 

func (x *Trigger) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Trigger) MarshalTo 

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

func (*Trigger) MarshalToSizedBuffer 

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

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) Reset 

func (m *Trigger) Reset()

func (*Trigger) Size 

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

func (*Trigger) String 

func (m *Trigger) String() string

func (*Trigger) Unmarshal 

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

func (*Trigger) XXX_DiscardUnknown 

func (m *Trigger) XXX_DiscardUnknown()

func (*Trigger) XXX_Marshal 

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

func (*Trigger) XXX_Merge 

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

func (*Trigger) XXX_Size 

func (m *Trigger) XXX_Size() int

func (*Trigger) XXX_Unmarshal 

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

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) ActivateAuth 

func (*UnimplementedAPIServer) ActivateAuth(ctx context.Context, req *ActivateAuthRequest) (*ActivateAuthResponse, error)

func (*UnimplementedAPIServer) AddFileSet 

func (*UnimplementedAPIServer) AddFileSet(ctx context.Context, req *AddFileSetRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) CheckStorage 

func (*UnimplementedAPIServer) CheckStorage(ctx context.Context, req *CheckStorageRequest) (*CheckStorageResponse, error)

func (*UnimplementedAPIServer) ClearCache 

func (*UnimplementedAPIServer) ClearCache(ctx context.Context, req *ClearCacheRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) ClearCommit 

func (*UnimplementedAPIServer) ClearCommit(ctx context.Context, req *ClearCommitRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) ComposeFileSet 

func (*UnimplementedAPIServer) ComposeFileSet(ctx context.Context, req *ComposeFileSetRequest) (*CreateFileSetResponse, error)

func (*UnimplementedAPIServer) CreateBranch 

func (*UnimplementedAPIServer) CreateBranch(ctx context.Context, req *CreateBranchRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) CreateFileSet 

func (*UnimplementedAPIServer) CreateFileSet(srv API_CreateFileSetServer) error

func (*UnimplementedAPIServer) CreateProject 

func (*UnimplementedAPIServer) CreateProject(ctx context.Context, req *CreateProjectRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) CreateRepo 

func (*UnimplementedAPIServer) CreateRepo(ctx context.Context, req *CreateRepoRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteAll 

func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *types.Empty) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteBranch 

func (*UnimplementedAPIServer) DeleteBranch(ctx context.Context, req *DeleteBranchRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteProject 

func (*UnimplementedAPIServer) DeleteProject(ctx context.Context, req *DeleteProjectRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteRepo 

func (*UnimplementedAPIServer) DeleteRepo(ctx context.Context, req *DeleteRepoRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteRepos 

func (*UnimplementedAPIServer) DeleteRepos(ctx context.Context, req *DeleteReposRequest) (*DeleteReposResponse, error)

func (*UnimplementedAPIServer) DiffFile 

func (*UnimplementedAPIServer) DiffFile(req *DiffFileRequest, srv API_DiffFileServer) error

func (*UnimplementedAPIServer) DropCommitSet 

func (*UnimplementedAPIServer) DropCommitSet(ctx context.Context, req *DropCommitSetRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) Egress 

func (*UnimplementedAPIServer) Egress(ctx context.Context, req *EgressRequest) (*EgressResponse, error)

func (*UnimplementedAPIServer) FindCommits 

func (*UnimplementedAPIServer) FindCommits(req *FindCommitsRequest, srv API_FindCommitsServer) error

func (*UnimplementedAPIServer) FinishCommit 

func (*UnimplementedAPIServer) FinishCommit(ctx context.Context, req *FinishCommitRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) Fsck 

func (*UnimplementedAPIServer) Fsck(req *FsckRequest, srv API_FsckServer) error

func (*UnimplementedAPIServer) GetCache 

func (*UnimplementedAPIServer) GetCache(ctx context.Context, req *GetCacheRequest) (*GetCacheResponse, error)

func (*UnimplementedAPIServer) GetFile 

func (*UnimplementedAPIServer) GetFile(req *GetFileRequest, srv API_GetFileServer) error

func (*UnimplementedAPIServer) GetFileSet 

func (*UnimplementedAPIServer) GetFileSet(ctx context.Context, req *GetFileSetRequest) (*CreateFileSetResponse, error)

func (*UnimplementedAPIServer) GetFileTAR 

func (*UnimplementedAPIServer) GetFileTAR(req *GetFileRequest, srv API_GetFileTARServer) error

func (*UnimplementedAPIServer) GlobFile 

func (*UnimplementedAPIServer) GlobFile(req *GlobFileRequest, srv API_GlobFileServer) error

func (*UnimplementedAPIServer) InspectBranch 

func (*UnimplementedAPIServer) InspectBranch(ctx context.Context, req *InspectBranchRequest) (*BranchInfo, error)

func (*UnimplementedAPIServer) InspectCommit 

func (*UnimplementedAPIServer) InspectCommit(ctx context.Context, req *InspectCommitRequest) (*CommitInfo, error)

func (*UnimplementedAPIServer) InspectCommitSet 

func (*UnimplementedAPIServer) InspectCommitSet(req *InspectCommitSetRequest, srv API_InspectCommitSetServer) error

func (*UnimplementedAPIServer) InspectFile 

func (*UnimplementedAPIServer) InspectFile(ctx context.Context, req *InspectFileRequest) (*FileInfo, error)

func (*UnimplementedAPIServer) InspectProject 

func (*UnimplementedAPIServer) InspectProject(ctx context.Context, req *InspectProjectRequest) (*ProjectInfo, error)

func (*UnimplementedAPIServer) InspectRepo 

func (*UnimplementedAPIServer) InspectRepo(ctx context.Context, req *InspectRepoRequest) (*RepoInfo, error)

func (*UnimplementedAPIServer) ListBranch 

func (*UnimplementedAPIServer) ListBranch(req *ListBranchRequest, srv API_ListBranchServer) error

func (*UnimplementedAPIServer) ListCommit 

func (*UnimplementedAPIServer) ListCommit(req *ListCommitRequest, srv API_ListCommitServer) error

func (*UnimplementedAPIServer) ListCommitSet 

func (*UnimplementedAPIServer) ListCommitSet(req *ListCommitSetRequest, srv API_ListCommitSetServer) error

func (*UnimplementedAPIServer) ListFile 

func (*UnimplementedAPIServer) ListFile(req *ListFileRequest, srv API_ListFileServer) error

func (*UnimplementedAPIServer) ListProject 

func (*UnimplementedAPIServer) ListProject(req *ListProjectRequest, srv API_ListProjectServer) error

func (*UnimplementedAPIServer) ListRepo 

func (*UnimplementedAPIServer) ListRepo(req *ListRepoRequest, srv API_ListRepoServer) error

func (*UnimplementedAPIServer) ListTask 

func (*UnimplementedAPIServer) ListTask(req *task.ListTaskRequest, srv API_ListTaskServer) error

func (*UnimplementedAPIServer) ModifyFile 

func (*UnimplementedAPIServer) ModifyFile(srv API_ModifyFileServer) error

func (*UnimplementedAPIServer) PutCache 

func (*UnimplementedAPIServer) PutCache(ctx context.Context, req *PutCacheRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) RenewFileSet 

func (*UnimplementedAPIServer) RenewFileSet(ctx context.Context, req *RenewFileSetRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) RunLoadTest 

func (*UnimplementedAPIServer) RunLoadTest(ctx context.Context, req *RunLoadTestRequest) (*RunLoadTestResponse, error)

func (*UnimplementedAPIServer) RunLoadTestDefault 

func (*UnimplementedAPIServer) RunLoadTestDefault(ctx context.Context, req *types.Empty) (*RunLoadTestResponse, error)

func (*UnimplementedAPIServer) ShardFileSet 

func (*UnimplementedAPIServer) ShardFileSet(ctx context.Context, req *ShardFileSetRequest) (*ShardFileSetResponse, error)

func (*UnimplementedAPIServer) SquashCommitSet 

func (*UnimplementedAPIServer) SquashCommitSet(ctx context.Context, req *SquashCommitSetRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) StartCommit 

func (*UnimplementedAPIServer) StartCommit(ctx context.Context, req *StartCommitRequest) (*Commit, error)

func (*UnimplementedAPIServer) SubscribeCommit 

func (*UnimplementedAPIServer) SubscribeCommit(req *SubscribeCommitRequest, srv API_SubscribeCommitServer) error

func (*UnimplementedAPIServer) WalkFile 

func (*UnimplementedAPIServer) WalkFile(req *WalkFileRequest, srv API_WalkFileServer) error

type WalkFileRequest 

type WalkFileRequest struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// Marker for pagination. If set, the files that come after the marker in
	// lexicographical order will be returned. If reverse is also set, the files
	// that come before the marker in lexicographical order will be returned.
	PaginationMarker *File `protobuf:"bytes,2,opt,name=paginationMarker,proto3" json:"paginationMarker,omitempty"`
	// Number of files to return
	Number int64 `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"`
	// If true, return files in reverse order
	Reverse              bool     `protobuf:"varint,4,opt,name=reverse,proto3" json:"reverse,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WalkFileRequest) Descriptor 

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

func (*WalkFileRequest) GetFile 

func (m *WalkFileRequest) GetFile() *File

func (*WalkFileRequest) GetNumber 

func (m *WalkFileRequest) GetNumber() int64

func (*WalkFileRequest) GetPaginationMarker 

func (m *WalkFileRequest) GetPaginationMarker() *File

func (*WalkFileRequest) GetReverse 

func (m *WalkFileRequest) GetReverse() bool

func (*WalkFileRequest) Marshal 

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

func (*WalkFileRequest) MarshalLogObject 

func (x *WalkFileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*WalkFileRequest) MarshalTo 

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

func (*WalkFileRequest) MarshalToSizedBuffer 

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

func (*WalkFileRequest) ProtoMessage 

func (*WalkFileRequest) ProtoMessage()

func (*WalkFileRequest) Reset 

func (m *WalkFileRequest) Reset()

func (*WalkFileRequest) Size 

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

func (*WalkFileRequest) String 

func (m *WalkFileRequest) String() string

func (*WalkFileRequest) Unmarshal 

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

func (*WalkFileRequest) XXX_DiscardUnknown 

func (m *WalkFileRequest) XXX_DiscardUnknown()

func (*WalkFileRequest) XXX_Marshal 

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

func (*WalkFileRequest) XXX_Merge 

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

func (*WalkFileRequest) XXX_Size 

func (m *WalkFileRequest) XXX_Size() int

func (*WalkFileRequest) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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