Trait mz_storage_client::types::connections::inline::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<KafkaSinkFormat<InlinedConnection>, R> for KafkaSinkFormat<ReferencedConnection>

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

impl<R: ConnectionResolver> IntoInlineConnection<StorageSinkConnectionBuilder<InlinedConnection>, R> for StorageSinkConnectionBuilder<ReferencedConnection>

impl<R: ConnectionResolver> IntoInlineConnection<DataEncodingInner<InlinedConnection>, R> for DataEncodingInner<ReferencedConnection>

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

impl<R: ConnectionResolver> IntoInlineConnection<SourceDataEncodingInner<InlinedConnection>, R> for SourceDataEncodingInner<ReferencedConnection>

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

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

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

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

impl<R: ConnectionResolver> IntoInlineConnection<KafkaSinkConnectionBuilder<InlinedConnection>, R> for KafkaSinkConnectionBuilder<ReferencedConnection>

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

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

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

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

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

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

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

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

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

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

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