GetDefaultReplicaConfig returns a default ReplicaConfig.

NewMockAPIV2Helpers creates a new mock instance.

NewOpenAPIV2 creates a new OpenAPIV2.

NewOpenAPIV2ForTest creates a new OpenAPIV2.

RegisterOpenAPIV2Routes registers routes for OpenAPI.

ToAPIEventFilterRule converts *config.EventFilterRule to API EventFilterRule.

ToAPIReplicaConfig coverts *config.ReplicaConfig into *v2.ReplicaConfig.

RegisterImportTaskPrefix denotes the key prefix associated with the entries containning import/restore information in the embedded Etcd of the upstream PD.

APIV2HelpersImpl is an implementation of AVIV2Helpers interface.

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.

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.

MockAPIV2Helpers is a mock of APIV2Helpers interface.

MockAPIV2HelpersMockRecorder is the mock recorder for MockAPIV2Helpers.

MounterConfig represents mounter config for a changefeed.

MySQLConfig represents a MySQL sink configuration.

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.

APIV2Helpers is a collections of helper functions of OpenAPIV2.

Liveness is the liveness status of a capture.