gearbox 3.0.0

Excessive tooling for Rust, boosting productivity and operations
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use crate::template::pipeline::{Pipeline, PipelineValue};
use crate::time::DateTime;
use core::any::Any;

/// A pipeline for formatting dates.
#[derive(Debug, Clone)]
pub struct PrefixPipeline {
    prefix: String,
}

unsafe impl Send for PrefixPipeline {}
unsafe impl Sync for PrefixPipeline {}

impl PrefixPipeline {
    /// Creates a new DatePipeline with a default format.
    ///
    /// # Example
    ///
    /// ```
    /// use gearbox::template::pipelines::date_time::DatePipeline;
    ///
    /// let pipeline = DatePipeline::new();
    /// ```
    pub fn new() -> Self {
        PrefixPipeline {
            prefix: String::from(""),
        }
    }
}

impl Default for PrefixPipeline {
    fn default() -> Self {
        PrefixPipeline::new()
    }
}

impl Pipeline for PrefixPipeline {
    fn format(
        &self,
        pipe_object: &Box<dyn PipelineValue + Send + Sync>,
    ) -> Box<dyn PipelineValue + Send + Sync + 'static> {
        if let Some(t) = pipe_object.as_any().downcast_ref::<String>() {
            return Box::new(format!("{}{}", self.prefix, t));
        }
        Box::new("Invalid Date".to_string())
    }

    fn options(&self, options: &str) -> Box<dyn Pipeline + Send + Sync> {
        Box::new(PrefixPipeline {
            prefix: options.to_string(),
        })
    }

    fn boxed_clone(&self) -> Box<dyn Pipeline + Send + Sync> {
        Box::new(self.clone())
    }
}