module Mongo::Commands::Aggregate


Performs aggregation operation using the aggregation pipeline. The pipeline allows users to process data from a collection or other source with a sequence of stage-based manipulations.

NOTE for more details, please check the official MongoDB documentation.

Extended Modules

Defined in:


Class Method Summary

Instance Method Summary

Class Method Detail

def #

Instance Method Detail

def command(database : String, collection : Collection::CollectionKey, pipeline : Array, options = nil) #

Returns a pair of OP_MSG body and sequences associated with the command and arguments.

def may_use_secondary?(**args) #

def result(bson : BSON) #

Transforms the server result.

def retryable?(**args) #

def write_command?(**args) #