Versions in this module Expand all Collapse all v1 v1.2.1 May 30, 2024 v1.2.0 May 23, 2024 Changes in this version + const CodecTypeFST + const CodecTypeKRYO + const CodecTypeProtobuf + const CodecTypeSeata + func Init() + type AbstractIdentifyRequestCodec struct + func (c *AbstractIdentifyRequestCodec) Decode(in []byte) interface{} + func (c *AbstractIdentifyRequestCodec) Encode(in interface{}) []byte + type AbstractIdentifyResponseCodec struct + func (c *AbstractIdentifyResponseCodec) Decode(in []byte) interface{} + func (c *AbstractIdentifyResponseCodec) Encode(in interface{}) []byte + type BranchCommitRequestCodec struct + func (g *BranchCommitRequestCodec) Decode(in []byte) interface{} + func (g *BranchCommitRequestCodec) Encode(in interface{}) []byte + func (g *BranchCommitRequestCodec) GetMessageType() message.MessageType + type BranchCommitResponseCodec struct + func (g *BranchCommitResponseCodec) Decode(in []byte) interface{} + func (g *BranchCommitResponseCodec) Encode(in interface{}) []byte + func (g *BranchCommitResponseCodec) GetMessageType() message.MessageType + type BranchRegisterRequestCodec struct + func (c *BranchRegisterRequestCodec) Encode(in interface{}) []byte + func (g *BranchRegisterRequestCodec) Decode(in []byte) interface{} + func (g *BranchRegisterRequestCodec) GetMessageType() message.MessageType + type BranchRegisterResponseCodec struct + func (c *BranchRegisterResponseCodec) Encode(in interface{}) []byte + func (g *BranchRegisterResponseCodec) Decode(in []byte) interface{} + func (g *BranchRegisterResponseCodec) GetMessageType() message.MessageType + type BranchReportRequestCodec struct + func (g *BranchReportRequestCodec) Decode(in []byte) interface{} + func (g *BranchReportRequestCodec) Encode(in interface{}) []byte + func (g *BranchReportRequestCodec) GetMessageType() message.MessageType + type BranchReportResponseCodec struct + func (g *BranchReportResponseCodec) Decode(in []byte) interface{} + func (g *BranchReportResponseCodec) Encode(in interface{}) []byte + func (g *BranchReportResponseCodec) GetMessageType() message.MessageType + type BranchRollbackRequestCodec struct + func (g *BranchRollbackRequestCodec) Decode(in []byte) interface{} + func (g *BranchRollbackRequestCodec) Encode(in interface{}) []byte + func (g *BranchRollbackRequestCodec) GetMessageType() message.MessageType + type BranchRollbackResponseCodec struct + func (g *BranchRollbackResponseCodec) Decode(in []byte) interface{} + func (g *BranchRollbackResponseCodec) Encode(in interface{}) []byte + func (g *BranchRollbackResponseCodec) GetMessageType() message.MessageType + type Codec interface + Decode func(in []byte) interface{} + Encode func(in interface{}) []byte + GetMessageType func() message.MessageType + type CodecManager struct + func GetCodecManager() *CodecManager + func (c *CodecManager) Decode(codecType CodecType, in []byte) interface{} + func (c *CodecManager) Encode(codecType CodecType, in interface{}) []byte + func (c *CodecManager) GetCodec(codecType CodecType, msgType message.MessageType) Codec + func (c *CodecManager) RegisterCodec(codecType CodecType, codec Codec) + type CodecType byte + type CommonGlobalEndRequestCodec struct + func (c *CommonGlobalEndRequestCodec) Decode(in []byte) interface{} + func (c *CommonGlobalEndRequestCodec) Encode(in interface{}) []byte + type CommonGlobalEndResponseCodec struct + func (c *CommonGlobalEndResponseCodec) Decode(in []byte) interface{} + func (c *CommonGlobalEndResponseCodec) Encode(in interface{}) []byte + type GlobalBeginRequestCodec struct + func (c *GlobalBeginRequestCodec) Encode(in interface{}) []byte + func (g *GlobalBeginRequestCodec) Decode(in []byte) interface{} + func (g *GlobalBeginRequestCodec) GetMessageType() message.MessageType + type GlobalBeginResponseCodec struct + func (c *GlobalBeginResponseCodec) Encode(in interface{}) []byte + func (g *GlobalBeginResponseCodec) Decode(in []byte) interface{} + func (g *GlobalBeginResponseCodec) GetMessageType() message.MessageType + type GlobalCommitRequestCodec struct + func (g *GlobalCommitRequestCodec) Decode(in []byte) interface{} + func (g *GlobalCommitRequestCodec) Encode(in interface{}) []byte + func (g *GlobalCommitRequestCodec) GetMessageType() message.MessageType + type GlobalCommitResponseCodec struct + func (g *GlobalCommitResponseCodec) Decode(in []byte) interface{} + func (g *GlobalCommitResponseCodec) Encode(in interface{}) []byte + func (g *GlobalCommitResponseCodec) GetMessageType() message.MessageType + type GlobalLockQueryRequestCodec struct + func (c *GlobalLockQueryRequestCodec) Encode(in interface{}) []byte + func (g *GlobalLockQueryRequestCodec) Decode(in []byte) interface{} + func (g *GlobalLockQueryRequestCodec) GetMessageType() message.MessageType + type GlobalLockQueryResponseCodec struct + func (c *GlobalLockQueryResponseCodec) Encode(in interface{}) []byte + func (g *GlobalLockQueryResponseCodec) Decode(in []byte) interface{} + func (g *GlobalLockQueryResponseCodec) GetMessageType() message.MessageType + type GlobalReportRequestCodec struct + func (g *GlobalReportRequestCodec) Decode(in []byte) interface{} + func (g *GlobalReportRequestCodec) Encode(in interface{}) []byte + func (g *GlobalReportRequestCodec) GetMessageType() message.MessageType + type GlobalReportResponseCodec struct + func (g *GlobalReportResponseCodec) Decode(in []byte) interface{} + func (g *GlobalReportResponseCodec) Encode(in interface{}) []byte + func (g *GlobalReportResponseCodec) GetMessageType() message.MessageType + type GlobalRollbackRequestCodec struct + func (g *GlobalRollbackRequestCodec) Decode(in []byte) interface{} + func (g *GlobalRollbackRequestCodec) Encode(in interface{}) []byte + func (g *GlobalRollbackRequestCodec) GetMessageType() message.MessageType + type GlobalRollbackResponseCodec struct + func (g *GlobalRollbackResponseCodec) Decode(in []byte) interface{} + func (g *GlobalRollbackResponseCodec) Encode(in interface{}) []byte + func (g *GlobalRollbackResponseCodec) GetMessageType() message.MessageType + type GlobalStatusRequestCodec struct + func (g *GlobalStatusRequestCodec) Decode(in []byte) interface{} + func (g *GlobalStatusRequestCodec) Encode(in interface{}) []byte + func (g *GlobalStatusRequestCodec) GetMessageType() message.MessageType + type GlobalStatusResponseCodec struct + func (g *GlobalStatusResponseCodec) Decode(in []byte) interface{} + func (g *GlobalStatusResponseCodec) Encode(in interface{}) []byte + func (g *GlobalStatusResponseCodec) GetMessageType() message.MessageType + type RegisterRMRequestCodec struct + func (c *RegisterRMRequestCodec) Encode(in interface{}) []byte + func (g *RegisterRMRequestCodec) Decode(in []byte) interface{} + func (g *RegisterRMRequestCodec) GetMessageType() message.MessageType + type RegisterRMResponseCodec struct + func (c *RegisterRMResponseCodec) Encode(in interface{}) []byte + func (g *RegisterRMResponseCodec) Decode(in []byte) interface{} + func (g *RegisterRMResponseCodec) GetMessageType() message.MessageType + type RegisterTMRequestCodec struct + func (c *RegisterTMRequestCodec) Encode(in interface{}) []byte + func (g *RegisterTMRequestCodec) Decode(in []byte) interface{} + func (g *RegisterTMRequestCodec) GetMessageType() message.MessageType + type RegisterTMResponseCodec struct + func (c *RegisterTMResponseCodec) Encode(in interface{}) []byte + func (g *RegisterTMResponseCodec) Decode(in []byte) interface{} + func (g *RegisterTMResponseCodec) GetMessageType() message.MessageType
Go to main page