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.