apis

package
v2.0.7 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2021 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSeata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSeata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSeata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BranchMessageType_name = map[int32]string{
	0: "TypeBranchCommit",
	1: "TypeBranchCommitResult",
	2: "TypeBranchRollback",
	3: "TypeBranchRollBackResult",
}
View Source 
var BranchMessageType_value = map[string]int32{
	"TypeBranchCommit":         0,
	"TypeBranchCommitResult":   1,
	"TypeBranchRollback":       2,
	"TypeBranchRollBackResult": 3,
}
View Source 
var BranchSession_BranchStatus_name = map[int32]string{
	0:  "UnknownBranchStatus",
	1:  "Registered",
	2:  "PhaseOneDone",
	3:  "PhaseOneFailed",
	4:  "PhaseOneTimeout",
	5:  "PhaseTwoCommitted",
	6:  "PhaseTwoCommitFailedRetryable",
	7:  "PhaseTwoCommitFailedCanNotRetry",
	8:  "PhaseTwoRolledBack",
	9:  "PhaseTwoRollbackFailedRetryable",
	10: "PhaseTwoRollbackFailedCanNotRetry",
}
View Source 
var BranchSession_BranchStatus_value = map[string]int32{
	"UnknownBranchStatus":               0,
	"Registered":                        1,
	"PhaseOneDone":                      2,
	"PhaseOneFailed":                    3,
	"PhaseOneTimeout":                   4,
	"PhaseTwoCommitted":                 5,
	"PhaseTwoCommitFailedRetryable":     6,
	"PhaseTwoCommitFailedCanNotRetry":   7,
	"PhaseTwoRolledBack":                8,
	"PhaseTwoRollbackFailedRetryable":   9,
	"PhaseTwoRollbackFailedCanNotRetry": 10,
}
View Source 
var BranchSession_BranchType_name = map[int32]string{
	0: "AT",
	1: "TCC",
	2: "SAGA",
	3: "XA",
}
View Source 
var BranchSession_BranchType_value = map[string]int32{
	"AT":   0,
	"TCC":  1,
	"SAGA": 2,
	"XA":   3,
}
View Source 
var ExceptionCode_name = map[int32]string{
	0:  "UnknownErr",
	1:  "BeginFailed",
	2:  "LockKeyConflict",
	3:  "IO",
	4:  "BranchRollbackFailedRetryable",
	5:  "BranchRollbackFailedUnretryable",
	6:  "BranchRegisterFailed",
	7:  "BranchReportFailed",
	8:  "LockableCheckFailed",
	9:  "BranchTransactionNotExist",
	10: "GlobalTransactionNotExist",
	11: "GlobalTransactionNotActive",
	12: "GlobalTransactionStatusInvalid",
	13: "FailedToSendBranchCommitRequest",
	14: "FailedToSendBranchRollbackRequest",
	15: "FailedToAddBranch",
	16: "FailedLockGlobalTransaction",
	17: "FailedWriteSession",
	18: "FailedStore",
}
View Source 
var ExceptionCode_value = map[string]int32{
	"UnknownErr":                        0,
	"BeginFailed":                       1,
	"LockKeyConflict":                   2,
	"IO":                                3,
	"BranchRollbackFailedRetryable":     4,
	"BranchRollbackFailedUnretryable":   5,
	"BranchRegisterFailed":              6,
	"BranchReportFailed":                7,
	"LockableCheckFailed":               8,
	"BranchTransactionNotExist":         9,
	"GlobalTransactionNotExist":         10,
	"GlobalTransactionNotActive":        11,
	"GlobalTransactionStatusInvalid":    12,
	"FailedToSendBranchCommitRequest":   13,
	"FailedToSendBranchRollbackRequest": 14,
	"FailedToAddBranch":                 15,
	"FailedLockGlobalTransaction":       16,
	"FailedWriteSession":                17,
	"FailedStore":                       18,
}
View Source 
var GlobalSession_GlobalStatus_name = map[int32]string{
	0:  "UnknownGlobalStatus",
	1:  "Begin",
	2:  "Committing",
	3:  "CommitRetrying",
	4:  "RollingBack",
	5:  "RollbackRetrying",
	6:  "TimeoutRollingBack",
	7:  "TimeoutRollbackRetrying",
	8:  "AsyncCommitting",
	9:  "Committed",
	10: "CommitFailed",
	11: "RolledBack",
	12: "RollbackFailed",
	13: "TimeoutRolledBack",
	14: "TimeoutRollbackFailed",
	15: "Finished",
}
View Source 
var GlobalSession_GlobalStatus_value = map[string]int32{
	"UnknownGlobalStatus":     0,
	"Begin":                   1,
	"Committing":              2,
	"CommitRetrying":          3,
	"RollingBack":             4,
	"RollbackRetrying":        5,
	"TimeoutRollingBack":      6,
	"TimeoutRollbackRetrying": 7,
	"AsyncCommitting":         8,
	"Committed":               9,
	"CommitFailed":            10,
	"RolledBack":              11,
	"RollbackFailed":          12,
	"TimeoutRolledBack":       13,
	"TimeoutRollbackFailed":   14,
	"Finished":                15,
}
View Source 
var ResourceManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apis.ResourceManagerService",
	HandlerType: (*ResourceManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BranchRegister",
			Handler:    _ResourceManagerService_BranchRegister_Handler,
		},
		{
			MethodName: "BranchReport",
			Handler:    _ResourceManagerService_BranchReport_Handler,
		},
		{
			MethodName: "LockQuery",
			Handler:    _ResourceManagerService_LockQuery_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BranchCommunicate",
			Handler:       _ResourceManagerService_BranchCommunicate_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "seata.proto",
}

ResourceManagerService_ServiceDesc is the grpc.ServiceDesc for ResourceManagerService 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 ResultCode_name = map[int32]string{
	0: "ResultCodeFailed",
	1: "ResultCodeSuccess",
}
View Source 
var ResultCode_value = map[string]int32{
	"ResultCodeFailed":  0,
	"ResultCodeSuccess": 1,
}
View Source 
var TransactionManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apis.TransactionManagerService",
	HandlerType: (*TransactionManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Begin",
			Handler:    _TransactionManagerService_Begin_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _TransactionManagerService_GetStatus_Handler,
		},
		{
			MethodName: "GlobalReport",
			Handler:    _TransactionManagerService_GlobalReport_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _TransactionManagerService_Commit_Handler,
		},
		{
			MethodName: "Rollback",
			Handler:    _TransactionManagerService_Rollback_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "seata.proto",
}

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

Functions

func RegisterResourceManagerServiceServer 

func RegisterResourceManagerServiceServer(s grpc.ServiceRegistrar, srv ResourceManagerServiceServer)

func RegisterTransactionManagerServiceServer 

func RegisterTransactionManagerServiceServer(s grpc.ServiceRegistrar, srv TransactionManagerServiceServer)

Types

type BranchCommitRequest 

type BranchCommitRequest struct {
	XID             string                   `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
	BranchID        int64                    `protobuf:"varint,2,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	ResourceID      string                   `protobuf:"bytes,3,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	LockKey         string                   `protobuf:"bytes,4,opt,name=LockKey,proto3" json:"LockKey,omitempty"`
	BranchType      BranchSession_BranchType `protobuf:"varint,5,opt,name=BranchType,proto3,enum=apis.BranchSession_BranchType" json:"BranchType,omitempty"`
	ApplicationData []byte                   `protobuf:"bytes,6,opt,name=ApplicationData,proto3" json:"ApplicationData,omitempty"`
}

BranchCommitRequest represents a request to commit branch transaction

func (*BranchCommitRequest) Descriptor 

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

func (*BranchCommitRequest) Equal 

func (this *BranchCommitRequest) Equal(that interface{}) bool

func (*BranchCommitRequest) GetApplicationData 

func (m *BranchCommitRequest) GetApplicationData() []byte

func (*BranchCommitRequest) GetBranchID 

func (m *BranchCommitRequest) GetBranchID() int64

func (*BranchCommitRequest) GetBranchType 

func (m *BranchCommitRequest) GetBranchType() BranchSession_BranchType

func (*BranchCommitRequest) GetLockKey 

func (m *BranchCommitRequest) GetLockKey() string

func (*BranchCommitRequest) GetResourceID 

func (m *BranchCommitRequest) GetResourceID() string

func (*BranchCommitRequest) GetXID 

func (m *BranchCommitRequest) GetXID() string

func (*BranchCommitRequest) GoString 

func (this *BranchCommitRequest) GoString() string

func (*BranchCommitRequest) Marshal 

func (m *BranchCommitRequest) Marshal() (dAtA []byte, err error)

func (*BranchCommitRequest) MarshalTo 

func (m *BranchCommitRequest) MarshalTo(dAtA []byte) (int, error)

func (*BranchCommitRequest) MarshalToSizedBuffer 

func (m *BranchCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchCommitRequest) ProtoMessage 

func (*BranchCommitRequest) ProtoMessage()

func (*BranchCommitRequest) Reset 

func (m *BranchCommitRequest) Reset()

func (*BranchCommitRequest) Size 

func (m *BranchCommitRequest) Size() (n int)

func (*BranchCommitRequest) String 

func (this *BranchCommitRequest) String() string

func (*BranchCommitRequest) Unmarshal 

func (m *BranchCommitRequest) Unmarshal(dAtA []byte) error

func (*BranchCommitRequest) XXX_DiscardUnknown 

func (m *BranchCommitRequest) XXX_DiscardUnknown()

func (*BranchCommitRequest) XXX_Marshal 

func (m *BranchCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchCommitRequest) XXX_Merge 

func (m *BranchCommitRequest) XXX_Merge(src proto.Message)

func (*BranchCommitRequest) XXX_Size 

func (m *BranchCommitRequest) XXX_Size() int

func (*BranchCommitRequest) XXX_Unmarshal 

func (m *BranchCommitRequest) XXX_Unmarshal(b []byte) error

type BranchCommitResponse 

type BranchCommitResponse struct {
	ResultCode    ResultCode                 `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode              `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string                     `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	XID           string                     `protobuf:"bytes,4,opt,name=XID,proto3" json:"XID,omitempty"`
	BranchID      int64                      `protobuf:"varint,5,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	BranchStatus  BranchSession_BranchStatus `protobuf:"varint,6,opt,name=BranchStatus,proto3,enum=apis.BranchSession_BranchStatus" json:"BranchStatus,omitempty"`
}

BranchCommitResponse represents a response to BranchCommitRequest

func (*BranchCommitResponse) Descriptor 

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

func (*BranchCommitResponse) Equal 

func (this *BranchCommitResponse) Equal(that interface{}) bool

func (*BranchCommitResponse) GetBranchID 

func (m *BranchCommitResponse) GetBranchID() int64

func (*BranchCommitResponse) GetBranchStatus 

func (m *BranchCommitResponse) GetBranchStatus() BranchSession_BranchStatus

func (*BranchCommitResponse) GetExceptionCode 

func (m *BranchCommitResponse) GetExceptionCode() ExceptionCode

func (*BranchCommitResponse) GetMessage 

func (m *BranchCommitResponse) GetMessage() string

func (*BranchCommitResponse) GetResultCode 

func (m *BranchCommitResponse) GetResultCode() ResultCode

func (*BranchCommitResponse) GetXID 

func (m *BranchCommitResponse) GetXID() string

func (*BranchCommitResponse) GoString 

func (this *BranchCommitResponse) GoString() string

func (*BranchCommitResponse) Marshal 

func (m *BranchCommitResponse) Marshal() (dAtA []byte, err error)

func (*BranchCommitResponse) MarshalTo 

func (m *BranchCommitResponse) MarshalTo(dAtA []byte) (int, error)

func (*BranchCommitResponse) MarshalToSizedBuffer 

func (m *BranchCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchCommitResponse) ProtoMessage 

func (*BranchCommitResponse) ProtoMessage()

func (*BranchCommitResponse) Reset 

func (m *BranchCommitResponse) Reset()

func (*BranchCommitResponse) Size 

func (m *BranchCommitResponse) Size() (n int)

func (*BranchCommitResponse) String 

func (this *BranchCommitResponse) String() string

func (*BranchCommitResponse) Unmarshal 

func (m *BranchCommitResponse) Unmarshal(dAtA []byte) error

func (*BranchCommitResponse) XXX_DiscardUnknown 

func (m *BranchCommitResponse) XXX_DiscardUnknown()

func (*BranchCommitResponse) XXX_Marshal 

func (m *BranchCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchCommitResponse) XXX_Merge 

func (m *BranchCommitResponse) XXX_Merge(src proto.Message)

func (*BranchCommitResponse) XXX_Size 

func (m *BranchCommitResponse) XXX_Size() int

func (*BranchCommitResponse) XXX_Unmarshal 

func (m *BranchCommitResponse) XXX_Unmarshal(b []byte) error

type BranchMessage 

type BranchMessage struct {
	ID                int64             `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	BranchMessageType BranchMessageType `protobuf:"varint,2,opt,name=BranchMessageType,proto3,enum=apis.BranchMessageType" json:"BranchMessageType,omitempty"`
	Message           *types.Any        `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
}

func (*BranchMessage) Descriptor 

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

func (*BranchMessage) Equal 

func (this *BranchMessage) Equal(that interface{}) bool

func (*BranchMessage) GetBranchMessageType 

func (m *BranchMessage) GetBranchMessageType() BranchMessageType

func (*BranchMessage) GetID 

func (m *BranchMessage) GetID() int64

func (*BranchMessage) GetMessage 

func (m *BranchMessage) GetMessage() *types.Any

func (*BranchMessage) GoString 

func (this *BranchMessage) GoString() string

func (*BranchMessage) Marshal 

func (m *BranchMessage) Marshal() (dAtA []byte, err error)

func (*BranchMessage) MarshalTo 

func (m *BranchMessage) MarshalTo(dAtA []byte) (int, error)

func (*BranchMessage) MarshalToSizedBuffer 

func (m *BranchMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchMessage) ProtoMessage 

func (*BranchMessage) ProtoMessage()

func (*BranchMessage) Reset 

func (m *BranchMessage) Reset()

func (*BranchMessage) Size 

func (m *BranchMessage) Size() (n int)

func (*BranchMessage) String 

func (this *BranchMessage) String() string

func (*BranchMessage) Unmarshal 

func (m *BranchMessage) Unmarshal(dAtA []byte) error

func (*BranchMessage) XXX_DiscardUnknown 

func (m *BranchMessage) XXX_DiscardUnknown()

func (*BranchMessage) XXX_Marshal 

func (m *BranchMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchMessage) XXX_Merge 

func (m *BranchMessage) XXX_Merge(src proto.Message)

func (*BranchMessage) XXX_Size 

func (m *BranchMessage) XXX_Size() int

func (*BranchMessage) XXX_Unmarshal 

func (m *BranchMessage) XXX_Unmarshal(b []byte) error

type BranchMessageType 

type BranchMessageType int32
const (
	TypeBranchCommit         BranchMessageType = 0
	TypeBranchCommitResult   BranchMessageType = 1
	TypeBranchRollback       BranchMessageType = 2
	TypeBranchRollBackResult BranchMessageType = 3
)

func (BranchMessageType) EnumDescriptor 

func (BranchMessageType) EnumDescriptor() ([]byte, []int)

func (BranchMessageType) String 

func (x BranchMessageType) String() string

type BranchRegisterRequest 

type BranchRegisterRequest struct {
	Addressing      string                   `protobuf:"bytes,1,opt,name=Addressing,proto3" json:"Addressing,omitempty"`
	XID             string                   `protobuf:"bytes,2,opt,name=XID,proto3" json:"XID,omitempty"`
	ResourceID      string                   `protobuf:"bytes,3,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	LockKey         string                   `protobuf:"bytes,4,opt,name=LockKey,proto3" json:"LockKey,omitempty"`
	BranchType      BranchSession_BranchType `protobuf:"varint,5,opt,name=BranchType,proto3,enum=apis.BranchSession_BranchType" json:"BranchType,omitempty"`
	ApplicationData []byte                   `protobuf:"bytes,6,opt,name=ApplicationData,proto3" json:"ApplicationData,omitempty"`
}

BranchRegisterRequest represents a branch transaction join in the global transaction

func (*BranchRegisterRequest) Descriptor 

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

func (*BranchRegisterRequest) Equal 

func (this *BranchRegisterRequest) Equal(that interface{}) bool

func (*BranchRegisterRequest) GetAddressing 

func (m *BranchRegisterRequest) GetAddressing() string

func (*BranchRegisterRequest) GetApplicationData 

func (m *BranchRegisterRequest) GetApplicationData() []byte

func (*BranchRegisterRequest) GetBranchType 

func (m *BranchRegisterRequest) GetBranchType() BranchSession_BranchType

func (*BranchRegisterRequest) GetLockKey 

func (m *BranchRegisterRequest) GetLockKey() string

func (*BranchRegisterRequest) GetResourceID 

func (m *BranchRegisterRequest) GetResourceID() string

func (*BranchRegisterRequest) GetXID 

func (m *BranchRegisterRequest) GetXID() string

func (*BranchRegisterRequest) GoString 

func (this *BranchRegisterRequest) GoString() string

func (*BranchRegisterRequest) Marshal 

func (m *BranchRegisterRequest) Marshal() (dAtA []byte, err error)

func (*BranchRegisterRequest) MarshalTo 

func (m *BranchRegisterRequest) MarshalTo(dAtA []byte) (int, error)

func (*BranchRegisterRequest) MarshalToSizedBuffer 

func (m *BranchRegisterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchRegisterRequest) ProtoMessage 

func (*BranchRegisterRequest) ProtoMessage()

func (*BranchRegisterRequest) Reset 

func (m *BranchRegisterRequest) Reset()

func (*BranchRegisterRequest) Size 

func (m *BranchRegisterRequest) Size() (n int)

func (*BranchRegisterRequest) String 

func (this *BranchRegisterRequest) String() string

func (*BranchRegisterRequest) Unmarshal 

func (m *BranchRegisterRequest) Unmarshal(dAtA []byte) error

func (*BranchRegisterRequest) XXX_DiscardUnknown 

func (m *BranchRegisterRequest) XXX_DiscardUnknown()

func (*BranchRegisterRequest) XXX_Marshal 

func (m *BranchRegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchRegisterRequest) XXX_Merge 

func (m *BranchRegisterRequest) XXX_Merge(src proto.Message)

func (*BranchRegisterRequest) XXX_Size 

func (m *BranchRegisterRequest) XXX_Size() int

func (*BranchRegisterRequest) XXX_Unmarshal 

func (m *BranchRegisterRequest) XXX_Unmarshal(b []byte) error

type BranchRegisterResponse 

type BranchRegisterResponse struct {
	ResultCode    ResultCode    `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string        `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	BranchID      int64         `protobuf:"varint,4,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
}

BranchRegisterResponse represents a response to BranchRegisterRequest

func (*BranchRegisterResponse) Descriptor 

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

func (*BranchRegisterResponse) Equal 

func (this *BranchRegisterResponse) Equal(that interface{}) bool

func (*BranchRegisterResponse) GetBranchID 

func (m *BranchRegisterResponse) GetBranchID() int64

func (*BranchRegisterResponse) GetExceptionCode 

func (m *BranchRegisterResponse) GetExceptionCode() ExceptionCode

func (*BranchRegisterResponse) GetMessage 

func (m *BranchRegisterResponse) GetMessage() string

func (*BranchRegisterResponse) GetResultCode 

func (m *BranchRegisterResponse) GetResultCode() ResultCode

func (*BranchRegisterResponse) GoString 

func (this *BranchRegisterResponse) GoString() string

func (*BranchRegisterResponse) Marshal 

func (m *BranchRegisterResponse) Marshal() (dAtA []byte, err error)

func (*BranchRegisterResponse) MarshalTo 

func (m *BranchRegisterResponse) MarshalTo(dAtA []byte) (int, error)

func (*BranchRegisterResponse) MarshalToSizedBuffer 

func (m *BranchRegisterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchRegisterResponse) ProtoMessage 

func (*BranchRegisterResponse) ProtoMessage()

func (*BranchRegisterResponse) Reset 

func (m *BranchRegisterResponse) Reset()

func (*BranchRegisterResponse) Size 

func (m *BranchRegisterResponse) Size() (n int)

func (*BranchRegisterResponse) String 

func (this *BranchRegisterResponse) String() string

func (*BranchRegisterResponse) Unmarshal 

func (m *BranchRegisterResponse) Unmarshal(dAtA []byte) error

func (*BranchRegisterResponse) XXX_DiscardUnknown 

func (m *BranchRegisterResponse) XXX_DiscardUnknown()

func (*BranchRegisterResponse) XXX_Marshal 

func (m *BranchRegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchRegisterResponse) XXX_Merge 

func (m *BranchRegisterResponse) XXX_Merge(src proto.Message)

func (*BranchRegisterResponse) XXX_Size 

func (m *BranchRegisterResponse) XXX_Size() int

func (*BranchRegisterResponse) XXX_Unmarshal 

func (m *BranchRegisterResponse) XXX_Unmarshal(b []byte) error

type BranchReportRequest 

type BranchReportRequest struct {
	XID             string                     `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
	BranchID        int64                      `protobuf:"varint,2,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	ResourceID      string                     `protobuf:"bytes,3,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	BranchType      BranchSession_BranchType   `protobuf:"varint,4,opt,name=BranchType,proto3,enum=apis.BranchSession_BranchType" json:"BranchType,omitempty"`
	BranchStatus    BranchSession_BranchStatus `protobuf:"varint,5,opt,name=BranchStatus,proto3,enum=apis.BranchSession_BranchStatus" json:"BranchStatus,omitempty"`
	ApplicationData []byte                     `protobuf:"bytes,6,opt,name=ApplicationData,proto3" json:"ApplicationData,omitempty"`
}

BranchReportRequest represents a request to report branch transaction execution status

func (*BranchReportRequest) Descriptor 

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

func (*BranchReportRequest) Equal 

func (this *BranchReportRequest) Equal(that interface{}) bool

func (*BranchReportRequest) GetApplicationData 

func (m *BranchReportRequest) GetApplicationData() []byte

func (*BranchReportRequest) GetBranchID 

func (m *BranchReportRequest) GetBranchID() int64

func (*BranchReportRequest) GetBranchStatus 

func (m *BranchReportRequest) GetBranchStatus() BranchSession_BranchStatus

func (*BranchReportRequest) GetBranchType 

func (m *BranchReportRequest) GetBranchType() BranchSession_BranchType

func (*BranchReportRequest) GetResourceID 

func (m *BranchReportRequest) GetResourceID() string

func (*BranchReportRequest) GetXID 

func (m *BranchReportRequest) GetXID() string

func (*BranchReportRequest) GoString 

func (this *BranchReportRequest) GoString() string

func (*BranchReportRequest) Marshal 

func (m *BranchReportRequest) Marshal() (dAtA []byte, err error)

func (*BranchReportRequest) MarshalTo 

func (m *BranchReportRequest) MarshalTo(dAtA []byte) (int, error)

func (*BranchReportRequest) MarshalToSizedBuffer 

func (m *BranchReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchReportRequest) ProtoMessage 

func (*BranchReportRequest) ProtoMessage()

func (*BranchReportRequest) Reset 

func (m *BranchReportRequest) Reset()

func (*BranchReportRequest) Size 

func (m *BranchReportRequest) Size() (n int)

func (*BranchReportRequest) String 

func (this *BranchReportRequest) String() string

func (*BranchReportRequest) Unmarshal 

func (m *BranchReportRequest) Unmarshal(dAtA []byte) error

func (*BranchReportRequest) XXX_DiscardUnknown 

func (m *BranchReportRequest) XXX_DiscardUnknown()

func (*BranchReportRequest) XXX_Marshal 

func (m *BranchReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchReportRequest) XXX_Merge 

func (m *BranchReportRequest) XXX_Merge(src proto.Message)

func (*BranchReportRequest) XXX_Size 

func (m *BranchReportRequest) XXX_Size() int

func (*BranchReportRequest) XXX_Unmarshal 

func (m *BranchReportRequest) XXX_Unmarshal(b []byte) error

type BranchReportResponse 

type BranchReportResponse struct {
	ResultCode    ResultCode    `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string        `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
}

BranchReportResponse represents a response to BranchReportRequest

func (*BranchReportResponse) Descriptor 

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

func (*BranchReportResponse) Equal 

func (this *BranchReportResponse) Equal(that interface{}) bool

func (*BranchReportResponse) GetExceptionCode 

func (m *BranchReportResponse) GetExceptionCode() ExceptionCode

func (*BranchReportResponse) GetMessage 

func (m *BranchReportResponse) GetMessage() string

func (*BranchReportResponse) GetResultCode 

func (m *BranchReportResponse) GetResultCode() ResultCode

func (*BranchReportResponse) GoString 

func (this *BranchReportResponse) GoString() string

func (*BranchReportResponse) Marshal 

func (m *BranchReportResponse) Marshal() (dAtA []byte, err error)

func (*BranchReportResponse) MarshalTo 

func (m *BranchReportResponse) MarshalTo(dAtA []byte) (int, error)

func (*BranchReportResponse) MarshalToSizedBuffer 

func (m *BranchReportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchReportResponse) ProtoMessage 

func (*BranchReportResponse) ProtoMessage()

func (*BranchReportResponse) Reset 

func (m *BranchReportResponse) Reset()

func (*BranchReportResponse) Size 

func (m *BranchReportResponse) Size() (n int)

func (*BranchReportResponse) String 

func (this *BranchReportResponse) String() string

func (*BranchReportResponse) Unmarshal 

func (m *BranchReportResponse) Unmarshal(dAtA []byte) error

func (*BranchReportResponse) XXX_DiscardUnknown 

func (m *BranchReportResponse) XXX_DiscardUnknown()

func (*BranchReportResponse) XXX_Marshal 

func (m *BranchReportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchReportResponse) XXX_Merge 

func (m *BranchReportResponse) XXX_Merge(src proto.Message)

func (*BranchReportResponse) XXX_Size 

func (m *BranchReportResponse) XXX_Size() int

func (*BranchReportResponse) XXX_Unmarshal 

func (m *BranchReportResponse) XXX_Unmarshal(b []byte) error

type BranchRollbackRequest 

type BranchRollbackRequest struct {
	XID             string                   `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
	BranchID        int64                    `protobuf:"varint,2,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	ResourceID      string                   `protobuf:"bytes,3,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	LockKey         string                   `protobuf:"bytes,4,opt,name=LockKey,proto3" json:"LockKey,omitempty"`
	BranchType      BranchSession_BranchType `protobuf:"varint,5,opt,name=BranchType,proto3,enum=apis.BranchSession_BranchType" json:"BranchType,omitempty"`
	ApplicationData []byte                   `protobuf:"bytes,6,opt,name=ApplicationData,proto3" json:"ApplicationData,omitempty"`
}

BranchCommitRequest represents a request to rollback branch transaction

func (*BranchRollbackRequest) Descriptor 

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

func (*BranchRollbackRequest) Equal 

func (this *BranchRollbackRequest) Equal(that interface{}) bool

func (*BranchRollbackRequest) GetApplicationData 

func (m *BranchRollbackRequest) GetApplicationData() []byte

func (*BranchRollbackRequest) GetBranchID 

func (m *BranchRollbackRequest) GetBranchID() int64

func (*BranchRollbackRequest) GetBranchType 

func (m *BranchRollbackRequest) GetBranchType() BranchSession_BranchType

func (*BranchRollbackRequest) GetLockKey 

func (m *BranchRollbackRequest) GetLockKey() string

func (*BranchRollbackRequest) GetResourceID 

func (m *BranchRollbackRequest) GetResourceID() string

func (*BranchRollbackRequest) GetXID 

func (m *BranchRollbackRequest) GetXID() string

func (*BranchRollbackRequest) GoString 

func (this *BranchRollbackRequest) GoString() string

func (*BranchRollbackRequest) Marshal 

func (m *BranchRollbackRequest) Marshal() (dAtA []byte, err error)

func (*BranchRollbackRequest) MarshalTo 

func (m *BranchRollbackRequest) MarshalTo(dAtA []byte) (int, error)

func (*BranchRollbackRequest) MarshalToSizedBuffer 

func (m *BranchRollbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchRollbackRequest) ProtoMessage 

func (*BranchRollbackRequest) ProtoMessage()

func (*BranchRollbackRequest) Reset 

func (m *BranchRollbackRequest) Reset()

func (*BranchRollbackRequest) Size 

func (m *BranchRollbackRequest) Size() (n int)

func (*BranchRollbackRequest) String 

func (this *BranchRollbackRequest) String() string

func (*BranchRollbackRequest) Unmarshal 

func (m *BranchRollbackRequest) Unmarshal(dAtA []byte) error

func (*BranchRollbackRequest) XXX_DiscardUnknown 

func (m *BranchRollbackRequest) XXX_DiscardUnknown()

func (*BranchRollbackRequest) XXX_Marshal 

func (m *BranchRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchRollbackRequest) XXX_Merge 

func (m *BranchRollbackRequest) XXX_Merge(src proto.Message)

func (*BranchRollbackRequest) XXX_Size 

func (m *BranchRollbackRequest) XXX_Size() int

func (*BranchRollbackRequest) XXX_Unmarshal 

func (m *BranchRollbackRequest) XXX_Unmarshal(b []byte) error

type BranchRollbackResponse 

type BranchRollbackResponse struct {
	ResultCode    ResultCode                 `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode              `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string                     `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	XID           string                     `protobuf:"bytes,4,opt,name=XID,proto3" json:"XID,omitempty"`
	BranchID      int64                      `protobuf:"varint,5,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	BranchStatus  BranchSession_BranchStatus `protobuf:"varint,6,opt,name=BranchStatus,proto3,enum=apis.BranchSession_BranchStatus" json:"BranchStatus,omitempty"`
}

BranchRollbackResponse represents a response to BranchRollbackRequest

func (*BranchRollbackResponse) Descriptor 

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

func (*BranchRollbackResponse) Equal 

func (this *BranchRollbackResponse) Equal(that interface{}) bool

func (*BranchRollbackResponse) GetBranchID 

func (m *BranchRollbackResponse) GetBranchID() int64

func (*BranchRollbackResponse) GetBranchStatus 

func (m *BranchRollbackResponse) GetBranchStatus() BranchSession_BranchStatus

func (*BranchRollbackResponse) GetExceptionCode 

func (m *BranchRollbackResponse) GetExceptionCode() ExceptionCode

func (*BranchRollbackResponse) GetMessage 

func (m *BranchRollbackResponse) GetMessage() string

func (*BranchRollbackResponse) GetResultCode 

func (m *BranchRollbackResponse) GetResultCode() ResultCode

func (*BranchRollbackResponse) GetXID 

func (m *BranchRollbackResponse) GetXID() string

func (*BranchRollbackResponse) GoString 

func (this *BranchRollbackResponse) GoString() string

func (*BranchRollbackResponse) Marshal 

func (m *BranchRollbackResponse) Marshal() (dAtA []byte, err error)

func (*BranchRollbackResponse) MarshalTo 

func (m *BranchRollbackResponse) MarshalTo(dAtA []byte) (int, error)

func (*BranchRollbackResponse) MarshalToSizedBuffer 

func (m *BranchRollbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchRollbackResponse) ProtoMessage 

func (*BranchRollbackResponse) ProtoMessage()

func (*BranchRollbackResponse) Reset 

func (m *BranchRollbackResponse) Reset()

func (*BranchRollbackResponse) Size 

func (m *BranchRollbackResponse) Size() (n int)

func (*BranchRollbackResponse) String 

func (this *BranchRollbackResponse) String() string

func (*BranchRollbackResponse) Unmarshal 

func (m *BranchRollbackResponse) Unmarshal(dAtA []byte) error

func (*BranchRollbackResponse) XXX_DiscardUnknown 

func (m *BranchRollbackResponse) XXX_DiscardUnknown()

func (*BranchRollbackResponse) XXX_Marshal 

func (m *BranchRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchRollbackResponse) XXX_Merge 

func (m *BranchRollbackResponse) XXX_Merge(src proto.Message)

func (*BranchRollbackResponse) XXX_Size 

func (m *BranchRollbackResponse) XXX_Size() int

func (*BranchRollbackResponse) XXX_Unmarshal 

func (m *BranchRollbackResponse) XXX_Unmarshal(b []byte) error

type BranchSession 

type BranchSession struct {
	Addressing      string                     `protobuf:"bytes,1,opt,name=Addressing,proto3" json:"Addressing,omitempty" xorm:"addressing"`
	XID             string                     `protobuf:"bytes,2,opt,name=XID,proto3" json:"XID,omitempty" xorm:"xid"`
	BranchID        int64                      `protobuf:"varint,3,opt,name=BranchID,proto3" json:"BranchID,omitempty" xorm:"branch_id"`
	TransactionID   int64                      `protobuf:"varint,4,opt,name=TransactionID,proto3" json:"TransactionID,omitempty" xorm:"transaction_id"`
	ResourceID      string                     `protobuf:"bytes,5,opt,name=ResourceID,proto3" json:"ResourceID,omitempty" xorm:"resource_id"`
	LockKey         string                     `protobuf:"bytes,6,opt,name=LockKey,proto3" json:"LockKey,omitempty" xorm:"lock_key"`
	Type            BranchSession_BranchType   `protobuf:"varint,7,opt,name=Type,proto3,enum=apis.BranchSession_BranchType" json:"Type,omitempty" xorm:"branch_type"`
	Status          BranchSession_BranchStatus `protobuf:"varint,8,opt,name=Status,proto3,enum=apis.BranchSession_BranchStatus" json:"Status,omitempty" xorm:"status"`
	ApplicationData []byte                     `protobuf:"bytes,9,opt,name=ApplicationData,proto3" json:"ApplicationData,omitempty" xorm:"application_data"`
}

func (*BranchSession) Descriptor 

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

func (*BranchSession) Equal 

func (this *BranchSession) Equal(that interface{}) bool

func (*BranchSession) GetAddressing 

func (m *BranchSession) GetAddressing() string

func (*BranchSession) GetApplicationData 

func (m *BranchSession) GetApplicationData() []byte

func (*BranchSession) GetBranchID 

func (m *BranchSession) GetBranchID() int64

func (*BranchSession) GetLockKey 

func (m *BranchSession) GetLockKey() string

func (*BranchSession) GetResourceID 

func (m *BranchSession) GetResourceID() string

func (*BranchSession) GetStatus 

func (m *BranchSession) GetStatus() BranchSession_BranchStatus

func (*BranchSession) GetTransactionID 

func (m *BranchSession) GetTransactionID() int64

func (*BranchSession) GetType 

func (m *BranchSession) GetType() BranchSession_BranchType

func (*BranchSession) GetXID 

func (m *BranchSession) GetXID() string

func (*BranchSession) GoString 

func (this *BranchSession) GoString() string

func (*BranchSession) Marshal 

func (m *BranchSession) Marshal() (dAtA []byte, err error)

func (*BranchSession) MarshalTo 

func (m *BranchSession) MarshalTo(dAtA []byte) (int, error)

func (*BranchSession) MarshalToSizedBuffer 

func (m *BranchSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BranchSession) ProtoMessage 

func (*BranchSession) ProtoMessage()

func (*BranchSession) Reset 

func (m *BranchSession) Reset()

func (*BranchSession) Size 

func (m *BranchSession) Size() (n int)

func (*BranchSession) String 

func (this *BranchSession) String() string

func (*BranchSession) Unmarshal 

func (m *BranchSession) Unmarshal(dAtA []byte) error

func (*BranchSession) XXX_DiscardUnknown 

func (m *BranchSession) XXX_DiscardUnknown()

func (*BranchSession) XXX_Marshal 

func (m *BranchSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchSession) XXX_Merge 

func (m *BranchSession) XXX_Merge(src proto.Message)

func (*BranchSession) XXX_Size 

func (m *BranchSession) XXX_Size() int

func (*BranchSession) XXX_Unmarshal 

func (m *BranchSession) XXX_Unmarshal(b []byte) error

type BranchSession_BranchStatus 

type BranchSession_BranchStatus int32
const (
	// description:BranchStatus_Unknown branch status.
	UnknownBranchStatus BranchSession_BranchStatus = 0
	// description:BranchStatus_Registered to TC.
	Registered BranchSession_BranchStatus = 1
	// The Phase one done.
	// description:Branch logic is successfully done at phase one.
	PhaseOneDone BranchSession_BranchStatus = 2
	// The Phase one failed.
	// description:Branch logic is failed at phase one.
	PhaseOneFailed BranchSession_BranchStatus = 3
	// The Phase one timeout.
	// description:Branch logic is NOT reported for a timeout.
	PhaseOneTimeout BranchSession_BranchStatus = 4
	// The Phase two committed.
	// description:Commit logic is successfully done at phase two.
	PhaseTwoCommitted BranchSession_BranchStatus = 5
	// The Phase two commit failed retryable.
	// description:Commit logic is failed but retryable.
	PhaseTwoCommitFailedRetryable BranchSession_BranchStatus = 6
	// The Phase two commit failed and can not retry.
	// description:Commit logic is failed and NOT retryable.
	PhaseTwoCommitFailedCanNotRetry BranchSession_BranchStatus = 7
	// The Phase two rollback completed.
	// description:Rollback logic is successfully done at phase two.
	PhaseTwoRolledBack BranchSession_BranchStatus = 8
	// The Phase two rollback failed retryable.
	// description:Rollback logic is failed but retryable.
	PhaseTwoRollbackFailedRetryable BranchSession_BranchStatus = 9
	// The Phase two rollback failed and can not retry.
	// description:Rollback logic is failed but NOT retryable.
	PhaseTwoRollbackFailedCanNotRetry BranchSession_BranchStatus = 10
)

func (BranchSession_BranchStatus) EnumDescriptor 

func (BranchSession_BranchStatus) EnumDescriptor() ([]byte, []int)

func (BranchSession_BranchStatus) String 

func (x BranchSession_BranchStatus) String() string

type BranchSession_BranchType 

type BranchSession_BranchType int32
const (
	AT   BranchSession_BranchType = 0
	TCC  BranchSession_BranchType = 1
	SAGA BranchSession_BranchType = 2
	XA   BranchSession_BranchType = 3
)

func (BranchSession_BranchType) EnumDescriptor 

func (BranchSession_BranchType) EnumDescriptor() ([]byte, []int)

func (BranchSession_BranchType) String 

func (x BranchSession_BranchType) String() string

type ExceptionCode 

type ExceptionCode int32
const (
	// Unknown transaction error code.
	UnknownErr ExceptionCode = 0
	// BeginFailed
	BeginFailed ExceptionCode = 1
	// Lock key conflict transaction error code.
	LockKeyConflict ExceptionCode = 2
	// Io transaction error code.
	IO ExceptionCode = 3
	// Branch rollback failed retryable transaction error code.
	BranchRollbackFailedRetryable ExceptionCode = 4
	// Branch rollback failed unretryable transaction error code.
	BranchRollbackFailedUnretryable ExceptionCode = 5
	// Branch register failed transaction error code.
	BranchRegisterFailed ExceptionCode = 6
	// Branch report failed transaction error code.
	BranchReportFailed ExceptionCode = 7
	// Lockable check failed transaction error code.
	LockableCheckFailed ExceptionCode = 8
	// Branch transaction not exist transaction error code.
	BranchTransactionNotExist ExceptionCode = 9
	// Global transaction not exist transaction error code.
	GlobalTransactionNotExist ExceptionCode = 10
	// Global transaction not active transaction error code.
	GlobalTransactionNotActive ExceptionCode = 11
	// Global transaction status invalid transaction error code.
	GlobalTransactionStatusInvalid ExceptionCode = 12
	// Failed to send branch commit request transaction error code.
	FailedToSendBranchCommitRequest ExceptionCode = 13
	// Failed to send branch rollback request transaction error code.
	FailedToSendBranchRollbackRequest ExceptionCode = 14
	// Failed to add branch transaction error code.
	FailedToAddBranch ExceptionCode = 15
	// Failed to lock global transaction error code.
	FailedLockGlobalTransaction ExceptionCode = 16
	// FailedWriteSession
	FailedWriteSession ExceptionCode = 17
	// Failed to holder error code
	FailedStore ExceptionCode = 18
)

func (ExceptionCode) EnumDescriptor 

func (ExceptionCode) EnumDescriptor() ([]byte, []int)

func (ExceptionCode) String 

func (x ExceptionCode) String() string

type GlobalBeginRequest 

type GlobalBeginRequest struct {
	Addressing      string `protobuf:"bytes,1,opt,name=Addressing,proto3" json:"Addressing,omitempty"`
	Timeout         int32  `protobuf:"varint,2,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	TransactionName string `protobuf:"bytes,3,opt,name=TransactionName,proto3" json:"TransactionName,omitempty"`
}

GlobalBeginRequest represents a global transaction begin

func (*GlobalBeginRequest) Descriptor 

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

func (*GlobalBeginRequest) Equal 

func (this *GlobalBeginRequest) Equal(that interface{}) bool

func (*GlobalBeginRequest) GetAddressing 

func (m *GlobalBeginRequest) GetAddressing() string

func (*GlobalBeginRequest) GetTimeout 

func (m *GlobalBeginRequest) GetTimeout() int32

func (*GlobalBeginRequest) GetTransactionName 

func (m *GlobalBeginRequest) GetTransactionName() string

func (*GlobalBeginRequest) GoString 

func (this *GlobalBeginRequest) GoString() string

func (*GlobalBeginRequest) Marshal 

func (m *GlobalBeginRequest) Marshal() (dAtA []byte, err error)

func (*GlobalBeginRequest) MarshalTo 

func (m *GlobalBeginRequest) MarshalTo(dAtA []byte) (int, error)

func (*GlobalBeginRequest) MarshalToSizedBuffer 

func (m *GlobalBeginRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalBeginRequest) ProtoMessage 

func (*GlobalBeginRequest) ProtoMessage()

func (*GlobalBeginRequest) Reset 

func (m *GlobalBeginRequest) Reset()

func (*GlobalBeginRequest) Size 

func (m *GlobalBeginRequest) Size() (n int)

func (*GlobalBeginRequest) String 

func (this *GlobalBeginRequest) String() string

func (*GlobalBeginRequest) Unmarshal 

func (m *GlobalBeginRequest) Unmarshal(dAtA []byte) error

func (*GlobalBeginRequest) XXX_DiscardUnknown 

func (m *GlobalBeginRequest) XXX_DiscardUnknown()

func (*GlobalBeginRequest) XXX_Marshal 

func (m *GlobalBeginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalBeginRequest) XXX_Merge 

func (m *GlobalBeginRequest) XXX_Merge(src proto.Message)

func (*GlobalBeginRequest) XXX_Size 

func (m *GlobalBeginRequest) XXX_Size() int

func (*GlobalBeginRequest) XXX_Unmarshal 

func (m *GlobalBeginRequest) XXX_Unmarshal(b []byte) error

type GlobalBeginResponse 

type GlobalBeginResponse struct {
	ResultCode    ResultCode    `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string        `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	XID           string        `protobuf:"bytes,4,opt,name=XID,proto3" json:"XID,omitempty"`
}

GlobalBeginResponse represents a response to GlobalBeginRequest

func (*GlobalBeginResponse) Descriptor 

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

func (*GlobalBeginResponse) Equal 

func (this *GlobalBeginResponse) Equal(that interface{}) bool

func (*GlobalBeginResponse) GetExceptionCode 

func (m *GlobalBeginResponse) GetExceptionCode() ExceptionCode

func (*GlobalBeginResponse) GetMessage 

func (m *GlobalBeginResponse) GetMessage() string

func (*GlobalBeginResponse) GetResultCode 

func (m *GlobalBeginResponse) GetResultCode() ResultCode

func (*GlobalBeginResponse) GetXID 

func (m *GlobalBeginResponse) GetXID() string

func (*GlobalBeginResponse) GoString 

func (this *GlobalBeginResponse) GoString() string

func (*GlobalBeginResponse) Marshal 

func (m *GlobalBeginResponse) Marshal() (dAtA []byte, err error)

func (*GlobalBeginResponse) MarshalTo 

func (m *GlobalBeginResponse) MarshalTo(dAtA []byte) (int, error)

func (*GlobalBeginResponse) MarshalToSizedBuffer 

func (m *GlobalBeginResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalBeginResponse) ProtoMessage 

func (*GlobalBeginResponse) ProtoMessage()

func (*GlobalBeginResponse) Reset 

func (m *GlobalBeginResponse) Reset()

func (*GlobalBeginResponse) Size 

func (m *GlobalBeginResponse) Size() (n int)

func (*GlobalBeginResponse) String 

func (this *GlobalBeginResponse) String() string

func (*GlobalBeginResponse) Unmarshal 

func (m *GlobalBeginResponse) Unmarshal(dAtA []byte) error

func (*GlobalBeginResponse) XXX_DiscardUnknown 

func (m *GlobalBeginResponse) XXX_DiscardUnknown()

func (*GlobalBeginResponse) XXX_Marshal 

func (m *GlobalBeginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalBeginResponse) XXX_Merge 

func (m *GlobalBeginResponse) XXX_Merge(src proto.Message)

func (*GlobalBeginResponse) XXX_Size 

func (m *GlobalBeginResponse) XXX_Size() int

func (*GlobalBeginResponse) XXX_Unmarshal 

func (m *GlobalBeginResponse) XXX_Unmarshal(b []byte) error

type GlobalCommitRequest 

type GlobalCommitRequest struct {
	XID string `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
}

GlobalCommitRequest represents a request to commit global transaction

func (*GlobalCommitRequest) Descriptor 

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

func (*GlobalCommitRequest) Equal 

func (this *GlobalCommitRequest) Equal(that interface{}) bool

func (*GlobalCommitRequest) GetXID 

func (m *GlobalCommitRequest) GetXID() string

func (*GlobalCommitRequest) GoString 

func (this *GlobalCommitRequest) GoString() string

func (*GlobalCommitRequest) Marshal 

func (m *GlobalCommitRequest) Marshal() (dAtA []byte, err error)

func (*GlobalCommitRequest) MarshalTo 

func (m *GlobalCommitRequest) MarshalTo(dAtA []byte) (int, error)

func (*GlobalCommitRequest) MarshalToSizedBuffer 

func (m *GlobalCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalCommitRequest) ProtoMessage 

func (*GlobalCommitRequest) ProtoMessage()

func (*GlobalCommitRequest) Reset 

func (m *GlobalCommitRequest) Reset()

func (*GlobalCommitRequest) Size 

func (m *GlobalCommitRequest) Size() (n int)

func (*GlobalCommitRequest) String 

func (this *GlobalCommitRequest) String() string

func (*GlobalCommitRequest) Unmarshal 

func (m *GlobalCommitRequest) Unmarshal(dAtA []byte) error

func (*GlobalCommitRequest) XXX_DiscardUnknown 

func (m *GlobalCommitRequest) XXX_DiscardUnknown()

func (*GlobalCommitRequest) XXX_Marshal 

func (m *GlobalCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalCommitRequest) XXX_Merge 

func (m *GlobalCommitRequest) XXX_Merge(src proto.Message)

func (*GlobalCommitRequest) XXX_Size 

func (m *GlobalCommitRequest) XXX_Size() int

func (*GlobalCommitRequest) XXX_Unmarshal 

func (m *GlobalCommitRequest) XXX_Unmarshal(b []byte) error

type GlobalCommitResponse 

type GlobalCommitResponse struct {
	ResultCode    ResultCode                 `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode              `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string                     `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus  GlobalSession_GlobalStatus `protobuf:"varint,4,opt,name=GlobalStatus,proto3,enum=apis.GlobalSession_GlobalStatus" json:"GlobalStatus,omitempty"`
}

GlobalCommitResponse represents a response to GlobalCommitRequest

func (*GlobalCommitResponse) Descriptor 

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

func (*GlobalCommitResponse) Equal 

func (this *GlobalCommitResponse) Equal(that interface{}) bool

func (*GlobalCommitResponse) GetExceptionCode 

func (m *GlobalCommitResponse) GetExceptionCode() ExceptionCode

func (*GlobalCommitResponse) GetGlobalStatus 

func (m *GlobalCommitResponse) GetGlobalStatus() GlobalSession_GlobalStatus

func (*GlobalCommitResponse) GetMessage 

func (m *GlobalCommitResponse) GetMessage() string

func (*GlobalCommitResponse) GetResultCode 

func (m *GlobalCommitResponse) GetResultCode() ResultCode

func (*GlobalCommitResponse) GoString 

func (this *GlobalCommitResponse) GoString() string

func (*GlobalCommitResponse) Marshal 

func (m *GlobalCommitResponse) Marshal() (dAtA []byte, err error)

func (*GlobalCommitResponse) MarshalTo 

func (m *GlobalCommitResponse) MarshalTo(dAtA []byte) (int, error)

func (*GlobalCommitResponse) MarshalToSizedBuffer 

func (m *GlobalCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalCommitResponse) ProtoMessage 

func (*GlobalCommitResponse) ProtoMessage()

func (*GlobalCommitResponse) Reset 

func (m *GlobalCommitResponse) Reset()

func (*GlobalCommitResponse) Size 

func (m *GlobalCommitResponse) Size() (n int)

func (*GlobalCommitResponse) String 

func (this *GlobalCommitResponse) String() string

func (*GlobalCommitResponse) Unmarshal 

func (m *GlobalCommitResponse) Unmarshal(dAtA []byte) error

func (*GlobalCommitResponse) XXX_DiscardUnknown 

func (m *GlobalCommitResponse) XXX_DiscardUnknown()

func (*GlobalCommitResponse) XXX_Marshal 

func (m *GlobalCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalCommitResponse) XXX_Merge 

func (m *GlobalCommitResponse) XXX_Merge(src proto.Message)

func (*GlobalCommitResponse) XXX_Size 

func (m *GlobalCommitResponse) XXX_Size() int

func (*GlobalCommitResponse) XXX_Unmarshal 

func (m *GlobalCommitResponse) XXX_Unmarshal(b []byte) error

type GlobalLockQueryRequest 

type GlobalLockQueryRequest struct {
	XID        string                   `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
	ResourceID string                   `protobuf:"bytes,2,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	LockKey    string                   `protobuf:"bytes,3,opt,name=LockKey,proto3" json:"LockKey,omitempty"`
	BranchType BranchSession_BranchType `protobuf:"varint,4,opt,name=BranchType,proto3,enum=apis.BranchSession_BranchType" json:"BranchType,omitempty"`
}

GlobalLockQueryRequest represents a request to query the global lock

func (*GlobalLockQueryRequest) Descriptor 

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

func (*GlobalLockQueryRequest) Equal 

func (this *GlobalLockQueryRequest) Equal(that interface{}) bool

func (*GlobalLockQueryRequest) GetBranchType 

func (m *GlobalLockQueryRequest) GetBranchType() BranchSession_BranchType

func (*GlobalLockQueryRequest) GetLockKey 

func (m *GlobalLockQueryRequest) GetLockKey() string

func (*GlobalLockQueryRequest) GetResourceID 

func (m *GlobalLockQueryRequest) GetResourceID() string

func (*GlobalLockQueryRequest) GetXID 

func (m *GlobalLockQueryRequest) GetXID() string

func (*GlobalLockQueryRequest) GoString 

func (this *GlobalLockQueryRequest) GoString() string

func (*GlobalLockQueryRequest) Marshal 

func (m *GlobalLockQueryRequest) Marshal() (dAtA []byte, err error)

func (*GlobalLockQueryRequest) MarshalTo 

func (m *GlobalLockQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*GlobalLockQueryRequest) MarshalToSizedBuffer 

func (m *GlobalLockQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalLockQueryRequest) ProtoMessage 

func (*GlobalLockQueryRequest) ProtoMessage()

func (*GlobalLockQueryRequest) Reset 

func (m *GlobalLockQueryRequest) Reset()

func (*GlobalLockQueryRequest) Size 

func (m *GlobalLockQueryRequest) Size() (n int)

func (*GlobalLockQueryRequest) String 

func (this *GlobalLockQueryRequest) String() string

func (*GlobalLockQueryRequest) Unmarshal 

func (m *GlobalLockQueryRequest) Unmarshal(dAtA []byte) error

func (*GlobalLockQueryRequest) XXX_DiscardUnknown 

func (m *GlobalLockQueryRequest) XXX_DiscardUnknown()

func (*GlobalLockQueryRequest) XXX_Marshal 

func (m *GlobalLockQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalLockQueryRequest) XXX_Merge 

func (m *GlobalLockQueryRequest) XXX_Merge(src proto.Message)

func (*GlobalLockQueryRequest) XXX_Size 

func (m *GlobalLockQueryRequest) XXX_Size() int

func (*GlobalLockQueryRequest) XXX_Unmarshal 

func (m *GlobalLockQueryRequest) XXX_Unmarshal(b []byte) error

type GlobalLockQueryResponse 

type GlobalLockQueryResponse struct {
	ResultCode    ResultCode    `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string        `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	Lockable      bool          `protobuf:"varint,4,opt,name=Lockable,proto3" json:"Lockable,omitempty"`
}

GlobalLockQueryResponse represents a response to GlobalLockQueryRequest

func (*GlobalLockQueryResponse) Descriptor 

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

func (*GlobalLockQueryResponse) Equal 

func (this *GlobalLockQueryResponse) Equal(that interface{}) bool

func (*GlobalLockQueryResponse) GetExceptionCode 

func (m *GlobalLockQueryResponse) GetExceptionCode() ExceptionCode

func (*GlobalLockQueryResponse) GetLockable 

func (m *GlobalLockQueryResponse) GetLockable() bool

func (*GlobalLockQueryResponse) GetMessage 

func (m *GlobalLockQueryResponse) GetMessage() string

func (*GlobalLockQueryResponse) GetResultCode 

func (m *GlobalLockQueryResponse) GetResultCode() ResultCode

func (*GlobalLockQueryResponse) GoString 

func (this *GlobalLockQueryResponse) GoString() string

func (*GlobalLockQueryResponse) Marshal 

func (m *GlobalLockQueryResponse) Marshal() (dAtA []byte, err error)

func (*GlobalLockQueryResponse) MarshalTo 

func (m *GlobalLockQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*GlobalLockQueryResponse) MarshalToSizedBuffer 

func (m *GlobalLockQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalLockQueryResponse) ProtoMessage 

func (*GlobalLockQueryResponse) ProtoMessage()

func (*GlobalLockQueryResponse) Reset 

func (m *GlobalLockQueryResponse) Reset()

func (*GlobalLockQueryResponse) Size 

func (m *GlobalLockQueryResponse) Size() (n int)

func (*GlobalLockQueryResponse) String 

func (this *GlobalLockQueryResponse) String() string

func (*GlobalLockQueryResponse) Unmarshal 

func (m *GlobalLockQueryResponse) Unmarshal(dAtA []byte) error

func (*GlobalLockQueryResponse) XXX_DiscardUnknown 

func (m *GlobalLockQueryResponse) XXX_DiscardUnknown()

func (*GlobalLockQueryResponse) XXX_Marshal 

func (m *GlobalLockQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalLockQueryResponse) XXX_Merge 

func (m *GlobalLockQueryResponse) XXX_Merge(src proto.Message)

func (*GlobalLockQueryResponse) XXX_Size 

func (m *GlobalLockQueryResponse) XXX_Size() int

func (*GlobalLockQueryResponse) XXX_Unmarshal 

func (m *GlobalLockQueryResponse) XXX_Unmarshal(b []byte) error

type GlobalReportRequest 

type GlobalReportRequest struct {
	XID          string                     `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
	GlobalStatus GlobalSession_GlobalStatus `protobuf:"varint,2,opt,name=GlobalStatus,proto3,enum=apis.GlobalSession_GlobalStatus" json:"GlobalStatus,omitempty"`
}

GlobalReportRequest represents a request to report global transaction execution status

func (*GlobalReportRequest) Descriptor 

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

func (*GlobalReportRequest) Equal 

func (this *GlobalReportRequest) Equal(that interface{}) bool

func (*GlobalReportRequest) GetGlobalStatus 

func (m *GlobalReportRequest) GetGlobalStatus() GlobalSession_GlobalStatus

func (*GlobalReportRequest) GetXID 

func (m *GlobalReportRequest) GetXID() string

func (*GlobalReportRequest) GoString 

func (this *GlobalReportRequest) GoString() string

func (*GlobalReportRequest) Marshal 

func (m *GlobalReportRequest) Marshal() (dAtA []byte, err error)

func (*GlobalReportRequest) MarshalTo 

func (m *GlobalReportRequest) MarshalTo(dAtA []byte) (int, error)

func (*GlobalReportRequest) MarshalToSizedBuffer 

func (m *GlobalReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalReportRequest) ProtoMessage 

func (*GlobalReportRequest) ProtoMessage()

func (*GlobalReportRequest) Reset 

func (m *GlobalReportRequest) Reset()

func (*GlobalReportRequest) Size 

func (m *GlobalReportRequest) Size() (n int)

func (*GlobalReportRequest) String 

func (this *GlobalReportRequest) String() string

func (*GlobalReportRequest) Unmarshal 

func (m *GlobalReportRequest) Unmarshal(dAtA []byte) error

func (*GlobalReportRequest) XXX_DiscardUnknown 

func (m *GlobalReportRequest) XXX_DiscardUnknown()

func (*GlobalReportRequest) XXX_Marshal 

func (m *GlobalReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalReportRequest) XXX_Merge 

func (m *GlobalReportRequest) XXX_Merge(src proto.Message)

func (*GlobalReportRequest) XXX_Size 

func (m *GlobalReportRequest) XXX_Size() int

func (*GlobalReportRequest) XXX_Unmarshal 

func (m *GlobalReportRequest) XXX_Unmarshal(b []byte) error

type GlobalReportResponse 

type GlobalReportResponse struct {
	ResultCode    ResultCode                 `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode              `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string                     `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus  GlobalSession_GlobalStatus `protobuf:"varint,4,opt,name=GlobalStatus,proto3,enum=apis.GlobalSession_GlobalStatus" json:"GlobalStatus,omitempty"`
}

GlobalReportResponse represents a response to GlobalReportRequest

func (*GlobalReportResponse) Descriptor 

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

func (*GlobalReportResponse) Equal 

func (this *GlobalReportResponse) Equal(that interface{}) bool

func (*GlobalReportResponse) GetExceptionCode 

func (m *GlobalReportResponse) GetExceptionCode() ExceptionCode

func (*GlobalReportResponse) GetGlobalStatus 

func (m *GlobalReportResponse) GetGlobalStatus() GlobalSession_GlobalStatus

func (*GlobalReportResponse) GetMessage 

func (m *GlobalReportResponse) GetMessage() string

func (*GlobalReportResponse) GetResultCode 

func (m *GlobalReportResponse) GetResultCode() ResultCode

func (*GlobalReportResponse) GoString 

func (this *GlobalReportResponse) GoString() string

func (*GlobalReportResponse) Marshal 

func (m *GlobalReportResponse) Marshal() (dAtA []byte, err error)

func (*GlobalReportResponse) MarshalTo 

func (m *GlobalReportResponse) MarshalTo(dAtA []byte) (int, error)

func (*GlobalReportResponse) MarshalToSizedBuffer 

func (m *GlobalReportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalReportResponse) ProtoMessage 

func (*GlobalReportResponse) ProtoMessage()

func (*GlobalReportResponse) Reset 

func (m *GlobalReportResponse) Reset()

func (*GlobalReportResponse) Size 

func (m *GlobalReportResponse) Size() (n int)

func (*GlobalReportResponse) String 

func (this *GlobalReportResponse) String() string

func (*GlobalReportResponse) Unmarshal 

func (m *GlobalReportResponse) Unmarshal(dAtA []byte) error

func (*GlobalReportResponse) XXX_DiscardUnknown 

func (m *GlobalReportResponse) XXX_DiscardUnknown()

func (*GlobalReportResponse) XXX_Marshal 

func (m *GlobalReportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalReportResponse) XXX_Merge 

func (m *GlobalReportResponse) XXX_Merge(src proto.Message)

func (*GlobalReportResponse) XXX_Size 

func (m *GlobalReportResponse) XXX_Size() int

func (*GlobalReportResponse) XXX_Unmarshal 

func (m *GlobalReportResponse) XXX_Unmarshal(b []byte) error

type GlobalRollbackRequest 

type GlobalRollbackRequest struct {
	XID string `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
}

GlobalRollbackRequest represents a request to rollback global transaction

func (*GlobalRollbackRequest) Descriptor 

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

func (*GlobalRollbackRequest) Equal 

func (this *GlobalRollbackRequest) Equal(that interface{}) bool

func (*GlobalRollbackRequest) GetXID 

func (m *GlobalRollbackRequest) GetXID() string

func (*GlobalRollbackRequest) GoString 

func (this *GlobalRollbackRequest) GoString() string

func (*GlobalRollbackRequest) Marshal 

func (m *GlobalRollbackRequest) Marshal() (dAtA []byte, err error)

func (*GlobalRollbackRequest) MarshalTo 

func (m *GlobalRollbackRequest) MarshalTo(dAtA []byte) (int, error)

func (*GlobalRollbackRequest) MarshalToSizedBuffer 

func (m *GlobalRollbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalRollbackRequest) ProtoMessage 

func (*GlobalRollbackRequest) ProtoMessage()

func (*GlobalRollbackRequest) Reset 

func (m *GlobalRollbackRequest) Reset()

func (*GlobalRollbackRequest) Size 

func (m *GlobalRollbackRequest) Size() (n int)

func (*GlobalRollbackRequest) String 

func (this *GlobalRollbackRequest) String() string

func (*GlobalRollbackRequest) Unmarshal 

func (m *GlobalRollbackRequest) Unmarshal(dAtA []byte) error

func (*GlobalRollbackRequest) XXX_DiscardUnknown 

func (m *GlobalRollbackRequest) XXX_DiscardUnknown()

func (*GlobalRollbackRequest) XXX_Marshal 

func (m *GlobalRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalRollbackRequest) XXX_Merge 

func (m *GlobalRollbackRequest) XXX_Merge(src proto.Message)

func (*GlobalRollbackRequest) XXX_Size 

func (m *GlobalRollbackRequest) XXX_Size() int

func (*GlobalRollbackRequest) XXX_Unmarshal 

func (m *GlobalRollbackRequest) XXX_Unmarshal(b []byte) error

type GlobalRollbackResponse 

type GlobalRollbackResponse struct {
	ResultCode    ResultCode                 `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode              `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string                     `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus  GlobalSession_GlobalStatus `protobuf:"varint,4,opt,name=GlobalStatus,proto3,enum=apis.GlobalSession_GlobalStatus" json:"GlobalStatus,omitempty"`
}

GlobalRollbackResponse represents a response to GlobalRollbackRequest

func (*GlobalRollbackResponse) Descriptor 

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

func (*GlobalRollbackResponse) Equal 

func (this *GlobalRollbackResponse) Equal(that interface{}) bool

func (*GlobalRollbackResponse) GetExceptionCode 

func (m *GlobalRollbackResponse) GetExceptionCode() ExceptionCode

func (*GlobalRollbackResponse) GetGlobalStatus 

func (m *GlobalRollbackResponse) GetGlobalStatus() GlobalSession_GlobalStatus

func (*GlobalRollbackResponse) GetMessage 

func (m *GlobalRollbackResponse) GetMessage() string

func (*GlobalRollbackResponse) GetResultCode 

func (m *GlobalRollbackResponse) GetResultCode() ResultCode

func (*GlobalRollbackResponse) GoString 

func (this *GlobalRollbackResponse) GoString() string

func (*GlobalRollbackResponse) Marshal 

func (m *GlobalRollbackResponse) Marshal() (dAtA []byte, err error)

func (*GlobalRollbackResponse) MarshalTo 

func (m *GlobalRollbackResponse) MarshalTo(dAtA []byte) (int, error)

func (*GlobalRollbackResponse) MarshalToSizedBuffer 

func (m *GlobalRollbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalRollbackResponse) ProtoMessage 

func (*GlobalRollbackResponse) ProtoMessage()

func (*GlobalRollbackResponse) Reset 

func (m *GlobalRollbackResponse) Reset()

func (*GlobalRollbackResponse) Size 

func (m *GlobalRollbackResponse) Size() (n int)

func (*GlobalRollbackResponse) String 

func (this *GlobalRollbackResponse) String() string

func (*GlobalRollbackResponse) Unmarshal 

func (m *GlobalRollbackResponse) Unmarshal(dAtA []byte) error

func (*GlobalRollbackResponse) XXX_DiscardUnknown 

func (m *GlobalRollbackResponse) XXX_DiscardUnknown()

func (*GlobalRollbackResponse) XXX_Marshal 

func (m *GlobalRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalRollbackResponse) XXX_Merge 

func (m *GlobalRollbackResponse) XXX_Merge(src proto.Message)

func (*GlobalRollbackResponse) XXX_Size 

func (m *GlobalRollbackResponse) XXX_Size() int

func (*GlobalRollbackResponse) XXX_Unmarshal 

func (m *GlobalRollbackResponse) XXX_Unmarshal(b []byte) error

type GlobalSession 

type GlobalSession struct {
	Addressing      string                     `protobuf:"bytes,1,opt,name=Addressing,proto3" json:"Addressing,omitempty" xorm:"addressing"`
	XID             string                     `protobuf:"bytes,2,opt,name=XID,proto3" json:"XID,omitempty" xorm:"xid"`
	TransactionID   int64                      `protobuf:"varint,3,opt,name=TransactionID,proto3" json:"TransactionID,omitempty" xorm:"transaction_id"`
	TransactionName string                     `protobuf:"bytes,4,opt,name=TransactionName,proto3" json:"TransactionName,omitempty" xorm:"transaction_name"`
	Timeout         int32                      `protobuf:"varint,5,opt,name=Timeout,proto3" json:"Timeout,omitempty" xorm:"timeout"`
	BeginTime       int64                      `protobuf:"varint,6,opt,name=BeginTime,proto3" json:"BeginTime,omitempty" xorm:"begin_time"`
	Status          GlobalSession_GlobalStatus `protobuf:"varint,7,opt,name=Status,proto3,enum=apis.GlobalSession_GlobalStatus" json:"Status,omitempty" xorm:"status"`
	Active          bool                       `protobuf:"varint,8,opt,name=Active,proto3" json:"Active,omitempty" xorm:"active"`
}

func (*GlobalSession) Descriptor 

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

func (*GlobalSession) Equal 

func (this *GlobalSession) Equal(that interface{}) bool

func (*GlobalSession) GetActive 

func (m *GlobalSession) GetActive() bool

func (*GlobalSession) GetAddressing 

func (m *GlobalSession) GetAddressing() string

func (*GlobalSession) GetBeginTime 

func (m *GlobalSession) GetBeginTime() int64

func (*GlobalSession) GetStatus 

func (m *GlobalSession) GetStatus() GlobalSession_GlobalStatus

func (*GlobalSession) GetTimeout 

func (m *GlobalSession) GetTimeout() int32

func (*GlobalSession) GetTransactionID 

func (m *GlobalSession) GetTransactionID() int64

func (*GlobalSession) GetTransactionName 

func (m *GlobalSession) GetTransactionName() string

func (*GlobalSession) GetXID 

func (m *GlobalSession) GetXID() string

func (*GlobalSession) GoString 

func (this *GlobalSession) GoString() string

func (*GlobalSession) Marshal 

func (m *GlobalSession) Marshal() (dAtA []byte, err error)

func (*GlobalSession) MarshalTo 

func (m *GlobalSession) MarshalTo(dAtA []byte) (int, error)

func (*GlobalSession) MarshalToSizedBuffer 

func (m *GlobalSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalSession) ProtoMessage 

func (*GlobalSession) ProtoMessage()

func (*GlobalSession) Reset 

func (m *GlobalSession) Reset()

func (*GlobalSession) Size 

func (m *GlobalSession) Size() (n int)

func (*GlobalSession) String 

func (this *GlobalSession) String() string

func (*GlobalSession) Unmarshal 

func (m *GlobalSession) Unmarshal(dAtA []byte) error

func (*GlobalSession) XXX_DiscardUnknown 

func (m *GlobalSession) XXX_DiscardUnknown()

func (*GlobalSession) XXX_Marshal 

func (m *GlobalSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalSession) XXX_Merge 

func (m *GlobalSession) XXX_Merge(src proto.Message)

func (*GlobalSession) XXX_Size 

func (m *GlobalSession) XXX_Size() int

func (*GlobalSession) XXX_Unmarshal 

func (m *GlobalSession) XXX_Unmarshal(b []byte) error

type GlobalSession_GlobalStatus 

type GlobalSession_GlobalStatus int32
const (
	// Un known global status.
	UnknownGlobalStatus GlobalSession_GlobalStatus = 0
	// PHASE 1: can accept new branch registering.
	Begin GlobalSession_GlobalStatus = 1
	// PHASE 2: Running Status: may be changed any time.
	Committing GlobalSession_GlobalStatus = 2
	// The Commit retrying.
	// Retrying commit after a recoverable failure.
	CommitRetrying GlobalSession_GlobalStatus = 3
	// Rolling back global status.
	RollingBack GlobalSession_GlobalStatus = 4
	// The Rollback retrying.
	// Retrying rollback after a recoverable failure.
	RollbackRetrying GlobalSession_GlobalStatus = 5
	// The Timeout rolling back.
	// Rolling back since timeout
	TimeoutRollingBack GlobalSession_GlobalStatus = 6
	// The Timeout rollback retrying.
	// Retrying rollback (since timeout) after a recoverable failure.
	TimeoutRollbackRetrying GlobalSession_GlobalStatus = 7
	// All branches can be async committed. The committing is NOT done yet, but it can be seen as
	// committed for TM/RM rpc_client.
	AsyncCommitting GlobalSession_GlobalStatus = 8
	// PHASE 2: Final Status: will NOT change any more.
	// Finally: global transaction is successfully committed.
	Committed GlobalSession_GlobalStatus = 9
	// The Commit failed.
	// Finally: failed to commit
	CommitFailed GlobalSession_GlobalStatus = 10
	// The RolledBack.
	// Finally: global transaction is successfully rollback.
	RolledBack GlobalSession_GlobalStatus = 11
	// The Rollback failed.
	// Finally: failed to rollback
	RollbackFailed GlobalSession_GlobalStatus = 12
	// The Timeout rolled back.
	// Finally: global transaction is successfully rollback since timeout.
	TimeoutRolledBack GlobalSession_GlobalStatus = 13
	// The Timeout rollback failed.
	// Finally: failed to rollback since timeout
	TimeoutRollbackFailed GlobalSession_GlobalStatus = 14
	// The Finished.
	// Not managed in getty_session MAP any more
	Finished GlobalSession_GlobalStatus = 15
)

func (GlobalSession_GlobalStatus) EnumDescriptor 

func (GlobalSession_GlobalStatus) EnumDescriptor() ([]byte, []int)

func (GlobalSession_GlobalStatus) String 

func (x GlobalSession_GlobalStatus) String() string

type GlobalStatusRequest 

type GlobalStatusRequest struct {
	XID string `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
}

GlobalStatusRequest represents a request to query the global transaction status

func (*GlobalStatusRequest) Descriptor 

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

func (*GlobalStatusRequest) Equal 

func (this *GlobalStatusRequest) Equal(that interface{}) bool

func (*GlobalStatusRequest) GetXID 

func (m *GlobalStatusRequest) GetXID() string

func (*GlobalStatusRequest) GoString 

func (this *GlobalStatusRequest) GoString() string

func (*GlobalStatusRequest) Marshal 

func (m *GlobalStatusRequest) Marshal() (dAtA []byte, err error)

func (*GlobalStatusRequest) MarshalTo 

func (m *GlobalStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*GlobalStatusRequest) MarshalToSizedBuffer 

func (m *GlobalStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalStatusRequest) ProtoMessage 

func (*GlobalStatusRequest) ProtoMessage()

func (*GlobalStatusRequest) Reset 

func (m *GlobalStatusRequest) Reset()

func (*GlobalStatusRequest) Size 

func (m *GlobalStatusRequest) Size() (n int)

func (*GlobalStatusRequest) String 

func (this *GlobalStatusRequest) String() string

func (*GlobalStatusRequest) Unmarshal 

func (m *GlobalStatusRequest) Unmarshal(dAtA []byte) error

func (*GlobalStatusRequest) XXX_DiscardUnknown 

func (m *GlobalStatusRequest) XXX_DiscardUnknown()

func (*GlobalStatusRequest) XXX_Marshal 

func (m *GlobalStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalStatusRequest) XXX_Merge 

func (m *GlobalStatusRequest) XXX_Merge(src proto.Message)

func (*GlobalStatusRequest) XXX_Size 

func (m *GlobalStatusRequest) XXX_Size() int

func (*GlobalStatusRequest) XXX_Unmarshal 

func (m *GlobalStatusRequest) XXX_Unmarshal(b []byte) error

type GlobalStatusResponse 

type GlobalStatusResponse struct {
	ResultCode    ResultCode                 `protobuf:"varint,1,opt,name=ResultCode,proto3,enum=apis.ResultCode" json:"ResultCode,omitempty"`
	ExceptionCode ExceptionCode              `protobuf:"varint,2,opt,name=ExceptionCode,proto3,enum=apis.ExceptionCode" json:"ExceptionCode,omitempty"`
	Message       string                     `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus  GlobalSession_GlobalStatus `protobuf:"varint,4,opt,name=GlobalStatus,proto3,enum=apis.GlobalSession_GlobalStatus" json:"GlobalStatus,omitempty"`
}

GlobalStatusResponse represents a response to GlobalStatusRequest

func (*GlobalStatusResponse) Descriptor 

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

func (*GlobalStatusResponse) Equal 

func (this *GlobalStatusResponse) Equal(that interface{}) bool

func (*GlobalStatusResponse) GetExceptionCode 

func (m *GlobalStatusResponse) GetExceptionCode() ExceptionCode

func (*GlobalStatusResponse) GetGlobalStatus 

func (m *GlobalStatusResponse) GetGlobalStatus() GlobalSession_GlobalStatus

func (*GlobalStatusResponse) GetMessage 

func (m *GlobalStatusResponse) GetMessage() string

func (*GlobalStatusResponse) GetResultCode 

func (m *GlobalStatusResponse) GetResultCode() ResultCode

func (*GlobalStatusResponse) GoString 

func (this *GlobalStatusResponse) GoString() string

func (*GlobalStatusResponse) Marshal 

func (m *GlobalStatusResponse) Marshal() (dAtA []byte, err error)

func (*GlobalStatusResponse) MarshalTo 

func (m *GlobalStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*GlobalStatusResponse) MarshalToSizedBuffer 

func (m *GlobalStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalStatusResponse) ProtoMessage 

func (*GlobalStatusResponse) ProtoMessage()

func (*GlobalStatusResponse) Reset 

func (m *GlobalStatusResponse) Reset()

func (*GlobalStatusResponse) Size 

func (m *GlobalStatusResponse) Size() (n int)

func (*GlobalStatusResponse) String 

func (this *GlobalStatusResponse) String() string

func (*GlobalStatusResponse) Unmarshal 

func (m *GlobalStatusResponse) Unmarshal(dAtA []byte) error

func (*GlobalStatusResponse) XXX_DiscardUnknown 

func (m *GlobalStatusResponse) XXX_DiscardUnknown()

func (*GlobalStatusResponse) XXX_Marshal 

func (m *GlobalStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalStatusResponse) XXX_Merge 

func (m *GlobalStatusResponse) XXX_Merge(src proto.Message)

func (*GlobalStatusResponse) XXX_Size 

func (m *GlobalStatusResponse) XXX_Size() int

func (*GlobalStatusResponse) XXX_Unmarshal 

func (m *GlobalStatusResponse) XXX_Unmarshal(b []byte) error

type ResourceManagerServiceClient 

type ResourceManagerServiceClient interface {
	BranchCommunicate(ctx context.Context, opts ...grpc.CallOption) (ResourceManagerService_BranchCommunicateClient, error)
	BranchRegister(ctx context.Context, in *BranchRegisterRequest, opts ...grpc.CallOption) (*BranchRegisterResponse, error)
	BranchReport(ctx context.Context, in *BranchReportRequest, opts ...grpc.CallOption) (*BranchReportResponse, error)
	LockQuery(ctx context.Context, in *GlobalLockQueryRequest, opts ...grpc.CallOption) (*GlobalLockQueryResponse, error)
}

ResourceManagerServiceClient is the client API for ResourceManagerService 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 NewResourceManagerServiceClient 

func NewResourceManagerServiceClient(cc grpc.ClientConnInterface) ResourceManagerServiceClient

type ResourceManagerServiceServer 

type ResourceManagerServiceServer interface {
	BranchCommunicate(ResourceManagerService_BranchCommunicateServer) error
	BranchRegister(context.Context, *BranchRegisterRequest) (*BranchRegisterResponse, error)
	BranchReport(context.Context, *BranchReportRequest) (*BranchReportResponse, error)
	LockQuery(context.Context, *GlobalLockQueryRequest) (*GlobalLockQueryResponse, error)
}

ResourceManagerServiceServer is the server API for ResourceManagerService service. All implementations should embed UnimplementedResourceManagerServiceServer for forward compatibility

type ResourceManagerService_BranchCommunicateClient 

type ResourceManagerService_BranchCommunicateClient interface {
	Send(*BranchMessage) error
	Recv() (*BranchMessage, error)
	grpc.ClientStream
}

type ResourceManagerService_BranchCommunicateServer 

type ResourceManagerService_BranchCommunicateServer interface {
	Send(*BranchMessage) error
	Recv() (*BranchMessage, error)
	grpc.ServerStream
}

type ResultCode 

type ResultCode int32
const (
	ResultCodeFailed  ResultCode = 0
	ResultCodeSuccess ResultCode = 1
)

func (ResultCode) EnumDescriptor 

func (ResultCode) EnumDescriptor() ([]byte, []int)

func (ResultCode) String 

func (x ResultCode) String() string

type RowLock 

type RowLock struct {
	XID           string `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty" xorm:"xid"`
	TransactionID int64  `protobuf:"varint,2,opt,name=TransactionID,proto3" json:"TransactionID,omitempty" xorm:"transaction_id"`
	BranchID      int64  `protobuf:"varint,3,opt,name=BranchID,proto3" json:"BranchID,omitempty" xorm:"branch_id"`
	ResourceID    string `protobuf:"bytes,4,opt,name=ResourceID,proto3" json:"ResourceID,omitempty" xorm:"resource_id"`
	TableName     string `protobuf:"bytes,5,opt,name=TableName,proto3" json:"TableName,omitempty" xorm:"table_name"`
	PK            string `protobuf:"bytes,6,opt,name=PK,proto3" json:"PK,omitempty" xorm:"pk"`
	RowKey        string `protobuf:"bytes,7,opt,name=RowKey,proto3" json:"RowKey,omitempty" xorm:"row_key"`
}

func (*RowLock) Descriptor 

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

func (*RowLock) Equal 

func (this *RowLock) Equal(that interface{}) bool

func (*RowLock) GetBranchID 

func (m *RowLock) GetBranchID() int64

func (*RowLock) GetPK 

func (m *RowLock) GetPK() string

func (*RowLock) GetResourceID 

func (m *RowLock) GetResourceID() string

func (*RowLock) GetRowKey 

func (m *RowLock) GetRowKey() string

func (*RowLock) GetTableName 

func (m *RowLock) GetTableName() string

func (*RowLock) GetTransactionID 

func (m *RowLock) GetTransactionID() int64

func (*RowLock) GetXID 

func (m *RowLock) GetXID() string

func (*RowLock) GoString 

func (this *RowLock) GoString() string

func (*RowLock) Marshal 

func (m *RowLock) Marshal() (dAtA []byte, err error)

func (*RowLock) MarshalTo 

func (m *RowLock) MarshalTo(dAtA []byte) (int, error)

func (*RowLock) MarshalToSizedBuffer 

func (m *RowLock) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowLock) ProtoMessage 

func (*RowLock) ProtoMessage()

func (*RowLock) Reset 

func (m *RowLock) Reset()

func (*RowLock) Size 

func (m *RowLock) Size() (n int)

func (*RowLock) String 

func (this *RowLock) String() string

func (*RowLock) Unmarshal 

func (m *RowLock) Unmarshal(dAtA []byte) error

func (*RowLock) XXX_DiscardUnknown 

func (m *RowLock) XXX_DiscardUnknown()

func (*RowLock) XXX_Marshal 

func (m *RowLock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowLock) XXX_Merge 

func (m *RowLock) XXX_Merge(src proto.Message)

func (*RowLock) XXX_Size 

func (m *RowLock) XXX_Size() int

func (*RowLock) XXX_Unmarshal 

func (m *RowLock) XXX_Unmarshal(b []byte) error

type TransactionManagerServiceClient 

type TransactionManagerServiceClient interface {
	Begin(ctx context.Context, in *GlobalBeginRequest, opts ...grpc.CallOption) (*GlobalBeginResponse, error)
	GetStatus(ctx context.Context, in *GlobalStatusRequest, opts ...grpc.CallOption) (*GlobalStatusResponse, error)
	GlobalReport(ctx context.Context, in *GlobalReportRequest, opts ...grpc.CallOption) (*GlobalReportResponse, error)
	Commit(ctx context.Context, in *GlobalCommitRequest, opts ...grpc.CallOption) (*GlobalCommitResponse, error)
	Rollback(ctx context.Context, in *GlobalRollbackRequest, opts ...grpc.CallOption) (*GlobalRollbackResponse, error)
}

TransactionManagerServiceClient is the client API for TransactionManagerService 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 NewTransactionManagerServiceClient 

func NewTransactionManagerServiceClient(cc grpc.ClientConnInterface) TransactionManagerServiceClient

type TransactionManagerServiceServer 

type TransactionManagerServiceServer interface {
	Begin(context.Context, *GlobalBeginRequest) (*GlobalBeginResponse, error)
	GetStatus(context.Context, *GlobalStatusRequest) (*GlobalStatusResponse, error)
	GlobalReport(context.Context, *GlobalReportRequest) (*GlobalReportResponse, error)
	Commit(context.Context, *GlobalCommitRequest) (*GlobalCommitResponse, error)
	Rollback(context.Context, *GlobalRollbackRequest) (*GlobalRollbackResponse, error)
}

TransactionManagerServiceServer is the server API for TransactionManagerService service. All implementations should embed UnimplementedTransactionManagerServiceServer for forward compatibility

type UnimplementedResourceManagerServiceServer 

type UnimplementedResourceManagerServiceServer struct {
}

UnimplementedResourceManagerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedResourceManagerServiceServer) BranchCommunicate 

func (UnimplementedResourceManagerServiceServer) BranchCommunicate(ResourceManagerService_BranchCommunicateServer) error

func (UnimplementedResourceManagerServiceServer) BranchRegister 

func (UnimplementedResourceManagerServiceServer) BranchRegister(context.Context, *BranchRegisterRequest) (*BranchRegisterResponse, error)

func (UnimplementedResourceManagerServiceServer) BranchReport 

func (UnimplementedResourceManagerServiceServer) BranchReport(context.Context, *BranchReportRequest) (*BranchReportResponse, error)

func (UnimplementedResourceManagerServiceServer) LockQuery 

func (UnimplementedResourceManagerServiceServer) LockQuery(context.Context, *GlobalLockQueryRequest) (*GlobalLockQueryResponse, error)

type UnimplementedTransactionManagerServiceServer 

type UnimplementedTransactionManagerServiceServer struct {
}

UnimplementedTransactionManagerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTransactionManagerServiceServer) Begin 

func (UnimplementedTransactionManagerServiceServer) Begin(context.Context, *GlobalBeginRequest) (*GlobalBeginResponse, error)

func (UnimplementedTransactionManagerServiceServer) Commit 

func (UnimplementedTransactionManagerServiceServer) Commit(context.Context, *GlobalCommitRequest) (*GlobalCommitResponse, error)

func (UnimplementedTransactionManagerServiceServer) GetStatus 

func (UnimplementedTransactionManagerServiceServer) GetStatus(context.Context, *GlobalStatusRequest) (*GlobalStatusResponse, error)

func (UnimplementedTransactionManagerServiceServer) GlobalReport 

func (UnimplementedTransactionManagerServiceServer) GlobalReport(context.Context, *GlobalReportRequest) (*GlobalReportResponse, error)

func (UnimplementedTransactionManagerServiceServer) Rollback 

func (UnimplementedTransactionManagerServiceServer) Rollback(context.Context, *GlobalRollbackRequest) (*GlobalRollbackResponse, error)

type UnsafeResourceManagerServiceServer 

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

UnsafeResourceManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResourceManagerServiceServer will result in compilation errors.

type UnsafeTransactionManagerServiceServer 

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

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