Module replication

Code to render the ingestion dataflow of a SqlServerSourceConnection.

Structs

PrometheusSqlServerCdcMetrics 🔒

Provides an implemntation of SqlServerCdcMetrics that will update SqlServerSourceMetrics`

Statics

REPL_READER 🔒

Used as a partition ID to determine the worker that is responsible for reading data from SQL Server.

Functions

handle_data_event 🔒

render 🔒

return_definite_error 🔒

Helper method to return a “definite” error upstream.

Type Aliases

StackedAsyncOutputHandle 🔒