async fn buffer_operation(&mut self, dml_operation: DmlOperation) {
        let lifecycle_handle = NoopLifecycleHandle {};

        // set up partitioner for writes
        if matches!(dml_operation, DmlOperation::Write(_)) {
            let sequence_number = SequenceNumber::new(
                dml_operation.meta().sequence().unwrap().sequence_number as i64,
            );
            self.partitioner
                .set(self.partition_keys.get(&sequence_number).unwrap().clone());
        }

        let should_pause = self
            .ingester_data
            .buffer_operation(
                self.sequencer.sequencer.id,
                dml_operation,
                &lifecycle_handle,
            )
            .await
            .unwrap();
        assert!(!should_pause);
    }
/// Buffer up [`DmlOperation`] in ingester memory.
///
/// This will never persist.
///
/// Takes `&self mut` because our partioning implementation does not work with concurrent
/// access.
Buffer up [`DmlOperation`] in ingester memory.
This will never persist.

Takes `&self mut` because our partioning implementation does not work with concurrent
access.
Buffer up [ ` DmlOperation ` ] in ingester memory . This will never persist . Takes ` &self mut ` because our partioning implementation does not work with concurrent access .
async fn buffer_operation(&mut self, dml_operation: DmlOperation) {
        let lifecycle_handle = NoopLifecycleHandle {};
        // set up partitioner for writes
        if matches!(dml_operation, DmlOperation::Write(_)) {
            let sequence_number = SequenceNumber::new(
                dml_operation.meta().sequence().unwrap().sequence_number as i64,
            );
            self.partitioner
                .set(self.partition_keys.get(&sequence_number).unwrap().clone());
        }
        let should_pause = self
            .ingester_data
            .buffer_operation(
                self.sequencer.sequencer.id,
                dml_operation,
                &lifecycle_handle,
            )
            .await
            .unwrap();
        assert!(!should_pause);
    }
async fn buffer_operation ( & mut self , dml_operation : DmlOperation ) { let lifecycle_handle = NoopLifecycleHandle { } ; // set up partitioner for writes if matches ! ( dml_operation DmlOperation Write ( ) ) { let sequence_number = SequenceNumber :: new ( dml_operation . meta ( ) . sequence ( ) . unwrap ( ) . sequence_number as i64 , ) ; self . partitioner . set ( self . partition_keys . get ( & sequence_number ) . unwrap ( ) . clone ( ) ) ; } let should_pause = self . ingester_data . buffer_operation ( self . sequencer . sequencer . id , dml_operation , & lifecycle_handle , ) . await . unwrap ( ) ; assert ! ( should_pause ) ; }
Buffer up [`DmlOperation`] in ingester memory.
Buffer up [ ` DmlOperation ` ] in ingester memory .
&mut self
dml_operation
DmlOperation
&mut self
dml_operation
DmlOperation