/// Simulates what the router would do when it encouters the given delete predicate.
Simulates what the router would do when it encouters the given delete predicate.
Simulates what the router would do when it encouters the given delete predicate .
async fn simulate_delete_routing(
        &mut self,
        delete_table_name: &str,
        predicate: DeletePredicate,
    ) -> DmlOperation {
        // ensure that table for deletions is also present in the catalog
        self.ns.create_table(delete_table_name).await;
        let sequence_number = self.next_sequence_number();
        let meta = DmlMeta::sequenced(
            Sequence::new(self.sequencer.sequencer.id.get() as u32, sequence_number),
            self.catalog.time_provider().now(),
            None,
            0,
        );
        DmlOperation::Delete(DmlDelete::new(
            self.ns.namespace.name.clone(),
            predicate,
            Some(NonEmptyString::new(delete_table_name).unwrap()),
            meta,
        ))
    }
async fn simulate_delete_routing ( & mut self , delete_table_name : & str , predicate : DeletePredicate , ) -> DmlOperation { // ensure that table for deletions is also present in the catalog self . ns . create_table ( delete_table_name ) . await ; let sequence_number = self . next_sequence_number ( ) ; let meta = DmlMeta :: sequenced ( Sequence :: new ( self . sequencer . sequencer . id . get ( ) as u32 , sequence_number ) , self . catalog . time_provider ( ) . now ( ) , None , 0 , ) ; DmlOperation :: Delete ( DmlDelete :: new ( self . ns . namespace . name . clone ( ) , predicate , Some ( NonEmptyString :: new ( delete_table_name ) . unwrap ( ) ) , meta , ) ) }
Simulates what the router would do when it encouters the given delete predicate.
Simulates what the router would do when it encouters the given delete predicate .
&mut self
delete_table_name
&str
predicate
DeletePredicate