Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Unmarshal ¶
func Unmarshal(input jsoniter.RawMessage) (expression.Expr, error)
Unmarshal to unmarshal an aggregation object.
func UnmarshalAggObject ¶
func UnmarshalAggObject(input jsoniter.RawMessage) (expression.Expr, error)
UnmarshalAggObject unmarshal the input to the aggregation. Note the return after the first check, this is mainly because an aggregation object can have nested objects but top level it will be one expression.
Types ¶
type AccumulatorFactory ¶
type AccumulatorFactory struct {
Avg *AccumulatorOp `json:"$avg,omitempty"`
Min *AccumulatorOp `json:"$min,omitempty"`
Max *AccumulatorOp `json:"$max,omitempty"`
Sum *AccumulatorOp `json:"$sum,omitempty"`
}
AccumulatorFactory to return the object of the accumulator type.
func (*AccumulatorFactory) Get ¶
func (a *AccumulatorFactory) Get() Aggregation
type AccumulatorOp ¶
type AccumulatorOp struct {
Type string
Agg expression.Expr
}
AccumulatorOp is a type of aggregation that can also be use in the group by to group values into subsets.
func (*AccumulatorOp) Apply ¶
func (*AccumulatorOp) Apply(_ jsoniter.RawMessage)
func (*AccumulatorOp) String ¶
func (a *AccumulatorOp) String() string
func (*AccumulatorOp) UnmarshalJSON ¶
func (a *AccumulatorOp) UnmarshalJSON(input []byte) error
type Aggregation ¶
type Aggregation interface {
Apply(document jsoniter.RawMessage)
}
Aggregation operators either can pass a single expression or an array of expression. The below is an example of how a caller can pass aggregation,
{ $aggregation: <expression> }
OR
{ $aggregation: [ <expression1>, <expression2> ... ] }
As an example, for sum across two fields the grammar would be,
{
"$sum": {
"$multiply": ["$price", "$quantity"]
}
}
More examples,
{
"$sum": "$qty"
}
{ "$sum": [ "$final", "$midterm" ] }}.
type ArithmeticFactory ¶
type ArithmeticFactory struct {
Add *ArithmeticOp `json:"$add,omitempty"`
Multiply *ArithmeticOp `json:"$multiply,omitempty"`
}
ArithmeticFactory to return the object of the arithmeticOp type.
func (*ArithmeticFactory) Get ¶
func (a *ArithmeticFactory) Get() Aggregation
type ArithmeticOp ¶
type ArithmeticOp struct {
Type string
Agg expression.Expr
}
func (*ArithmeticOp) Apply ¶
func (*ArithmeticOp) Apply(_ jsoniter.RawMessage)
func (*ArithmeticOp) String ¶
func (a *ArithmeticOp) String() string
func (*ArithmeticOp) UnmarshalJSON ¶
func (a *ArithmeticOp) UnmarshalJSON(input []byte) error
Source Files