aggregator

Documentation

Index

• type Aggregator
  • func NewAggregator[T any](collection *mongo.Collection) *Aggregator[T]
  • func (a *Aggregator[T]) Aggregate(ctx context.Context, opts ...*options.AggregateOptions) ([]*T, error)
  • func (a *Aggregator[T]) AggregateWithParse(ctx context.Context, result any, opts ...*options.AggregateOptions) error
  • func (a *Aggregator[T]) Pipeline(pipeline any) *Aggregator[T]
• type IAggregator

Types

type Aggregator

type Aggregator[T any] struct {
	// contains filtered or unexported fields
}

func NewAggregator

func NewAggregator[T any](collection *mongo.Collection) *Aggregator[T]

func (*Aggregator[T]) Aggregate

func (a *Aggregator[T]) Aggregate(ctx context.Context, opts ...*options.AggregateOptions) ([]*T, error)

func (*Aggregator[T]) AggregateWithParse

func (a *Aggregator[T]) AggregateWithParse(ctx context.Context, result any, opts ...*options.AggregateOptions) error

AggregateWithParse is used to parse the result of the aggregation result must be a pointer to a slice

func (*Aggregator[T]) Pipeline

func (a *Aggregator[T]) Pipeline(pipeline any) *Aggregator[T]

type IAggregator

type IAggregator[T any] interface {
	Aggregate(ctx context.Context, opts ...*options.AggregateOptions) ([]*T, error)
	AggregateWithParse(ctx context.Context, result any, opts ...*options.AggregateOptions) error
}