getdozer / dozer / 5354609869

5354609869

Pull #1672

github

web-flow 
Merge 6cf1be0fb into 83dc51225
Pull Request #1672: feat: pg tls config connectivity

213 of 213 new or added lines in 7 files covered. (100.0%)

39666 of 53621 relevant lines covered (73.97%)

24400.87 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

71.43
/dozer-sql/src/pipeline/product/table/processor.rs
1 
use dozer_core::channels::ProcessorChannelForwarder;
2 
use dozer_core::epoch::Epoch;
3 
use dozer_core::node::{PortHandle, Processor};
4 
use dozer_core::DEFAULT_PORT_HANDLE;
5 
use dozer_types::errors::internal::BoxedError;
6 
use dozer_types::types::Operation;
7 









8



#[derive(Debug)]




×







9



pub struct TableProcessor {










10



    _id: String,










11



}










12






×







13



impl TableProcessor {




×







14



    pub fn new(id: String) -> Self {




249✔





15



        Self { _id: id }




249✔





16



    }




249✔





17



}










18






×







19



impl Processor for TableProcessor {




×







20



    fn commit(&self, _epoch: &Epoch) -> Result<(), BoxedError> {




249✔





21



        Ok(())




249✔





22



    }




249✔





23






×







24



    fn process(




13,488✔





25



        &mut self,




13,488✔





26



        _from_port: PortHandle,




13,488✔





27



        op: Operation,




13,488✔





28



        fw: &mut dyn ProcessorChannelForwarder,




13,488✔





29



    ) -> Result<(), BoxedError> {




13,488✔





30



        fw.send(op, DEFAULT_PORT_HANDLE);




13,488✔





31



        Ok(())




13,488✔





32



    }




13,488✔





33



}
























    

  • 

    •