GetDefaultReplicaConfig returns the default replica config.

GetDefaultServerConfig returns the default server config.

GetGlobalServerConfig returns the global configuration for this server.

NewDefaultDBConfig return the default db configuration.

NewDefaultEventServiceConfig return the default event service configuration.

NewDefaultKVClientConfig return the default kv client configuration.

NewDefaultLargeMessageHandleConfig return the default Config.

NewDefaultPullerConfig return the default puller configuration.

NewDefaultSchedulerConfig return the default scheduler configuration.

NewDefaultSchemaStoreConfig return the default schema store configuration.

NewTimeMill returns a new time in milliseconds.

NewTimeSec returns a new time in seconds.

ParseSinkProtocolFromString converts the protocol from string to Protocol enum type.

StoreGlobalServerConfig stores a new config to the globalServerConfig.

Backslash is a constant for '\'.

BinaryEncodingBase64 encodes binary data to base64 string.

BinaryEncodingHex encodes binary data to hex string.

CheckLevelCorrectness means check each row data correctness.

CheckLevelNone means no integrity check, the default value.

Comma is a constant for ','.

CorruptionHandleLevelError means log the corrupted event, and then stopped the changefeed.

CorruptionHandleLevelWarn is the default value, log the corrupted event, and mark it as corrupted and send it to the downstream.

CR is an abbreviation for carriage return.

CRLF is an abbreviation for '\r\n'.

Enum types of DateSeparator.

Enum types of DateSeparator.

Enum types of DateSeparator.

Enum types of DateSeparator.

DebugConfigurationItem is the name of debug configurations.

DefaultAdvanceTimeoutInSec sets the default value for advance-timeout-in-sec.

DefaultBasicEventHandlerConcurrency is used to calculate the number of workers for eventService and eventCollector.

1GB.

DefaultEncoderGroupConcurrency is the default concurrency of encoder group.

DefaultFileIndexWidth is the default width of file index.

10M.

DefaultMaxReconnectToPulsarBroker is the default max reconnect times to pulsar broker.

DefaultPulsarProducerCacheSize is the default size of the cache for producers 10240 producers maybe cost 1.1G memory.

DefaultRedoDir is a subordinate directory path of data-dir.

DefaultSendAllBootstrapAtStart is the default value of whether to send all tables bootstrap message at changefeed start.

DefaultSendBootstrapInMsgCount is the default number of messages to send bootstrap message.

DefaultSendBootstrapIntervalInSec is the default interval to send bootstrap message.

DefaultSendBootstrapToAllPartition is the default value of whether to send bootstrap message to all partitions.

DefaultSortDir is the default value of sort-dir, it will be a subordinate directory of data-dir.

DefaultTiDBSourceID is the default source ID of TiDB cluster.

DisableMemoryLimit is the default max memory percentage for TiCDC server.

DoubleQuoteChar is a constant for '"'.

EnablePDForwarding is the value of whether to enable PD client forwarding function.

LargeMessageHandleOptionClaimCheck means handling large message by sending to the claim check storage.

LargeMessageHandleOptionHandleKeyOnly means handling large message by sending only handle key columns.

LargeMessageHandleOptionNone means not handling large message.

LF is an abbreviation for line feed.

enough for 2^64 files.

enough for 2^19 files.

NULL is a constant for '\N'.

Enum types of the Protocol.

Enum types of the Protocol.

Enum types of the Protocol.

Enum types of the Protocol.

Enum types of the Protocol.

Enum types of the Protocol.

Enum types of the Protocol.

ProtocolKey specifies the key of the protocol in the SinkURI.

Enum types of the Protocol.

Enum types of the Protocol.

Enum types of the Protocol.

Enum types of the Protocol.

TxnAtomicityKey specifies the key of the transaction-atomicity in the SinkURI.

ReservedClusterIDs contains a list of reserved cluster id, these words are the part of old cdc etcd key prefix like: /tidb/cdc/owner.

ChangeFeedInfo describes the detail of a ChangeFeed.

ChangefeedSchedulerConfig is per changefeed scheduler settings.

ChangeFeedStatus stores information about a ChangeFeed It is stored in etcd.

CloudStorageConfig represents a cloud storage sink configuration.

CodecConfig represents a MQ codec configuration.

ColumnSelector represents a column selector for a table.

Config represents integrity check config for a changefeed.

ConsistentConfig represents replication consistency config for a changefeed.

ConsistentMemoryUsage represents memory usage of Consistent module.

CSVConfig defines a series of configuration items for csv codec.

DBConfig represents db sorter config.

DebeziumConfig represents the configurations for debezium protocol encoding.

DebugConfig represents config for ticdc unexposed feature configurations.

DispatchRule represents partition rule for a table.

Duration wrap time.Duration to override UnmarshalText func.

EventFilterRule is used by sql event filter and expression filter.

EventServiceConfig represents config for event service.

FilterConfig represents filter config for a changefeed.

GlueSchemaRegistryConfig represents a Glue Schema Registry configuration.

KafkaConfig represents a kafka sink configuration.

KVClientConfig represents config for kv client.

LargeMessageHandleConfig is the configuration for handling large message.

LogConfig represents log config for server.

LogFileConfig represents log file config for server.

MessagesConfig configs MessageServer and MessageClient.

MounterConfig represents mounter config for a changefeed.

MySQLConfig represents a MySQL sink configuration.

OAuth2 is the configuration for OAuth2.

OpenProtocolConfig represents the configurations for open protocol encoding.

PullerConfig represents config for puller.

PulsarConfig pulsar sink configuration.

SchedulerConfig configs TiCDC scheduler.

SchemaStoreConfig represents config for schema store.

ServerConfig represents a config for server.

SinkConfig represents sink config for a changefeed.

SorterConfig represents sorter config for a changefeed.

SyncedStatusConfig represents synced check interval config for a changefeed.

UpstreamInfo store in etcd.

AtomicityLevel represents the atomicity level of a changefeed.

DateSeparator specifies the date separator in storage destination path.

Protocol is the protocol of the message.

PulsarCompressionType is the compression type for pulsar.

ReplicaConfig represents some addition replication config for a changefeed.

TimeMill is the time in milliseconds.

TimeSec is the time in seconds.

TomlDuration is a duration with a custom json decoder and toml decoder.

UpstreamID is the type for upstream ID.