Function shard_source_descs
Source pub(crate) fn shard_source_descs<K, V, D, G>(
scope: &G,
name: &str,
client: impl Future<Output = PersistClient> + Send + 'static,
shard_id: ShardId,
as_of: Option<Antichain<G::Timestamp>>,
snapshot_mode: SnapshotMode,
until: Antichain<G::Timestamp>,
completed_fetches_stream: Stream<G, Infallible>,
chosen_worker: usize,
key_schema: Arc<K::Schema>,
val_schema: Arc<V::Schema>,
filter_fn: impl FnMut(&PartStats, AntichainRef<'_, G::Timestamp>) -> FilterResult + 'static,
listen_sleep: Option<impl Fn() -> RetryParameters + 'static>,
start_signal: impl Future<Output = ()> + 'static,
error_handler: ErrorHandler,
) -> (Stream<G, (usize, ExchangeableBatchPart<G::Timestamp>)>, PressOnDropButton)