Function selection 

fn selection(
    source: &PublishedSourceDescriptor,
    selection: ConsumerSourceSelection,
    pending_upgrade: Option<PendingUpgrade>,
    now: Instant,
) -> DiagnosticsSourceSelection