CleanMetrics remove metrics belong to the given changefeed.

Compress the given data by the given compression, also record the compression ratio metric.

Decompress the given data by the given compression.

InitMetrics registers all metrics in this file.

MustBinaryLiteralToInt convert bytes into uint64, by follow https://github.com/pingcap/tidb/blob/e3417913f58cdd5a136259b902bf177eaf3aa637/types/binary_literal.go#L105.

MustQueryTimezone query the timezone from the upstream database.

MustSnapshotQuery query the db by the snapshot read with the given commitTs.

NewConfig return a Config for codec.

NewMsg should be used when creating a Message struct.

UnmarshalClaimCheckMessage unmarshal bytes to ClaimCheckMessage.

VerifyChecksum calculate the checksum value, and compare it with the expected one, return error if not identical.

BigintUnsignedHandlingModeLong is the long mode for unsigned bigint handling.

BigintUnsignedHandlingModeString is the string mode for unsigned bigint handling.

DecimalHandlingModePrecise is the precise mode for decimal handling.

DecimalHandlingModeString is the string mode for decimal handling.

EncodingFormatAvro is the avro format.

EncodingFormatJSON is the json format.

MaxRecordOverhead is used to calculate message size by sarama kafka client.

MessageTypeDDL is ddl type of message key.

MessageTypeResolved is resolved type of message key.

MessageTypeRow is row type of message key.

MessageTypeUnknown is unknown type of message key.

SchemaRegistryTypeConfluent is the type of Confluent Schema Registry.

SchemaRegistryTypeGlue is the type of AWS Glue Schema Registry.

ClaimCheckMessage is the message sent to the claim-check external storage.

ColumnsHolder read columns from sql.Rows.

Config use to create the encoder.

Message represents an message to the sink.

EncodingFormatType is the type of encoding format.

MessageType is the type of message, which is used by MqSink and RedoLog.