query

Documentation

Overview

Package query implement the query module for liaison and other modules to retrieve data.

Index

• func NewService(_ context.Context, streamService stream.Service, ...) (run.Unit, error)
• type PostProcessor
  • func CreateTopNPostAggregator(topN int32, aggrFunc modelv1.AggregationFunction, sort modelv1.Sort) PostProcessor

Functions

func NewService

func NewService(_ context.Context, streamService stream.Service, measureService measure.Service,
	metaService metadata.Repo, pipeline queue.Server,
) (run.Unit, error)

NewService return a new query service.

Types

type PostProcessor

type PostProcessor interface {
	Put(entityValues pbv1.EntityValues, val int64, timestampMillis uint64) error
	Val([]string) []*measurev1.TopNList
}

PostProcessor defines necessary methods for Top-N post processor with or without aggregation.

func CreateTopNPostAggregator

func CreateTopNPostAggregator(topN int32, aggrFunc modelv1.AggregationFunction, sort modelv1.Sort) PostProcessor

CreateTopNPostAggregator creates a Top-N post processor with or without aggregation.