transaction

package
v2.7.6 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
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

View Source 
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)

View Source 
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.

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.