codec

package
v0.0.0-...-e946c5d Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL