Crate risingwave_connector

Modules§

bail_invalid_option_error
Constructs a InvalidOptionError and bails out.
bail_malformed_response_error
Constructs a MalformedResponseError and bails out.
call_method
call_static_method
dispatch_sink
dispatch_sink_formatter_impl
Macro to dispatch formatting implementation for all supported sink formatter types. Used when the message key can be either bytes or string.
dispatch_sink_formatter_str_key_impl
Macro to dispatch formatting implementation for sink formatters that require string keys. Used when the message key must be a string (excludes some Avro and bytes implementations).
dispatch_source_enum
Usage: dispatch_source_enum!(EnumType, enum_value, |inner_ident| body).
dispatch_source_enum_inner
The invocation:
dispatch_source_prop
dispatch_source_enum with ConnectorProperties as the enum type.
dispatch_split_impl
dispatch_source_enum with SplitImpl as the enum type.
for_all_classified_sources
for_all_connections
for_all_sinks
for_all_sources
for_all_sources_inner
impl_cdc_source_type
impl_connection
impl_connector_properties
impl_split
invalid_option_error
Constructs a InvalidOptionError.
malformed_response_error
Constructs a MalformedResponseError.
match_sink_name_str
match_source_name_str
Matches against SourceProperties::SOURCE_NAME to dispatch logic.
match_source_name_str_inner
only_parse_payload
paste
tri
tri! in generators yield Err and return () ? in generators return Err

WithOptionsSecResolved
Options or properties extracted from the WITH clause of DDLs.

WithPropertiesExt
Utility methods for WITH properties (HashMap and BTreeMap).