Versions in this module Expand all Collapse all v0 v0.5.0 Dec 23, 2022 v0.4.1 Aug 18, 2022 v0.4.0 Aug 13, 2022 v0.3.3 Aug 4, 2022 v0.3.2 Jul 29, 2022 v0.3.1 Jul 29, 2022 v0.3.0 Jul 24, 2022 v0.2.2 Jul 14, 2022 v0.2.1 Jul 12, 2022 v0.2.0 Jul 7, 2022 v0.1.2 Jun 13, 2022 v0.1.1 Jun 8, 2022 v0.1.0 May 24, 2022 Changes in this version + var BranchSession_BranchStatus_name = map[int32]string + var BranchSession_BranchStatus_value = map[string]int32 + var BranchSession_BranchType_name = map[int32]string + var BranchSession_BranchType_value = map[string]int32 + var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group") + var GlobalSession_GlobalStatus_name = map[int32]string + var GlobalSession_GlobalStatus_value = map[string]int32 + var ResultCode_name = map[int32]string + var ResultCode_value = map[string]int32 + var TransactionManagerService_ServiceDesc = grpc.ServiceDesc + func RegisterTransactionManagerServiceServer(s grpc.ServiceRegistrar, srv TransactionManagerServiceServer) + type BranchRegisterRequest struct + ApplicationData []byte + BranchType BranchSession_BranchType + LockKey string + ResourceID string + XID string + func (*BranchRegisterRequest) Descriptor() ([]byte, []int) + func (*BranchRegisterRequest) ProtoMessage() + func (m *BranchRegisterRequest) GetApplicationData() []byte + func (m *BranchRegisterRequest) GetBranchType() BranchSession_BranchType + func (m *BranchRegisterRequest) GetLockKey() string + func (m *BranchRegisterRequest) GetResourceID() string + func (m *BranchRegisterRequest) GetXID() string + func (m *BranchRegisterRequest) Marshal() (dAtA []byte, err error) + func (m *BranchRegisterRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BranchRegisterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchRegisterRequest) Reset() + func (m *BranchRegisterRequest) Size() (n int) + func (m *BranchRegisterRequest) Unmarshal(dAtA []byte) error + func (m *BranchRegisterRequest) XXX_DiscardUnknown() + func (m *BranchRegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchRegisterRequest) XXX_Merge(src proto.Message) + func (m *BranchRegisterRequest) XXX_Size() int + func (m *BranchRegisterRequest) XXX_Unmarshal(b []byte) error + func (this *BranchRegisterRequest) Equal(that interface{}) bool + func (this *BranchRegisterRequest) GoString() string + func (this *BranchRegisterRequest) String() string + type BranchRegisterResponse struct + BranchID string + BranchSessionID int64 + Message string + ResultCode ResultCode + func (*BranchRegisterResponse) Descriptor() ([]byte, []int) + func (*BranchRegisterResponse) ProtoMessage() + func (m *BranchRegisterResponse) GetBranchID() string + func (m *BranchRegisterResponse) GetBranchSessionID() int64 + func (m *BranchRegisterResponse) GetMessage() string + func (m *BranchRegisterResponse) GetResultCode() ResultCode + func (m *BranchRegisterResponse) Marshal() (dAtA []byte, err error) + func (m *BranchRegisterResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BranchRegisterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchRegisterResponse) Reset() + func (m *BranchRegisterResponse) Size() (n int) + func (m *BranchRegisterResponse) Unmarshal(dAtA []byte) error + func (m *BranchRegisterResponse) XXX_DiscardUnknown() + func (m *BranchRegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchRegisterResponse) XXX_Merge(src proto.Message) + func (m *BranchRegisterResponse) XXX_Size() int + func (m *BranchRegisterResponse) XXX_Unmarshal(b []byte) error + func (this *BranchRegisterResponse) Equal(that interface{}) bool + func (this *BranchRegisterResponse) GoString() string + func (this *BranchRegisterResponse) String() string + type BranchReportRequest struct + BranchID string + BranchStatus BranchSession_BranchStatus + func (*BranchReportRequest) Descriptor() ([]byte, []int) + func (*BranchReportRequest) ProtoMessage() + func (m *BranchReportRequest) GetBranchID() string + func (m *BranchReportRequest) GetBranchStatus() BranchSession_BranchStatus + func (m *BranchReportRequest) Marshal() (dAtA []byte, err error) + func (m *BranchReportRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BranchReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchReportRequest) Reset() + func (m *BranchReportRequest) Size() (n int) + func (m *BranchReportRequest) Unmarshal(dAtA []byte) error + func (m *BranchReportRequest) XXX_DiscardUnknown() + func (m *BranchReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchReportRequest) XXX_Merge(src proto.Message) + func (m *BranchReportRequest) XXX_Size() int + func (m *BranchReportRequest) XXX_Unmarshal(b []byte) error + func (this *BranchReportRequest) Equal(that interface{}) bool + func (this *BranchReportRequest) GoString() string + func (this *BranchReportRequest) String() string + type BranchReportResponse struct + Message string + ResultCode ResultCode + func (*BranchReportResponse) Descriptor() ([]byte, []int) + func (*BranchReportResponse) ProtoMessage() + func (m *BranchReportResponse) GetMessage() string + func (m *BranchReportResponse) GetResultCode() ResultCode + func (m *BranchReportResponse) Marshal() (dAtA []byte, err error) + func (m *BranchReportResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BranchReportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchReportResponse) Reset() + func (m *BranchReportResponse) Size() (n int) + func (m *BranchReportResponse) Unmarshal(dAtA []byte) error + func (m *BranchReportResponse) XXX_DiscardUnknown() + func (m *BranchReportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchReportResponse) XXX_Merge(src proto.Message) + func (m *BranchReportResponse) XXX_Size() int + func (m *BranchReportResponse) XXX_Unmarshal(b []byte) error + func (this *BranchReportResponse) Equal(that interface{}) bool + func (this *BranchReportResponse) GoString() string + func (this *BranchReportResponse) String() string + type BranchSession struct + ApplicationData []byte + ApplicationID string + BeginTime int64 + BranchID string + BranchSessionID int64 + LockKey string + ResourceID string + Status BranchSession_BranchStatus + TransactionID int64 + Type BranchSession_BranchType + XID string + func (*BranchSession) Descriptor() ([]byte, []int) + func (*BranchSession) ProtoMessage() + func (m *BranchSession) GetApplicationData() []byte + func (m *BranchSession) GetApplicationID() string + func (m *BranchSession) GetBeginTime() int64 + func (m *BranchSession) GetBranchID() string + func (m *BranchSession) GetBranchSessionID() int64 + func (m *BranchSession) GetLockKey() string + func (m *BranchSession) GetResourceID() string + func (m *BranchSession) GetStatus() BranchSession_BranchStatus + func (m *BranchSession) GetTransactionID() int64 + func (m *BranchSession) GetType() BranchSession_BranchType + func (m *BranchSession) GetXID() string + func (m *BranchSession) Marshal() (dAtA []byte, err error) + func (m *BranchSession) MarshalTo(dAtA []byte) (int, error) + func (m *BranchSession) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchSession) Reset() + func (m *BranchSession) Size() (n int) + func (m *BranchSession) Unmarshal(dAtA []byte) error + func (m *BranchSession) XXX_DiscardUnknown() + func (m *BranchSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchSession) XXX_Merge(src proto.Message) + func (m *BranchSession) XXX_Size() int + func (m *BranchSession) XXX_Unmarshal(b []byte) error + func (this *BranchSession) Equal(that interface{}) bool + func (this *BranchSession) GoString() string + func (this *BranchSession) String() string + type BranchSession_BranchStatus int32 + const Complete + const PhaseOneFailed + const PhaseTwoCommitting + const PhaseTwoRollbacking + const Registered + func (BranchSession_BranchStatus) EnumDescriptor() ([]byte, []int) + func (x BranchSession_BranchStatus) String() string + type BranchSession_BranchType int32 + const AT + const SAGA + const TCC + const XA + func (BranchSession_BranchType) EnumDescriptor() ([]byte, []int) + func (x BranchSession_BranchType) String() string + type GlobalBeginRequest struct + ApplicationID string + Timeout int32 + TransactionName string + func (*GlobalBeginRequest) Descriptor() ([]byte, []int) + func (*GlobalBeginRequest) ProtoMessage() + func (m *GlobalBeginRequest) GetApplicationID() string + func (m *GlobalBeginRequest) GetTimeout() int32 + func (m *GlobalBeginRequest) GetTransactionName() string + func (m *GlobalBeginRequest) Marshal() (dAtA []byte, err error) + func (m *GlobalBeginRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalBeginRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalBeginRequest) Reset() + func (m *GlobalBeginRequest) Size() (n int) + func (m *GlobalBeginRequest) Unmarshal(dAtA []byte) error + func (m *GlobalBeginRequest) XXX_DiscardUnknown() + func (m *GlobalBeginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalBeginRequest) XXX_Merge(src proto.Message) + func (m *GlobalBeginRequest) XXX_Size() int + func (m *GlobalBeginRequest) XXX_Unmarshal(b []byte) error + func (this *GlobalBeginRequest) Equal(that interface{}) bool + func (this *GlobalBeginRequest) GoString() string + func (this *GlobalBeginRequest) String() string + type GlobalBeginResponse struct + Message string + ResultCode ResultCode + XID string + func (*GlobalBeginResponse) Descriptor() ([]byte, []int) + func (*GlobalBeginResponse) ProtoMessage() + func (m *GlobalBeginResponse) GetMessage() string + func (m *GlobalBeginResponse) GetResultCode() ResultCode + func (m *GlobalBeginResponse) GetXID() string + func (m *GlobalBeginResponse) Marshal() (dAtA []byte, err error) + func (m *GlobalBeginResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalBeginResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalBeginResponse) Reset() + func (m *GlobalBeginResponse) Size() (n int) + func (m *GlobalBeginResponse) Unmarshal(dAtA []byte) error + func (m *GlobalBeginResponse) XXX_DiscardUnknown() + func (m *GlobalBeginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalBeginResponse) XXX_Merge(src proto.Message) + func (m *GlobalBeginResponse) XXX_Size() int + func (m *GlobalBeginResponse) XXX_Unmarshal(b []byte) error + func (this *GlobalBeginResponse) Equal(that interface{}) bool + func (this *GlobalBeginResponse) GoString() string + func (this *GlobalBeginResponse) String() string + type GlobalCommitRequest struct + XID string + func (*GlobalCommitRequest) Descriptor() ([]byte, []int) + func (*GlobalCommitRequest) ProtoMessage() + func (m *GlobalCommitRequest) GetXID() string + func (m *GlobalCommitRequest) Marshal() (dAtA []byte, err error) + func (m *GlobalCommitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalCommitRequest) Reset() + func (m *GlobalCommitRequest) Size() (n int) + func (m *GlobalCommitRequest) Unmarshal(dAtA []byte) error + func (m *GlobalCommitRequest) XXX_DiscardUnknown() + func (m *GlobalCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalCommitRequest) XXX_Merge(src proto.Message) + func (m *GlobalCommitRequest) XXX_Size() int + func (m *GlobalCommitRequest) XXX_Unmarshal(b []byte) error + func (this *GlobalCommitRequest) Equal(that interface{}) bool + func (this *GlobalCommitRequest) GoString() string + func (this *GlobalCommitRequest) String() string + type GlobalCommitResponse struct + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalCommitResponse) Descriptor() ([]byte, []int) + func (*GlobalCommitResponse) ProtoMessage() + func (m *GlobalCommitResponse) GetGlobalStatus() GlobalSession_GlobalStatus + func (m *GlobalCommitResponse) GetMessage() string + func (m *GlobalCommitResponse) GetResultCode() ResultCode + func (m *GlobalCommitResponse) Marshal() (dAtA []byte, err error) + func (m *GlobalCommitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalCommitResponse) Reset() + func (m *GlobalCommitResponse) Size() (n int) + func (m *GlobalCommitResponse) Unmarshal(dAtA []byte) error + func (m *GlobalCommitResponse) XXX_DiscardUnknown() + func (m *GlobalCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalCommitResponse) XXX_Merge(src proto.Message) + func (m *GlobalCommitResponse) XXX_Size() int + func (m *GlobalCommitResponse) XXX_Unmarshal(b []byte) error + func (this *GlobalCommitResponse) Equal(that interface{}) bool + func (this *GlobalCommitResponse) GoString() string + func (this *GlobalCommitResponse) String() string + type GlobalLockQueryRequest struct + LockKey string + ResourceID string + func (*GlobalLockQueryRequest) Descriptor() ([]byte, []int) + func (*GlobalLockQueryRequest) ProtoMessage() + func (m *GlobalLockQueryRequest) GetLockKey() string + func (m *GlobalLockQueryRequest) GetResourceID() string + func (m *GlobalLockQueryRequest) Marshal() (dAtA []byte, err error) + func (m *GlobalLockQueryRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalLockQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalLockQueryRequest) Reset() + func (m *GlobalLockQueryRequest) Size() (n int) + func (m *GlobalLockQueryRequest) Unmarshal(dAtA []byte) error + func (m *GlobalLockQueryRequest) XXX_DiscardUnknown() + func (m *GlobalLockQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalLockQueryRequest) XXX_Merge(src proto.Message) + func (m *GlobalLockQueryRequest) XXX_Size() int + func (m *GlobalLockQueryRequest) XXX_Unmarshal(b []byte) error + func (this *GlobalLockQueryRequest) Equal(that interface{}) bool + func (this *GlobalLockQueryRequest) GoString() string + func (this *GlobalLockQueryRequest) String() string + type GlobalLockQueryResponse struct + Lockable bool + Message string + ResultCode ResultCode + func (*GlobalLockQueryResponse) Descriptor() ([]byte, []int) + func (*GlobalLockQueryResponse) ProtoMessage() + func (m *GlobalLockQueryResponse) GetLockable() bool + func (m *GlobalLockQueryResponse) GetMessage() string + func (m *GlobalLockQueryResponse) GetResultCode() ResultCode + func (m *GlobalLockQueryResponse) Marshal() (dAtA []byte, err error) + func (m *GlobalLockQueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalLockQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalLockQueryResponse) Reset() + func (m *GlobalLockQueryResponse) Size() (n int) + func (m *GlobalLockQueryResponse) Unmarshal(dAtA []byte) error + func (m *GlobalLockQueryResponse) XXX_DiscardUnknown() + func (m *GlobalLockQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalLockQueryResponse) XXX_Merge(src proto.Message) + func (m *GlobalLockQueryResponse) XXX_Size() int + func (m *GlobalLockQueryResponse) XXX_Unmarshal(b []byte) error + func (this *GlobalLockQueryResponse) Equal(that interface{}) bool + func (this *GlobalLockQueryResponse) GoString() string + func (this *GlobalLockQueryResponse) String() string + type GlobalReportRequest struct + GlobalStatus GlobalSession_GlobalStatus + XID string + func (*GlobalReportRequest) Descriptor() ([]byte, []int) + func (*GlobalReportRequest) ProtoMessage() + func (m *GlobalReportRequest) GetGlobalStatus() GlobalSession_GlobalStatus + func (m *GlobalReportRequest) GetXID() string + func (m *GlobalReportRequest) Marshal() (dAtA []byte, err error) + func (m *GlobalReportRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalReportRequest) Reset() + func (m *GlobalReportRequest) Size() (n int) + func (m *GlobalReportRequest) Unmarshal(dAtA []byte) error + func (m *GlobalReportRequest) XXX_DiscardUnknown() + func (m *GlobalReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalReportRequest) XXX_Merge(src proto.Message) + func (m *GlobalReportRequest) XXX_Size() int + func (m *GlobalReportRequest) XXX_Unmarshal(b []byte) error + func (this *GlobalReportRequest) Equal(that interface{}) bool + func (this *GlobalReportRequest) GoString() string + func (this *GlobalReportRequest) String() string + type GlobalReportResponse struct + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalReportResponse) Descriptor() ([]byte, []int) + func (*GlobalReportResponse) ProtoMessage() + func (m *GlobalReportResponse) GetGlobalStatus() GlobalSession_GlobalStatus + func (m *GlobalReportResponse) GetMessage() string + func (m *GlobalReportResponse) GetResultCode() ResultCode + func (m *GlobalReportResponse) Marshal() (dAtA []byte, err error) + func (m *GlobalReportResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalReportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalReportResponse) Reset() + func (m *GlobalReportResponse) Size() (n int) + func (m *GlobalReportResponse) Unmarshal(dAtA []byte) error + func (m *GlobalReportResponse) XXX_DiscardUnknown() + func (m *GlobalReportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalReportResponse) XXX_Merge(src proto.Message) + func (m *GlobalReportResponse) XXX_Size() int + func (m *GlobalReportResponse) XXX_Unmarshal(b []byte) error + func (this *GlobalReportResponse) Equal(that interface{}) bool + func (this *GlobalReportResponse) GoString() string + func (this *GlobalReportResponse) String() string + type GlobalRollbackRequest struct + XID string + func (*GlobalRollbackRequest) Descriptor() ([]byte, []int) + func (*GlobalRollbackRequest) ProtoMessage() + func (m *GlobalRollbackRequest) GetXID() string + func (m *GlobalRollbackRequest) Marshal() (dAtA []byte, err error) + func (m *GlobalRollbackRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalRollbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalRollbackRequest) Reset() + func (m *GlobalRollbackRequest) Size() (n int) + func (m *GlobalRollbackRequest) Unmarshal(dAtA []byte) error + func (m *GlobalRollbackRequest) XXX_DiscardUnknown() + func (m *GlobalRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalRollbackRequest) XXX_Merge(src proto.Message) + func (m *GlobalRollbackRequest) XXX_Size() int + func (m *GlobalRollbackRequest) XXX_Unmarshal(b []byte) error + func (this *GlobalRollbackRequest) Equal(that interface{}) bool + func (this *GlobalRollbackRequest) GoString() string + func (this *GlobalRollbackRequest) String() string + type GlobalRollbackResponse struct + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalRollbackResponse) Descriptor() ([]byte, []int) + func (*GlobalRollbackResponse) ProtoMessage() + func (m *GlobalRollbackResponse) GetGlobalStatus() GlobalSession_GlobalStatus + func (m *GlobalRollbackResponse) GetMessage() string + func (m *GlobalRollbackResponse) GetResultCode() ResultCode + func (m *GlobalRollbackResponse) Marshal() (dAtA []byte, err error) + func (m *GlobalRollbackResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalRollbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalRollbackResponse) Reset() + func (m *GlobalRollbackResponse) Size() (n int) + func (m *GlobalRollbackResponse) Unmarshal(dAtA []byte) error + func (m *GlobalRollbackResponse) XXX_DiscardUnknown() + func (m *GlobalRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalRollbackResponse) XXX_Merge(src proto.Message) + func (m *GlobalRollbackResponse) XXX_Size() int + func (m *GlobalRollbackResponse) XXX_Unmarshal(b []byte) error + func (this *GlobalRollbackResponse) Equal(that interface{}) bool + func (this *GlobalRollbackResponse) GoString() string + func (this *GlobalRollbackResponse) String() string + type GlobalSession struct + ApplicationID string + BeginTime int64 + Status GlobalSession_GlobalStatus + Timeout int32 + TransactionID int64 + TransactionName string + XID string + func (*GlobalSession) Descriptor() ([]byte, []int) + func (*GlobalSession) ProtoMessage() + func (m *GlobalSession) GetApplicationID() string + func (m *GlobalSession) GetBeginTime() int64 + func (m *GlobalSession) GetStatus() GlobalSession_GlobalStatus + func (m *GlobalSession) GetTimeout() int32 + func (m *GlobalSession) GetTransactionID() int64 + func (m *GlobalSession) GetTransactionName() string + func (m *GlobalSession) GetXID() string + func (m *GlobalSession) Marshal() (dAtA []byte, err error) + func (m *GlobalSession) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalSession) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalSession) Reset() + func (m *GlobalSession) Size() (n int) + func (m *GlobalSession) Unmarshal(dAtA []byte) error + func (m *GlobalSession) XXX_DiscardUnknown() + func (m *GlobalSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalSession) XXX_Merge(src proto.Message) + func (m *GlobalSession) XXX_Size() int + func (m *GlobalSession) XXX_Unmarshal(b []byte) error + func (this *GlobalSession) Equal(that interface{}) bool + func (this *GlobalSession) GoString() string + func (this *GlobalSession) String() string + type GlobalSession_GlobalStatus int32 + const Begin + const Committing + const Finished + const Rollbacking + func (GlobalSession_GlobalStatus) EnumDescriptor() ([]byte, []int) + func (x GlobalSession_GlobalStatus) String() string + type GlobalStatusRequest struct + XID string + func (*GlobalStatusRequest) Descriptor() ([]byte, []int) + func (*GlobalStatusRequest) ProtoMessage() + func (m *GlobalStatusRequest) GetXID() string + func (m *GlobalStatusRequest) Marshal() (dAtA []byte, err error) + func (m *GlobalStatusRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalStatusRequest) Reset() + func (m *GlobalStatusRequest) Size() (n int) + func (m *GlobalStatusRequest) Unmarshal(dAtA []byte) error + func (m *GlobalStatusRequest) XXX_DiscardUnknown() + func (m *GlobalStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalStatusRequest) XXX_Merge(src proto.Message) + func (m *GlobalStatusRequest) XXX_Size() int + func (m *GlobalStatusRequest) XXX_Unmarshal(b []byte) error + func (this *GlobalStatusRequest) Equal(that interface{}) bool + func (this *GlobalStatusRequest) GoString() string + func (this *GlobalStatusRequest) String() string + type GlobalStatusResponse struct + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalStatusResponse) Descriptor() ([]byte, []int) + func (*GlobalStatusResponse) ProtoMessage() + func (m *GlobalStatusResponse) GetGlobalStatus() GlobalSession_GlobalStatus + func (m *GlobalStatusResponse) GetMessage() string + func (m *GlobalStatusResponse) GetResultCode() ResultCode + func (m *GlobalStatusResponse) Marshal() (dAtA []byte, err error) + func (m *GlobalStatusResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GlobalStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GlobalStatusResponse) Reset() + func (m *GlobalStatusResponse) Size() (n int) + func (m *GlobalStatusResponse) Unmarshal(dAtA []byte) error + func (m *GlobalStatusResponse) XXX_DiscardUnknown() + func (m *GlobalStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GlobalStatusResponse) XXX_Merge(src proto.Message) + func (m *GlobalStatusResponse) XXX_Size() int + func (m *GlobalStatusResponse) XXX_Unmarshal(b []byte) error + func (this *GlobalStatusResponse) Equal(that interface{}) bool + func (this *GlobalStatusResponse) GoString() string + func (this *GlobalStatusResponse) String() string + type ResultCode int32 + const ResultCodeFailed + const ResultCodeSuccess + func (ResultCode) EnumDescriptor() ([]byte, []int) + func (x ResultCode) String() string + type TransactionManagerServiceClient interface + Begin func(ctx context.Context, in *GlobalBeginRequest, opts ...grpc.CallOption) (*GlobalBeginResponse, error) + Commit func(ctx context.Context, in *GlobalCommitRequest, opts ...grpc.CallOption) (*GlobalCommitResponse, error) + Rollback func(ctx context.Context, in *GlobalRollbackRequest, opts ...grpc.CallOption) (*GlobalRollbackResponse, error) + func NewTransactionManagerServiceClient(cc grpc.ClientConnInterface) TransactionManagerServiceClient + type TransactionManagerServiceServer interface + Begin func(context.Context, *GlobalBeginRequest) (*GlobalBeginResponse, error) + Commit func(context.Context, *GlobalCommitRequest) (*GlobalCommitResponse, error) + Rollback func(context.Context, *GlobalRollbackRequest) (*GlobalRollbackResponse, error) + type UnimplementedTransactionManagerServiceServer struct + func (UnimplementedTransactionManagerServiceServer) Begin(context.Context, *GlobalBeginRequest) (*GlobalBeginResponse, error) + func (UnimplementedTransactionManagerServiceServer) Commit(context.Context, *GlobalCommitRequest) (*GlobalCommitResponse, error) + func (UnimplementedTransactionManagerServiceServer) Rollback(context.Context, *GlobalRollbackRequest) (*GlobalRollbackResponse, error) + type UnsafeTransactionManagerServiceServer interface
Go to main page