api

package
v0.0.0-...-8572fe3 Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_TransactionalService_proto protoreflect.FileDescriptor
View Source 
var TransactionalRequest_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "id.secondbaser.service.api.TransactionalRequest",
	HandlerType: (*TransactionalRequestServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartTransaction",
			Handler:    _TransactionalRequest_StartTransaction_Handler,
		},
		{
			MethodName: "RegisterParticipant",
			Handler:    _TransactionalRequest_RegisterParticipant_Handler,
		},
		{
			MethodName: "QueryTransactionStatus",
			Handler:    _TransactionalRequest_QueryTransactionStatus_Handler,
		},
		{
			MethodName: "CommitTransaction",
			Handler:    _TransactionalRequest_CommitTransaction_Handler,
		},
		{
			MethodName: "RollbackTransaction",
			Handler:    _TransactionalRequest_RollbackTransaction_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "TransactionalService.proto",
}

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

Functions

func RegisterTransactionalRequestServer 

func RegisterTransactionalRequestServer(s grpc.ServiceRegistrar, srv TransactionalRequestServer)

Types

type TransactionRequest 

type TransactionRequest struct {
	TransactionId     string                 `protobuf:"bytes,1,opt,name=transactionId,proto3" json:"transactionId,omitempty"`
	InitSystem        string                 `protobuf:"bytes,2,opt,name=initSystem,proto3" json:"initSystem,omitempty"`
	ParticipantSystem string                 `protobuf:"bytes,3,opt,name=participantSystem,proto3" json:"participantSystem,omitempty"`
	TransactionStart  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=transactionStart,proto3" json:"transactionStart,omitempty"`
	Success           bool                   `protobuf:"varint,5,opt,name=success,proto3" json:"success,omitempty"`
	BizType           string                 `protobuf:"bytes,6,opt,name=bizType,proto3" json:"bizType,omitempty"`
	BizId             string                 `protobuf:"bytes,7,opt,name=bizId,proto3" json:"bizId,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionRequest) Descriptor deprecated 

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

Deprecated: Use TransactionRequest.ProtoReflect.Descriptor instead.

func (*TransactionRequest) GetBizId 

func (x *TransactionRequest) GetBizId() string

func (*TransactionRequest) GetBizType 

func (x *TransactionRequest) GetBizType() string

func (*TransactionRequest) GetInitSystem 

func (x *TransactionRequest) GetInitSystem() string

func (*TransactionRequest) GetParticipantSystem 

func (x *TransactionRequest) GetParticipantSystem() string

func (*TransactionRequest) GetSuccess 

func (x *TransactionRequest) GetSuccess() bool

func (*TransactionRequest) GetTransactionId 

func (x *TransactionRequest) GetTransactionId() string

func (*TransactionRequest) GetTransactionStart 

func (x *TransactionRequest) GetTransactionStart() *timestamppb.Timestamp

func (*TransactionRequest) ProtoMessage 

func (*TransactionRequest) ProtoMessage()

func (*TransactionRequest) ProtoReflect 

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 {
	TransactionStatus string                 `protobuf:"bytes,1,opt,name=transactionStatus,proto3" json:"transactionStatus,omitempty"`
	TransactionStart  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=transactionStart,proto3" json:"transactionStart,omitempty"`
	TransactionId     string                 `protobuf:"bytes,3,opt,name=transactionId,proto3" json:"transactionId,omitempty"`
	InitSystem        string                 `protobuf:"bytes,4,opt,name=initSystem,proto3" json:"initSystem,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionResponse) Descriptor deprecated 

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

Deprecated: Use TransactionResponse.ProtoReflect.Descriptor instead.

func (*TransactionResponse) GetInitSystem 

func (x *TransactionResponse) GetInitSystem() string

func (*TransactionResponse) GetTransactionId 

func (x *TransactionResponse) GetTransactionId() string

func (*TransactionResponse) GetTransactionStart 

func (x *TransactionResponse) GetTransactionStart() *timestamppb.Timestamp

func (*TransactionResponse) GetTransactionStatus 

func (x *TransactionResponse) GetTransactionStatus() string

func (*TransactionResponse) ProtoMessage 

func (*TransactionResponse) ProtoMessage()

func (*TransactionResponse) ProtoReflect 

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

func (*TransactionResponse) Reset 

func (x *TransactionResponse) Reset()

func (*TransactionResponse) String 

func (x *TransactionResponse) String() string

type TransactionalRequestClient 

type TransactionalRequestClient interface {
	StartTransaction(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*TransactionResponse, error)
	RegisterParticipant(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*TransactionResponse, error)
	QueryTransactionStatus(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*TransactionResponse, error)
	CommitTransaction(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*TransactionResponse, error)
	RollbackTransaction(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*TransactionResponse, error)
}

TransactionalRequestClient is the client API for TransactionalRequest 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 NewTransactionalRequestClient 

func NewTransactionalRequestClient(cc grpc.ClientConnInterface) TransactionalRequestClient

type TransactionalRequestServer 

type TransactionalRequestServer interface {
	StartTransaction(context.Context, *TransactionRequest) (*TransactionResponse, error)
	RegisterParticipant(context.Context, *TransactionRequest) (*TransactionResponse, error)
	QueryTransactionStatus(context.Context, *TransactionRequest) (*TransactionResponse, error)
	CommitTransaction(context.Context, *TransactionRequest) (*TransactionResponse, error)
	RollbackTransaction(context.Context, *TransactionRequest) (*TransactionResponse, error)
}

TransactionalRequestServer is the server API for TransactionalRequest service. All implementations should embed UnimplementedTransactionalRequestServer for forward compatibility

type UnimplementedTransactionalRequestServer 

type UnimplementedTransactionalRequestServer struct {
}

UnimplementedTransactionalRequestServer should be embedded to have forward compatible implementations.

func (UnimplementedTransactionalRequestServer) CommitTransaction 

func (UnimplementedTransactionalRequestServer) CommitTransaction(context.Context, *TransactionRequest) (*TransactionResponse, error)

func (UnimplementedTransactionalRequestServer) QueryTransactionStatus 

func (UnimplementedTransactionalRequestServer) QueryTransactionStatus(context.Context, *TransactionRequest) (*TransactionResponse, error)

func (UnimplementedTransactionalRequestServer) RegisterParticipant 

func (UnimplementedTransactionalRequestServer) RegisterParticipant(context.Context, *TransactionRequest) (*TransactionResponse, error)

func (UnimplementedTransactionalRequestServer) RollbackTransaction 

func (UnimplementedTransactionalRequestServer) RollbackTransaction(context.Context, *TransactionRequest) (*TransactionResponse, error)

func (UnimplementedTransactionalRequestServer) StartTransaction 

func (UnimplementedTransactionalRequestServer) StartTransaction(context.Context, *TransactionRequest) (*TransactionResponse, error)

type UnsafeTransactionalRequestServer 

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

UnsafeTransactionalRequestServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransactionalRequestServer 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.