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

decode 🔒

Helper method to decode a row from a tiberius::Row (or 2 of them in the case of update) to a Row. This centralizes the decode and mapping to result.

handle_data_event 🔒

render 🔒

return_definite_error 🔒

Helper method to return a “definite” error upstream.

Type Aliases

StackedAsyncOutputHandle 🔒