Module action

Source

Modulesยง

consistency
file ๐Ÿ”’
fivetran ๐Ÿ”’
http ๐Ÿ”’
kafka ๐Ÿ”’
mysql ๐Ÿ”’
nop ๐Ÿ”’
persist ๐Ÿ”’
postgres ๐Ÿ”’
protobuf ๐Ÿ”’
psql ๐Ÿ”’
s3 ๐Ÿ”’
schema_registry ๐Ÿ”’
set ๐Ÿ”’
skip_end ๐Ÿ”’
skip_if ๐Ÿ”’
sleep ๐Ÿ”’
sql ๐Ÿ”’
sql_server ๐Ÿ”’
version_check ๐Ÿ”’
webhook ๐Ÿ”’

Structsยง

CatalogConfig
Configuration for the Catalog.
Config
User-settable configuration parameters.
MaterializeState
Rewrite
State

Enumsยง

ControlFlow

Traitsยง

Run ๐Ÿ”’

Functionsยง

create_materialize_state ๐Ÿ”’
create_state
Initializes a State object by connecting to the various external services specified in config.
substitute_vars ๐Ÿ”’
Substituted ${}-delimited variables from vars into msg