queryhandler

Documentation

Index

• func New(db *minitsdb.Database) *queryHandler
• type QueryCluster
  • func (c *QueryCluster) Execute() error
• type QueryClusterParameters
• type QueryResultWriter
• type SubQuery

Functions

func New

func New(db *minitsdb.Database) *queryHandler

Types

type QueryCluster

type QueryCluster struct {
	Parameters QueryClusterParameters
	SubQueries []*SubQuery
	TimeStart  time.Time
}

QueryCluster is used to collect multiple API queries to the same Series into a single query, which reduces load on the server

func (*QueryCluster) Execute

func (c *QueryCluster) Execute() error

type QueryClusterParameters

type QueryClusterParameters struct {
	Series   *minitsdb.Series
	Range    TimeRange
	TimeStep int64
}

QueryClusterParameters is separate struct so we can use it as a map index

type QueryResultWriter

type QueryResultWriter interface {
	Write(buffer storage.PointBuffer) error
}

type SubQuery

type SubQuery struct {
	Series  *minitsdb.Series       // the requested series
	Columns []minitsdb.QueryColumn // and columns

	// interface to the HTTP request
	Done   *sync.WaitGroup
	Cancel chan struct{}
	Sink   QueryResultWriter
}

QueryClusterReceiver