pub(crate) fn render<'scope>(
scope: Scope<'scope, GtidPartition>,
config: RawSourceCreationConfig,
connection: MySqlSourceConnection,
source_outputs: Vec<SourceOutputInfo>,
rewind_stream: StreamVec<'scope, GtidPartition, RewindRequest>,
metrics: MySqlSourceMetrics,
) -> (StackedCollection<'scope, GtidPartition, (usize, Result<SourceMessage, DataflowError>)>, StreamVec<'scope, GtidPartition, ReplicationError>, PressOnDropButton)Expand description
Renders the replication dataflow. See the module documentation for more information.