api

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2022 License: Apache-2.0 Imports: 13 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BranchSession_BranchStatus_name = map[int32]string{
	0: "Registered",
	1: "PhaseOneFailed",
	2: "PhaseTwoCommitting",
	3: "PhaseTwoRollbacking",
	4: "Complete",
}
View Source 
var BranchSession_BranchStatus_value = map[string]int32{
	"Registered":          0,
	"PhaseOneFailed":      1,
	"PhaseTwoCommitting":  2,
	"PhaseTwoRollbacking": 3,
	"Complete":            4,
}
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 GlobalSession_GlobalStatus_name = map[int32]string{
	0: "Begin",
	1: "Committing",
	2: "Rollbacking",
	3: "Finished",
}
View Source 
var GlobalSession_GlobalStatus_value = map[string]int32{
	"Begin":       0,
	"Committing":  1,
	"Rollbacking": 2,
	"Finished":    3,
}
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: "api.TransactionManagerService",
	HandlerType: (*TransactionManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Begin",
			Handler:    _TransactionManagerService_Begin_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _TransactionManagerService_Commit_Handler,
		},
		{
			MethodName: "Rollback",
			Handler:    _TransactionManagerService_Rollback_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.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 RegisterTransactionManagerServiceServer 

func RegisterTransactionManagerServiceServer(s grpc.ServiceRegistrar, srv TransactionManagerServiceServer)

Types

type BranchRegisterRequest 

type BranchRegisterRequest 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=api.BranchSession_BranchType" json:"BranchType,omitempty"`
	ApplicationData []byte                   `protobuf:"bytes,5,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) 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=api.ResultCode" json:"ResultCode,omitempty"`
	Message         string     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	BranchID        string     `protobuf:"bytes,3,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	BranchSessionID int64      `protobuf:"varint,4,opt,name=BranchSessionID,proto3" json:"BranchSessionID,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() string

func (*BranchRegisterResponse) GetBranchSessionID 

func (m *BranchRegisterResponse) GetBranchSessionID() int64

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 {
	BranchID     string                     `protobuf:"bytes,1,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	BranchStatus BranchSession_BranchStatus `protobuf:"varint,2,opt,name=BranchStatus,proto3,enum=api.BranchSession_BranchStatus" json:"BranchStatus,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) GetBranchID 

func (m *BranchReportRequest) GetBranchID() string

func (*BranchReportRequest) GetBranchStatus 

func (m *BranchReportRequest) GetBranchStatus() BranchSession_BranchStatus

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=api.ResultCode" json:"ResultCode,omitempty"`
	Message    string     `protobuf:"bytes,2,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) 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 BranchSession 

type BranchSession struct {
	BranchID        string                     `protobuf:"bytes,1,opt,name=BranchID,proto3" json:"BranchID,omitempty"`
	ApplicationID   string                     `protobuf:"bytes,2,opt,name=ApplicationID,proto3" json:"ApplicationID,omitempty"`
	BranchSessionID int64                      `protobuf:"varint,3,opt,name=BranchSessionID,proto3" json:"BranchSessionID,omitempty"`
	XID             string                     `protobuf:"bytes,4,opt,name=XID,proto3" json:"XID,omitempty"`
	TransactionID   int64                      `protobuf:"varint,5,opt,name=TransactionID,proto3" json:"TransactionID,omitempty"`
	ResourceID      string                     `protobuf:"bytes,6,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	LockKey         string                     `protobuf:"bytes,7,opt,name=LockKey,proto3" json:"LockKey,omitempty"`
	Type            BranchSession_BranchType   `protobuf:"varint,8,opt,name=Type,proto3,enum=api.BranchSession_BranchType" json:"Type,omitempty"`
	Status          BranchSession_BranchStatus `protobuf:"varint,9,opt,name=Status,proto3,enum=api.BranchSession_BranchStatus" json:"Status,omitempty"`
	ApplicationData []byte                     `protobuf:"bytes,10,opt,name=ApplicationData,proto3" json:"ApplicationData,omitempty"`
	BeginTime       int64                      `protobuf:"varint,11,opt,name=BeginTime,proto3" json:"BeginTime,omitempty"`
}

func (*BranchSession) Descriptor 

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

func (*BranchSession) Equal 

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

func (*BranchSession) GetApplicationData 

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

func (*BranchSession) GetApplicationID 

func (m *BranchSession) GetApplicationID() string

func (*BranchSession) GetBeginTime 

func (m *BranchSession) GetBeginTime() int64

func (*BranchSession) GetBranchID 

func (m *BranchSession) GetBranchID() string

func (*BranchSession) GetBranchSessionID 

func (m *BranchSession) GetBranchSessionID() 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 (
	Registered          BranchSession_BranchStatus = 0
	PhaseOneFailed      BranchSession_BranchStatus = 1
	PhaseTwoCommitting  BranchSession_BranchStatus = 2
	PhaseTwoRollbacking BranchSession_BranchStatus = 3
	Complete            BranchSession_BranchStatus = 4
)

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 GlobalBeginRequest 

type GlobalBeginRequest struct {
	ApplicationID   string `protobuf:"bytes,1,opt,name=ApplicationID,proto3" json:"ApplicationID,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) GetApplicationID 

func (m *GlobalBeginRequest) GetApplicationID() 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=api.ResultCode" json:"ResultCode,omitempty"`
	Message    string     `protobuf:"bytes,2,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) 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=api.ResultCode" json:"ResultCode,omitempty"`
	Message      string                     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus GlobalSession_GlobalStatus `protobuf:"varint,3,opt,name=GlobalStatus,proto3,enum=api.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) 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 {
	ResourceID string `protobuf:"bytes,1,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	LockKey    string `protobuf:"bytes,2,opt,name=LockKey,proto3" json:"LockKey,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) GetLockKey 

func (m *GlobalLockQueryRequest) GetLockKey() string

func (*GlobalLockQueryRequest) GetResourceID 

func (m *GlobalLockQueryRequest) GetResourceID() 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=api.ResultCode" json:"ResultCode,omitempty"`
	Message    string     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	Lockable   bool       `protobuf:"varint,3,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) 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=api.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=api.ResultCode" json:"ResultCode,omitempty"`
	Message      string                     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus GlobalSession_GlobalStatus `protobuf:"varint,3,opt,name=GlobalStatus,proto3,enum=api.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) 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=api.ResultCode" json:"ResultCode,omitempty"`
	Message      string                     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus GlobalSession_GlobalStatus `protobuf:"varint,3,opt,name=GlobalStatus,proto3,enum=api.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) 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 {
	XID             string                     `protobuf:"bytes,1,opt,name=XID,proto3" json:"XID,omitempty"`
	ApplicationID   string                     `protobuf:"bytes,2,opt,name=ApplicationID,proto3" json:"ApplicationID,omitempty"`
	TransactionID   int64                      `protobuf:"varint,3,opt,name=TransactionID,proto3" json:"TransactionID,omitempty"`
	TransactionName string                     `protobuf:"bytes,4,opt,name=TransactionName,proto3" json:"TransactionName,omitempty"`
	Timeout         int32                      `protobuf:"varint,5,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	BeginTime       int64                      `protobuf:"varint,6,opt,name=BeginTime,proto3" json:"BeginTime,omitempty"`
	Status          GlobalSession_GlobalStatus `protobuf:"varint,7,opt,name=Status,proto3,enum=api.GlobalSession_GlobalStatus" json:"Status,omitempty"`
}

func (*GlobalSession) Descriptor 

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

func (*GlobalSession) Equal 

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

func (*GlobalSession) GetApplicationID 

func (m *GlobalSession) GetApplicationID() 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 (
	Begin       GlobalSession_GlobalStatus = 0
	Committing  GlobalSession_GlobalStatus = 1
	Rollbacking GlobalSession_GlobalStatus = 2
	Finished    GlobalSession_GlobalStatus = 3
)

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=api.ResultCode" json:"ResultCode,omitempty"`
	Message      string                     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	GlobalStatus GlobalSession_GlobalStatus `protobuf:"varint,3,opt,name=GlobalStatus,proto3,enum=api.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) 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 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 TransactionManagerServiceClient 

type TransactionManagerServiceClient interface {
	Begin(ctx context.Context, in *GlobalBeginRequest, opts ...grpc.CallOption) (*GlobalBeginResponse, 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)
	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 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) Rollback 

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

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.