Versions in this module Expand all Collapse all v2 v2.0.7 Sep 17, 2021 v2.0.6 Sep 16, 2021 Changes in this version + var BranchMessageType_name = map[int32]string + var BranchMessageType_value = map[string]int32 + 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 ErrIntOverflowSeata = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthSeata = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupSeata = fmt.Errorf("proto: unexpected end of group") + var ExceptionCode_name = map[int32]string + var ExceptionCode_value = map[string]int32 + var GlobalSession_GlobalStatus_name = map[int32]string + var GlobalSession_GlobalStatus_value = map[string]int32 + var ResourceManagerService_ServiceDesc = grpc.ServiceDesc + var ResultCode_name = map[int32]string + var ResultCode_value = map[string]int32 + var TransactionManagerService_ServiceDesc = grpc.ServiceDesc + func RegisterResourceManagerServiceServer(s grpc.ServiceRegistrar, srv ResourceManagerServiceServer) + func RegisterTransactionManagerServiceServer(s grpc.ServiceRegistrar, srv TransactionManagerServiceServer) + type BranchCommitRequest struct + ApplicationData []byte + BranchID int64 + BranchType BranchSession_BranchType + LockKey string + ResourceID string + XID string + func (*BranchCommitRequest) Descriptor() ([]byte, []int) + func (*BranchCommitRequest) ProtoMessage() + func (m *BranchCommitRequest) GetApplicationData() []byte + func (m *BranchCommitRequest) GetBranchID() int64 + func (m *BranchCommitRequest) GetBranchType() BranchSession_BranchType + func (m *BranchCommitRequest) GetLockKey() string + func (m *BranchCommitRequest) GetResourceID() string + func (m *BranchCommitRequest) GetXID() string + func (m *BranchCommitRequest) Marshal() (dAtA []byte, err error) + func (m *BranchCommitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BranchCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchCommitRequest) Reset() + func (m *BranchCommitRequest) Size() (n int) + func (m *BranchCommitRequest) Unmarshal(dAtA []byte) error + func (m *BranchCommitRequest) XXX_DiscardUnknown() + func (m *BranchCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchCommitRequest) XXX_Merge(src proto.Message) + func (m *BranchCommitRequest) XXX_Size() int + func (m *BranchCommitRequest) XXX_Unmarshal(b []byte) error + func (this *BranchCommitRequest) Equal(that interface{}) bool + func (this *BranchCommitRequest) GoString() string + func (this *BranchCommitRequest) String() string + type BranchCommitResponse struct + BranchID int64 + BranchStatus BranchSession_BranchStatus + ExceptionCode ExceptionCode + Message string + ResultCode ResultCode + XID string + func (*BranchCommitResponse) Descriptor() ([]byte, []int) + func (*BranchCommitResponse) ProtoMessage() + func (m *BranchCommitResponse) GetBranchID() int64 + func (m *BranchCommitResponse) GetBranchStatus() BranchSession_BranchStatus + func (m *BranchCommitResponse) GetExceptionCode() ExceptionCode + func (m *BranchCommitResponse) GetMessage() string + func (m *BranchCommitResponse) GetResultCode() ResultCode + func (m *BranchCommitResponse) GetXID() string + func (m *BranchCommitResponse) Marshal() (dAtA []byte, err error) + func (m *BranchCommitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BranchCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchCommitResponse) Reset() + func (m *BranchCommitResponse) Size() (n int) + func (m *BranchCommitResponse) Unmarshal(dAtA []byte) error + func (m *BranchCommitResponse) XXX_DiscardUnknown() + func (m *BranchCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchCommitResponse) XXX_Merge(src proto.Message) + func (m *BranchCommitResponse) XXX_Size() int + func (m *BranchCommitResponse) XXX_Unmarshal(b []byte) error + func (this *BranchCommitResponse) Equal(that interface{}) bool + func (this *BranchCommitResponse) GoString() string + func (this *BranchCommitResponse) String() string + type BranchMessage struct + BranchMessageType BranchMessageType + ID int64 + Message *types.Any + func (*BranchMessage) Descriptor() ([]byte, []int) + func (*BranchMessage) ProtoMessage() + func (m *BranchMessage) GetBranchMessageType() BranchMessageType + func (m *BranchMessage) GetID() int64 + func (m *BranchMessage) GetMessage() *types.Any + func (m *BranchMessage) Marshal() (dAtA []byte, err error) + func (m *BranchMessage) MarshalTo(dAtA []byte) (int, error) + func (m *BranchMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchMessage) Reset() + func (m *BranchMessage) Size() (n int) + func (m *BranchMessage) Unmarshal(dAtA []byte) error + func (m *BranchMessage) XXX_DiscardUnknown() + func (m *BranchMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchMessage) XXX_Merge(src proto.Message) + func (m *BranchMessage) XXX_Size() int + func (m *BranchMessage) XXX_Unmarshal(b []byte) error + func (this *BranchMessage) Equal(that interface{}) bool + func (this *BranchMessage) GoString() string + func (this *BranchMessage) String() string + type BranchMessageType int32 + const TypeBranchCommit + const TypeBranchCommitResult + const TypeBranchRollBackResult + const TypeBranchRollback + func (BranchMessageType) EnumDescriptor() ([]byte, []int) + func (x BranchMessageType) String() string + type BranchRegisterRequest struct + Addressing string + ApplicationData []byte + BranchType BranchSession_BranchType + LockKey string + ResourceID string + XID string + func (*BranchRegisterRequest) Descriptor() ([]byte, []int) + func (*BranchRegisterRequest) ProtoMessage() + func (m *BranchRegisterRequest) GetAddressing() string + 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 int64 + ExceptionCode ExceptionCode + Message string + ResultCode ResultCode + func (*BranchRegisterResponse) Descriptor() ([]byte, []int) + func (*BranchRegisterResponse) ProtoMessage() + func (m *BranchRegisterResponse) GetBranchID() int64 + func (m *BranchRegisterResponse) GetExceptionCode() ExceptionCode + 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 + ApplicationData []byte + BranchID int64 + BranchStatus BranchSession_BranchStatus + BranchType BranchSession_BranchType + ResourceID string + XID string + func (*BranchReportRequest) Descriptor() ([]byte, []int) + func (*BranchReportRequest) ProtoMessage() + func (m *BranchReportRequest) GetApplicationData() []byte + func (m *BranchReportRequest) GetBranchID() int64 + func (m *BranchReportRequest) GetBranchStatus() BranchSession_BranchStatus + func (m *BranchReportRequest) GetBranchType() BranchSession_BranchType + func (m *BranchReportRequest) GetResourceID() string + func (m *BranchReportRequest) GetXID() string + 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 + ExceptionCode ExceptionCode + Message string + ResultCode ResultCode + func (*BranchReportResponse) Descriptor() ([]byte, []int) + func (*BranchReportResponse) ProtoMessage() + func (m *BranchReportResponse) GetExceptionCode() ExceptionCode + 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 BranchRollbackRequest struct + ApplicationData []byte + BranchID int64 + BranchType BranchSession_BranchType + LockKey string + ResourceID string + XID string + func (*BranchRollbackRequest) Descriptor() ([]byte, []int) + func (*BranchRollbackRequest) ProtoMessage() + func (m *BranchRollbackRequest) GetApplicationData() []byte + func (m *BranchRollbackRequest) GetBranchID() int64 + func (m *BranchRollbackRequest) GetBranchType() BranchSession_BranchType + func (m *BranchRollbackRequest) GetLockKey() string + func (m *BranchRollbackRequest) GetResourceID() string + func (m *BranchRollbackRequest) GetXID() string + func (m *BranchRollbackRequest) Marshal() (dAtA []byte, err error) + func (m *BranchRollbackRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BranchRollbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchRollbackRequest) Reset() + func (m *BranchRollbackRequest) Size() (n int) + func (m *BranchRollbackRequest) Unmarshal(dAtA []byte) error + func (m *BranchRollbackRequest) XXX_DiscardUnknown() + func (m *BranchRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchRollbackRequest) XXX_Merge(src proto.Message) + func (m *BranchRollbackRequest) XXX_Size() int + func (m *BranchRollbackRequest) XXX_Unmarshal(b []byte) error + func (this *BranchRollbackRequest) Equal(that interface{}) bool + func (this *BranchRollbackRequest) GoString() string + func (this *BranchRollbackRequest) String() string + type BranchRollbackResponse struct + BranchID int64 + BranchStatus BranchSession_BranchStatus + ExceptionCode ExceptionCode + Message string + ResultCode ResultCode + XID string + func (*BranchRollbackResponse) Descriptor() ([]byte, []int) + func (*BranchRollbackResponse) ProtoMessage() + func (m *BranchRollbackResponse) GetBranchID() int64 + func (m *BranchRollbackResponse) GetBranchStatus() BranchSession_BranchStatus + func (m *BranchRollbackResponse) GetExceptionCode() ExceptionCode + func (m *BranchRollbackResponse) GetMessage() string + func (m *BranchRollbackResponse) GetResultCode() ResultCode + func (m *BranchRollbackResponse) GetXID() string + func (m *BranchRollbackResponse) Marshal() (dAtA []byte, err error) + func (m *BranchRollbackResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BranchRollbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BranchRollbackResponse) Reset() + func (m *BranchRollbackResponse) Size() (n int) + func (m *BranchRollbackResponse) Unmarshal(dAtA []byte) error + func (m *BranchRollbackResponse) XXX_DiscardUnknown() + func (m *BranchRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BranchRollbackResponse) XXX_Merge(src proto.Message) + func (m *BranchRollbackResponse) XXX_Size() int + func (m *BranchRollbackResponse) XXX_Unmarshal(b []byte) error + func (this *BranchRollbackResponse) Equal(that interface{}) bool + func (this *BranchRollbackResponse) GoString() string + func (this *BranchRollbackResponse) String() string + type BranchSession struct + Addressing string + ApplicationData []byte + BranchID 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) GetAddressing() string + func (m *BranchSession) GetApplicationData() []byte + func (m *BranchSession) GetBranchID() 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 PhaseOneDone + const PhaseOneFailed + const PhaseOneTimeout + const PhaseTwoCommitFailedCanNotRetry + const PhaseTwoCommitFailedRetryable + const PhaseTwoCommitted + const PhaseTwoRollbackFailedCanNotRetry + const PhaseTwoRollbackFailedRetryable + const PhaseTwoRolledBack + const Registered + const UnknownBranchStatus + 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 ExceptionCode int32 + const BeginFailed + const BranchRegisterFailed + const BranchReportFailed + const BranchRollbackFailedRetryable + const BranchRollbackFailedUnretryable + const BranchTransactionNotExist + const FailedLockGlobalTransaction + const FailedStore + const FailedToAddBranch + const FailedToSendBranchCommitRequest + const FailedToSendBranchRollbackRequest + const FailedWriteSession + const GlobalTransactionNotActive + const GlobalTransactionNotExist + const GlobalTransactionStatusInvalid + const IO + const LockKeyConflict + const LockableCheckFailed + const UnknownErr + func (ExceptionCode) EnumDescriptor() ([]byte, []int) + func (x ExceptionCode) String() string + type GlobalBeginRequest struct + Addressing string + Timeout int32 + TransactionName string + func (*GlobalBeginRequest) Descriptor() ([]byte, []int) + func (*GlobalBeginRequest) ProtoMessage() + func (m *GlobalBeginRequest) GetAddressing() 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 + ExceptionCode ExceptionCode + Message string + ResultCode ResultCode + XID string + func (*GlobalBeginResponse) Descriptor() ([]byte, []int) + func (*GlobalBeginResponse) ProtoMessage() + func (m *GlobalBeginResponse) GetExceptionCode() ExceptionCode + 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 + ExceptionCode ExceptionCode + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalCommitResponse) Descriptor() ([]byte, []int) + func (*GlobalCommitResponse) ProtoMessage() + func (m *GlobalCommitResponse) GetExceptionCode() ExceptionCode + 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 + BranchType BranchSession_BranchType + LockKey string + ResourceID string + XID string + func (*GlobalLockQueryRequest) Descriptor() ([]byte, []int) + func (*GlobalLockQueryRequest) ProtoMessage() + func (m *GlobalLockQueryRequest) GetBranchType() BranchSession_BranchType + func (m *GlobalLockQueryRequest) GetLockKey() string + func (m *GlobalLockQueryRequest) GetResourceID() string + func (m *GlobalLockQueryRequest) GetXID() 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 + ExceptionCode ExceptionCode + Lockable bool + Message string + ResultCode ResultCode + func (*GlobalLockQueryResponse) Descriptor() ([]byte, []int) + func (*GlobalLockQueryResponse) ProtoMessage() + func (m *GlobalLockQueryResponse) GetExceptionCode() ExceptionCode + 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 + ExceptionCode ExceptionCode + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalReportResponse) Descriptor() ([]byte, []int) + func (*GlobalReportResponse) ProtoMessage() + func (m *GlobalReportResponse) GetExceptionCode() ExceptionCode + 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 + ExceptionCode ExceptionCode + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalRollbackResponse) Descriptor() ([]byte, []int) + func (*GlobalRollbackResponse) ProtoMessage() + func (m *GlobalRollbackResponse) GetExceptionCode() ExceptionCode + 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 + Active bool + Addressing 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) GetActive() bool + func (m *GlobalSession) GetAddressing() 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 AsyncCommitting + const Begin + const CommitFailed + const CommitRetrying + const Committed + const Committing + const Finished + const RollbackFailed + const RollbackRetrying + const RolledBack + const RollingBack + const TimeoutRollbackFailed + const TimeoutRollbackRetrying + const TimeoutRolledBack + const TimeoutRollingBack + const UnknownGlobalStatus + 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 + ExceptionCode ExceptionCode + GlobalStatus GlobalSession_GlobalStatus + Message string + ResultCode ResultCode + func (*GlobalStatusResponse) Descriptor() ([]byte, []int) + func (*GlobalStatusResponse) ProtoMessage() + func (m *GlobalStatusResponse) GetExceptionCode() ExceptionCode + 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 ResourceManagerServiceClient interface + BranchCommunicate func(ctx context.Context, opts ...grpc.CallOption) (ResourceManagerService_BranchCommunicateClient, error) + BranchRegister func(ctx context.Context, in *BranchRegisterRequest, opts ...grpc.CallOption) (*BranchRegisterResponse, error) + BranchReport func(ctx context.Context, in *BranchReportRequest, opts ...grpc.CallOption) (*BranchReportResponse, error) + LockQuery func(ctx context.Context, in *GlobalLockQueryRequest, opts ...grpc.CallOption) (*GlobalLockQueryResponse, error) + func NewResourceManagerServiceClient(cc grpc.ClientConnInterface) ResourceManagerServiceClient + type ResourceManagerServiceServer interface + BranchCommunicate func(ResourceManagerService_BranchCommunicateServer) error + BranchRegister func(context.Context, *BranchRegisterRequest) (*BranchRegisterResponse, error) + BranchReport func(context.Context, *BranchReportRequest) (*BranchReportResponse, error) + LockQuery func(context.Context, *GlobalLockQueryRequest) (*GlobalLockQueryResponse, error) + type ResourceManagerService_BranchCommunicateClient interface + Recv func() (*BranchMessage, error) + Send func(*BranchMessage) error + type ResourceManagerService_BranchCommunicateServer interface + Recv func() (*BranchMessage, error) + Send func(*BranchMessage) error + type ResultCode int32 + const ResultCodeFailed + const ResultCodeSuccess + func (ResultCode) EnumDescriptor() ([]byte, []int) + func (x ResultCode) String() string + type RowLock struct + BranchID int64 + PK string + ResourceID string + RowKey string + TableName string + TransactionID int64 + XID string + func (*RowLock) Descriptor() ([]byte, []int) + func (*RowLock) ProtoMessage() + func (m *RowLock) GetBranchID() int64 + func (m *RowLock) GetPK() string + func (m *RowLock) GetResourceID() string + func (m *RowLock) GetRowKey() string + func (m *RowLock) GetTableName() string + func (m *RowLock) GetTransactionID() int64 + func (m *RowLock) GetXID() string + func (m *RowLock) Marshal() (dAtA []byte, err error) + func (m *RowLock) MarshalTo(dAtA []byte) (int, error) + func (m *RowLock) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RowLock) Reset() + func (m *RowLock) Size() (n int) + func (m *RowLock) Unmarshal(dAtA []byte) error + func (m *RowLock) XXX_DiscardUnknown() + func (m *RowLock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RowLock) XXX_Merge(src proto.Message) + func (m *RowLock) XXX_Size() int + func (m *RowLock) XXX_Unmarshal(b []byte) error + func (this *RowLock) Equal(that interface{}) bool + func (this *RowLock) GoString() string + func (this *RowLock) 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) + GetStatus func(ctx context.Context, in *GlobalStatusRequest, opts ...grpc.CallOption) (*GlobalStatusResponse, error) + GlobalReport func(ctx context.Context, in *GlobalReportRequest, opts ...grpc.CallOption) (*GlobalReportResponse, 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) + GetStatus func(context.Context, *GlobalStatusRequest) (*GlobalStatusResponse, error) + GlobalReport func(context.Context, *GlobalReportRequest) (*GlobalReportResponse, error) + Rollback func(context.Context, *GlobalRollbackRequest) (*GlobalRollbackResponse, error) + type UnimplementedResourceManagerServiceServer struct + func (UnimplementedResourceManagerServiceServer) BranchCommunicate(ResourceManagerService_BranchCommunicateServer) error + func (UnimplementedResourceManagerServiceServer) BranchRegister(context.Context, *BranchRegisterRequest) (*BranchRegisterResponse, error) + func (UnimplementedResourceManagerServiceServer) BranchReport(context.Context, *BranchReportRequest) (*BranchReportResponse, error) + func (UnimplementedResourceManagerServiceServer) LockQuery(context.Context, *GlobalLockQueryRequest) (*GlobalLockQueryResponse, error) + type UnimplementedTransactionManagerServiceServer struct + func (UnimplementedTransactionManagerServiceServer) Begin(context.Context, *GlobalBeginRequest) (*GlobalBeginResponse, error) + func (UnimplementedTransactionManagerServiceServer) Commit(context.Context, *GlobalCommitRequest) (*GlobalCommitResponse, error) + func (UnimplementedTransactionManagerServiceServer) GetStatus(context.Context, *GlobalStatusRequest) (*GlobalStatusResponse, error) + func (UnimplementedTransactionManagerServiceServer) GlobalReport(context.Context, *GlobalReportRequest) (*GlobalReportResponse, error) + func (UnimplementedTransactionManagerServiceServer) Rollback(context.Context, *GlobalRollbackRequest) (*GlobalRollbackResponse, error) + type UnsafeResourceManagerServiceServer interface + type UnsafeTransactionManagerServiceServer interface