pipe

Documentation

Index

• type DocGroupId
• type Pipeline
  • func (p *Pipeline) Count(target string) *Pipeline
  • func (p *Pipeline) Documents(docs []any) *Pipeline
  • func (p *Pipeline) GraphLookup(join *aggregate.GraphLookup) *Pipeline
  • func (p *Pipeline) Group(id groupId, fields ...model.Pair[bson.M]) *Pipeline
  • func (p *Pipeline) Limit(value int64) *Pipeline
  • func (p *Pipeline) Lookup(join *aggregate.Lookup) *Pipeline
  • func (p *Pipeline) Marshal() mongo.Pipeline
  • func (p *Pipeline) Match(match *filters.Filter) *Pipeline
  • func (p *Pipeline) Project(fields ...model.Pair[bool]) *Pipeline
  • func (p *Pipeline) Sort(sort *sorts.SortOptions) *Pipeline
  • func (p *Pipeline) Unset(fields ...string) *Pipeline
• type StringGroupId

Types

type DocGroupId

type DocGroupId bson.D

type Pipeline

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

func (*Pipeline) Count

func (p *Pipeline) Count(target string) *Pipeline

func (*Pipeline) Documents

func (p *Pipeline) Documents(docs []any) *Pipeline

func (*Pipeline) GraphLookup

func (p *Pipeline) GraphLookup(join *aggregate.GraphLookup) *Pipeline

func (*Pipeline) Group

func (p *Pipeline) Group(id groupId, fields ...model.Pair[bson.M]) *Pipeline

func (*Pipeline) Limit

func (p *Pipeline) Limit(value int64) *Pipeline

func (*Pipeline) Lookup

func (p *Pipeline) Lookup(join *aggregate.Lookup) *Pipeline

func (*Pipeline) Marshal

func (p *Pipeline) Marshal() mongo.Pipeline

func (*Pipeline) Match

func (p *Pipeline) Match(match *filters.Filter) *Pipeline

func (*Pipeline) Project

func (p *Pipeline) Project(fields ...model.Pair[bool]) *Pipeline

func (*Pipeline) Sort

func (p *Pipeline) Sort(sort *sorts.SortOptions) *Pipeline

func (*Pipeline) Unset

func (p *Pipeline) Unset(fields ...string) *Pipeline

type StringGroupId

type StringGroupId string