Function mz_storage::source::mysql::replication::render

source ยท
pub(crate) fn render<G: Scope<Timestamp = GtidPartition>>(
    scope: G,
    config: RawSourceCreationConfig,
    connection: MySqlSourceConnection,
    source_outputs: Vec<SourceOutputInfo>,
    rewind_stream: &Stream<G, RewindRequest>,
    metrics: MySqlSourceMetrics,
) -> (StackedCollection<G, (usize, Result<SourceMessage, DataflowError>)>, Stream<G, Infallible>, Stream<G, ReplicationError>, PressOnDropButton)
Expand description

Renders the replication dataflow. See the module documentation for more information.