mongo/aggregation

Types

AggregateOption

pub type AggregateOption {
  BatchSize(Int)
  Let(value.Value)
}

Constructors

```
BatchSize(Int)
```
```
Let(value.Value)
```

Pipeline

</>

pub opaque type Pipeline

Functions

add_fields

</>

pub fn add_fields(pipeline: Pipeline, doc: Value) -> Pipeline

aggregate

</>

pub fn aggregate(collection: Collection, options: List(
    AggregateOption,
  )) -> Pipeline

exec

</>

pub fn exec(pipeline: Pipeline) -> Result(Cursor, MongoError)

group

</>

pub fn group(pipeline: Pipeline, doc: Value) -> Pipeline

limit

</>

pub fn limit(pipeline: Pipeline, count: Int) -> Pipeline

lookup

</>

pub fn lookup(pipeline: Pipeline, from from: String, local_field local_field: String, foreign_field foreign_field: String, alias alias: String) -> Pipeline

match

</>

pub fn match(pipeline: Pipeline, doc: Value) -> Pipeline

project

</>

pub fn project(pipeline: Pipeline, doc: Value) -> Pipeline

skip

</>

pub fn skip(pipeline: Pipeline, count: Int) -> Pipeline

sort

</>

pub fn sort(pipeline: Pipeline, doc: Value) -> Pipeline

stages

</>

pub fn stages(pipeline: Pipeline, docs: List(Value)) -> Pipeline