AvroNameToSQLName is the inverse of SQLNameToAvroName.

IsRetryableError returns true if the supplied error, or any of its parent causes, is a IsRetryableError.

KafkaNameToSQLName is the inverse of SQLNameToKafkaName except when SQLNameToKafkaName had to truncate.

MakeMetrics makes the metrics for changefeed monitoring.

MarkRetryableError wraps the given error, marking it as retryable to changefeeds.

MaybeStripRetryableErrorMarker performs some minimal attempt to clean the RetryableError marker out.

SQLNameToAvroName escapes a sql table name into a valid avro record or field name.

SQLNameToKafkaName escapes a sql table name into a valid kafka topic name.

Metrics are for production monitoring of changefeeds.

TestingKnobs are the testing knobs for changefeed.

Encoder turns a row into a serialized changefeed key, value, or resolved timestamp.

Sink is an abstraction for anything that a changefeed may emit into.