aggregator

Documentation

Index

• func GetAggFromName(name string) func() merge.Aggregator
• func LoadAggs(fields []ast.SelectElement) map[int]func() merge.Aggregator
• type AddAggregator
  • func (s *AddAggregator) Aggregate(values []proto.Value)
  • func (s *AddAggregator) GetResult() (proto.Value, bool)
• type AvgAggregator
  • func (s *AvgAggregator) Aggregate(values []proto.Value)
  • func (s *AvgAggregator) GetResult() (proto.Value, bool)
• type MaxAggregator
  • func (s *MaxAggregator) Aggregate(values []proto.Value)
  • func (s *MaxAggregator) GetResult() (proto.Value, bool)
• type MinAggregator
  • func (s *MinAggregator) Aggregate(values []proto.Value)
  • func (s *MinAggregator) GetResult() (proto.Value, bool)

Functions

func GetAggFromName

func GetAggFromName(name string) func() merge.Aggregator

func LoadAggs

func LoadAggs(fields []ast.SelectElement) map[int]func() merge.Aggregator

Types

type AddAggregator

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

func (*AddAggregator) Aggregate

func (s *AddAggregator) Aggregate(values []proto.Value)

func (*AddAggregator) GetResult

func (s *AddAggregator) GetResult() (proto.Value, bool)

type AvgAggregator

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

func (*AvgAggregator) Aggregate

func (s *AvgAggregator) Aggregate(values []proto.Value)

func (*AvgAggregator) GetResult

func (s *AvgAggregator) GetResult() (proto.Value, bool)

type MaxAggregator

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

func (*MaxAggregator) Aggregate

func (s *MaxAggregator) Aggregate(values []proto.Value)

func (*MaxAggregator) GetResult

func (s *MaxAggregator) GetResult() (proto.Value, bool)

type MinAggregator

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

func (*MinAggregator) Aggregate

func (s *MinAggregator) Aggregate(values []proto.Value)

func (*MinAggregator) GetResult

func (s *MinAggregator) GetResult() (proto.Value, bool)