Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
- type APIClient
- type APIServer
- type BatchTransactionRequest
- func (*BatchTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BatchTransactionRequest) GetRequests() []*TransactionRequest
- func (x *BatchTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*BatchTransactionRequest) ProtoMessage()
- func (x *BatchTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *BatchTransactionRequest) Reset()
- func (x *BatchTransactionRequest) String() string
- type DeleteAllRequest
- func (*DeleteAllRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteAllRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DeleteAllRequest) ProtoMessage()
- func (x *DeleteAllRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteAllRequest) Reset()
- func (x *DeleteAllRequest) String() string
- type DeleteTransactionRequest
- func (*DeleteTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTransactionRequest) GetTransaction() *Transaction
- func (x *DeleteTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DeleteTransactionRequest) ProtoMessage()
- func (x *DeleteTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTransactionRequest) Reset()
- func (x *DeleteTransactionRequest) String() string
- type FinishTransactionRequest
- func (*FinishTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FinishTransactionRequest) GetTransaction() *Transaction
- func (x *FinishTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*FinishTransactionRequest) ProtoMessage()
- func (x *FinishTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *FinishTransactionRequest) Reset()
- func (x *FinishTransactionRequest) String() string
- type InspectTransactionRequest
- func (*InspectTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InspectTransactionRequest) GetTransaction() *Transaction
- func (x *InspectTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*InspectTransactionRequest) ProtoMessage()
- func (x *InspectTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *InspectTransactionRequest) Reset()
- func (x *InspectTransactionRequest) String() string
- type ListTransactionRequest
- func (*ListTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ListTransactionRequest) ProtoMessage()
- func (x *ListTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *ListTransactionRequest) Reset()
- func (x *ListTransactionRequest) String() string
- type StartTransactionRequest
- func (*StartTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*StartTransactionRequest) ProtoMessage()
- func (x *StartTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *StartTransactionRequest) Reset()
- func (x *StartTransactionRequest) String() string
- type Transaction
- func (*Transaction) Descriptor() ([]byte, []int)deprecated
- func (x *Transaction) GetId() string
- func (x *Transaction) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*Transaction) ProtoMessage()
- func (x *Transaction) ProtoReflect() protoreflect.Message
- func (x *Transaction) Reset()
- func (x *Transaction) String() string
- type TransactionInfo
- func (*TransactionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionInfo) GetRequests() []*TransactionRequest
- func (x *TransactionInfo) GetResponses() []*TransactionResponse
- func (x *TransactionInfo) GetStarted() *timestamppb.Timestamp
- func (x *TransactionInfo) GetTransaction() *Transaction
- func (x *TransactionInfo) GetVersion() uint64
- func (x *TransactionInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*TransactionInfo) ProtoMessage()
- func (x *TransactionInfo) ProtoReflect() protoreflect.Message
- func (x *TransactionInfo) Reset()
- func (x *TransactionInfo) String() string
- type TransactionInfos
- func (*TransactionInfos) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionInfos) GetTransactionInfo() []*TransactionInfo
- func (x *TransactionInfos) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*TransactionInfos) ProtoMessage()
- func (x *TransactionInfos) ProtoReflect() protoreflect.Message
- func (x *TransactionInfos) Reset()
- func (x *TransactionInfos) String() string
- type TransactionRequest
- func (*TransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionRequest) GetCreateBranch() *pfs.CreateBranchRequest
- func (x *TransactionRequest) GetCreatePipeline() *pps.CreatePipelineRequest
- func (x *TransactionRequest) GetCreateRepo() *pfs.CreateRepoRequest
- func (x *TransactionRequest) GetDeleteBranch() *pfs.DeleteBranchRequest
- func (x *TransactionRequest) GetDeleteRepo() *pfs.DeleteRepoRequest
- func (x *TransactionRequest) GetFinishCommit() *pfs.FinishCommitRequest
- func (x *TransactionRequest) GetSquashCommitSet() *pfs.SquashCommitSetRequest
- func (x *TransactionRequest) GetStartCommit() *pfs.StartCommitRequest
- func (x *TransactionRequest) GetStopJob() *pps.StopJobRequest
- func (x *TransactionRequest) GetUpdateJobState() *pps.UpdateJobStateRequest
- func (x *TransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*TransactionRequest) ProtoMessage()
- func (x *TransactionRequest) ProtoReflect() protoreflect.Message
- func (x *TransactionRequest) Reset()
- func (x *TransactionRequest) String() string
- type TransactionResponse
- func (*TransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionResponse) GetCommit() *pfs.Commit
- func (x *TransactionResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*TransactionResponse) ProtoMessage()
- func (x *TransactionResponse) ProtoReflect() protoreflect.Message
- func (x *TransactionResponse) Reset()
- func (x *TransactionResponse) String() string
- type UnimplementedAPIServer
- func (UnimplementedAPIServer) BatchTransaction(context.Context, *BatchTransactionRequest) (*TransactionInfo, error)
- func (UnimplementedAPIServer) DeleteAll(context.Context, *DeleteAllRequest) (*emptypb.Empty, error)
- func (UnimplementedAPIServer) DeleteTransaction(context.Context, *DeleteTransactionRequest) (*emptypb.Empty, error)
- func (UnimplementedAPIServer) FinishTransaction(context.Context, *FinishTransactionRequest) (*TransactionInfo, error)
- func (UnimplementedAPIServer) InspectTransaction(context.Context, *InspectTransactionRequest) (*TransactionInfo, error)
- func (UnimplementedAPIServer) ListTransaction(context.Context, *ListTransactionRequest) (*TransactionInfos, error)
- func (UnimplementedAPIServer) StartTransaction(context.Context, *StartTransactionRequest) (*Transaction, error)
- type UnsafeAPIServer
Constants ¶
const ( API_BatchTransaction_FullMethodName = "/transaction_v2.API/BatchTransaction" API_StartTransaction_FullMethodName = "/transaction_v2.API/StartTransaction" API_InspectTransaction_FullMethodName = "/transaction_v2.API/InspectTransaction" API_DeleteTransaction_FullMethodName = "/transaction_v2.API/DeleteTransaction" API_ListTransaction_FullMethodName = "/transaction_v2.API/ListTransaction" API_FinishTransaction_FullMethodName = "/transaction_v2.API/FinishTransaction" API_DeleteAll_FullMethodName = "/transaction_v2.API/DeleteAll" )
Variables ¶
var API_ServiceDesc = grpc.ServiceDesc{ ServiceName: "transaction_v2.API", HandlerType: (*APIServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "BatchTransaction", Handler: _API_BatchTransaction_Handler, }, { MethodName: "StartTransaction", Handler: _API_StartTransaction_Handler, }, { MethodName: "InspectTransaction", Handler: _API_InspectTransaction_Handler, }, { MethodName: "DeleteTransaction", Handler: _API_DeleteTransaction_Handler, }, { MethodName: "ListTransaction", Handler: _API_ListTransaction_Handler, }, { MethodName: "FinishTransaction", Handler: _API_FinishTransaction_Handler, }, { MethodName: "DeleteAll", Handler: _API_DeleteAll_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "transaction/transaction.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)
var File_transaction_transaction_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAPIServer ¶
func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
Types ¶
type APIClient ¶
type APIClient interface { // Transaction rpcs BatchTransaction(ctx context.Context, in *BatchTransactionRequest, opts ...grpc.CallOption) (*TransactionInfo, error) StartTransaction(ctx context.Context, in *StartTransactionRequest, opts ...grpc.CallOption) (*Transaction, error) InspectTransaction(ctx context.Context, in *InspectTransactionRequest, opts ...grpc.CallOption) (*TransactionInfo, error) DeleteTransaction(ctx context.Context, in *DeleteTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) ListTransaction(ctx context.Context, in *ListTransactionRequest, opts ...grpc.CallOption) (*TransactionInfos, error) FinishTransaction(ctx context.Context, in *FinishTransactionRequest, opts ...grpc.CallOption) (*TransactionInfo, error) DeleteAll(ctx context.Context, in *DeleteAllRequest, 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 { // Transaction rpcs BatchTransaction(context.Context, *BatchTransactionRequest) (*TransactionInfo, error) StartTransaction(context.Context, *StartTransactionRequest) (*Transaction, error) InspectTransaction(context.Context, *InspectTransactionRequest) (*TransactionInfo, error) DeleteTransaction(context.Context, *DeleteTransactionRequest) (*emptypb.Empty, error) ListTransaction(context.Context, *ListTransactionRequest) (*TransactionInfos, error) FinishTransaction(context.Context, *FinishTransactionRequest) (*TransactionInfo, error) DeleteAll(context.Context, *DeleteAllRequest) (*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 BatchTransactionRequest ¶
type BatchTransactionRequest struct { Requests []*TransactionRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"` // contains filtered or unexported fields }
func (*BatchTransactionRequest) Descriptor
deprecated
func (*BatchTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use BatchTransactionRequest.ProtoReflect.Descriptor instead.
func (*BatchTransactionRequest) GetRequests ¶
func (x *BatchTransactionRequest) GetRequests() []*TransactionRequest
func (*BatchTransactionRequest) MarshalLogObject ¶
func (x *BatchTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*BatchTransactionRequest) ProtoMessage ¶
func (*BatchTransactionRequest) ProtoMessage()
func (*BatchTransactionRequest) ProtoReflect ¶ added in v2.7.0
func (x *BatchTransactionRequest) ProtoReflect() protoreflect.Message
func (*BatchTransactionRequest) Reset ¶
func (x *BatchTransactionRequest) Reset()
func (*BatchTransactionRequest) String ¶
func (x *BatchTransactionRequest) String() string
type DeleteAllRequest ¶
type DeleteAllRequest struct {
// contains filtered or unexported fields
}
func (*DeleteAllRequest) Descriptor
deprecated
func (*DeleteAllRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteAllRequest.ProtoReflect.Descriptor instead.
func (*DeleteAllRequest) MarshalLogObject ¶
func (x *DeleteAllRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DeleteAllRequest) ProtoMessage ¶
func (*DeleteAllRequest) ProtoMessage()
func (*DeleteAllRequest) ProtoReflect ¶ added in v2.7.0
func (x *DeleteAllRequest) ProtoReflect() protoreflect.Message
func (*DeleteAllRequest) Reset ¶
func (x *DeleteAllRequest) Reset()
func (*DeleteAllRequest) String ¶
func (x *DeleteAllRequest) String() string
type DeleteTransactionRequest ¶
type DeleteTransactionRequest struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` // contains filtered or unexported fields }
func (*DeleteTransactionRequest) Descriptor
deprecated
func (*DeleteTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTransactionRequest.ProtoReflect.Descriptor instead.
func (*DeleteTransactionRequest) GetTransaction ¶
func (x *DeleteTransactionRequest) GetTransaction() *Transaction
func (*DeleteTransactionRequest) MarshalLogObject ¶
func (x *DeleteTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DeleteTransactionRequest) ProtoMessage ¶
func (*DeleteTransactionRequest) ProtoMessage()
func (*DeleteTransactionRequest) ProtoReflect ¶ added in v2.7.0
func (x *DeleteTransactionRequest) ProtoReflect() protoreflect.Message
func (*DeleteTransactionRequest) Reset ¶
func (x *DeleteTransactionRequest) Reset()
func (*DeleteTransactionRequest) String ¶
func (x *DeleteTransactionRequest) String() string
type FinishTransactionRequest ¶
type FinishTransactionRequest struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` // contains filtered or unexported fields }
func (*FinishTransactionRequest) Descriptor
deprecated
func (*FinishTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use FinishTransactionRequest.ProtoReflect.Descriptor instead.
func (*FinishTransactionRequest) GetTransaction ¶
func (x *FinishTransactionRequest) GetTransaction() *Transaction
func (*FinishTransactionRequest) MarshalLogObject ¶
func (x *FinishTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*FinishTransactionRequest) ProtoMessage ¶
func (*FinishTransactionRequest) ProtoMessage()
func (*FinishTransactionRequest) ProtoReflect ¶ added in v2.7.0
func (x *FinishTransactionRequest) ProtoReflect() protoreflect.Message
func (*FinishTransactionRequest) Reset ¶
func (x *FinishTransactionRequest) Reset()
func (*FinishTransactionRequest) String ¶
func (x *FinishTransactionRequest) String() string
type InspectTransactionRequest ¶
type InspectTransactionRequest struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` // contains filtered or unexported fields }
func (*InspectTransactionRequest) Descriptor
deprecated
func (*InspectTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use InspectTransactionRequest.ProtoReflect.Descriptor instead.
func (*InspectTransactionRequest) GetTransaction ¶
func (x *InspectTransactionRequest) GetTransaction() *Transaction
func (*InspectTransactionRequest) MarshalLogObject ¶
func (x *InspectTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*InspectTransactionRequest) ProtoMessage ¶
func (*InspectTransactionRequest) ProtoMessage()
func (*InspectTransactionRequest) ProtoReflect ¶ added in v2.7.0
func (x *InspectTransactionRequest) ProtoReflect() protoreflect.Message
func (*InspectTransactionRequest) Reset ¶
func (x *InspectTransactionRequest) Reset()
func (*InspectTransactionRequest) String ¶
func (x *InspectTransactionRequest) String() string
type ListTransactionRequest ¶
type ListTransactionRequest struct {
// contains filtered or unexported fields
}
func (*ListTransactionRequest) Descriptor
deprecated
func (*ListTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTransactionRequest.ProtoReflect.Descriptor instead.
func (*ListTransactionRequest) MarshalLogObject ¶
func (x *ListTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ListTransactionRequest) ProtoMessage ¶
func (*ListTransactionRequest) ProtoMessage()
func (*ListTransactionRequest) ProtoReflect ¶ added in v2.7.0
func (x *ListTransactionRequest) ProtoReflect() protoreflect.Message
func (*ListTransactionRequest) Reset ¶
func (x *ListTransactionRequest) Reset()
func (*ListTransactionRequest) String ¶
func (x *ListTransactionRequest) String() string
type StartTransactionRequest ¶
type StartTransactionRequest struct {
// contains filtered or unexported fields
}
func (*StartTransactionRequest) Descriptor
deprecated
func (*StartTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartTransactionRequest.ProtoReflect.Descriptor instead.
func (*StartTransactionRequest) MarshalLogObject ¶
func (x *StartTransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*StartTransactionRequest) ProtoMessage ¶
func (*StartTransactionRequest) ProtoMessage()
func (*StartTransactionRequest) ProtoReflect ¶ added in v2.7.0
func (x *StartTransactionRequest) ProtoReflect() protoreflect.Message
func (*StartTransactionRequest) Reset ¶
func (x *StartTransactionRequest) Reset()
func (*StartTransactionRequest) String ¶
func (x *StartTransactionRequest) String() string
type Transaction ¶
type Transaction struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*Transaction) Descriptor
deprecated
func (*Transaction) Descriptor() ([]byte, []int)
Deprecated: Use Transaction.ProtoReflect.Descriptor instead.
func (*Transaction) GetId ¶ added in v2.7.0
func (x *Transaction) GetId() string
func (*Transaction) MarshalLogObject ¶
func (x *Transaction) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Transaction) ProtoMessage ¶
func (*Transaction) ProtoMessage()
func (*Transaction) ProtoReflect ¶ added in v2.7.0
func (x *Transaction) ProtoReflect() protoreflect.Message
func (*Transaction) Reset ¶
func (x *Transaction) Reset()
func (*Transaction) String ¶
func (x *Transaction) String() string
type TransactionInfo ¶
type TransactionInfo struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` Requests []*TransactionRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"` Responses []*TransactionResponse `protobuf:"bytes,3,rep,name=responses,proto3" json:"responses,omitempty"` Started *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started,proto3" json:"started,omitempty"` Version uint64 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*TransactionInfo) Descriptor
deprecated
func (*TransactionInfo) Descriptor() ([]byte, []int)
Deprecated: Use TransactionInfo.ProtoReflect.Descriptor instead.
func (*TransactionInfo) GetRequests ¶
func (x *TransactionInfo) GetRequests() []*TransactionRequest
func (*TransactionInfo) GetResponses ¶
func (x *TransactionInfo) GetResponses() []*TransactionResponse
func (*TransactionInfo) GetStarted ¶
func (x *TransactionInfo) GetStarted() *timestamppb.Timestamp
func (*TransactionInfo) GetTransaction ¶
func (x *TransactionInfo) GetTransaction() *Transaction
func (*TransactionInfo) GetVersion ¶
func (x *TransactionInfo) GetVersion() uint64
func (*TransactionInfo) MarshalLogObject ¶
func (x *TransactionInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TransactionInfo) ProtoMessage ¶
func (*TransactionInfo) ProtoMessage()
func (*TransactionInfo) ProtoReflect ¶ added in v2.7.0
func (x *TransactionInfo) ProtoReflect() protoreflect.Message
func (*TransactionInfo) Reset ¶
func (x *TransactionInfo) Reset()
func (*TransactionInfo) String ¶
func (x *TransactionInfo) String() string
type TransactionInfos ¶
type TransactionInfos struct { TransactionInfo []*TransactionInfo `protobuf:"bytes,1,rep,name=transaction_info,json=transactionInfo,proto3" json:"transaction_info,omitempty"` // contains filtered or unexported fields }
func (*TransactionInfos) Descriptor
deprecated
func (*TransactionInfos) Descriptor() ([]byte, []int)
Deprecated: Use TransactionInfos.ProtoReflect.Descriptor instead.
func (*TransactionInfos) GetTransactionInfo ¶
func (x *TransactionInfos) GetTransactionInfo() []*TransactionInfo
func (*TransactionInfos) MarshalLogObject ¶
func (x *TransactionInfos) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TransactionInfos) ProtoMessage ¶
func (*TransactionInfos) ProtoMessage()
func (*TransactionInfos) ProtoReflect ¶ added in v2.7.0
func (x *TransactionInfos) ProtoReflect() protoreflect.Message
func (*TransactionInfos) Reset ¶
func (x *TransactionInfos) Reset()
func (*TransactionInfos) String ¶
func (x *TransactionInfos) String() string
type TransactionRequest ¶
type TransactionRequest struct { // Exactly one of these fields should be set CreateRepo *pfs.CreateRepoRequest `protobuf:"bytes,1,opt,name=create_repo,json=createRepo,proto3" json:"create_repo,omitempty"` DeleteRepo *pfs.DeleteRepoRequest `protobuf:"bytes,2,opt,name=delete_repo,json=deleteRepo,proto3" json:"delete_repo,omitempty"` StartCommit *pfs.StartCommitRequest `protobuf:"bytes,3,opt,name=start_commit,json=startCommit,proto3" json:"start_commit,omitempty"` FinishCommit *pfs.FinishCommitRequest `protobuf:"bytes,4,opt,name=finish_commit,json=finishCommit,proto3" json:"finish_commit,omitempty"` SquashCommitSet *pfs.SquashCommitSetRequest `protobuf:"bytes,5,opt,name=squash_commit_set,json=squashCommitSet,proto3" json:"squash_commit_set,omitempty"` CreateBranch *pfs.CreateBranchRequest `protobuf:"bytes,6,opt,name=create_branch,json=createBranch,proto3" json:"create_branch,omitempty"` DeleteBranch *pfs.DeleteBranchRequest `protobuf:"bytes,7,opt,name=delete_branch,json=deleteBranch,proto3" json:"delete_branch,omitempty"` UpdateJobState *pps.UpdateJobStateRequest `protobuf:"bytes,8,opt,name=update_job_state,json=updateJobState,proto3" json:"update_job_state,omitempty"` CreatePipeline *pps.CreatePipelineRequest `protobuf:"bytes,9,opt,name=create_pipeline,json=createPipeline,proto3" json:"create_pipeline,omitempty"` StopJob *pps.StopJobRequest `protobuf:"bytes,10,opt,name=stop_job,json=stopJob,proto3" json:"stop_job,omitempty"` // contains filtered or unexported fields }
func (*TransactionRequest) Descriptor
deprecated
func (*TransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use TransactionRequest.ProtoReflect.Descriptor instead.
func (*TransactionRequest) GetCreateBranch ¶
func (x *TransactionRequest) GetCreateBranch() *pfs.CreateBranchRequest
func (*TransactionRequest) GetCreatePipeline ¶
func (x *TransactionRequest) GetCreatePipeline() *pps.CreatePipelineRequest
func (*TransactionRequest) GetCreateRepo ¶
func (x *TransactionRequest) GetCreateRepo() *pfs.CreateRepoRequest
func (*TransactionRequest) GetDeleteBranch ¶
func (x *TransactionRequest) GetDeleteBranch() *pfs.DeleteBranchRequest
func (*TransactionRequest) GetDeleteRepo ¶
func (x *TransactionRequest) GetDeleteRepo() *pfs.DeleteRepoRequest
func (*TransactionRequest) GetFinishCommit ¶
func (x *TransactionRequest) GetFinishCommit() *pfs.FinishCommitRequest
func (*TransactionRequest) GetSquashCommitSet ¶
func (x *TransactionRequest) GetSquashCommitSet() *pfs.SquashCommitSetRequest
func (*TransactionRequest) GetStartCommit ¶
func (x *TransactionRequest) GetStartCommit() *pfs.StartCommitRequest
func (*TransactionRequest) GetStopJob ¶
func (x *TransactionRequest) GetStopJob() *pps.StopJobRequest
func (*TransactionRequest) GetUpdateJobState ¶
func (x *TransactionRequest) GetUpdateJobState() *pps.UpdateJobStateRequest
func (*TransactionRequest) MarshalLogObject ¶
func (x *TransactionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TransactionRequest) ProtoMessage ¶
func (*TransactionRequest) ProtoMessage()
func (*TransactionRequest) ProtoReflect ¶ added in v2.7.0
func (x *TransactionRequest) ProtoReflect() protoreflect.Message
func (*TransactionRequest) Reset ¶
func (x *TransactionRequest) Reset()
func (*TransactionRequest) String ¶
func (x *TransactionRequest) String() string
type TransactionResponse ¶
type TransactionResponse struct { // At most, one of these fields should be set (most responses are empty) Commit *pfs.Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` // Only used for StartCommit - any way we can deterministically provide this before finishing the transaction? // contains filtered or unexported fields }
func (*TransactionResponse) Descriptor
deprecated
func (*TransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransactionResponse.ProtoReflect.Descriptor instead.
func (*TransactionResponse) GetCommit ¶
func (x *TransactionResponse) GetCommit() *pfs.Commit
func (*TransactionResponse) MarshalLogObject ¶
func (x *TransactionResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TransactionResponse) ProtoMessage ¶
func (*TransactionResponse) ProtoMessage()
func (*TransactionResponse) ProtoReflect ¶ added in v2.7.0
func (x *TransactionResponse) ProtoReflect() protoreflect.Message
func (*TransactionResponse) Reset ¶
func (x *TransactionResponse) Reset()
func (*TransactionResponse) String ¶
func (x *TransactionResponse) String() string
type UnimplementedAPIServer ¶
type UnimplementedAPIServer struct { }
UnimplementedAPIServer must be embedded to have forward compatible implementations.
func (UnimplementedAPIServer) BatchTransaction ¶
func (UnimplementedAPIServer) BatchTransaction(context.Context, *BatchTransactionRequest) (*TransactionInfo, error)
func (UnimplementedAPIServer) DeleteAll ¶
func (UnimplementedAPIServer) DeleteAll(context.Context, *DeleteAllRequest) (*emptypb.Empty, error)
func (UnimplementedAPIServer) DeleteTransaction ¶
func (UnimplementedAPIServer) DeleteTransaction(context.Context, *DeleteTransactionRequest) (*emptypb.Empty, error)
func (UnimplementedAPIServer) FinishTransaction ¶
func (UnimplementedAPIServer) FinishTransaction(context.Context, *FinishTransactionRequest) (*TransactionInfo, error)
func (UnimplementedAPIServer) InspectTransaction ¶
func (UnimplementedAPIServer) InspectTransaction(context.Context, *InspectTransactionRequest) (*TransactionInfo, error)
func (UnimplementedAPIServer) ListTransaction ¶
func (UnimplementedAPIServer) ListTransaction(context.Context, *ListTransactionRequest) (*TransactionInfos, error)
func (UnimplementedAPIServer) StartTransaction ¶
func (UnimplementedAPIServer) StartTransaction(context.Context, *StartTransactionRequest) (*Transaction, 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.