aggregate

Documentation

Index

• func Abs[E model.Bson](expression E) bson.D
• func Accumulator(acc *Accumulate) bson.D
• func Add(vars ...model.Variable) bson.D
• func AddToSet(variable model.StringVariable) bson.D
• func And(filters ...*filters.Filter) bson.D
• func Avg[E model.Bson](expr E) bson.D
• func Ceil(variable model.StringVariable) bson.D
• func Compare[E model.Bson](expr1, expr2 E) bson.D
• func Concat[E model.Bson](expr1, expr2 E) bson.D
• func Count() bson.D
• type Accumulate
  • func NewAccumulate(init, accumulate, merge string, accumulateArgs bson.Array, lang text.Langeuage) *Accumulate
  • func (a *Accumulate) Marshal() primitive.D
  • func (a *Accumulate) Tag()
  • func (a *Accumulate) ToMap() primitive.M
• type GraphLookup
  • func (l *GraphLookup) Marshal() bson.D
• type Lookup
  • func NewLookup(from, as string) *Lookup
  • func (l *Lookup) Join(localField, foreignField string) *Lookup
  • func (l *Lookup) Marshal() bson.D
  • func (l *Lookup) MultiJoin(let bson.M, pipeline Pipeline) *Lookup
• type Pipeline

Functions

func Abs

func Abs[E model.Bson](expression E) bson.D

func Accumulator

func Accumulator(acc *Accumulate) bson.D

func Add

func Add(vars ...model.Variable) bson.D

func AddToSet

func AddToSet(variable model.StringVariable) bson.D

func And

func And(filters ...*filters.Filter) bson.D

func Avg

func Avg[E model.Bson](expr E) bson.D

func Ceil

func Ceil(variable model.StringVariable) bson.D

func Compare

func Compare[E model.Bson](expr1, expr2 E) bson.D

func Concat

func Concat[E model.Bson](expr1, expr2 E) bson.D

func Count

func Count() bson.D

Types

type Accumulate

type Accumulate struct {
	// contains filtered or unexported fields
}

func NewAccumulate

func NewAccumulate(init, accumulate, merge string, accumulateArgs bson.Array, lang text.Langeuage) *Accumulate

func (*Accumulate) Marshal

func (a *Accumulate) Marshal() primitive.D

func (*Accumulate) Tag

func (a *Accumulate) Tag()

func (*Accumulate) ToMap

func (a *Accumulate) ToMap() primitive.M

type GraphLookup

type GraphLookup struct {
	// contains filtered or unexported fields
}

func (*GraphLookup) Marshal

func (l *GraphLookup) Marshal() bson.D

type Lookup

type Lookup struct {
	// contains filtered or unexported fields
}

func NewLookup

func NewLookup(from, as string) *Lookup

func (*Lookup) Join

func (l *Lookup) Join(localField, foreignField string) *Lookup

func (*Lookup) Marshal

func (l *Lookup) Marshal() bson.D

func (*Lookup) MultiJoin

func (l *Lookup) MultiJoin(let bson.M, pipeline Pipeline) *Lookup

type Pipeline

type Pipeline interface {
	Marshal() mongo.Pipeline
}