Function render

Source

pub(crate) fn render<'scope>(
    scope: Scope<'scope, GtidPartition>,
    config: RawSourceCreationConfig,
    connection: MySqlSourceConnection,
    source_outputs: Vec<SourceOutputInfo>,
    metrics: MySqlSnapshotMetrics,
) -> (StackedCollection<'scope, GtidPartition, (usize, Result<SourceMessage, DataflowError>)>, StreamVec<'scope, GtidPartition, RewindRequest>, StreamVec<'scope, GtidPartition, ReplicationError>, PressOnDropButton)

Expand description

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

render

Function render Copy item path

Function render