chewdata 3.6.1

Extract Transform and Load data
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

pub mod scan;

use self::scan::Scan;
use crate::connector::psql::Psql;
use serde::{Deserialize, Serialize};
use std::io::Result;

#[derive(Debug, Deserialize, Serialize, Clone)]
#[serde(tag = "type")]
pub enum CounterType {
    #[serde(alias = "scan")]
    #[serde(skip_serializing)]
    Scan(Scan),
}

impl Default for CounterType {
    fn default() -> Self {
        CounterType::Scan(Scan::default())
    }
}

impl CounterType {
    pub async fn count(&self, connector: &Psql) -> Result<usize> {
        match self {
            CounterType::Scan(scan) => scan.count(connector).await,
        }
    }
}