aggregator

Documentation

Index

• type Aggregator
  • func NewAggregator[T any](collection *mongo.Collection, dbCallbacks *callback.Callback, ...) *Aggregator[T]
  • func (a *Aggregator[T]) Aggregate(ctx context.Context, opts ...options.Lister[options.AggregateOptions]) ([]*T, error)
  • func (a *Aggregator[T]) AggregateWithParse(ctx context.Context, result any, ...) error
  • func (a *Aggregator[T]) ModelHook(modelHook any) *Aggregator[T]
  • func (a *Aggregator[T]) Pipeline(pipeline any) *Aggregator[T]
  • func (a *Aggregator[T]) RegisterAfterHooks(hooks ...afterHookFn) *Aggregator[T]
  • func (a *Aggregator[T]) RegisterBeforeHooks(hooks ...beforeHookFn) *Aggregator[T]
• type IAggregator
• type OpContext
  • func NewOpContext(col *mongo.Collection, pipeline any, opts ...OpContextOption) *OpContext
• type OpContextOption
  • func WithFields(fields []*field.Filed) OpContextOption
  • func WithModelHook(modelHook any) OpContextOption
  • func WithMongoOptions(mongoOptions any) OpContextOption
  • func WithResult(result any) OpContextOption
  • func WithStartTime(startTime time.Time) OpContextOption

Types

type Aggregator

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

func NewAggregator

func NewAggregator[T any](collection *mongo.Collection, dbCallbacks *callback.Callback, fields []*field.Filed) *Aggregator[T]

func (*Aggregator[T]) Aggregate

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

func (*Aggregator[T]) AggregateWithParse

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

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

func (*Aggregator[T]) ModelHook

func (a *Aggregator[T]) ModelHook(modelHook any) *Aggregator[T]

func (*Aggregator[T]) Pipeline

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

func (*Aggregator[T]) RegisterAfterHooks

func (a *Aggregator[T]) RegisterAfterHooks(hooks ...afterHookFn) *Aggregator[T]

func (*Aggregator[T]) RegisterBeforeHooks

func (a *Aggregator[T]) RegisterBeforeHooks(hooks ...beforeHookFn) *Aggregator[T]

type IAggregator

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

type OpContext

type OpContext struct {
	Col      *mongo.Collection `opt:"-"`
	Pipeline any               `opt:"-"`

	Fields []*field.Filed

	MongoOptions any
	ModelHook    any
	StartTime    time.Time

	Result any
}

func NewOpContext

func NewOpContext(col *mongo.Collection, pipeline any, opts ...OpContextOption) *OpContext

type OpContextOption

type OpContextOption func(*OpContext)

func WithFields

func WithFields(fields []*field.Filed) OpContextOption

func WithModelHook

func WithModelHook(modelHook any) OpContextOption

func WithMongoOptions

func WithMongoOptions(mongoOptions any) OpContextOption

func WithResult

func WithResult(result any) OpContextOption

func WithStartTime

func WithStartTime(startTime time.Time) OpContextOption