Modules§
- consistency
- duckdb 🔒
- file 🔒
- fivetran 🔒
- glue 🔒
- http 🔒
- kafka 🔒
- mysql 🔒
- nop 🔒
- persist 🔒
- postgres 🔒
- protobuf 🔒
- psql 🔒
- s3 🔒
- schema_
registry 🔒 - set 🔒
- skip_
end 🔒 - skip_if 🔒
- sleep 🔒
- sql 🔒
- sql_
server 🔒 - version_
check 🔒 - webhook 🔒
Structs§
- Background
Task 🔒 - A query spawned by
postgres-execute background=true, retained so it can be joined at the end of the file. - Catalog
Config - Configuration for the Catalog.
- Config
- User-settable configuration parameters.
- Materialize
State - Rewrite
- State
Enums§
Traits§
- Run 🔒
Functions§
- cancel_
background_ 🔒query - Best-effort cancellation of the in-progress query on the connection
cancel_tokenwas derived from. Opens a fresh connection to send the cancel request. Cancellation is inherently racy and the caller aborts the task regardless, so failures are logged rather than propagated. - create_
materialize_ 🔒state - create_
state - Initializes a
Stateobject by connecting to the various external services specified inconfig. - substitute_
vars 🔒 - Substituted
${}-delimited variables fromvarsintomsg - verify_
kafka_ 🔒topics_ exhausted