encoding

package

v0.0.0-...-be15534 Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tiflow

Links

Open Source Insights

Documentation ¶

Index ¶

func DecodeCRTs(key []byte) uint64
func DecodeKey(key []byte) (uniqueID uint32, tableID uint64, startTs, CRTs uint64)
func EncodeKey(uniqueID uint32, tableID uint64, event *model.PolymorphicEvent) []byte
func EncodeTsKey(uniqueID uint32, tableID uint64, CRTs uint64, startTs ...uint64) []byte
type MsgPackGenSerde
- func (m *MsgPackGenSerde) Marshal(event *model.PolymorphicEvent, bytes []byte) ([]byte, error)
- func (m *MsgPackGenSerde) Unmarshal(event *model.PolymorphicEvent, bytes []byte) ([]byte, error)
type SerializerDeserializer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DecodeCRTs ¶

func DecodeCRTs(key []byte) uint64

DecodeCRTs decodes CRTs from the given key.

func DecodeKey ¶

func DecodeKey(key []byte) (uniqueID uint32, tableID uint64, startTs, CRTs uint64)

DecodeKey decodes a key to uniqueID, tableID, startTs, CRTs.

func EncodeKey ¶

func EncodeKey(uniqueID uint32, tableID uint64, event *model.PolymorphicEvent) []byte

EncodeKey encodes a key according to event. Format: uniqueID, tableID, CRTs, startTs, delete/update/insert, Key.

func EncodeTsKey ¶

func EncodeTsKey(uniqueID uint32, tableID uint64, CRTs uint64, startTs ...uint64) []byte

EncodeTsKey encodes uniqueID, tableID, CRTs and StartTs. StartTs is optional.

Types ¶

type MsgPackGenSerde ¶

type MsgPackGenSerde struct{}

MsgPackGenSerde encodes model.PolymorphicEvent into bytes and decodes model.PolymorphicEvent from bytes.

func (*MsgPackGenSerde) Marshal ¶

func (m *MsgPackGenSerde) Marshal(event *model.PolymorphicEvent, bytes []byte) ([]byte, error)

Marshal encodes model.PolymorphicEvent into bytes.

func (*MsgPackGenSerde) Unmarshal ¶

func (m *MsgPackGenSerde) Unmarshal(event *model.PolymorphicEvent, bytes []byte) ([]byte, error)

Unmarshal decodes model.PolymorphicEvent from bytes.

type SerializerDeserializer ¶

type SerializerDeserializer interface {
	Marshal(event *model.PolymorphicEvent, bytes []byte) ([]byte, error)
	Unmarshal(event *model.PolymorphicEvent, bytes []byte) ([]byte, error)
}

SerializerDeserializer is the interface encodes and decodes model.PolymorphicEvent.

Source Files ¶

View all Source files

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