pfs

package
v2.7.0-alpha.5 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2023 License: Apache-2.0 Imports: 25 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"
)
View Source 
const (
	API_CreateRepo_FullMethodName         = "/pfs_v2.API/CreateRepo"
	API_InspectRepo_FullMethodName        = "/pfs_v2.API/InspectRepo"
	API_ListRepo_FullMethodName           = "/pfs_v2.API/ListRepo"
	API_DeleteRepo_FullMethodName         = "/pfs_v2.API/DeleteRepo"
	API_DeleteRepos_FullMethodName        = "/pfs_v2.API/DeleteRepos"
	API_StartCommit_FullMethodName        = "/pfs_v2.API/StartCommit"
	API_FinishCommit_FullMethodName       = "/pfs_v2.API/FinishCommit"
	API_ClearCommit_FullMethodName        = "/pfs_v2.API/ClearCommit"
	API_InspectCommit_FullMethodName      = "/pfs_v2.API/InspectCommit"
	API_ListCommit_FullMethodName         = "/pfs_v2.API/ListCommit"
	API_SubscribeCommit_FullMethodName    = "/pfs_v2.API/SubscribeCommit"
	API_InspectCommitSet_FullMethodName   = "/pfs_v2.API/InspectCommitSet"
	API_ListCommitSet_FullMethodName      = "/pfs_v2.API/ListCommitSet"
	API_SquashCommitSet_FullMethodName    = "/pfs_v2.API/SquashCommitSet"
	API_DropCommitSet_FullMethodName      = "/pfs_v2.API/DropCommitSet"
	API_FindCommits_FullMethodName        = "/pfs_v2.API/FindCommits"
	API_CreateBranch_FullMethodName       = "/pfs_v2.API/CreateBranch"
	API_InspectBranch_FullMethodName      = "/pfs_v2.API/InspectBranch"
	API_ListBranch_FullMethodName         = "/pfs_v2.API/ListBranch"
	API_DeleteBranch_FullMethodName       = "/pfs_v2.API/DeleteBranch"
	API_ModifyFile_FullMethodName         = "/pfs_v2.API/ModifyFile"
	API_GetFile_FullMethodName            = "/pfs_v2.API/GetFile"
	API_GetFileTAR_FullMethodName         = "/pfs_v2.API/GetFileTAR"
	API_InspectFile_FullMethodName        = "/pfs_v2.API/InspectFile"
	API_ListFile_FullMethodName           = "/pfs_v2.API/ListFile"
	API_WalkFile_FullMethodName           = "/pfs_v2.API/WalkFile"
	API_GlobFile_FullMethodName           = "/pfs_v2.API/GlobFile"
	API_DiffFile_FullMethodName           = "/pfs_v2.API/DiffFile"
	API_ActivateAuth_FullMethodName       = "/pfs_v2.API/ActivateAuth"
	API_DeleteAll_FullMethodName          = "/pfs_v2.API/DeleteAll"
	API_Fsck_FullMethodName               = "/pfs_v2.API/Fsck"
	API_CreateFileSet_FullMethodName      = "/pfs_v2.API/CreateFileSet"
	API_GetFileSet_FullMethodName         = "/pfs_v2.API/GetFileSet"
	API_AddFileSet_FullMethodName         = "/pfs_v2.API/AddFileSet"
	API_RenewFileSet_FullMethodName       = "/pfs_v2.API/RenewFileSet"
	API_ComposeFileSet_FullMethodName     = "/pfs_v2.API/ComposeFileSet"
	API_ShardFileSet_FullMethodName       = "/pfs_v2.API/ShardFileSet"
	API_CheckStorage_FullMethodName       = "/pfs_v2.API/CheckStorage"
	API_PutCache_FullMethodName           = "/pfs_v2.API/PutCache"
	API_GetCache_FullMethodName           = "/pfs_v2.API/GetCache"
	API_ClearCache_FullMethodName         = "/pfs_v2.API/ClearCache"
	API_RunLoadTest_FullMethodName        = "/pfs_v2.API/RunLoadTest"
	API_RunLoadTestDefault_FullMethodName = "/pfs_v2.API/RunLoadTestDefault"
	API_ListTask_FullMethodName           = "/pfs_v2.API/ListTask"
	API_Egress_FullMethodName             = "/pfs_v2.API/Egress"
	API_CreateProject_FullMethodName      = "/pfs_v2.API/CreateProject"
	API_InspectProject_FullMethodName     = "/pfs_v2.API/InspectProject"
	API_ListProject_FullMethodName        = "/pfs_v2.API/ListProject"
	API_DeleteProject_FullMethodName      = "/pfs_v2.API/DeleteProject"
)

Variables

View Source 
var (
	OriginKind_name = map[int32]string{
		0: "ORIGIN_KIND_UNKNOWN",
		1: "USER",
		2: "AUTO",
		3: "FSCK",
	}
	OriginKind_value = map[string]int32{
		"ORIGIN_KIND_UNKNOWN": 0,
		"USER":                1,
		"AUTO":                2,
		"FSCK":                3,
	}
)

Enum value maps for OriginKind.

View Source 
var (
	FileType_name = map[int32]string{
		0: "RESERVED",
		1: "FILE",
		2: "DIR",
	}
	FileType_value = map[string]int32{
		"RESERVED": 0,
		"FILE":     1,
		"DIR":      2,
	}
)

Enum value maps for FileType.

View Source 
var (
	CommitState_name = map[int32]string{
		0: "COMMIT_STATE_UNKNOWN",
		1: "STARTED",
		2: "READY",
		3: "FINISHING",
		4: "FINISHED",
	}
	CommitState_value = map[string]int32{
		"COMMIT_STATE_UNKNOWN": 0,
		"STARTED":              1,
		"READY":                2,
		"FINISHING":            3,
		"FINISHED":             4,
	}
)

Enum value maps for CommitState.

View Source 
var (
	Delimiter_name = map[int32]string{
		0: "NONE",
		1: "JSON",
		2: "LINE",
		3: "SQL",
		4: "CSV",
	}
	Delimiter_value = map[string]int32{
		"NONE": 0,
		"JSON": 1,
		"LINE": 2,
		"SQL":  3,
		"CSV":  4,
	}
)

Enum value maps for Delimiter.

View Source 
var (
	SQLDatabaseEgress_FileFormat_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "CSV",
		2: "JSON",
		3: "PARQUET",
	}
	SQLDatabaseEgress_FileFormat_Type_value = map[string]int32{
		"UNKNOWN": 0,
		"CSV":     1,
		"JSON":    2,
		"PARQUET": 3,
	}
)

Enum value maps for SQLDatabaseEgress_FileFormat_Type.

View Source 
var API_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pfs_v2.API",
	HandlerType: (*APIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateRepo",
			Handler:    _API_CreateRepo_Handler,
		},
		{
			MethodName: "InspectRepo",
			Handler:    _API_InspectRepo_Handler,
		},
		{
			MethodName: "DeleteRepo",
			Handler:    _API_DeleteRepo_Handler,
		},
		{
			MethodName: "DeleteRepos",
			Handler:    _API_DeleteRepos_Handler,
		},
		{
			MethodName: "StartCommit",
			Handler:    _API_StartCommit_Handler,
		},
		{
			MethodName: "FinishCommit",
			Handler:    _API_FinishCommit_Handler,
		},
		{
			MethodName: "ClearCommit",
			Handler:    _API_ClearCommit_Handler,
		},
		{
			MethodName: "InspectCommit",
			Handler:    _API_InspectCommit_Handler,
		},
		{
			MethodName: "SquashCommitSet",
			Handler:    _API_SquashCommitSet_Handler,
		},
		{
			MethodName: "DropCommitSet",
			Handler:    _API_DropCommitSet_Handler,
		},
		{
			MethodName: "CreateBranch",
			Handler:    _API_CreateBranch_Handler,
		},
		{
			MethodName: "InspectBranch",
			Handler:    _API_InspectBranch_Handler,
		},
		{
			MethodName: "DeleteBranch",
			Handler:    _API_DeleteBranch_Handler,
		},
		{
			MethodName: "InspectFile",
			Handler:    _API_InspectFile_Handler,
		},
		{
			MethodName: "ActivateAuth",
			Handler:    _API_ActivateAuth_Handler,
		},
		{
			MethodName: "DeleteAll",
			Handler:    _API_DeleteAll_Handler,
		},
		{
			MethodName: "GetFileSet",
			Handler:    _API_GetFileSet_Handler,
		},
		{
			MethodName: "AddFileSet",
			Handler:    _API_AddFileSet_Handler,
		},
		{
			MethodName: "RenewFileSet",
			Handler:    _API_RenewFileSet_Handler,
		},
		{
			MethodName: "ComposeFileSet",
			Handler:    _API_ComposeFileSet_Handler,
		},
		{
			MethodName: "ShardFileSet",
			Handler:    _API_ShardFileSet_Handler,
		},
		{
			MethodName: "CheckStorage",
			Handler:    _API_CheckStorage_Handler,
		},
		{
			MethodName: "PutCache",
			Handler:    _API_PutCache_Handler,
		},
		{
			MethodName: "GetCache",
			Handler:    _API_GetCache_Handler,
		},
		{
			MethodName: "ClearCache",
			Handler:    _API_ClearCache_Handler,
		},
		{
			MethodName: "RunLoadTest",
			Handler:    _API_RunLoadTest_Handler,
		},
		{
			MethodName: "RunLoadTestDefault",
			Handler:    _API_RunLoadTestDefault_Handler,
		},
		{
			MethodName: "Egress",
			Handler:    _API_Egress_Handler,
		},
		{
			MethodName: "CreateProject",
			Handler:    _API_CreateProject_Handler,
		},
		{
			MethodName: "InspectProject",
			Handler:    _API_InspectProject_Handler,
		},
		{
			MethodName: "DeleteProject",
			Handler:    _API_DeleteProject_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListRepo",
			Handler:       _API_ListRepo_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListCommit",
			Handler:       _API_ListCommit_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeCommit",
			Handler:       _API_SubscribeCommit_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "InspectCommitSet",
			Handler:       _API_InspectCommitSet_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListCommitSet",
			Handler:       _API_ListCommitSet_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "FindCommits",
			Handler:       _API_FindCommits_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListBranch",
			Handler:       _API_ListBranch_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ModifyFile",
			Handler:       _API_ModifyFile_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "GetFile",
			Handler:       _API_GetFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetFileTAR",
			Handler:       _API_GetFileTAR_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListFile",
			Handler:       _API_ListFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WalkFile",
			Handler:       _API_WalkFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GlobFile",
			Handler:       _API_GlobFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DiffFile",
			Handler:       _API_DiffFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Fsck",
			Handler:       _API_Fsck_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CreateFileSet",
			Handler:       _API_CreateFileSet_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ListTask",
			Handler:       _API_ListTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListProject",
			Handler:       _API_ListProject_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pfs/pfs.proto",
}

API_ServiceDesc is the grpc.ServiceDesc for API service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pfs_pfs_proto protoreflect.FileDescriptor

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.ServiceRegistrar, srv APIServer)

Types

type APIClient 

type APIClient interface {
	// CreateRepo creates a new repo.
	CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*emptypb.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) (*emptypb.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) (*emptypb.Empty, error)
	// ClearCommit removes all data from the commit.
	ClearCommit(ctx context.Context, in *ClearCommitRequest, opts ...grpc.CallOption) (*emptypb.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) (*emptypb.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) (*emptypb.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) (*emptypb.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) (*emptypb.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 *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.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) (*emptypb.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) (*emptypb.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) (*emptypb.Empty, error)
	GetCache(ctx context.Context, in *GetCacheRequest, opts ...grpc.CallOption) (*GetCacheResponse, error)
	ClearCache(ctx context.Context, in *ClearCacheRequest, opts ...grpc.CallOption) (*emptypb.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 *emptypb.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) (*emptypb.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) (*emptypb.Empty, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc grpc.ClientConnInterface) APIClient

type APIServer 

type APIServer interface {
	// CreateRepo creates a new repo.
	CreateRepo(context.Context, *CreateRepoRequest) (*emptypb.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) (*emptypb.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) (*emptypb.Empty, error)
	// ClearCommit removes all data from the commit.
	ClearCommit(context.Context, *ClearCommitRequest) (*emptypb.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) (*emptypb.Empty, error)
	// DropCommitSet drops the commits of a CommitSet and all data included in the commits.
	DropCommitSet(context.Context, *DropCommitSetRequest) (*emptypb.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) (*emptypb.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) (*emptypb.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, *emptypb.Empty) (*emptypb.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) (*emptypb.Empty, error)
	// RenewFileSet prevents a file set from being deleted for a set amount of time.
	RenewFileSet(context.Context, *RenewFileSetRequest) (*emptypb.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) (*emptypb.Empty, error)
	GetCache(context.Context, *GetCacheRequest) (*GetCacheResponse, error)
	ClearCache(context.Context, *ClearCacheRequest) (*emptypb.Empty, error)
	// RunLoadTest runs a load test.
	RunLoadTest(context.Context, *RunLoadTestRequest) (*RunLoadTestResponse, error)
	// RunLoadTestDefault runs the default load tests.
	RunLoadTestDefault(context.Context, *emptypb.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) (*emptypb.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) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility

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() (*wrapperspb.BytesValue, error)
	grpc.ClientStream
}

type API_GetFileServer 

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

type API_GetFileTARClient 

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

type API_GetFileTARServer 

type API_GetFileTARServer interface {
	Send(*wrapperspb.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() (*emptypb.Empty, error)
	grpc.ClientStream
}

type API_ModifyFileServer 

type API_ModifyFileServer interface {
	SendAndClose(*emptypb.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 {
	// contains filtered or unexported fields
}

func (*ActivateAuthRequest) Descriptor deprecated 

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

Deprecated: Use ActivateAuthRequest.ProtoReflect.Descriptor instead.

func (*ActivateAuthRequest) MarshalLogObject 

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

func (*ActivateAuthRequest) ProtoMessage 

func (*ActivateAuthRequest) ProtoMessage()

func (*ActivateAuthRequest) ProtoReflect added in v2.7.0 

func (x *ActivateAuthRequest) ProtoReflect() protoreflect.Message

func (*ActivateAuthRequest) Reset 

func (x *ActivateAuthRequest) Reset()

func (*ActivateAuthRequest) String 

func (x *ActivateAuthRequest) String() string

type ActivateAuthResponse 

type ActivateAuthResponse struct {
	// contains filtered or unexported fields
}

func (*ActivateAuthResponse) Descriptor deprecated 

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

Deprecated: Use ActivateAuthResponse.ProtoReflect.Descriptor instead.

func (*ActivateAuthResponse) MarshalLogObject 

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

func (*ActivateAuthResponse) ProtoMessage 

func (*ActivateAuthResponse) ProtoMessage()

func (*ActivateAuthResponse) ProtoReflect added in v2.7.0 

func (x *ActivateAuthResponse) ProtoReflect() protoreflect.Message

func (*ActivateAuthResponse) Reset 

func (x *ActivateAuthResponse) Reset()

func (*ActivateAuthResponse) String 

func (x *ActivateAuthResponse) String() string

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 assignable to Source:
	//
	//	*AddFile_Raw
	//	*AddFile_Url
	Source isAddFile_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*AddFile) Descriptor deprecated 

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

Deprecated: Use AddFile.ProtoReflect.Descriptor instead.

func (*AddFile) GetDatum 

func (x *AddFile) GetDatum() string

func (*AddFile) GetPath 

func (x *AddFile) GetPath() string

func (*AddFile) GetRaw 

func (x *AddFile) GetRaw() *wrapperspb.BytesValue

func (*AddFile) GetSource 

func (m *AddFile) GetSource() isAddFile_Source

func (*AddFile) GetUrl 

func (x *AddFile) GetUrl() *AddFile_URLSource

func (*AddFile) MarshalLogObject 

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

func (*AddFile) ProtoMessage 

func (*AddFile) ProtoMessage()

func (*AddFile) ProtoReflect added in v2.7.0 

func (x *AddFile) ProtoReflect() protoreflect.Message

func (*AddFile) Reset 

func (x *AddFile) Reset()

func (*AddFile) String 

func (x *AddFile) String() string

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"`
	// contains filtered or unexported fields
}

func (*AddFileSetRequest) Descriptor deprecated 

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

Deprecated: Use AddFileSetRequest.ProtoReflect.Descriptor instead.

func (*AddFileSetRequest) GetCommit 

func (x *AddFileSetRequest) GetCommit() *Commit

func (*AddFileSetRequest) GetFileSetId 

func (x *AddFileSetRequest) GetFileSetId() string

func (*AddFileSetRequest) MarshalLogObject 

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

func (*AddFileSetRequest) ProtoMessage 

func (*AddFileSetRequest) ProtoMessage()

func (*AddFileSetRequest) ProtoReflect added in v2.7.0 

func (x *AddFileSetRequest) ProtoReflect() protoreflect.Message

func (*AddFileSetRequest) Reset 

func (x *AddFileSetRequest) Reset()

func (*AddFileSetRequest) String 

func (x *AddFileSetRequest) String() string

type AddFile_Raw 

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

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"`
	// contains filtered or unexported fields
}

func (*AddFile_URLSource) Descriptor deprecated 

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

Deprecated: Use AddFile_URLSource.ProtoReflect.Descriptor instead.

func (*AddFile_URLSource) GetConcurrency 

func (x *AddFile_URLSource) GetConcurrency() uint32

func (*AddFile_URLSource) GetRecursive 

func (x *AddFile_URLSource) GetRecursive() bool

func (*AddFile_URLSource) GetURL 

func (x *AddFile_URLSource) GetURL() string

func (*AddFile_URLSource) MarshalLogObject 

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

func (*AddFile_URLSource) ProtoMessage 

func (*AddFile_URLSource) ProtoMessage()

func (*AddFile_URLSource) ProtoReflect added in v2.7.0 

func (x *AddFile_URLSource) ProtoReflect() protoreflect.Message

func (*AddFile_URLSource) Reset 

func (x *AddFile_URLSource) Reset()

func (*AddFile_URLSource) String 

func (x *AddFile_URLSource) String() string

type AddFile_Url 

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

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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use AuthInfo.ProtoReflect.Descriptor instead.

func (*AuthInfo) GetPermissions 

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

func (*AuthInfo) GetRoles 

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

func (*AuthInfo) MarshalLogObject 

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

func (*AuthInfo) ProtoMessage 

func (*AuthInfo) ProtoMessage()

func (*AuthInfo) ProtoReflect added in v2.7.0 

func (x *AuthInfo) ProtoReflect() protoreflect.Message

func (*AuthInfo) Reset 

func (x *AuthInfo) Reset()

func (*AuthInfo) String 

func (x *AuthInfo) String() string

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"`
	// contains filtered or unexported fields
}

func (*Branch) Descriptor deprecated 

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

Deprecated: Use Branch.ProtoReflect.Descriptor instead.

func (*Branch) GetName 

func (x *Branch) GetName() string

func (*Branch) GetRepo 

func (x *Branch) GetRepo() *Repo

func (*Branch) MarshalLogObject 

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

func (*Branch) NewCommit 

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

func (*Branch) ProtoMessage 

func (*Branch) ProtoMessage()

func (*Branch) ProtoReflect added in v2.7.0 

func (x *Branch) ProtoReflect() protoreflect.Message

func (*Branch) Reset 

func (x *Branch) Reset()

func (*Branch) String 

func (b *Branch) String() string

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"`
	// contains filtered or unexported fields
}

func (*BranchInfo) Descriptor deprecated 

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

Deprecated: Use BranchInfo.ProtoReflect.Descriptor instead.

func (*BranchInfo) GetBranch 

func (x *BranchInfo) GetBranch() *Branch

func (*BranchInfo) GetDirectProvenance 

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

func (*BranchInfo) GetHead 

func (x *BranchInfo) GetHead() *Commit

func (*BranchInfo) GetProvenance 

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

func (*BranchInfo) GetSubvenance 

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

func (*BranchInfo) GetTrigger 

func (x *BranchInfo) GetTrigger() *Trigger

func (*BranchInfo) MarshalLogObject 

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

func (*BranchInfo) ProtoMessage 

func (*BranchInfo) ProtoMessage()

func (*BranchInfo) ProtoReflect added in v2.7.0 

func (x *BranchInfo) ProtoReflect() protoreflect.Message

func (*BranchInfo) Reset 

func (x *BranchInfo) Reset()

func (*BranchInfo) String 

func (x *BranchInfo) String() string

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"`
	// contains filtered or unexported fields
}

func (*CheckStorageRequest) Descriptor deprecated 

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

Deprecated: Use CheckStorageRequest.ProtoReflect.Descriptor instead.

func (*CheckStorageRequest) GetChunkBegin 

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

func (*CheckStorageRequest) GetChunkEnd 

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

func (*CheckStorageRequest) GetReadChunkData 

func (x *CheckStorageRequest) GetReadChunkData() bool

func (*CheckStorageRequest) MarshalLogObject 

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

func (*CheckStorageRequest) ProtoMessage 

func (*CheckStorageRequest) ProtoMessage()

func (*CheckStorageRequest) ProtoReflect added in v2.7.0 

func (x *CheckStorageRequest) ProtoReflect() protoreflect.Message

func (*CheckStorageRequest) Reset 

func (x *CheckStorageRequest) Reset()

func (*CheckStorageRequest) String 

func (x *CheckStorageRequest) String() string

type CheckStorageResponse 

type CheckStorageResponse struct {
	ChunkObjectCount int64 `protobuf:"varint,1,opt,name=chunk_object_count,json=chunkObjectCount,proto3" json:"chunk_object_count,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckStorageResponse) Descriptor deprecated 

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

Deprecated: Use CheckStorageResponse.ProtoReflect.Descriptor instead.

func (*CheckStorageResponse) GetChunkObjectCount 

func (x *CheckStorageResponse) GetChunkObjectCount() int64

func (*CheckStorageResponse) MarshalLogObject 

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

func (*CheckStorageResponse) ProtoMessage 

func (*CheckStorageResponse) ProtoMessage()

func (*CheckStorageResponse) ProtoReflect added in v2.7.0 

func (x *CheckStorageResponse) ProtoReflect() protoreflect.Message

func (*CheckStorageResponse) Reset 

func (x *CheckStorageResponse) Reset()

func (*CheckStorageResponse) String 

func (x *CheckStorageResponse) String() string

type ClearCacheRequest 

type ClearCacheRequest struct {
	TagPrefix string `protobuf:"bytes,1,opt,name=tag_prefix,json=tagPrefix,proto3" json:"tag_prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ClearCacheRequest) Descriptor deprecated 

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

Deprecated: Use ClearCacheRequest.ProtoReflect.Descriptor instead.

func (*ClearCacheRequest) GetTagPrefix 

func (x *ClearCacheRequest) GetTagPrefix() string

func (*ClearCacheRequest) MarshalLogObject 

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

func (*ClearCacheRequest) ProtoMessage 

func (*ClearCacheRequest) ProtoMessage()

func (*ClearCacheRequest) ProtoReflect added in v2.7.0 

func (x *ClearCacheRequest) ProtoReflect() protoreflect.Message

func (*ClearCacheRequest) Reset 

func (x *ClearCacheRequest) Reset()

func (*ClearCacheRequest) String 

func (x *ClearCacheRequest) String() string

type ClearCommitRequest 

type ClearCommitRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// contains filtered or unexported fields
}

func (*ClearCommitRequest) Descriptor deprecated 

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

Deprecated: Use ClearCommitRequest.ProtoReflect.Descriptor instead.

func (*ClearCommitRequest) GetCommit 

func (x *ClearCommitRequest) GetCommit() *Commit

func (*ClearCommitRequest) MarshalLogObject 

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

func (*ClearCommitRequest) ProtoMessage 

func (*ClearCommitRequest) ProtoMessage()

func (*ClearCommitRequest) ProtoReflect added in v2.7.0 

func (x *ClearCommitRequest) ProtoReflect() protoreflect.Message

func (*ClearCommitRequest) Reset 

func (x *ClearCommitRequest) Reset()

func (*ClearCommitRequest) String 

func (x *ClearCommitRequest) String() string

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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use Commit.ProtoReflect.Descriptor instead.

func (*Commit) GetBranch 

func (x *Commit) GetBranch() *Branch

func (*Commit) GetId added in v2.7.0 

func (x *Commit) GetId() string

func (*Commit) GetRepo 

func (x *Commit) GetRepo() *Repo

func (*Commit) MarshalLogObject 

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

func (*Commit) NewFile 

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

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) ProtoReflect added in v2.7.0 

func (x *Commit) ProtoReflect() protoreflect.Message

func (*Commit) Reset 

func (x *Commit) Reset()

func (*Commit) String 

func (c *Commit) String() string

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             *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started,proto3" json:"started,omitempty"`
	Finishing           *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=finishing,proto3" json:"finishing,omitempty"`
	Finished            *timestamppb.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"`
	// contains filtered or unexported fields
}

CommitInfo is the main data structure representing a commit in etcd

func (*CommitInfo) Descriptor deprecated 

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

Deprecated: Use CommitInfo.ProtoReflect.Descriptor instead.

func (*CommitInfo) GetChildCommits 

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

func (*CommitInfo) GetCommit 

func (x *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetDescription 

func (x *CommitInfo) GetDescription() string

func (*CommitInfo) GetDetails 

func (x *CommitInfo) GetDetails() *CommitInfo_Details

func (*CommitInfo) GetDirectProvenance 

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

func (*CommitInfo) GetError 

func (x *CommitInfo) GetError() string

func (*CommitInfo) GetFinished 

func (x *CommitInfo) GetFinished() *timestamppb.Timestamp

func (*CommitInfo) GetFinishing 

func (x *CommitInfo) GetFinishing() *timestamppb.Timestamp

func (*CommitInfo) GetOrigin 

func (x *CommitInfo) GetOrigin() *CommitOrigin

func (*CommitInfo) GetParentCommit 

func (x *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetSizeBytesUpperBound 

func (x *CommitInfo) GetSizeBytesUpperBound() int64

func (*CommitInfo) GetStarted 

func (x *CommitInfo) GetStarted() *timestamppb.Timestamp

func (*CommitInfo) MarshalLogObject 

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

func (*CommitInfo) ProtoMessage 

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) ProtoReflect added in v2.7.0 

func (x *CommitInfo) ProtoReflect() protoreflect.Message

func (*CommitInfo) Reset 

func (x *CommitInfo) Reset()

func (*CommitInfo) String 

func (x *CommitInfo) String() string

type CommitInfo_Details 

type CommitInfo_Details struct {
	SizeBytes      int64                `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	CompactingTime *durationpb.Duration `protobuf:"bytes,2,opt,name=compacting_time,json=compactingTime,proto3" json:"compacting_time,omitempty"`
	ValidatingTime *durationpb.Duration `protobuf:"bytes,3,opt,name=validating_time,json=validatingTime,proto3" json:"validating_time,omitempty"`
	// contains filtered or unexported fields
}

Details are only provided when explicitly requested

func (*CommitInfo_Details) Descriptor deprecated 

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

Deprecated: Use CommitInfo_Details.ProtoReflect.Descriptor instead.

func (*CommitInfo_Details) GetCompactingTime 

func (x *CommitInfo_Details) GetCompactingTime() *durationpb.Duration

func (*CommitInfo_Details) GetSizeBytes 

func (x *CommitInfo_Details) GetSizeBytes() int64

func (*CommitInfo_Details) GetValidatingTime 

func (x *CommitInfo_Details) GetValidatingTime() *durationpb.Duration

func (*CommitInfo_Details) MarshalLogObject 

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

func (*CommitInfo_Details) ProtoMessage 

func (*CommitInfo_Details) ProtoMessage()

func (*CommitInfo_Details) ProtoReflect added in v2.7.0 

func (x *CommitInfo_Details) ProtoReflect() protoreflect.Message

func (*CommitInfo_Details) Reset 

func (x *CommitInfo_Details) Reset()

func (*CommitInfo_Details) String 

func (x *CommitInfo_Details) String() string

type CommitOrigin 

type CommitOrigin struct {
	Kind OriginKind `protobuf:"varint,1,opt,name=kind,proto3,enum=pfs_v2.OriginKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitOrigin) Descriptor deprecated 

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

Deprecated: Use CommitOrigin.ProtoReflect.Descriptor instead.

func (*CommitOrigin) GetKind 

func (x *CommitOrigin) GetKind() OriginKind

func (*CommitOrigin) MarshalLogObject 

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

func (*CommitOrigin) ProtoMessage 

func (*CommitOrigin) ProtoMessage()

func (*CommitOrigin) ProtoReflect added in v2.7.0 

func (x *CommitOrigin) ProtoReflect() protoreflect.Message

func (*CommitOrigin) Reset 

func (x *CommitOrigin) Reset()

func (*CommitOrigin) String 

func (x *CommitOrigin) String() string

type CommitSet 

type CommitSet struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitSet) Descriptor deprecated 

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

Deprecated: Use CommitSet.ProtoReflect.Descriptor instead.

func (*CommitSet) GetId added in v2.7.0 

func (x *CommitSet) GetId() string

func (*CommitSet) MarshalLogObject 

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

func (*CommitSet) ProtoMessage 

func (*CommitSet) ProtoMessage()

func (*CommitSet) ProtoReflect added in v2.7.0 

func (x *CommitSet) ProtoReflect() protoreflect.Message

func (*CommitSet) Reset 

func (x *CommitSet) Reset()

func (*CommitSet) String 

func (x *CommitSet) String() string

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"`
	// contains filtered or unexported fields
}

func (*CommitSetInfo) Descriptor deprecated 

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

Deprecated: Use CommitSetInfo.ProtoReflect.Descriptor instead.

func (*CommitSetInfo) GetCommitSet 

func (x *CommitSetInfo) GetCommitSet() *CommitSet

func (*CommitSetInfo) GetCommits 

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

func (*CommitSetInfo) MarshalLogObject 

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

func (*CommitSetInfo) ProtoMessage 

func (*CommitSetInfo) ProtoMessage()

func (*CommitSetInfo) ProtoReflect added in v2.7.0 

func (x *CommitSetInfo) ProtoReflect() protoreflect.Message

func (*CommitSetInfo) Reset 

func (x *CommitSetInfo) Reset()

func (*CommitSetInfo) String 

func (x *CommitSetInfo) String() string

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 // The commit has been started, all commits satisfy this state.
	CommitState_READY                CommitState = 2 // The commit has been started, and all of its provenant commits have been finished.
	CommitState_FINISHING            CommitState = 3 // The commit is in the process of being finished.
	CommitState_FINISHED             CommitState = 4 // The commit has been finished.
)

func (CommitState) Descriptor added in v2.7.0 

func (CommitState) Descriptor() protoreflect.EnumDescriptor

func (CommitState) Enum added in v2.7.0 

func (x CommitState) Enum() *CommitState

func (CommitState) EnumDescriptor deprecated 

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

Deprecated: Use CommitState.Descriptor instead.

func (CommitState) Number added in v2.7.0 

func (x CommitState) Number() protoreflect.EnumNumber

func (CommitState) String 

func (x CommitState) String() string

func (CommitState) Type added in v2.7.0 

func (CommitState) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*ComposeFileSetRequest) Descriptor deprecated 

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

Deprecated: Use ComposeFileSetRequest.ProtoReflect.Descriptor instead.

func (*ComposeFileSetRequest) GetCompact 

func (x *ComposeFileSetRequest) GetCompact() bool

func (*ComposeFileSetRequest) GetFileSetIds 

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

func (*ComposeFileSetRequest) GetTtlSeconds 

func (x *ComposeFileSetRequest) GetTtlSeconds() int64

func (*ComposeFileSetRequest) MarshalLogObject 

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

func (*ComposeFileSetRequest) ProtoMessage 

func (*ComposeFileSetRequest) ProtoMessage()

func (*ComposeFileSetRequest) ProtoReflect added in v2.7.0 

func (x *ComposeFileSetRequest) ProtoReflect() protoreflect.Message

func (*ComposeFileSetRequest) Reset 

func (x *ComposeFileSetRequest) Reset()

func (*ComposeFileSetRequest) String 

func (x *ComposeFileSetRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CopyFile) Descriptor deprecated 

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

Deprecated: Use CopyFile.ProtoReflect.Descriptor instead.

func (*CopyFile) GetAppend 

func (x *CopyFile) GetAppend() bool

func (*CopyFile) GetDatum 

func (x *CopyFile) GetDatum() string

func (*CopyFile) GetDst 

func (x *CopyFile) GetDst() string

func (*CopyFile) GetSrc 

func (x *CopyFile) GetSrc() *File

func (*CopyFile) MarshalLogObject 

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

func (*CopyFile) ProtoMessage 

func (*CopyFile) ProtoMessage()

func (*CopyFile) ProtoReflect added in v2.7.0 

func (x *CopyFile) ProtoReflect() protoreflect.Message

func (*CopyFile) Reset 

func (x *CopyFile) Reset()

func (*CopyFile) String 

func (x *CopyFile) String() string

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"` // overrides the default behavior of using the same CommitSet as 'head'
	// contains filtered or unexported fields
}

func (*CreateBranchRequest) Descriptor deprecated 

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

Deprecated: Use CreateBranchRequest.ProtoReflect.Descriptor instead.

func (*CreateBranchRequest) GetBranch 

func (x *CreateBranchRequest) GetBranch() *Branch

func (*CreateBranchRequest) GetHead 

func (x *CreateBranchRequest) GetHead() *Commit

func (*CreateBranchRequest) GetNewCommitSet 

func (x *CreateBranchRequest) GetNewCommitSet() bool

func (*CreateBranchRequest) GetProvenance 

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

func (*CreateBranchRequest) GetTrigger 

func (x *CreateBranchRequest) GetTrigger() *Trigger

func (*CreateBranchRequest) MarshalLogObject 

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

func (*CreateBranchRequest) ProtoMessage 

func (*CreateBranchRequest) ProtoMessage()

func (*CreateBranchRequest) ProtoReflect added in v2.7.0 

func (x *CreateBranchRequest) ProtoReflect() protoreflect.Message

func (*CreateBranchRequest) Reset 

func (x *CreateBranchRequest) Reset()

func (*CreateBranchRequest) String 

func (x *CreateBranchRequest) String() string

type CreateFileSetResponse 

type CreateFileSetResponse struct {
	FileSetId string `protobuf:"bytes,1,opt,name=file_set_id,json=fileSetId,proto3" json:"file_set_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileSetResponse) Descriptor deprecated 

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

Deprecated: Use CreateFileSetResponse.ProtoReflect.Descriptor instead.

func (*CreateFileSetResponse) GetFileSetId 

func (x *CreateFileSetResponse) GetFileSetId() string

func (*CreateFileSetResponse) MarshalLogObject 

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

func (*CreateFileSetResponse) ProtoMessage 

func (*CreateFileSetResponse) ProtoMessage()

func (*CreateFileSetResponse) ProtoReflect added in v2.7.0 

func (x *CreateFileSetResponse) ProtoReflect() protoreflect.Message

func (*CreateFileSetResponse) Reset 

func (x *CreateFileSetResponse) Reset()

func (*CreateFileSetResponse) String 

func (x *CreateFileSetResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateProjectRequest) Descriptor deprecated 

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

Deprecated: Use CreateProjectRequest.ProtoReflect.Descriptor instead.

func (*CreateProjectRequest) GetDescription 

func (x *CreateProjectRequest) GetDescription() string

func (*CreateProjectRequest) GetProject 

func (x *CreateProjectRequest) GetProject() *Project

func (*CreateProjectRequest) GetUpdate 

func (x *CreateProjectRequest) GetUpdate() bool

func (*CreateProjectRequest) MarshalLogObject 

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

func (*CreateProjectRequest) ProtoMessage 

func (*CreateProjectRequest) ProtoMessage()

func (*CreateProjectRequest) ProtoReflect added in v2.7.0 

func (x *CreateProjectRequest) ProtoReflect() protoreflect.Message

func (*CreateProjectRequest) Reset 

func (x *CreateProjectRequest) Reset()

func (*CreateProjectRequest) String 

func (x *CreateProjectRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateRepoRequest) Descriptor deprecated 

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

Deprecated: Use CreateRepoRequest.ProtoReflect.Descriptor instead.

func (*CreateRepoRequest) GetDescription 

func (x *CreateRepoRequest) GetDescription() string

func (*CreateRepoRequest) GetRepo 

func (x *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) GetUpdate 

func (x *CreateRepoRequest) GetUpdate() bool

func (*CreateRepoRequest) MarshalLogObject 

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

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) ProtoReflect added in v2.7.0 

func (x *CreateRepoRequest) ProtoReflect() protoreflect.Message

func (*CreateRepoRequest) Reset 

func (x *CreateRepoRequest) Reset()

func (*CreateRepoRequest) String 

func (x *CreateRepoRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteBranchRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBranchRequest.ProtoReflect.Descriptor instead.

func (*DeleteBranchRequest) GetBranch 

func (x *DeleteBranchRequest) GetBranch() *Branch

func (*DeleteBranchRequest) GetForce 

func (x *DeleteBranchRequest) GetForce() bool

func (*DeleteBranchRequest) MarshalLogObject 

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

func (*DeleteBranchRequest) ProtoMessage 

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) ProtoReflect added in v2.7.0 

func (x *DeleteBranchRequest) ProtoReflect() protoreflect.Message

func (*DeleteBranchRequest) Reset 

func (x *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) String 

func (x *DeleteBranchRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteFile) Descriptor deprecated 

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

Deprecated: Use DeleteFile.ProtoReflect.Descriptor instead.

func (*DeleteFile) GetDatum 

func (x *DeleteFile) GetDatum() string

func (*DeleteFile) GetPath 

func (x *DeleteFile) GetPath() string

func (*DeleteFile) MarshalLogObject 

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

func (*DeleteFile) ProtoMessage 

func (*DeleteFile) ProtoMessage()

func (*DeleteFile) ProtoReflect added in v2.7.0 

func (x *DeleteFile) ProtoReflect() protoreflect.Message

func (*DeleteFile) Reset 

func (x *DeleteFile) Reset()

func (*DeleteFile) String 

func (x *DeleteFile) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteProjectRequest) Descriptor deprecated 

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

Deprecated: Use DeleteProjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteProjectRequest) GetForce 

func (x *DeleteProjectRequest) GetForce() bool

func (*DeleteProjectRequest) GetProject 

func (x *DeleteProjectRequest) GetProject() *Project

func (*DeleteProjectRequest) MarshalLogObject 

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

func (*DeleteProjectRequest) ProtoMessage 

func (*DeleteProjectRequest) ProtoMessage()

func (*DeleteProjectRequest) ProtoReflect added in v2.7.0 

func (x *DeleteProjectRequest) ProtoReflect() protoreflect.Message

func (*DeleteProjectRequest) Reset 

func (x *DeleteProjectRequest) Reset()

func (*DeleteProjectRequest) String 

func (x *DeleteProjectRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteRepoRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRepoRequest.ProtoReflect.Descriptor instead.

func (*DeleteRepoRequest) GetForce 

func (x *DeleteRepoRequest) GetForce() bool

func (*DeleteRepoRequest) GetRepo 

func (x *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) MarshalLogObject 

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

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) ProtoReflect added in v2.7.0 

func (x *DeleteRepoRequest) ProtoReflect() protoreflect.Message

func (*DeleteRepoRequest) Reset 

func (x *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) String 

func (x *DeleteRepoRequest) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*DeleteReposRequest) Descriptor deprecated 

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

Deprecated: Use DeleteReposRequest.ProtoReflect.Descriptor instead.

func (*DeleteReposRequest) GetAll 

func (x *DeleteReposRequest) GetAll() bool

func (*DeleteReposRequest) GetForce 

func (x *DeleteReposRequest) GetForce() bool

func (*DeleteReposRequest) GetProjects 

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

func (*DeleteReposRequest) MarshalLogObject 

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

func (*DeleteReposRequest) ProtoMessage 

func (*DeleteReposRequest) ProtoMessage()

func (*DeleteReposRequest) ProtoReflect added in v2.7.0 

func (x *DeleteReposRequest) ProtoReflect() protoreflect.Message

func (*DeleteReposRequest) Reset 

func (x *DeleteReposRequest) Reset()

func (*DeleteReposRequest) String 

func (x *DeleteReposRequest) String() string

type DeleteReposResponse 

type DeleteReposResponse struct {
	Repos []*Repo `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteReposResponse) Descriptor deprecated 

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

Deprecated: Use DeleteReposResponse.ProtoReflect.Descriptor instead.

func (*DeleteReposResponse) GetRepos 

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

func (*DeleteReposResponse) MarshalLogObject 

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

func (*DeleteReposResponse) ProtoMessage 

func (*DeleteReposResponse) ProtoMessage()

func (*DeleteReposResponse) ProtoReflect added in v2.7.0 

func (x *DeleteReposResponse) ProtoReflect() protoreflect.Message

func (*DeleteReposResponse) Reset 

func (x *DeleteReposResponse) Reset()

func (*DeleteReposResponse) String 

func (x *DeleteReposResponse) String() string

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) Descriptor added in v2.7.0 

func (Delimiter) Descriptor() protoreflect.EnumDescriptor

func (Delimiter) Enum added in v2.7.0 

func (x Delimiter) Enum() *Delimiter

func (Delimiter) EnumDescriptor deprecated 

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

Deprecated: Use Delimiter.Descriptor instead.

func (Delimiter) Number added in v2.7.0 

func (x Delimiter) Number() protoreflect.EnumNumber

func (Delimiter) String 

func (x Delimiter) String() string

func (Delimiter) Type added in v2.7.0 

func (Delimiter) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*DiffFileRequest) Descriptor deprecated 

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

Deprecated: Use DiffFileRequest.ProtoReflect.Descriptor instead.

func (*DiffFileRequest) GetNewFile 

func (x *DiffFileRequest) GetNewFile() *File

func (*DiffFileRequest) GetOldFile 

func (x *DiffFileRequest) GetOldFile() *File

func (*DiffFileRequest) GetShallow 

func (x *DiffFileRequest) GetShallow() bool

func (*DiffFileRequest) MarshalLogObject 

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

func (*DiffFileRequest) ProtoMessage 

func (*DiffFileRequest) ProtoMessage()

func (*DiffFileRequest) ProtoReflect added in v2.7.0 

func (x *DiffFileRequest) ProtoReflect() protoreflect.Message

func (*DiffFileRequest) Reset 

func (x *DiffFileRequest) Reset()

func (*DiffFileRequest) String 

func (x *DiffFileRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*DiffFileResponse) Descriptor deprecated 

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

Deprecated: Use DiffFileResponse.ProtoReflect.Descriptor instead.

func (*DiffFileResponse) GetNewFile 

func (x *DiffFileResponse) GetNewFile() *FileInfo

func (*DiffFileResponse) GetOldFile 

func (x *DiffFileResponse) GetOldFile() *FileInfo

func (*DiffFileResponse) MarshalLogObject 

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

func (*DiffFileResponse) ProtoMessage 

func (*DiffFileResponse) ProtoMessage()

func (*DiffFileResponse) ProtoReflect added in v2.7.0 

func (x *DiffFileResponse) ProtoReflect() protoreflect.Message

func (*DiffFileResponse) Reset 

func (x *DiffFileResponse) Reset()

func (*DiffFileResponse) String 

func (x *DiffFileResponse) String() string

type DropCommitSetRequest 

type DropCommitSetRequest struct {
	CommitSet *CommitSet `protobuf:"bytes,1,opt,name=commit_set,json=commitSet,proto3" json:"commit_set,omitempty"`
	// contains filtered or unexported fields
}

func (*DropCommitSetRequest) Descriptor deprecated 

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

Deprecated: Use DropCommitSetRequest.ProtoReflect.Descriptor instead.

func (*DropCommitSetRequest) GetCommitSet 

func (x *DropCommitSetRequest) GetCommitSet() *CommitSet

func (*DropCommitSetRequest) MarshalLogObject 

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

func (*DropCommitSetRequest) ProtoMessage 

func (*DropCommitSetRequest) ProtoMessage()

func (*DropCommitSetRequest) ProtoReflect added in v2.7.0 

func (x *DropCommitSetRequest) ProtoReflect() protoreflect.Message

func (*DropCommitSetRequest) Reset 

func (x *DropCommitSetRequest) Reset()

func (*DropCommitSetRequest) String 

func (x *DropCommitSetRequest) String() string

type EgressRequest 

type EgressRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// Types that are assignable to Target:
	//
	//	*EgressRequest_ObjectStorage
	//	*EgressRequest_SqlDatabase
	Target isEgressRequest_Target `protobuf_oneof:"target"`
	// contains filtered or unexported fields
}

func (*EgressRequest) Descriptor deprecated 

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

Deprecated: Use EgressRequest.ProtoReflect.Descriptor instead.

func (*EgressRequest) GetCommit 

func (x *EgressRequest) GetCommit() *Commit

func (*EgressRequest) GetObjectStorage 

func (x *EgressRequest) GetObjectStorage() *ObjectStorageEgress

func (*EgressRequest) GetSqlDatabase 

func (x *EgressRequest) GetSqlDatabase() *SQLDatabaseEgress

func (*EgressRequest) GetTarget 

func (m *EgressRequest) GetTarget() isEgressRequest_Target

func (*EgressRequest) MarshalLogObject 

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

func (*EgressRequest) ProtoMessage 

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) ProtoReflect added in v2.7.0 

func (x *EgressRequest) ProtoReflect() protoreflect.Message

func (*EgressRequest) Reset 

func (x *EgressRequest) Reset()

func (*EgressRequest) String 

func (x *EgressRequest) String() string

type EgressRequest_ObjectStorage 

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

type EgressRequest_SqlDatabase 

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

type EgressResponse 

type EgressResponse struct {

	// Types that are assignable to Result:
	//
	//	*EgressResponse_ObjectStorage
	//	*EgressResponse_SqlDatabase
	Result isEgressResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*EgressResponse) Descriptor deprecated 

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

Deprecated: Use EgressResponse.ProtoReflect.Descriptor instead.

func (*EgressResponse) GetObjectStorage 

func (x *EgressResponse) GetObjectStorage() *EgressResponse_ObjectStorageResult

func (*EgressResponse) GetResult 

func (m *EgressResponse) GetResult() isEgressResponse_Result

func (*EgressResponse) GetSqlDatabase 

func (x *EgressResponse) GetSqlDatabase() *EgressResponse_SQLDatabaseResult

func (*EgressResponse) MarshalLogObject 

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

func (*EgressResponse) ProtoMessage 

func (*EgressResponse) ProtoMessage()

func (*EgressResponse) ProtoReflect added in v2.7.0 

func (x *EgressResponse) ProtoReflect() protoreflect.Message

func (*EgressResponse) Reset 

func (x *EgressResponse) Reset()

func (*EgressResponse) String 

func (x *EgressResponse) String() string

type EgressResponse_ObjectStorage 

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

type EgressResponse_ObjectStorageResult 

type EgressResponse_ObjectStorageResult struct {
	BytesWritten int64 `protobuf:"varint,1,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	// contains filtered or unexported fields
}

func (*EgressResponse_ObjectStorageResult) Descriptor deprecated 

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

Deprecated: Use EgressResponse_ObjectStorageResult.ProtoReflect.Descriptor instead.

func (*EgressResponse_ObjectStorageResult) GetBytesWritten 

func (x *EgressResponse_ObjectStorageResult) GetBytesWritten() int64

func (*EgressResponse_ObjectStorageResult) MarshalLogObject 

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

func (*EgressResponse_ObjectStorageResult) ProtoMessage 

func (*EgressResponse_ObjectStorageResult) ProtoMessage()

func (*EgressResponse_ObjectStorageResult) ProtoReflect added in v2.7.0 

func (x *EgressResponse_ObjectStorageResult) ProtoReflect() protoreflect.Message

func (*EgressResponse_ObjectStorageResult) Reset 

func (x *EgressResponse_ObjectStorageResult) Reset()

func (*EgressResponse_ObjectStorageResult) String 

func (x *EgressResponse_ObjectStorageResult) String() string

type EgressResponse_SQLDatabaseResult 

type EgressResponse_SQLDatabaseResult struct {
	RowsWritten map[string]int64 `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EgressResponse_SQLDatabaseResult) Descriptor deprecated 

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

Deprecated: Use EgressResponse_SQLDatabaseResult.ProtoReflect.Descriptor instead.

func (*EgressResponse_SQLDatabaseResult) GetRowsWritten 

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

func (*EgressResponse_SQLDatabaseResult) MarshalLogObject 

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

func (*EgressResponse_SQLDatabaseResult) ProtoMessage 

func (*EgressResponse_SQLDatabaseResult) ProtoMessage()

func (*EgressResponse_SQLDatabaseResult) ProtoReflect added in v2.7.0 

func (x *EgressResponse_SQLDatabaseResult) ProtoReflect() protoreflect.Message

func (*EgressResponse_SQLDatabaseResult) Reset 

func (x *EgressResponse_SQLDatabaseResult) Reset()

func (*EgressResponse_SQLDatabaseResult) String 

func (x *EgressResponse_SQLDatabaseResult) String() string

type EgressResponse_SqlDatabase 

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

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"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetCommit 

func (x *File) GetCommit() *Commit

func (*File) GetDatum 

func (x *File) GetDatum() string

func (*File) GetPath 

func (x *File) GetPath() string

func (*File) MarshalLogObject 

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

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect added in v2.7.0 

func (x *File) ProtoReflect() protoreflect.Message

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

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 *timestamppb.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"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated 

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetCommitted 

func (x *FileInfo) GetCommitted() *timestamppb.Timestamp

func (*FileInfo) GetFile 

func (x *FileInfo) GetFile() *File

func (*FileInfo) GetFileType 

func (x *FileInfo) GetFileType() FileType

func (*FileInfo) GetHash 

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

func (*FileInfo) GetSizeBytes 

func (x *FileInfo) GetSizeBytes() int64

func (*FileInfo) MarshalLogObject 

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

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect added in v2.7.0 

func (x *FileInfo) ProtoReflect() protoreflect.Message

func (*FileInfo) Reset 

func (x *FileInfo) Reset()

func (*FileInfo) String 

func (x *FileInfo) String() string

type FileType 

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

func (FileType) Descriptor added in v2.7.0 

func (FileType) Descriptor() protoreflect.EnumDescriptor

func (FileType) Enum added in v2.7.0 

func (x FileType) Enum() *FileType

func (FileType) EnumDescriptor deprecated 

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

Deprecated: Use FileType.Descriptor instead.

func (FileType) Number added in v2.7.0 

func (x FileType) Number() protoreflect.EnumNumber

func (FileType) String 

func (x FileType) String() string

func (FileType) Type added in v2.7.0 

func (FileType) Type() protoreflect.EnumType

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"` // a limit of 0 means there is no upper bound on the limit.
	// contains filtered or unexported fields
}

func (*FindCommitsRequest) Descriptor deprecated 

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

Deprecated: Use FindCommitsRequest.ProtoReflect.Descriptor instead.

func (*FindCommitsRequest) GetFilePath 

func (x *FindCommitsRequest) GetFilePath() string

func (*FindCommitsRequest) GetLimit 

func (x *FindCommitsRequest) GetLimit() uint32

func (*FindCommitsRequest) GetStart 

func (x *FindCommitsRequest) GetStart() *Commit

func (*FindCommitsRequest) MarshalLogObject 

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

func (*FindCommitsRequest) ProtoMessage 

func (*FindCommitsRequest) ProtoMessage()

func (*FindCommitsRequest) ProtoReflect added in v2.7.0 

func (x *FindCommitsRequest) ProtoReflect() protoreflect.Message

func (*FindCommitsRequest) Reset 

func (x *FindCommitsRequest) Reset()

func (*FindCommitsRequest) String 

func (x *FindCommitsRequest) String() string

type FindCommitsResponse 

type FindCommitsResponse struct {

	// Types that are assignable 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"`
	// contains filtered or unexported fields
}

func (*FindCommitsResponse) Descriptor deprecated 

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

Deprecated: Use FindCommitsResponse.ProtoReflect.Descriptor instead.

func (*FindCommitsResponse) GetCommitsSearched 

func (x *FindCommitsResponse) GetCommitsSearched() uint32

func (*FindCommitsResponse) GetFoundCommit 

func (x *FindCommitsResponse) GetFoundCommit() *Commit

func (*FindCommitsResponse) GetLastSearchedCommit 

func (x *FindCommitsResponse) GetLastSearchedCommit() *Commit

func (*FindCommitsResponse) GetResult 

func (m *FindCommitsResponse) GetResult() isFindCommitsResponse_Result

func (*FindCommitsResponse) MarshalLogObject 

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

func (*FindCommitsResponse) ProtoMessage 

func (*FindCommitsResponse) ProtoMessage()

func (*FindCommitsResponse) ProtoReflect added in v2.7.0 

func (x *FindCommitsResponse) ProtoReflect() protoreflect.Message

func (*FindCommitsResponse) Reset 

func (x *FindCommitsResponse) Reset()

func (*FindCommitsResponse) String 

func (x *FindCommitsResponse) String() string

type FindCommitsResponse_FoundCommit 

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

type FindCommitsResponse_LastSearchedCommit 

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

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"`
	// contains filtered or unexported fields
}

func (*FinishCommitRequest) Descriptor deprecated 

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

Deprecated: Use FinishCommitRequest.ProtoReflect.Descriptor instead.

func (*FinishCommitRequest) GetCommit 

func (x *FinishCommitRequest) GetCommit() *Commit

func (*FinishCommitRequest) GetDescription 

func (x *FinishCommitRequest) GetDescription() string

func (*FinishCommitRequest) GetError 

func (x *FinishCommitRequest) GetError() string

func (*FinishCommitRequest) GetForce 

func (x *FinishCommitRequest) GetForce() bool

func (*FinishCommitRequest) MarshalLogObject 

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

func (*FinishCommitRequest) ProtoMessage 

func (*FinishCommitRequest) ProtoMessage()

func (*FinishCommitRequest) ProtoReflect added in v2.7.0 

func (x *FinishCommitRequest) ProtoReflect() protoreflect.Message

func (*FinishCommitRequest) Reset 

func (x *FinishCommitRequest) Reset()

func (*FinishCommitRequest) String 

func (x *FinishCommitRequest) String() string

type FsckRequest 

type FsckRequest struct {
	Fix bool `protobuf:"varint,1,opt,name=fix,proto3" json:"fix,omitempty"`
	// Types that are assignable to ZombieCheck:
	//
	//	*FsckRequest_ZombieTarget
	//	*FsckRequest_ZombieAll
	ZombieCheck isFsckRequest_ZombieCheck `protobuf_oneof:"zombie_check"`
	// contains filtered or unexported fields
}

func (*FsckRequest) Descriptor deprecated 

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

Deprecated: Use FsckRequest.ProtoReflect.Descriptor instead.

func (*FsckRequest) GetFix 

func (x *FsckRequest) GetFix() bool

func (*FsckRequest) GetZombieAll 

func (x *FsckRequest) GetZombieAll() bool

func (*FsckRequest) GetZombieCheck 

func (m *FsckRequest) GetZombieCheck() isFsckRequest_ZombieCheck

func (*FsckRequest) GetZombieTarget 

func (x *FsckRequest) GetZombieTarget() *Commit

func (*FsckRequest) MarshalLogObject 

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

func (*FsckRequest) ProtoMessage 

func (*FsckRequest) ProtoMessage()

func (*FsckRequest) ProtoReflect added in v2.7.0 

func (x *FsckRequest) ProtoReflect() protoreflect.Message

func (*FsckRequest) Reset 

func (x *FsckRequest) Reset()

func (*FsckRequest) String 

func (x *FsckRequest) String() string

type FsckRequest_ZombieAll 

type FsckRequest_ZombieAll struct {
	// run zombie data detection against all pipelines
	ZombieAll bool `protobuf:"varint,3,opt,name=zombie_all,json=zombieAll,proto3,oneof"`
}

type FsckRequest_ZombieTarget 

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

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"`
	// contains filtered or unexported fields
}

func (*FsckResponse) Descriptor deprecated 

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

Deprecated: Use FsckResponse.ProtoReflect.Descriptor instead.

func (*FsckResponse) GetError 

func (x *FsckResponse) GetError() string

func (*FsckResponse) GetFix 

func (x *FsckResponse) GetFix() string

func (*FsckResponse) MarshalLogObject 

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

func (*FsckResponse) ProtoMessage 

func (*FsckResponse) ProtoMessage()

func (*FsckResponse) ProtoReflect added in v2.7.0 

func (x *FsckResponse) ProtoReflect() protoreflect.Message

func (*FsckResponse) Reset 

func (x *FsckResponse) Reset()

func (*FsckResponse) String 

func (x *FsckResponse) String() string

type GetCacheRequest 

type GetCacheRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCacheRequest) Descriptor deprecated 

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

Deprecated: Use GetCacheRequest.ProtoReflect.Descriptor instead.

func (*GetCacheRequest) GetKey 

func (x *GetCacheRequest) GetKey() string

func (*GetCacheRequest) MarshalLogObject 

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

func (*GetCacheRequest) ProtoMessage 

func (*GetCacheRequest) ProtoMessage()

func (*GetCacheRequest) ProtoReflect added in v2.7.0 

func (x *GetCacheRequest) ProtoReflect() protoreflect.Message

func (*GetCacheRequest) Reset 

func (x *GetCacheRequest) Reset()

func (*GetCacheRequest) String 

func (x *GetCacheRequest) String() string

type GetCacheResponse 

type GetCacheResponse struct {
	Value *anypb.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCacheResponse) Descriptor deprecated 

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

Deprecated: Use GetCacheResponse.ProtoReflect.Descriptor instead.

func (*GetCacheResponse) GetValue 

func (x *GetCacheResponse) GetValue() *anypb.Any

func (*GetCacheResponse) MarshalLogObject 

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

func (*GetCacheResponse) ProtoMessage 

func (*GetCacheResponse) ProtoMessage()

func (*GetCacheResponse) ProtoReflect added in v2.7.0 

func (x *GetCacheResponse) ProtoReflect() protoreflect.Message

func (*GetCacheResponse) Reset 

func (x *GetCacheResponse) Reset()

func (*GetCacheResponse) String 

func (x *GetCacheResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetFileRequest) Descriptor deprecated 

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

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetFile 

func (x *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetOffset 

func (x *GetFileRequest) GetOffset() int64

func (*GetFileRequest) GetPathRange 

func (x *GetFileRequest) GetPathRange() *PathRange

func (*GetFileRequest) GetURL 

func (x *GetFileRequest) GetURL() string

func (*GetFileRequest) MarshalLogObject 

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

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect added in v2.7.0 

func (x *GetFileRequest) ProtoReflect() protoreflect.Message

func (*GetFileRequest) Reset 

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String 

func (x *GetFileRequest) String() string

type GetFileSetRequest 

type GetFileSetRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileSetRequest) Descriptor deprecated 

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

Deprecated: Use GetFileSetRequest.ProtoReflect.Descriptor instead.

func (*GetFileSetRequest) GetCommit 

func (x *GetFileSetRequest) GetCommit() *Commit

func (*GetFileSetRequest) MarshalLogObject 

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

func (*GetFileSetRequest) ProtoMessage 

func (*GetFileSetRequest) ProtoMessage()

func (*GetFileSetRequest) ProtoReflect added in v2.7.0 

func (x *GetFileSetRequest) ProtoReflect() protoreflect.Message

func (*GetFileSetRequest) Reset 

func (x *GetFileSetRequest) Reset()

func (*GetFileSetRequest) String 

func (x *GetFileSetRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GlobFileRequest) Descriptor deprecated 

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

Deprecated: Use GlobFileRequest.ProtoReflect.Descriptor instead.

func (*GlobFileRequest) GetCommit 

func (x *GlobFileRequest) GetCommit() *Commit

func (*GlobFileRequest) GetPathRange 

func (x *GlobFileRequest) GetPathRange() *PathRange

func (*GlobFileRequest) GetPattern 

func (x *GlobFileRequest) GetPattern() string

func (*GlobFileRequest) MarshalLogObject 

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

func (*GlobFileRequest) ProtoMessage 

func (*GlobFileRequest) ProtoMessage()

func (*GlobFileRequest) ProtoReflect added in v2.7.0 

func (x *GlobFileRequest) ProtoReflect() protoreflect.Message

func (*GlobFileRequest) Reset 

func (x *GlobFileRequest) Reset()

func (*GlobFileRequest) String 

func (x *GlobFileRequest) String() string

type InspectBranchRequest 

type InspectBranchRequest struct {
	Branch *Branch `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectBranchRequest) Descriptor deprecated 

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

Deprecated: Use InspectBranchRequest.ProtoReflect.Descriptor instead.

func (*InspectBranchRequest) GetBranch 

func (x *InspectBranchRequest) GetBranch() *Branch

func (*InspectBranchRequest) MarshalLogObject 

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

func (*InspectBranchRequest) ProtoMessage 

func (*InspectBranchRequest) ProtoMessage()

func (*InspectBranchRequest) ProtoReflect added in v2.7.0 

func (x *InspectBranchRequest) ProtoReflect() protoreflect.Message

func (*InspectBranchRequest) Reset 

func (x *InspectBranchRequest) Reset()

func (*InspectBranchRequest) String 

func (x *InspectBranchRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*InspectCommitRequest) Descriptor deprecated 

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

Deprecated: Use InspectCommitRequest.ProtoReflect.Descriptor instead.

func (*InspectCommitRequest) GetCommit 

func (x *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) GetWait 

func (x *InspectCommitRequest) GetWait() CommitState

func (*InspectCommitRequest) MarshalLogObject 

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

func (*InspectCommitRequest) ProtoMessage 

func (*InspectCommitRequest) ProtoMessage()

func (*InspectCommitRequest) ProtoReflect added in v2.7.0 

func (x *InspectCommitRequest) ProtoReflect() protoreflect.Message

func (*InspectCommitRequest) Reset 

func (x *InspectCommitRequest) Reset()

func (*InspectCommitRequest) String 

func (x *InspectCommitRequest) String() string

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"` // When true, wait until all commits in the set are finished
	// contains filtered or unexported fields
}

func (*InspectCommitSetRequest) Descriptor deprecated 

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

Deprecated: Use InspectCommitSetRequest.ProtoReflect.Descriptor instead.

func (*InspectCommitSetRequest) GetCommitSet 

func (x *InspectCommitSetRequest) GetCommitSet() *CommitSet

func (*InspectCommitSetRequest) GetWait 

func (x *InspectCommitSetRequest) GetWait() bool

func (*InspectCommitSetRequest) MarshalLogObject 

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

func (*InspectCommitSetRequest) ProtoMessage 

func (*InspectCommitSetRequest) ProtoMessage()

func (*InspectCommitSetRequest) ProtoReflect added in v2.7.0 

func (x *InspectCommitSetRequest) ProtoReflect() protoreflect.Message

func (*InspectCommitSetRequest) Reset 

func (x *InspectCommitSetRequest) Reset()

func (*InspectCommitSetRequest) String 

func (x *InspectCommitSetRequest) String() string

type InspectFileRequest 

type InspectFileRequest struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectFileRequest) Descriptor deprecated 

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

Deprecated: Use InspectFileRequest.ProtoReflect.Descriptor instead.

func (*InspectFileRequest) GetFile 

func (x *InspectFileRequest) GetFile() *File

func (*InspectFileRequest) MarshalLogObject 

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

func (*InspectFileRequest) ProtoMessage 

func (*InspectFileRequest) ProtoMessage()

func (*InspectFileRequest) ProtoReflect added in v2.7.0 

func (x *InspectFileRequest) ProtoReflect() protoreflect.Message

func (*InspectFileRequest) Reset 

func (x *InspectFileRequest) Reset()

func (*InspectFileRequest) String 

func (x *InspectFileRequest) String() string

type InspectProjectRequest 

type InspectProjectRequest struct {
	Project *Project `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectProjectRequest) Descriptor deprecated 

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

Deprecated: Use InspectProjectRequest.ProtoReflect.Descriptor instead.

func (*InspectProjectRequest) GetProject 

func (x *InspectProjectRequest) GetProject() *Project

func (*InspectProjectRequest) MarshalLogObject 

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

func (*InspectProjectRequest) ProtoMessage 

func (*InspectProjectRequest) ProtoMessage()

func (*InspectProjectRequest) ProtoReflect added in v2.7.0 

func (x *InspectProjectRequest) ProtoReflect() protoreflect.Message

func (*InspectProjectRequest) Reset 

func (x *InspectProjectRequest) Reset()

func (*InspectProjectRequest) String 

func (x *InspectProjectRequest) String() string

type InspectRepoRequest 

type InspectRepoRequest struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectRepoRequest) Descriptor deprecated 

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

Deprecated: Use InspectRepoRequest.ProtoReflect.Descriptor instead.

func (*InspectRepoRequest) GetRepo 

func (x *InspectRepoRequest) GetRepo() *Repo

func (*InspectRepoRequest) MarshalLogObject 

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

func (*InspectRepoRequest) ProtoMessage 

func (*InspectRepoRequest) ProtoMessage()

func (*InspectRepoRequest) ProtoReflect added in v2.7.0 

func (x *InspectRepoRequest) ProtoReflect() protoreflect.Message

func (*InspectRepoRequest) Reset 

func (x *InspectRepoRequest) Reset()

func (*InspectRepoRequest) String 

func (x *InspectRepoRequest) String() string

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"` // Returns branches oldest to newest
	// contains filtered or unexported fields
}

func (*ListBranchRequest) Descriptor deprecated 

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

Deprecated: Use ListBranchRequest.ProtoReflect.Descriptor instead.

func (*ListBranchRequest) GetRepo 

func (x *ListBranchRequest) GetRepo() *Repo

func (*ListBranchRequest) GetReverse 

func (x *ListBranchRequest) GetReverse() bool

func (*ListBranchRequest) MarshalLogObject 

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

func (*ListBranchRequest) ProtoMessage 

func (*ListBranchRequest) ProtoMessage()

func (*ListBranchRequest) ProtoReflect added in v2.7.0 

func (x *ListBranchRequest) ProtoReflect() protoreflect.Message

func (*ListBranchRequest) Reset 

func (x *ListBranchRequest) Reset()

func (*ListBranchRequest) String 

func (x *ListBranchRequest) String() string

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"`                                                // Return commits oldest to newest
	All         bool                   `protobuf:"varint,6,opt,name=all,proto3" json:"all,omitempty"`                                                        // Return commits of all kinds (without this, aliases are excluded)
	OriginKind  OriginKind             `protobuf:"varint,7,opt,name=origin_kind,json=originKind,proto3,enum=pfs_v2.OriginKind" json:"origin_kind,omitempty"` // Return only commits of this kind (mutually exclusive with all)
	StartedTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`                      // Return commits started before this time
	// contains filtered or unexported fields
}

func (*ListCommitRequest) Descriptor deprecated 

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

Deprecated: Use ListCommitRequest.ProtoReflect.Descriptor instead.

func (*ListCommitRequest) GetAll 

func (x *ListCommitRequest) GetAll() bool

func (*ListCommitRequest) GetFrom 

func (x *ListCommitRequest) GetFrom() *Commit

func (*ListCommitRequest) GetNumber 

func (x *ListCommitRequest) GetNumber() int64

func (*ListCommitRequest) GetOriginKind 

func (x *ListCommitRequest) GetOriginKind() OriginKind

func (*ListCommitRequest) GetRepo 

func (x *ListCommitRequest) GetRepo() *Repo

func (*ListCommitRequest) GetReverse 

func (x *ListCommitRequest) GetReverse() bool

func (*ListCommitRequest) GetStartedTime 

func (x *ListCommitRequest) GetStartedTime() *timestamppb.Timestamp

func (*ListCommitRequest) GetTo 

func (x *ListCommitRequest) GetTo() *Commit

func (*ListCommitRequest) MarshalLogObject 

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

func (*ListCommitRequest) ProtoMessage 

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) ProtoReflect added in v2.7.0 

func (x *ListCommitRequest) ProtoReflect() protoreflect.Message

func (*ListCommitRequest) Reset 

func (x *ListCommitRequest) Reset()

func (*ListCommitRequest) String 

func (x *ListCommitRequest) String() string

type ListCommitSetRequest 

type ListCommitSetRequest struct {
	Project *Project `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCommitSetRequest) Descriptor deprecated 

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

Deprecated: Use ListCommitSetRequest.ProtoReflect.Descriptor instead.

func (*ListCommitSetRequest) GetProject 

func (x *ListCommitSetRequest) GetProject() *Project

func (*ListCommitSetRequest) MarshalLogObject 

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

func (*ListCommitSetRequest) ProtoMessage 

func (*ListCommitSetRequest) ProtoMessage()

func (*ListCommitSetRequest) ProtoReflect added in v2.7.0 

func (x *ListCommitSetRequest) ProtoReflect() protoreflect.Message

func (*ListCommitSetRequest) Reset 

func (x *ListCommitSetRequest) Reset()

func (*ListCommitSetRequest) String 

func (x *ListCommitSetRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListFileRequest) Descriptor deprecated 

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

Deprecated: Use ListFileRequest.ProtoReflect.Descriptor instead.

func (*ListFileRequest) GetFile 

func (x *ListFileRequest) GetFile() *File

func (*ListFileRequest) GetNumber 

func (x *ListFileRequest) GetNumber() int64

func (*ListFileRequest) GetPaginationMarker 

func (x *ListFileRequest) GetPaginationMarker() *File

func (*ListFileRequest) GetReverse 

func (x *ListFileRequest) GetReverse() bool

func (*ListFileRequest) MarshalLogObject 

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

func (*ListFileRequest) ProtoMessage 

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) ProtoReflect added in v2.7.0 

func (x *ListFileRequest) ProtoReflect() protoreflect.Message

func (*ListFileRequest) Reset 

func (x *ListFileRequest) Reset()

func (*ListFileRequest) String 

func (x *ListFileRequest) String() string

type ListProjectRequest 

type ListProjectRequest struct {
	// contains filtered or unexported fields
}

func (*ListProjectRequest) Descriptor deprecated 

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

Deprecated: Use ListProjectRequest.ProtoReflect.Descriptor instead.

func (*ListProjectRequest) MarshalLogObject 

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

func (*ListProjectRequest) ProtoMessage 

func (*ListProjectRequest) ProtoMessage()

func (*ListProjectRequest) ProtoReflect added in v2.7.0 

func (x *ListProjectRequest) ProtoReflect() protoreflect.Message

func (*ListProjectRequest) Reset 

func (x *ListProjectRequest) Reset()

func (*ListProjectRequest) String 

func (x *ListProjectRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListRepoRequest) Descriptor deprecated 

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

Deprecated: Use ListRepoRequest.ProtoReflect.Descriptor instead.

func (*ListRepoRequest) GetProjects 

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

func (*ListRepoRequest) GetType 

func (x *ListRepoRequest) GetType() string

func (*ListRepoRequest) MarshalLogObject 

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

func (*ListRepoRequest) ProtoMessage 

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) ProtoReflect added in v2.7.0 

func (x *ListRepoRequest) ProtoReflect() protoreflect.Message

func (*ListRepoRequest) Reset 

func (x *ListRepoRequest) Reset()

func (*ListRepoRequest) String 

func (x *ListRepoRequest) String() string

type ModifyFileRequest 

type ModifyFileRequest struct {

	// Types that are assignable to Body:
	//
	//	*ModifyFileRequest_SetCommit
	//	*ModifyFileRequest_AddFile
	//	*ModifyFileRequest_DeleteFile
	//	*ModifyFileRequest_CopyFile
	Body isModifyFileRequest_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

func (*ModifyFileRequest) Descriptor deprecated 

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

Deprecated: Use ModifyFileRequest.ProtoReflect.Descriptor instead.

func (*ModifyFileRequest) GetAddFile 

func (x *ModifyFileRequest) GetAddFile() *AddFile

func (*ModifyFileRequest) GetBody 

func (m *ModifyFileRequest) GetBody() isModifyFileRequest_Body

func (*ModifyFileRequest) GetCopyFile 

func (x *ModifyFileRequest) GetCopyFile() *CopyFile

func (*ModifyFileRequest) GetDeleteFile 

func (x *ModifyFileRequest) GetDeleteFile() *DeleteFile

func (*ModifyFileRequest) GetSetCommit 

func (x *ModifyFileRequest) GetSetCommit() *Commit

func (*ModifyFileRequest) MarshalLogObject 

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

func (*ModifyFileRequest) ProtoMessage 

func (*ModifyFileRequest) ProtoMessage()

func (*ModifyFileRequest) ProtoReflect added in v2.7.0 

func (x *ModifyFileRequest) ProtoReflect() protoreflect.Message

func (*ModifyFileRequest) Reset 

func (x *ModifyFileRequest) Reset()

func (*ModifyFileRequest) String 

func (x *ModifyFileRequest) String() string

type ModifyFileRequest_AddFile 

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

type ModifyFileRequest_CopyFile 

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

type ModifyFileRequest_DeleteFile 

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

type ModifyFileRequest_SetCommit 

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

type ObjectStorageEgress 

type ObjectStorageEgress struct {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStorageEgress) Descriptor deprecated 

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

Deprecated: Use ObjectStorageEgress.ProtoReflect.Descriptor instead.

func (*ObjectStorageEgress) GetUrl 

func (x *ObjectStorageEgress) GetUrl() string

func (*ObjectStorageEgress) MarshalLogObject 

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

func (*ObjectStorageEgress) ProtoMessage 

func (*ObjectStorageEgress) ProtoMessage()

func (*ObjectStorageEgress) ProtoReflect added in v2.7.0 

func (x *ObjectStorageEgress) ProtoReflect() protoreflect.Message

func (*ObjectStorageEgress) Reset 

func (x *ObjectStorageEgress) Reset()

func (*ObjectStorageEgress) String 

func (x *ObjectStorageEgress) String() string

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) Descriptor added in v2.7.0 

func (OriginKind) Descriptor() protoreflect.EnumDescriptor

func (OriginKind) Enum added in v2.7.0 

func (x OriginKind) Enum() *OriginKind

func (OriginKind) EnumDescriptor deprecated 

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

Deprecated: Use OriginKind.Descriptor instead.

func (OriginKind) Number added in v2.7.0 

func (x OriginKind) Number() protoreflect.EnumNumber

func (OriginKind) String 

func (x OriginKind) String() string

func (OriginKind) Type added in v2.7.0 

func (OriginKind) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*PathRange) Descriptor deprecated 

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

Deprecated: Use PathRange.ProtoReflect.Descriptor instead.

func (*PathRange) GetLower 

func (x *PathRange) GetLower() string

func (*PathRange) GetUpper 

func (x *PathRange) GetUpper() string

func (*PathRange) MarshalLogObject 

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

func (*PathRange) ProtoMessage 

func (*PathRange) ProtoMessage()

func (*PathRange) ProtoReflect added in v2.7.0 

func (x *PathRange) ProtoReflect() protoreflect.Message

func (*PathRange) Reset 

func (x *PathRange) Reset()

func (*PathRange) String 

func (x *PathRange) String() string

type Project 

type Project struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Project) AuthResource 

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

AuthResource returns the auth resource for a project.

func (*Project) Descriptor deprecated 

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetName 

func (x *Project) GetName() string

func (*Project) MarshalLogObject 

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

func (*Project) ProtoMessage 

func (*Project) ProtoMessage()

func (*Project) ProtoReflect added in v2.7.0 

func (x *Project) ProtoReflect() protoreflect.Message

func (*Project) Reset 

func (x *Project) Reset()

func (*Project) String 

func (p *Project) String() string

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.

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   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectInfo) Descriptor deprecated 

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

Deprecated: Use ProjectInfo.ProtoReflect.Descriptor instead.

func (*ProjectInfo) GetAuthInfo 

func (x *ProjectInfo) GetAuthInfo() *AuthInfo

func (*ProjectInfo) GetCreatedAt 

func (x *ProjectInfo) GetCreatedAt() *timestamppb.Timestamp

func (*ProjectInfo) GetDescription 

func (x *ProjectInfo) GetDescription() string

func (*ProjectInfo) GetProject 

func (x *ProjectInfo) GetProject() *Project

func (*ProjectInfo) MarshalLogObject 

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

func (*ProjectInfo) ProtoMessage 

func (*ProjectInfo) ProtoMessage()

func (*ProjectInfo) ProtoReflect added in v2.7.0 

func (x *ProjectInfo) ProtoReflect() protoreflect.Message

func (*ProjectInfo) Reset 

func (x *ProjectInfo) Reset()

func (*ProjectInfo) String 

func (x *ProjectInfo) String() string

type PutCacheRequest 

type PutCacheRequest struct {
	Key        string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value      *anypb.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"`
	// contains filtered or unexported fields
}

func (*PutCacheRequest) Descriptor deprecated 

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

Deprecated: Use PutCacheRequest.ProtoReflect.Descriptor instead.

func (*PutCacheRequest) GetFileSetIds 

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

func (*PutCacheRequest) GetKey 

func (x *PutCacheRequest) GetKey() string

func (*PutCacheRequest) GetTag 

func (x *PutCacheRequest) GetTag() string

func (*PutCacheRequest) GetValue 

func (x *PutCacheRequest) GetValue() *anypb.Any

func (*PutCacheRequest) MarshalLogObject 

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

func (*PutCacheRequest) ProtoMessage 

func (*PutCacheRequest) ProtoMessage()

func (*PutCacheRequest) ProtoReflect added in v2.7.0 

func (x *PutCacheRequest) ProtoReflect() protoreflect.Message

func (*PutCacheRequest) Reset 

func (x *PutCacheRequest) Reset()

func (*PutCacheRequest) String 

func (x *PutCacheRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*RenewFileSetRequest) Descriptor deprecated 

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

Deprecated: Use RenewFileSetRequest.ProtoReflect.Descriptor instead.

func (*RenewFileSetRequest) GetFileSetId 

func (x *RenewFileSetRequest) GetFileSetId() string

func (*RenewFileSetRequest) GetTtlSeconds 

func (x *RenewFileSetRequest) GetTtlSeconds() int64

func (*RenewFileSetRequest) MarshalLogObject 

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

func (*RenewFileSetRequest) ProtoMessage 

func (*RenewFileSetRequest) ProtoMessage()

func (*RenewFileSetRequest) ProtoReflect added in v2.7.0 

func (x *RenewFileSetRequest) ProtoReflect() protoreflect.Message

func (*RenewFileSetRequest) Reset 

func (x *RenewFileSetRequest) Reset()

func (*RenewFileSetRequest) String 

func (x *RenewFileSetRequest) String() string

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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use Repo.ProtoReflect.Descriptor instead.

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 (x *Repo) GetName() string

func (*Repo) GetProject 

func (x *Repo) GetProject() *Project

func (*Repo) GetType 

func (x *Repo) GetType() string

func (*Repo) MarshalLogObject 

func (x *Repo) MarshalLogObject(enc zapcore.ObjectEncoder) 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) ProtoReflect added in v2.7.0 

func (x *Repo) ProtoReflect() protoreflect.Message

func (*Repo) Reset 

func (x *Repo) Reset()

func (*Repo) String 

func (r *Repo) String() string

type RepoInfo 

type RepoInfo struct {
	Repo                *Repo                  `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Created             *timestamppb.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"`
	// contains filtered or unexported fields
}

RepoInfo is the main data structure representing a Repo in etcd

func (*RepoInfo) Descriptor deprecated 

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

Deprecated: Use RepoInfo.ProtoReflect.Descriptor instead.

func (*RepoInfo) GetAuthInfo 

func (x *RepoInfo) GetAuthInfo() *AuthInfo

func (*RepoInfo) GetBranches 

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

func (*RepoInfo) GetCreated 

func (x *RepoInfo) GetCreated() *timestamppb.Timestamp

func (*RepoInfo) GetDescription 

func (x *RepoInfo) GetDescription() string

func (*RepoInfo) GetDetails 

func (x *RepoInfo) GetDetails() *RepoInfo_Details

func (*RepoInfo) GetRepo 

func (x *RepoInfo) GetRepo() *Repo

func (*RepoInfo) GetSizeBytesUpperBound 

func (x *RepoInfo) GetSizeBytesUpperBound() int64

func (*RepoInfo) MarshalLogObject 

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

func (*RepoInfo) ProtoMessage 

func (*RepoInfo) ProtoMessage()

func (*RepoInfo) ProtoReflect added in v2.7.0 

func (x *RepoInfo) ProtoReflect() protoreflect.Message

func (*RepoInfo) Reset 

func (x *RepoInfo) Reset()

func (*RepoInfo) String 

func (x *RepoInfo) String() string

type RepoInfo_Details 

type RepoInfo_Details struct {
	SizeBytes int64 `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// contains filtered or unexported fields
}

Details are only provided when explicitly requested

func (*RepoInfo_Details) Descriptor deprecated 

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

Deprecated: Use RepoInfo_Details.ProtoReflect.Descriptor instead.

func (*RepoInfo_Details) GetSizeBytes 

func (x *RepoInfo_Details) GetSizeBytes() int64

func (*RepoInfo_Details) MarshalLogObject 

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

func (*RepoInfo_Details) ProtoMessage 

func (*RepoInfo_Details) ProtoMessage()

func (*RepoInfo_Details) ProtoReflect added in v2.7.0 

func (x *RepoInfo_Details) ProtoReflect() protoreflect.Message

func (*RepoInfo_Details) Reset 

func (x *RepoInfo_Details) Reset()

func (*RepoInfo_Details) String 

func (x *RepoInfo_Details) String() string

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"`
	// contains filtered or unexported fields
}

func (*RunLoadTestRequest) Descriptor deprecated 

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

Deprecated: Use RunLoadTestRequest.ProtoReflect.Descriptor instead.

func (*RunLoadTestRequest) GetBranch 

func (x *RunLoadTestRequest) GetBranch() *Branch

func (*RunLoadTestRequest) GetSeed 

func (x *RunLoadTestRequest) GetSeed() int64

func (*RunLoadTestRequest) GetSpec 

func (x *RunLoadTestRequest) GetSpec() string

func (*RunLoadTestRequest) GetStateId 

func (x *RunLoadTestRequest) GetStateId() string

func (*RunLoadTestRequest) MarshalLogObject 

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

func (*RunLoadTestRequest) ProtoMessage 

func (*RunLoadTestRequest) ProtoMessage()

func (*RunLoadTestRequest) ProtoReflect added in v2.7.0 

func (x *RunLoadTestRequest) ProtoReflect() protoreflect.Message

func (*RunLoadTestRequest) Reset 

func (x *RunLoadTestRequest) Reset()

func (*RunLoadTestRequest) String 

func (x *RunLoadTestRequest) String() string

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 *durationpb.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"`
	// contains filtered or unexported fields
}

func (*RunLoadTestResponse) Descriptor deprecated 

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

Deprecated: Use RunLoadTestResponse.ProtoReflect.Descriptor instead.

func (*RunLoadTestResponse) GetBranch 

func (x *RunLoadTestResponse) GetBranch() *Branch

func (*RunLoadTestResponse) GetDuration 

func (x *RunLoadTestResponse) GetDuration() *durationpb.Duration

func (*RunLoadTestResponse) GetError 

func (x *RunLoadTestResponse) GetError() string

func (*RunLoadTestResponse) GetSeed 

func (x *RunLoadTestResponse) GetSeed() int64

func (*RunLoadTestResponse) GetSpec 

func (x *RunLoadTestResponse) GetSpec() string

func (*RunLoadTestResponse) GetStateId 

func (x *RunLoadTestResponse) GetStateId() string

func (*RunLoadTestResponse) MarshalLogObject 

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

func (*RunLoadTestResponse) ProtoMessage 

func (*RunLoadTestResponse) ProtoMessage()

func (*RunLoadTestResponse) ProtoReflect added in v2.7.0 

func (x *RunLoadTestResponse) ProtoReflect() protoreflect.Message

func (*RunLoadTestResponse) Reset 

func (x *RunLoadTestResponse) Reset()

func (*RunLoadTestResponse) String 

func (x *RunLoadTestResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*SQLDatabaseEgress) Descriptor deprecated 

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

Deprecated: Use SQLDatabaseEgress.ProtoReflect.Descriptor instead.

func (*SQLDatabaseEgress) GetFileFormat 

func (x *SQLDatabaseEgress) GetFileFormat() *SQLDatabaseEgress_FileFormat

func (*SQLDatabaseEgress) GetSecret 

func (x *SQLDatabaseEgress) GetSecret() *SQLDatabaseEgress_Secret

func (*SQLDatabaseEgress) GetUrl 

func (x *SQLDatabaseEgress) GetUrl() string

func (*SQLDatabaseEgress) MarshalLogObject 

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

func (*SQLDatabaseEgress) ProtoMessage 

func (*SQLDatabaseEgress) ProtoMessage()

func (*SQLDatabaseEgress) ProtoReflect added in v2.7.0 

func (x *SQLDatabaseEgress) ProtoReflect() protoreflect.Message

func (*SQLDatabaseEgress) Reset 

func (x *SQLDatabaseEgress) Reset()

func (*SQLDatabaseEgress) String 

func (x *SQLDatabaseEgress) String() string

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"`
	// contains filtered or unexported fields
}

func (*SQLDatabaseEgress_FileFormat) Descriptor deprecated 

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

Deprecated: Use SQLDatabaseEgress_FileFormat.ProtoReflect.Descriptor instead.

func (*SQLDatabaseEgress_FileFormat) GetColumns 

func (x *SQLDatabaseEgress_FileFormat) GetColumns() []string

func (*SQLDatabaseEgress_FileFormat) GetType 

func (x *SQLDatabaseEgress_FileFormat) GetType() SQLDatabaseEgress_FileFormat_Type

func (*SQLDatabaseEgress_FileFormat) MarshalLogObject 

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

func (*SQLDatabaseEgress_FileFormat) ProtoMessage 

func (*SQLDatabaseEgress_FileFormat) ProtoMessage()

func (*SQLDatabaseEgress_FileFormat) ProtoReflect added in v2.7.0 

func (x *SQLDatabaseEgress_FileFormat) ProtoReflect() protoreflect.Message

func (*SQLDatabaseEgress_FileFormat) Reset 

func (x *SQLDatabaseEgress_FileFormat) Reset()

func (*SQLDatabaseEgress_FileFormat) String 

func (x *SQLDatabaseEgress_FileFormat) String() string

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) Descriptor added in v2.7.0 

func (SQLDatabaseEgress_FileFormat_Type) Descriptor() protoreflect.EnumDescriptor

func (SQLDatabaseEgress_FileFormat_Type) Enum added in v2.7.0 

func (x SQLDatabaseEgress_FileFormat_Type) Enum() *SQLDatabaseEgress_FileFormat_Type

func (SQLDatabaseEgress_FileFormat_Type) EnumDescriptor deprecated 

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

Deprecated: Use SQLDatabaseEgress_FileFormat_Type.Descriptor instead.

func (SQLDatabaseEgress_FileFormat_Type) Number added in v2.7.0 

func (x SQLDatabaseEgress_FileFormat_Type) Number() protoreflect.EnumNumber

func (SQLDatabaseEgress_FileFormat_Type) String 

func (x SQLDatabaseEgress_FileFormat_Type) String() string

func (SQLDatabaseEgress_FileFormat_Type) Type added in v2.7.0 

func (SQLDatabaseEgress_FileFormat_Type) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*SQLDatabaseEgress_Secret) Descriptor deprecated 

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

Deprecated: Use SQLDatabaseEgress_Secret.ProtoReflect.Descriptor instead.

func (*SQLDatabaseEgress_Secret) GetKey 

func (x *SQLDatabaseEgress_Secret) GetKey() string

func (*SQLDatabaseEgress_Secret) GetName 

func (x *SQLDatabaseEgress_Secret) GetName() string

func (*SQLDatabaseEgress_Secret) MarshalLogObject 

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

func (*SQLDatabaseEgress_Secret) ProtoMessage 

func (*SQLDatabaseEgress_Secret) ProtoMessage()

func (*SQLDatabaseEgress_Secret) ProtoReflect added in v2.7.0 

func (x *SQLDatabaseEgress_Secret) ProtoReflect() protoreflect.Message

func (*SQLDatabaseEgress_Secret) Reset 

func (x *SQLDatabaseEgress_Secret) Reset()

func (*SQLDatabaseEgress_Secret) String 

func (x *SQLDatabaseEgress_Secret) String() string

type ShardFileSetRequest 

type ShardFileSetRequest struct {
	FileSetId string `protobuf:"bytes,1,opt,name=file_set_id,json=fileSetId,proto3" json:"file_set_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardFileSetRequest) Descriptor deprecated 

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

Deprecated: Use ShardFileSetRequest.ProtoReflect.Descriptor instead.

func (*ShardFileSetRequest) GetFileSetId 

func (x *ShardFileSetRequest) GetFileSetId() string

func (*ShardFileSetRequest) MarshalLogObject 

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

func (*ShardFileSetRequest) ProtoMessage 

func (*ShardFileSetRequest) ProtoMessage()

func (*ShardFileSetRequest) ProtoReflect added in v2.7.0 

func (x *ShardFileSetRequest) ProtoReflect() protoreflect.Message

func (*ShardFileSetRequest) Reset 

func (x *ShardFileSetRequest) Reset()

func (*ShardFileSetRequest) String 

func (x *ShardFileSetRequest) String() string

type ShardFileSetResponse 

type ShardFileSetResponse struct {
	Shards []*PathRange `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardFileSetResponse) Descriptor deprecated 

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

Deprecated: Use ShardFileSetResponse.ProtoReflect.Descriptor instead.

func (*ShardFileSetResponse) GetShards 

func (x *ShardFileSetResponse) GetShards() []*PathRange

func (*ShardFileSetResponse) MarshalLogObject 

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

func (*ShardFileSetResponse) ProtoMessage 

func (*ShardFileSetResponse) ProtoMessage()

func (*ShardFileSetResponse) ProtoReflect added in v2.7.0 

func (x *ShardFileSetResponse) ProtoReflect() protoreflect.Message

func (*ShardFileSetResponse) Reset 

func (x *ShardFileSetResponse) Reset()

func (*ShardFileSetResponse) String 

func (x *ShardFileSetResponse) String() string

type SquashCommitSetRequest 

type SquashCommitSetRequest struct {
	CommitSet *CommitSet `protobuf:"bytes,1,opt,name=commit_set,json=commitSet,proto3" json:"commit_set,omitempty"`
	// contains filtered or unexported fields
}

func (*SquashCommitSetRequest) Descriptor deprecated 

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

Deprecated: Use SquashCommitSetRequest.ProtoReflect.Descriptor instead.

func (*SquashCommitSetRequest) GetCommitSet 

func (x *SquashCommitSetRequest) GetCommitSet() *CommitSet

func (*SquashCommitSetRequest) MarshalLogObject 

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

func (*SquashCommitSetRequest) ProtoMessage 

func (*SquashCommitSetRequest) ProtoMessage()

func (*SquashCommitSetRequest) ProtoReflect added in v2.7.0 

func (x *SquashCommitSetRequest) ProtoReflect() protoreflect.Message

func (*SquashCommitSetRequest) Reset 

func (x *SquashCommitSetRequest) Reset()

func (*SquashCommitSetRequest) String 

func (x *SquashCommitSetRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*StartCommitRequest) Descriptor deprecated 

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

Deprecated: Use StartCommitRequest.ProtoReflect.Descriptor instead.

func (*StartCommitRequest) GetBranch 

func (x *StartCommitRequest) GetBranch() *Branch

func (*StartCommitRequest) GetDescription 

func (x *StartCommitRequest) GetDescription() string

func (*StartCommitRequest) GetParent 

func (x *StartCommitRequest) GetParent() *Commit

func (*StartCommitRequest) MarshalLogObject 

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

func (*StartCommitRequest) ProtoMessage 

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) ProtoReflect added in v2.7.0 

func (x *StartCommitRequest) ProtoReflect() protoreflect.Message

func (*StartCommitRequest) Reset 

func (x *StartCommitRequest) Reset()

func (*StartCommitRequest) String 

func (x *StartCommitRequest) String() string

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"`                                                        // Return commits of all kinds (without this, aliases are excluded)
	OriginKind OriginKind  `protobuf:"varint,6,opt,name=origin_kind,json=originKind,proto3,enum=pfs_v2.OriginKind" json:"origin_kind,omitempty"` // Return only commits of this kind (mutually exclusive with all)
	// contains filtered or unexported fields
}

func (*SubscribeCommitRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeCommitRequest.ProtoReflect.Descriptor instead.

func (*SubscribeCommitRequest) GetAll 

func (x *SubscribeCommitRequest) GetAll() bool

func (*SubscribeCommitRequest) GetBranch 

func (x *SubscribeCommitRequest) GetBranch() string

func (*SubscribeCommitRequest) GetFrom 

func (x *SubscribeCommitRequest) GetFrom() *Commit

func (*SubscribeCommitRequest) GetOriginKind 

func (x *SubscribeCommitRequest) GetOriginKind() OriginKind

func (*SubscribeCommitRequest) GetRepo 

func (x *SubscribeCommitRequest) GetRepo() *Repo

func (*SubscribeCommitRequest) GetState 

func (x *SubscribeCommitRequest) GetState() CommitState

func (*SubscribeCommitRequest) MarshalLogObject 

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

func (*SubscribeCommitRequest) ProtoMessage 

func (*SubscribeCommitRequest) ProtoMessage()

func (*SubscribeCommitRequest) ProtoReflect added in v2.7.0 

func (x *SubscribeCommitRequest) ProtoReflect() protoreflect.Message

func (*SubscribeCommitRequest) Reset 

func (x *SubscribeCommitRequest) Reset()

func (*SubscribeCommitRequest) String 

func (x *SubscribeCommitRequest) String() string

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 rate limit spec (cron expression) has been satisfied since
	// the last trigger.
	RateLimitSpec string `protobuf:"bytes,3,opt,name=rate_limit_spec,json=rateLimitSpec,proto3" json:"rate_limit_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"`
	// Creates a background process which fires the trigger on the schedule
	// provided by the cron spec.
	// This condition is mutually exclusive with respect to the others, so
	// setting this will result with the trigger only firing based on the cron
	// schedule.
	CronSpec string `protobuf:"bytes,6,opt,name=cron_spec,json=cronSpec,proto3" json:"cron_spec,omitempty"`
	// contains filtered or unexported fields
}

Trigger defines the conditions under which a head is moved, and to which branch it is moved.

func (*Trigger) Descriptor deprecated 

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetAll 

func (x *Trigger) GetAll() bool

func (*Trigger) GetBranch 

func (x *Trigger) GetBranch() string

func (*Trigger) GetCommits 

func (x *Trigger) GetCommits() int64

func (*Trigger) GetCronSpec 

func (x *Trigger) GetCronSpec() string

func (*Trigger) GetRateLimitSpec added in v2.6.6 

func (x *Trigger) GetRateLimitSpec() string

func (*Trigger) GetSize added in v2.7.0 

func (x *Trigger) GetSize() string

func (*Trigger) MarshalLogObject 

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

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect added in v2.7.0 

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServer) ActivateAuth 

func (UnimplementedAPIServer) ActivateAuth(context.Context, *ActivateAuthRequest) (*ActivateAuthResponse, error)

func (UnimplementedAPIServer) AddFileSet 

func (UnimplementedAPIServer) AddFileSet(context.Context, *AddFileSetRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) CheckStorage 

func (UnimplementedAPIServer) CheckStorage(context.Context, *CheckStorageRequest) (*CheckStorageResponse, error)

func (UnimplementedAPIServer) ClearCache 

func (UnimplementedAPIServer) ClearCache(context.Context, *ClearCacheRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) ClearCommit 

func (UnimplementedAPIServer) ClearCommit(context.Context, *ClearCommitRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) ComposeFileSet 

func (UnimplementedAPIServer) ComposeFileSet(context.Context, *ComposeFileSetRequest) (*CreateFileSetResponse, error)

func (UnimplementedAPIServer) CreateBranch 

func (UnimplementedAPIServer) CreateBranch(context.Context, *CreateBranchRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) CreateFileSet 

func (UnimplementedAPIServer) CreateFileSet(API_CreateFileSetServer) error

func (UnimplementedAPIServer) CreateProject 

func (UnimplementedAPIServer) CreateProject(context.Context, *CreateProjectRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) CreateRepo 

func (UnimplementedAPIServer) CreateRepo(context.Context, *CreateRepoRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) DeleteAll 

func (UnimplementedAPIServer) DeleteAll(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedAPIServer) DeleteBranch 

func (UnimplementedAPIServer) DeleteBranch(context.Context, *DeleteBranchRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) DeleteProject 

func (UnimplementedAPIServer) DeleteProject(context.Context, *DeleteProjectRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) DeleteRepo 

func (UnimplementedAPIServer) DeleteRepo(context.Context, *DeleteRepoRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) DeleteRepos 

func (UnimplementedAPIServer) DeleteRepos(context.Context, *DeleteReposRequest) (*DeleteReposResponse, error)

func (UnimplementedAPIServer) DiffFile 

func (UnimplementedAPIServer) DiffFile(*DiffFileRequest, API_DiffFileServer) error

func (UnimplementedAPIServer) DropCommitSet 

func (UnimplementedAPIServer) DropCommitSet(context.Context, *DropCommitSetRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) Egress 

func (UnimplementedAPIServer) Egress(context.Context, *EgressRequest) (*EgressResponse, error)

func (UnimplementedAPIServer) FindCommits 

func (UnimplementedAPIServer) FindCommits(*FindCommitsRequest, API_FindCommitsServer) error

func (UnimplementedAPIServer) FinishCommit 

func (UnimplementedAPIServer) FinishCommit(context.Context, *FinishCommitRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) Fsck 

func (UnimplementedAPIServer) Fsck(*FsckRequest, API_FsckServer) error

func (UnimplementedAPIServer) GetCache 

func (UnimplementedAPIServer) GetCache(context.Context, *GetCacheRequest) (*GetCacheResponse, error)

func (UnimplementedAPIServer) GetFile 

func (UnimplementedAPIServer) GetFile(*GetFileRequest, API_GetFileServer) error

func (UnimplementedAPIServer) GetFileSet 

func (UnimplementedAPIServer) GetFileSet(context.Context, *GetFileSetRequest) (*CreateFileSetResponse, error)

func (UnimplementedAPIServer) GetFileTAR 

func (UnimplementedAPIServer) GetFileTAR(*GetFileRequest, API_GetFileTARServer) error

func (UnimplementedAPIServer) GlobFile 

func (UnimplementedAPIServer) GlobFile(*GlobFileRequest, API_GlobFileServer) error

func (UnimplementedAPIServer) InspectBranch 

func (UnimplementedAPIServer) InspectBranch(context.Context, *InspectBranchRequest) (*BranchInfo, error)

func (UnimplementedAPIServer) InspectCommit 

func (UnimplementedAPIServer) InspectCommit(context.Context, *InspectCommitRequest) (*CommitInfo, error)

func (UnimplementedAPIServer) InspectCommitSet 

func (UnimplementedAPIServer) InspectCommitSet(*InspectCommitSetRequest, API_InspectCommitSetServer) error

func (UnimplementedAPIServer) InspectFile 

func (UnimplementedAPIServer) InspectFile(context.Context, *InspectFileRequest) (*FileInfo, error)

func (UnimplementedAPIServer) InspectProject 

func (UnimplementedAPIServer) InspectProject(context.Context, *InspectProjectRequest) (*ProjectInfo, error)

func (UnimplementedAPIServer) InspectRepo 

func (UnimplementedAPIServer) InspectRepo(context.Context, *InspectRepoRequest) (*RepoInfo, error)

func (UnimplementedAPIServer) ListBranch 

func (UnimplementedAPIServer) ListBranch(*ListBranchRequest, API_ListBranchServer) error

func (UnimplementedAPIServer) ListCommit 

func (UnimplementedAPIServer) ListCommit(*ListCommitRequest, API_ListCommitServer) error

func (UnimplementedAPIServer) ListCommitSet 

func (UnimplementedAPIServer) ListCommitSet(*ListCommitSetRequest, API_ListCommitSetServer) error

func (UnimplementedAPIServer) ListFile 

func (UnimplementedAPIServer) ListFile(*ListFileRequest, API_ListFileServer) error

func (UnimplementedAPIServer) ListProject 

func (UnimplementedAPIServer) ListProject(*ListProjectRequest, API_ListProjectServer) error

func (UnimplementedAPIServer) ListRepo 

func (UnimplementedAPIServer) ListRepo(*ListRepoRequest, API_ListRepoServer) error

func (UnimplementedAPIServer) ListTask 

func (UnimplementedAPIServer) ListTask(*task.ListTaskRequest, API_ListTaskServer) error

func (UnimplementedAPIServer) ModifyFile 

func (UnimplementedAPIServer) ModifyFile(API_ModifyFileServer) error

func (UnimplementedAPIServer) PutCache 

func (UnimplementedAPIServer) PutCache(context.Context, *PutCacheRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) RenewFileSet 

func (UnimplementedAPIServer) RenewFileSet(context.Context, *RenewFileSetRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) RunLoadTest 

func (UnimplementedAPIServer) RunLoadTest(context.Context, *RunLoadTestRequest) (*RunLoadTestResponse, error)

func (UnimplementedAPIServer) RunLoadTestDefault 

func (UnimplementedAPIServer) RunLoadTestDefault(context.Context, *emptypb.Empty) (*RunLoadTestResponse, error)

func (UnimplementedAPIServer) ShardFileSet 

func (UnimplementedAPIServer) ShardFileSet(context.Context, *ShardFileSetRequest) (*ShardFileSetResponse, error)

func (UnimplementedAPIServer) SquashCommitSet 

func (UnimplementedAPIServer) SquashCommitSet(context.Context, *SquashCommitSetRequest) (*emptypb.Empty, error)

func (UnimplementedAPIServer) StartCommit 

func (UnimplementedAPIServer) StartCommit(context.Context, *StartCommitRequest) (*Commit, error)

func (UnimplementedAPIServer) SubscribeCommit 

func (UnimplementedAPIServer) SubscribeCommit(*SubscribeCommitRequest, API_SubscribeCommitServer) error

func (UnimplementedAPIServer) WalkFile 

func (UnimplementedAPIServer) WalkFile(*WalkFileRequest, API_WalkFileServer) error

type UnsafeAPIServer added in v2.7.0 

type UnsafeAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServer will result in compilation errors.

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"`
	// contains filtered or unexported fields
}

func (*WalkFileRequest) Descriptor deprecated 

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

Deprecated: Use WalkFileRequest.ProtoReflect.Descriptor instead.

func (*WalkFileRequest) GetFile 

func (x *WalkFileRequest) GetFile() *File

func (*WalkFileRequest) GetNumber 

func (x *WalkFileRequest) GetNumber() int64

func (*WalkFileRequest) GetPaginationMarker 

func (x *WalkFileRequest) GetPaginationMarker() *File

func (*WalkFileRequest) GetReverse 

func (x *WalkFileRequest) GetReverse() bool

func (*WalkFileRequest) MarshalLogObject 

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

func (*WalkFileRequest) ProtoMessage 

func (*WalkFileRequest) ProtoMessage()

func (*WalkFileRequest) ProtoReflect added in v2.7.0 

func (x *WalkFileRequest) ProtoReflect() protoreflect.Message

func (*WalkFileRequest) Reset 

func (x *WalkFileRequest) Reset()

func (*WalkFileRequest) String 

func (x *WalkFileRequest) String() string

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.