codec

Documentation

Index

• Constants
• func AbstractBranchEndRequestDecoder(in []byte) (interface{}, int)
• func AbstractBranchEndRequestEncoder(in interface{}) []byte
• func AbstractBranchEndResponseDecoder(in []byte) (interface{}, int)
• func AbstractBranchEndResponseEncoder(in interface{}) []byte
• func AbstractGlobalEndRequestDecoder(in []byte) (interface{}, int)
• func AbstractGlobalEndRequestEncoder(in interface{}) []byte
• func AbstractGlobalEndResponseDecoder(in []byte) (interface{}, int)
• func AbstractGlobalEndResponseEncoder(in interface{}) []byte
• func AbstractIdentifyRequestDecoder(in []byte) (interface{}, int)
• func AbstractIdentifyRequestEncoder(in interface{}) []byte
• func AbstractIdentifyResponseDecoder(in []byte) (interface{}, int)
• func AbstractIdentifyResponseEncoder(in interface{}) []byte
• func AbstractResultMessageDecoder(in []byte) (interface{}, int)
• func AbstractResultMessageEncoder(in interface{}) []byte
• func AbstractTransactionResponseDecoder(in []byte) (interface{}, int)
• func AbstractTransactionResponseEncoder(in interface{}) []byte
• func BranchCommitRequestDecoder(in []byte) (interface{}, int)
• func BranchCommitRequestEncoder(in interface{}) []byte
• func BranchCommitResponseDecoder(in []byte) (interface{}, int)
• func BranchCommitResponseEncoder(in interface{}) []byte
• func BranchRegisterRequestDecoder(in []byte) (interface{}, int)
• func BranchRegisterRequestEncoder(in interface{}) []byte
• func BranchRegisterResponseDecoder(in []byte) (interface{}, int)
• func BranchRegisterResponseEncoder(in interface{}) []byte
• func BranchReportRequestDecoder(in []byte) (interface{}, int)
• func BranchReportRequestEncoder(in interface{}) []byte
• func BranchReportResponseDecoder(in []byte) (interface{}, int)
• func BranchReportResponseEncoder(in interface{}) []byte
• func BranchRollbackRequestDecoder(in []byte) (interface{}, int)
• func BranchRollbackRequestEncoder(in interface{}) []byte
• func BranchRollbackResponseDecoder(in []byte) (interface{}, int)
• func BranchRollbackResponseEncoder(in interface{}) []byte
• func GlobalBeginRequestDecoder(in []byte) (interface{}, int)
• func GlobalBeginRequestEncoder(in interface{}) []byte
• func GlobalBeginResponseDecoder(in []byte) (interface{}, int)
• func GlobalBeginResponseEncoder(in interface{}) []byte
• func GlobalCommitRequestDecoder(in []byte) (interface{}, int)
• func GlobalCommitRequestEncoder(in interface{}) []byte
• func GlobalCommitResponseDecoder(in []byte) (interface{}, int)
• func GlobalCommitResponseEncoder(in interface{}) []byte
• func GlobalLockQueryRequestDecoder(in []byte) (interface{}, int)
• func GlobalLockQueryRequestEncoder(in interface{}) []byte
• func GlobalLockQueryResponseDecoder(in []byte) (interface{}, int)
• func GlobalLockQueryResponseEncoder(in interface{}) []byte
• func GlobalReportRequestDecoder(in []byte) (interface{}, int)
• func GlobalReportRequestEncoder(in interface{}) []byte
• func GlobalReportResponseDecoder(in []byte) (interface{}, int)
• func GlobalReportResponseEncoder(in interface{}) []byte
• func GlobalRollbackRequestDecoder(in []byte) (interface{}, int)
• func GlobalRollbackRequestEncoder(in interface{}) []byte
• func GlobalRollbackResponseDecoder(in []byte) (interface{}, int)
• func GlobalRollbackResponseEncoder(in interface{}) []byte
• func GlobalStatusRequestDecoder(in []byte) (interface{}, int)
• func GlobalStatusRequestEncoder(in interface{}) []byte
• func GlobalStatusResponseDecoder(in []byte) (interface{}, int)
• func GlobalStatusResponseEncoder(in interface{}) []byte
• func MergeResultMessageDecoder(in []byte) (interface{}, int)
• func MergeResultMessageEncoder(in interface{}) []byte
• func MergedWarpMessageDecoder(in []byte) (interface{}, int)
• func MergedWarpMessageEncoder(in interface{}) []byte
• func MessageDecoder(codecType byte, in []byte) (interface{}, int)
• func MessageEncoder(codecType byte, in interface{}) []byte
• func RegisterRMRequestDecoder(in []byte) (interface{}, int)
• func RegisterRMRequestEncoder(in interface{}) []byte
• func RegisterRMResponseDecoder(in []byte) (interface{}, int)
• func RegisterRMResponseEncoder(in interface{}) []byte
• func RegisterTMRequestDecoder(in []byte) (interface{}, int)
• func RegisterTMRequestEncoder(in interface{}) []byte
• func RegisterTMResponseDecoder(in []byte) (interface{}, int)
• func RegisterTMResponseEncoder(in interface{}) []byte
• func SeataDecoder(in []byte) (interface{}, int)
• func SeataEncoder(in interface{}) []byte
• func UndoLogDeleteRequestDecoder(in []byte) (interface{}, int)
• func UndoLogDeleteRequestEncoder(in interface{}) []byte
• type Decoder
• type Encoder
• type SerializerType

Constants

const (
	SEATA    = byte(0x1)
	PROTOBUF = byte(0x2)
	KRYO     = byte(0x4)
	FST      = byte(0x8)
)

Functions

func AbstractBranchEndRequestDecoder

func AbstractBranchEndRequestDecoder(in []byte) (interface{}, int)

func AbstractBranchEndRequestEncoder

func AbstractBranchEndRequestEncoder(in interface{}) []byte

func AbstractBranchEndResponseDecoder

func AbstractBranchEndResponseDecoder(in []byte) (interface{}, int)

func AbstractBranchEndResponseEncoder

func AbstractBranchEndResponseEncoder(in interface{}) []byte

func AbstractGlobalEndRequestDecoder

func AbstractGlobalEndRequestDecoder(in []byte) (interface{}, int)

func AbstractGlobalEndRequestEncoder

func AbstractGlobalEndRequestEncoder(in interface{}) []byte

func AbstractGlobalEndResponseDecoder

func AbstractGlobalEndResponseDecoder(in []byte) (interface{}, int)

func AbstractGlobalEndResponseEncoder

func AbstractGlobalEndResponseEncoder(in interface{}) []byte

func AbstractIdentifyRequestDecoder

func AbstractIdentifyRequestDecoder(in []byte) (interface{}, int)

func AbstractIdentifyRequestEncoder

func AbstractIdentifyRequestEncoder(in interface{}) []byte

func AbstractIdentifyResponseDecoder

func AbstractIdentifyResponseDecoder(in []byte) (interface{}, int)

func AbstractIdentifyResponseEncoder

func AbstractIdentifyResponseEncoder(in interface{}) []byte

func AbstractResultMessageDecoder

func AbstractResultMessageDecoder(in []byte) (interface{}, int)

func AbstractResultMessageEncoder

func AbstractResultMessageEncoder(in interface{}) []byte

func AbstractTransactionResponseDecoder

func AbstractTransactionResponseDecoder(in []byte) (interface{}, int)

func AbstractTransactionResponseEncoder

func AbstractTransactionResponseEncoder(in interface{}) []byte

func BranchCommitRequestDecoder

func BranchCommitRequestDecoder(in []byte) (interface{}, int)

func BranchCommitRequestEncoder

func BranchCommitRequestEncoder(in interface{}) []byte

func BranchCommitResponseDecoder

func BranchCommitResponseDecoder(in []byte) (interface{}, int)

func BranchCommitResponseEncoder

func BranchCommitResponseEncoder(in interface{}) []byte

func BranchRegisterRequestDecoder

func BranchRegisterRequestDecoder(in []byte) (interface{}, int)

func BranchRegisterRequestEncoder

func BranchRegisterRequestEncoder(in interface{}) []byte

func BranchRegisterResponseDecoder

func BranchRegisterResponseDecoder(in []byte) (interface{}, int)

func BranchRegisterResponseEncoder

func BranchRegisterResponseEncoder(in interface{}) []byte

func BranchReportRequestDecoder

func BranchReportRequestDecoder(in []byte) (interface{}, int)

func BranchReportRequestEncoder

func BranchReportRequestEncoder(in interface{}) []byte

func BranchReportResponseDecoder

func BranchReportResponseDecoder(in []byte) (interface{}, int)

func BranchReportResponseEncoder

func BranchReportResponseEncoder(in interface{}) []byte

func BranchRollbackRequestDecoder

func BranchRollbackRequestDecoder(in []byte) (interface{}, int)

func BranchRollbackRequestEncoder

func BranchRollbackRequestEncoder(in interface{}) []byte

func BranchRollbackResponseDecoder

func BranchRollbackResponseDecoder(in []byte) (interface{}, int)

func BranchRollbackResponseEncoder

func BranchRollbackResponseEncoder(in interface{}) []byte

func GlobalBeginRequestDecoder

func GlobalBeginRequestDecoder(in []byte) (interface{}, int)

func GlobalBeginRequestEncoder

func GlobalBeginRequestEncoder(in interface{}) []byte

func GlobalBeginResponseDecoder

func GlobalBeginResponseDecoder(in []byte) (interface{}, int)

func GlobalBeginResponseEncoder

func GlobalBeginResponseEncoder(in interface{}) []byte

func GlobalCommitRequestDecoder

func GlobalCommitRequestDecoder(in []byte) (interface{}, int)

func GlobalCommitRequestEncoder

func GlobalCommitRequestEncoder(in interface{}) []byte

func GlobalCommitResponseDecoder

func GlobalCommitResponseDecoder(in []byte) (interface{}, int)

func GlobalCommitResponseEncoder

func GlobalCommitResponseEncoder(in interface{}) []byte

func GlobalLockQueryRequestDecoder

func GlobalLockQueryRequestDecoder(in []byte) (interface{}, int)

func GlobalLockQueryRequestEncoder

func GlobalLockQueryRequestEncoder(in interface{}) []byte

func GlobalLockQueryResponseDecoder

func GlobalLockQueryResponseDecoder(in []byte) (interface{}, int)

func GlobalLockQueryResponseEncoder

func GlobalLockQueryResponseEncoder(in interface{}) []byte

func GlobalReportRequestDecoder

func GlobalReportRequestDecoder(in []byte) (interface{}, int)

func GlobalReportRequestEncoder

func GlobalReportRequestEncoder(in interface{}) []byte

func GlobalReportResponseDecoder

func GlobalReportResponseDecoder(in []byte) (interface{}, int)

func GlobalReportResponseEncoder

func GlobalReportResponseEncoder(in interface{}) []byte

func GlobalRollbackRequestDecoder

func GlobalRollbackRequestDecoder(in []byte) (interface{}, int)

func GlobalRollbackRequestEncoder

func GlobalRollbackRequestEncoder(in interface{}) []byte

func GlobalRollbackResponseDecoder

func GlobalRollbackResponseDecoder(in []byte) (interface{}, int)

func GlobalRollbackResponseEncoder

func GlobalRollbackResponseEncoder(in interface{}) []byte

func GlobalStatusRequestDecoder

func GlobalStatusRequestDecoder(in []byte) (interface{}, int)

func GlobalStatusRequestEncoder

func GlobalStatusRequestEncoder(in interface{}) []byte

func GlobalStatusResponseDecoder

func GlobalStatusResponseDecoder(in []byte) (interface{}, int)

func GlobalStatusResponseEncoder

func GlobalStatusResponseEncoder(in interface{}) []byte

func MergeResultMessageDecoder

func MergeResultMessageDecoder(in []byte) (interface{}, int)

func MergeResultMessageEncoder

func MergeResultMessageEncoder(in interface{}) []byte

func MergedWarpMessageDecoder

func MergedWarpMessageDecoder(in []byte) (interface{}, int)

func MergedWarpMessageEncoder

func MergedWarpMessageEncoder(in interface{}) []byte

func MessageDecoder

func MessageDecoder(codecType byte, in []byte) (interface{}, int)

func MessageEncoder

func MessageEncoder(codecType byte, in interface{}) []byte

func RegisterRMRequestDecoder

func RegisterRMRequestDecoder(in []byte) (interface{}, int)

func RegisterRMRequestEncoder

func RegisterRMRequestEncoder(in interface{}) []byte

func RegisterRMResponseDecoder

func RegisterRMResponseDecoder(in []byte) (interface{}, int)

func RegisterRMResponseEncoder

func RegisterRMResponseEncoder(in interface{}) []byte

func RegisterTMRequestDecoder

func RegisterTMRequestDecoder(in []byte) (interface{}, int)

func RegisterTMRequestEncoder

func RegisterTMRequestEncoder(in interface{}) []byte

func RegisterTMResponseDecoder

func RegisterTMResponseDecoder(in []byte) (interface{}, int)

func RegisterTMResponseEncoder

func RegisterTMResponseEncoder(in interface{}) []byte

func SeataDecoder

func SeataDecoder(in []byte) (interface{}, int)

func SeataEncoder

func SeataEncoder(in interface{}) []byte

func UndoLogDeleteRequestDecoder

func UndoLogDeleteRequestDecoder(in []byte) (interface{}, int)

func UndoLogDeleteRequestEncoder

func UndoLogDeleteRequestEncoder(in interface{}) []byte

Types

type Decoder

type Decoder func(in []byte) (interface{}, int)

type Encoder

type Encoder func(in interface{}) []byte

type SerializerType

type SerializerType byte