Function dataflow::render::sources::get_persist_config[][src]

fn get_persist_config(
    source_id: &SourceInstanceId,
    persist_desc: SourcePersistDesc,
    persist_client: &mut RuntimeClient
) -> PersistentSourceConfig<Result<Row, DecodeError>, Result<Row, DecodeError>, SourceTimestamp, AssignedTimestamp>