Trait IntoInlineConnection

pub trait IntoInlineConnection<T, R: ConnectionResolver + ?Sized> {
    // Required method
    fn into_inline_connection(self, connection_resolver: R) -> T;
}

Takes ~T<ReferencedConnection> to ~T<InlinedConnection> by recursively inlining connections and resolving any referenced connections into their inlined version.

Note that this trait is overly generic.

Required Methods

fn into_inline_connection(self, connection_resolver: R) -> T

Implementors

impl<R: ConnectionResolver> IntoInlineConnection<KafkaSinkFormatType, R> for KafkaSinkFormatType<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<StorageSinkConnection, R> for StorageSinkConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<DataEncoding, R> for DataEncoding<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<GenericSourceConnection, R> for GenericSourceConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<Connection, R> for Connection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<IcebergCatalogImpl, R> for IcebergCatalogImpl<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<Tunnel, R> for Tunnel<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<IcebergSinkConnection, R> for IcebergSinkConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<KafkaSinkConnection, R> for KafkaSinkConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<KafkaSinkFormat, R> for KafkaSinkFormat<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<AvroEncoding, R> for AvroEncoding<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<SourceDataEncoding, R> for SourceDataEncoding<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<KafkaSourceConnection, R> for KafkaSourceConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<MySqlSourceConnection, R> for MySqlSourceConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<PostgresSourceConnection, R> for PostgresSourceConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<SqlServerSourceConnection, R> for SqlServerSourceConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<IngestionDescription, R> for IngestionDescription<(), ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<SourceDesc, R> for SourceDesc<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<SourceExportDataConfig, R> for SourceExportDataConfig<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<AwsConnectionReference, R> for AwsConnectionReference<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<CsrConnection, R> for CsrConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<IcebergCatalogConnection, R> for IcebergCatalogConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<KafkaBroker, R> for KafkaBroker<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<KafkaConnection, R> for KafkaConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<KafkaSaslConfig, R> for KafkaSaslConfig<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<MySqlConnection, R> for MySqlConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<PostgresConnection, R> for PostgresConnection<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<S3TablesRestIcebergCatalog, R> for S3TablesRestIcebergCatalog<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<SqlServerConnectionDetails, R> for SqlServerConnectionDetails<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<SshTunnel, R> for SshTunnel<ReferencedConnection>