mungo/aggregation

for more information, see here

Types

AggregateOption

pub type AggregateOption {
  BatchSize(Int)
  Let(List(#(String, bson.Value)))
}

Constructors

```
BatchSize(Int)
```
```
Let(List(#(String, bson.Value)))
```

Pipeline

</>

pub opaque type Pipeline

Functions

add_fields

</>

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

aggregate

</>

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

append_stage

</>

pub fn append_stage(
  pipeline: Pipeline,
  stage: #(String, Value),
) -> Pipeline

group

</>

pub fn group(
  pipeline: Pipeline,
  doc: List(#(String, 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

for more information, see here

match

</>

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

pipelined_lookup

</>

pub fn pipelined_lookup(
  pipeline: Pipeline,
  from from: String,
  define definitions: List(#(String, Value)),
  pipeline lookup_pipeline: List(List(#(String, Value))),
  alias alias: String,
) -> Pipeline

for more information, see here

project

</>

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

skip

</>

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

sort

</>

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

to_cursor

</>

pub fn to_cursor(pipeline: Pipeline) -> Result(Cursor, Error)

unwind

</>

pub fn unwind(
  pipeline: Pipeline,
  path: String,
  preserve_null_and_empty_arrays: Bool,
) -> Pipeline

unwind_with_index

</>

pub fn unwind_with_index(
  pipeline: Pipeline,
  path: String,
  index_field: String,
  preserve_null_and_empty_arrays: Bool,
) -> Pipeline