codec

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: May 29, 2023 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	CodecTypeSeata    = CodecType(0x1)
	CodecTypeProtobuf = CodecType(0x2)
	CodecTypeKRYO     = CodecType(0x4)
	CodecTypeFST      = CodecType(0x8)
)

Variables

This section is empty.

Functions

func Init 

func Init()

Types

type AbstractIdentifyRequestCodec 

type AbstractIdentifyRequestCodec struct{}

func (*AbstractIdentifyRequestCodec) Decode 

func (c *AbstractIdentifyRequestCodec) Decode(in []byte) interface{}

func (*AbstractIdentifyRequestCodec) Encode 

func (c *AbstractIdentifyRequestCodec) Encode(in interface{}) []byte

type AbstractIdentifyResponseCodec 

type AbstractIdentifyResponseCodec struct{}

func (*AbstractIdentifyResponseCodec) Decode 

func (c *AbstractIdentifyResponseCodec) Decode(in []byte) interface{}

func (*AbstractIdentifyResponseCodec) Encode 

func (c *AbstractIdentifyResponseCodec) Encode(in interface{}) []byte

type BranchCommitRequestCodec 

type BranchCommitRequestCodec struct{}

func (*BranchCommitRequestCodec) Decode 

func (g *BranchCommitRequestCodec) Decode(in []byte) interface{}

func (*BranchCommitRequestCodec) Encode 

func (g *BranchCommitRequestCodec) Encode(in interface{}) []byte

func (*BranchCommitRequestCodec) GetMessageType 

func (g *BranchCommitRequestCodec) GetMessageType() message.MessageType

type BranchCommitResponseCodec 

type BranchCommitResponseCodec struct{}

func (*BranchCommitResponseCodec) Decode 

func (g *BranchCommitResponseCodec) Decode(in []byte) interface{}

func (*BranchCommitResponseCodec) Encode 

func (g *BranchCommitResponseCodec) Encode(in interface{}) []byte

func (*BranchCommitResponseCodec) GetMessageType 

func (g *BranchCommitResponseCodec) GetMessageType() message.MessageType

type BranchRegisterRequestCodec 

type BranchRegisterRequestCodec struct{}

func (*BranchRegisterRequestCodec) Decode 

func (g *BranchRegisterRequestCodec) Decode(in []byte) interface{}

func (*BranchRegisterRequestCodec) Encode 

func (c *BranchRegisterRequestCodec) Encode(in interface{}) []byte

func (*BranchRegisterRequestCodec) GetMessageType 

func (g *BranchRegisterRequestCodec) GetMessageType() message.MessageType

type BranchRegisterResponseCodec 

type BranchRegisterResponseCodec struct{}

func (*BranchRegisterResponseCodec) Decode 

func (g *BranchRegisterResponseCodec) Decode(in []byte) interface{}

func (*BranchRegisterResponseCodec) Encode 

func (c *BranchRegisterResponseCodec) Encode(in interface{}) []byte

func (*BranchRegisterResponseCodec) GetMessageType 

func (g *BranchRegisterResponseCodec) GetMessageType() message.MessageType

type BranchReportRequestCodec 

type BranchReportRequestCodec struct {
}

func (*BranchReportRequestCodec) Decode 

func (g *BranchReportRequestCodec) Decode(in []byte) interface{}

func (*BranchReportRequestCodec) Encode 

func (g *BranchReportRequestCodec) Encode(in interface{}) []byte

func (*BranchReportRequestCodec) GetMessageType 

func (g *BranchReportRequestCodec) GetMessageType() message.MessageType

type BranchReportResponseCodec 

type BranchReportResponseCodec struct{}

func (*BranchReportResponseCodec) Decode 

func (g *BranchReportResponseCodec) Decode(in []byte) interface{}

func (*BranchReportResponseCodec) Encode 

func (g *BranchReportResponseCodec) Encode(in interface{}) []byte

func (*BranchReportResponseCodec) GetMessageType 

func (g *BranchReportResponseCodec) GetMessageType() message.MessageType

type BranchRollbackRequestCodec 

type BranchRollbackRequestCodec struct{}

func (*BranchRollbackRequestCodec) Decode 

func (g *BranchRollbackRequestCodec) Decode(in []byte) interface{}

func (*BranchRollbackRequestCodec) Encode 

func (g *BranchRollbackRequestCodec) Encode(in interface{}) []byte

func (*BranchRollbackRequestCodec) GetMessageType 

func (g *BranchRollbackRequestCodec) GetMessageType() message.MessageType

type BranchRollbackResponseCodec 

type BranchRollbackResponseCodec struct{}

func (*BranchRollbackResponseCodec) Decode 

func (g *BranchRollbackResponseCodec) Decode(in []byte) interface{}

func (*BranchRollbackResponseCodec) Encode 

func (g *BranchRollbackResponseCodec) Encode(in interface{}) []byte

func (*BranchRollbackResponseCodec) GetMessageType 

func (g *BranchRollbackResponseCodec) GetMessageType() message.MessageType

type Codec 

type Codec interface {
	Encode(in interface{}) []byte
	Decode(in []byte) interface{}
	GetMessageType() message.MessageType
}

type CodecManager 

type CodecManager struct {
	// contains filtered or unexported fields
}

func GetCodecManager 

func GetCodecManager() *CodecManager

func (*CodecManager) Decode 

func (c *CodecManager) Decode(codecType CodecType, in []byte) interface{}

func (*CodecManager) Encode 

func (c *CodecManager) Encode(codecType CodecType, in interface{}) []byte

func (*CodecManager) GetCodec 

func (c *CodecManager) GetCodec(codecType CodecType, msgType message.MessageType) Codec

func (*CodecManager) RegisterCodec 

func (c *CodecManager) RegisterCodec(codecType CodecType, codec Codec)

type CodecType 

type CodecType byte

type CommonGlobalEndRequestCodec 

type CommonGlobalEndRequestCodec struct{}

func (*CommonGlobalEndRequestCodec) Decode 

func (c *CommonGlobalEndRequestCodec) Decode(in []byte) interface{}

func (*CommonGlobalEndRequestCodec) Encode 

func (c *CommonGlobalEndRequestCodec) Encode(in interface{}) []byte

type CommonGlobalEndResponseCodec 

type CommonGlobalEndResponseCodec struct{}

func (*CommonGlobalEndResponseCodec) Decode 

func (c *CommonGlobalEndResponseCodec) Decode(in []byte) interface{}

func (*CommonGlobalEndResponseCodec) Encode 

func (c *CommonGlobalEndResponseCodec) Encode(in interface{}) []byte

type GlobalBeginRequestCodec 

type GlobalBeginRequestCodec struct{}

func (*GlobalBeginRequestCodec) Decode 

func (g *GlobalBeginRequestCodec) Decode(in []byte) interface{}

func (*GlobalBeginRequestCodec) Encode 

func (c *GlobalBeginRequestCodec) Encode(in interface{}) []byte

func (*GlobalBeginRequestCodec) GetMessageType 

func (g *GlobalBeginRequestCodec) GetMessageType() message.MessageType

type GlobalBeginResponseCodec 

type GlobalBeginResponseCodec struct{}

func (*GlobalBeginResponseCodec) Decode 

func (g *GlobalBeginResponseCodec) Decode(in []byte) interface{}

func (*GlobalBeginResponseCodec) Encode 

func (c *GlobalBeginResponseCodec) Encode(in interface{}) []byte

func (*GlobalBeginResponseCodec) GetMessageType 

func (g *GlobalBeginResponseCodec) GetMessageType() message.MessageType

type GlobalCommitRequestCodec 

type GlobalCommitRequestCodec struct {
	CommonGlobalEndRequestCodec
}

func (*GlobalCommitRequestCodec) Decode 

func (g *GlobalCommitRequestCodec) Decode(in []byte) interface{}

func (*GlobalCommitRequestCodec) Encode 

func (g *GlobalCommitRequestCodec) Encode(in interface{}) []byte

func (*GlobalCommitRequestCodec) GetMessageType 

func (g *GlobalCommitRequestCodec) GetMessageType() message.MessageType

type GlobalCommitResponseCodec 

type GlobalCommitResponseCodec struct {
	CommonGlobalEndResponseCodec
}

func (*GlobalCommitResponseCodec) Decode 

func (g *GlobalCommitResponseCodec) Decode(in []byte) interface{}

func (*GlobalCommitResponseCodec) Encode 

func (g *GlobalCommitResponseCodec) Encode(in interface{}) []byte

func (*GlobalCommitResponseCodec) GetMessageType 

func (g *GlobalCommitResponseCodec) GetMessageType() message.MessageType

type GlobalLockQueryRequestCodec added in v1.1.0 

type GlobalLockQueryRequestCodec struct {
}

func (*GlobalLockQueryRequestCodec) Decode added in v1.1.0 

func (g *GlobalLockQueryRequestCodec) Decode(in []byte) interface{}

func (*GlobalLockQueryRequestCodec) Encode added in v1.1.0 

func (c *GlobalLockQueryRequestCodec) Encode(in interface{}) []byte

func (*GlobalLockQueryRequestCodec) GetMessageType added in v1.1.0 

func (g *GlobalLockQueryRequestCodec) GetMessageType() message.MessageType

type GlobalLockQueryResponseCodec added in v1.1.0 

type GlobalLockQueryResponseCodec struct {
}

func (*GlobalLockQueryResponseCodec) Decode added in v1.1.0 

func (g *GlobalLockQueryResponseCodec) Decode(in []byte) interface{}

func (*GlobalLockQueryResponseCodec) Encode added in v1.1.0 

func (c *GlobalLockQueryResponseCodec) Encode(in interface{}) []byte

func (*GlobalLockQueryResponseCodec) GetMessageType added in v1.1.0 

func (g *GlobalLockQueryResponseCodec) GetMessageType() message.MessageType

type GlobalReportRequestCodec 

type GlobalReportRequestCodec struct {
	CommonGlobalEndRequestCodec
}

func (*GlobalReportRequestCodec) Decode 

func (g *GlobalReportRequestCodec) Decode(in []byte) interface{}

Decode decode global report request

func (*GlobalReportRequestCodec) Encode 

func (g *GlobalReportRequestCodec) Encode(in interface{}) []byte

Encode encode global report request

func (*GlobalReportRequestCodec) GetMessageType 

func (g *GlobalReportRequestCodec) GetMessageType() message.MessageType

GetMessageType get global report request's message type

type GlobalReportResponseCodec 

type GlobalReportResponseCodec struct {
	CommonGlobalEndResponseCodec
}

func (*GlobalReportResponseCodec) Decode 

func (g *GlobalReportResponseCodec) Decode(in []byte) interface{}

func (*GlobalReportResponseCodec) Encode 

func (g *GlobalReportResponseCodec) Encode(in interface{}) []byte

func (*GlobalReportResponseCodec) GetMessageType 

func (g *GlobalReportResponseCodec) GetMessageType() message.MessageType

type GlobalRollbackRequestCodec 

type GlobalRollbackRequestCodec struct {
	CommonGlobalEndRequestCodec
}

func (*GlobalRollbackRequestCodec) Decode 

func (g *GlobalRollbackRequestCodec) Decode(in []byte) interface{}

func (*GlobalRollbackRequestCodec) Encode 

func (g *GlobalRollbackRequestCodec) Encode(in interface{}) []byte

func (*GlobalRollbackRequestCodec) GetMessageType 

func (g *GlobalRollbackRequestCodec) GetMessageType() message.MessageType

type GlobalRollbackResponseCodec 

type GlobalRollbackResponseCodec struct {
	CommonGlobalEndResponseCodec
}

func (*GlobalRollbackResponseCodec) Decode 

func (g *GlobalRollbackResponseCodec) Decode(in []byte) interface{}

func (*GlobalRollbackResponseCodec) Encode 

func (g *GlobalRollbackResponseCodec) Encode(in interface{}) []byte

func (*GlobalRollbackResponseCodec) GetMessageType 

func (g *GlobalRollbackResponseCodec) GetMessageType() message.MessageType

type GlobalStatusRequestCodec 

type GlobalStatusRequestCodec struct {
	CommonGlobalEndRequestCodec
}

func (*GlobalStatusRequestCodec) Decode 

func (g *GlobalStatusRequestCodec) Decode(in []byte) interface{}

func (*GlobalStatusRequestCodec) Encode 

func (g *GlobalStatusRequestCodec) Encode(in interface{}) []byte

func (*GlobalStatusRequestCodec) GetMessageType 

func (g *GlobalStatusRequestCodec) GetMessageType() message.MessageType

type GlobalStatusResponseCodec 

type GlobalStatusResponseCodec struct {
	CommonGlobalEndResponseCodec
}

func (*GlobalStatusResponseCodec) Decode 

func (g *GlobalStatusResponseCodec) Decode(in []byte) interface{}

func (*GlobalStatusResponseCodec) Encode 

func (g *GlobalStatusResponseCodec) Encode(in interface{}) []byte

func (*GlobalStatusResponseCodec) GetMessageType 

func (g *GlobalStatusResponseCodec) GetMessageType() message.MessageType

type RegisterRMRequestCodec 

type RegisterRMRequestCodec struct{}

func (*RegisterRMRequestCodec) Decode 

func (g *RegisterRMRequestCodec) Decode(in []byte) interface{}

func (*RegisterRMRequestCodec) Encode 

func (c *RegisterRMRequestCodec) Encode(in interface{}) []byte

func (*RegisterRMRequestCodec) GetMessageType 

func (g *RegisterRMRequestCodec) GetMessageType() message.MessageType

type RegisterRMResponseCodec 

type RegisterRMResponseCodec struct {
	AbstractIdentifyResponseCodec
}

func (*RegisterRMResponseCodec) Decode 

func (g *RegisterRMResponseCodec) Decode(in []byte) interface{}

func (*RegisterRMResponseCodec) Encode 

func (c *RegisterRMResponseCodec) Encode(in interface{}) []byte

func (*RegisterRMResponseCodec) GetMessageType 

func (g *RegisterRMResponseCodec) GetMessageType() message.MessageType

type RegisterTMRequestCodec 

type RegisterTMRequestCodec struct {
	AbstractIdentifyRequestCodec
}

func (*RegisterTMRequestCodec) Decode 

func (g *RegisterTMRequestCodec) Decode(in []byte) interface{}

func (*RegisterTMRequestCodec) Encode 

func (c *RegisterTMRequestCodec) Encode(in interface{}) []byte

func (*RegisterTMRequestCodec) GetMessageType 

func (g *RegisterTMRequestCodec) GetMessageType() message.MessageType

type RegisterTMResponseCodec 

type RegisterTMResponseCodec struct {
	AbstractIdentifyResponseCodec
}

func (*RegisterTMResponseCodec) Decode 

func (g *RegisterTMResponseCodec) Decode(in []byte) interface{}

func (*RegisterTMResponseCodec) Encode 

func (c *RegisterTMResponseCodec) Encode(in interface{}) []byte

func (*RegisterTMResponseCodec) GetMessageType 

func (g *RegisterTMResponseCodec) GetMessageType() message.MessageType

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.