cdc

type CDCConnector struct {
	SinkURI *url.URL
	// contains filtered or unexported fields
}

type CSVConfig struct {
	Quote           string `json:"quote"`
	IncludeCommitTs bool   `json:"include_commit_ts"`
}

type ChangefeedConfig struct {
	ReplicaConfig *ReplicaConfig `json:"replica_config"`
	SinkURI       string         `json:"sink_uri"`
	StartTs       uint64         `json:"start_ts"`
}

type CloudStorageConfig struct {
	OutputColumnID *bool `json:"output_column_id,omitempty"`
}

type FilterConfig struct {
	Rules []string `json:"rules,omitempty"`
}

type ReplicaConfig struct {
	EnableOldValue bool          `json:"enable_old_value"`
	Filter         *FilterConfig `json:"filter"`
	Sink           *SinkConfig   `json:"sink"`
}

type SinkConfig struct {
	CSVConfig          *CSVConfig          `json:"csv,omitempty"`
	CloudStorageConfig *CloudStorageConfig `json:"cloud_storage_config,omitempty"`
	DateSeparator      string              `json:"date_separator,omitempty"`
}

type SinkURIConfig struct {
	// contains filtered or unexported fields
}