package
9.0.0-beta.1.pre+incompatible
Repository: https://github.com/pingcap/ticdc.git
Documentation: pkg.go.dev

# Functions

GetDefaultReplicaConfig returns a default ReplicaConfig.
NewOpenAPIV2 creates a new OpenAPIV2.
RegisterOpenAPIV2Routes registers routes for OpenAPI.
ToAPIEventFilterRule converts *config.EventFilterRule to API EventFilterRule.
ToAPIReplicaConfig coverts *config.ReplicaConfig into *v2.ReplicaConfig.

# Structs

Capture holds common information of a capture in cdc.
ChangefeedCommonInfo holds some common usage information of a changefeed.
ChangefeedConfig use by create changefeed api.
ChangeFeedInfo describes the detail of a ChangeFeed.
ChangefeedSchedulerConfig is per changefeed scheduler settings.
ChangefeedStatus holds common information of a changefeed in cdc.
CloudStorageConfig represents a cloud storage sink configuration.
CodecConfig represents a MQ codec configuration.
ColumnSelector represents a column selector for a table.
ConsistentConfig represents replication consistency config for a changefeed This is a duplicate of config.ConsistentConfig.
ConsistentMemoryUsage represents memory usage of Consistent module.
CSVConfig denotes the csv config This is the same as config.CSVConfig.
DebeziumConfig represents the configurations for debezium protocol encoding.
No description provided by the author
DispatchRule represents partition rule for a table This is a duplicate of config.DispatchRule.
EmptyResponse return empty {} to http client.
EtcdData contains key/value pair of etcd data.
EventFilterRule is used by sql event filter and expression filter.
FilterConfig represents filter config for a changefeed This is a duplicate of config.FilterConfig.
GlueSchemaRegistryConfig represents a glue schema registry configuration.
IntegrityConfig is the config for integrity check This is a duplicate of Integrity.Config.
JSONDuration used to wrap duration into json format.
KafkaConfig represents a kafka sink configuration.
LargeMessageHandleConfig denotes the large message handling config This is the same as config.LargeMessageHandleConfig.
ListResponse is the response for all List APIs.
LogLevelReq log level request.
MounterConfig represents mounter config for a changefeed.
MySQLConfig represents a MySQL sink configuration.
No description provided by the author
OpenAPIV2 provides CDC v2 APIs.
OpenProtocolConfig represents the configurations for open protocol encoding.
PDConfig is a configuration used to connect to pd.
ProcessorCommonInfo holds the common info of a processor.
ProcessorDetail holds the detail info of a processor.
PulsarConfig represents a pulsar sink configuration.
PulsarOAuth2 is the configuration for OAuth2.
ReplicaConfig is a duplicate of config.ReplicaConfig.
ResolveLockReq contains request parameter to resolve lock.
ResumeChangefeedConfig is used by resume changefeed api.
RunningError represents some running error from cdc components, such as processor.
ServerStatus holds some common information of a server.
SinkConfig represents sink config for a changefeed This is a duplicate of config.SinkConfig.
SyncedStatus describes the detail of a changefeed's synced status.
SyncedStatusConfig represents synced check interval config for a changefeed.
Table represents a qualified table name.
TableName contains table information.
Tables contains IneligibleTables and EligibleTables.
Tso contains timestamp get from PD.
UpstreamConfig contains info to connect to pd.
VerifyTableConfig use to verify tables.

# Type aliases

Liveness is the liveness status of a capture.