mongodb-aggregations 0.1.0

A library for building MongoDB aggregations pipelines in Rust
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

use crate::stages::PipelineStage;
use bson::Document;

pub struct Pipeline {
    pub stages: Vec<Document>,
    names: Vec<&'static str>,
}

impl Pipeline {
    pub fn builder() -> Self {
        Pipeline { stages: Vec::new(), names: Vec::new() }
    }

    pub fn add_stage<T>(&mut self, stage: T)
    where
        T: PipelineStage,
    {
        self.names.push(T::NAME);
        self.stages.push(stage.into());
    }

    pub fn build(self) -> Vec<Document> {
        self.stages
    }
}