readservice

Documentation

Index

• func NewProxyQueryService(queryController *control.Controller) query.ProxyQueryService
• func NewStore(viewer Viewer) reads.Store
• type Viewer

Functions

func NewProxyQueryService

func NewProxyQueryService(queryController *control.Controller) query.ProxyQueryService

NewProxyQueryService returns a proxy query service based on the given queryController suitable for the storage read service.

func NewStore

func NewStore(viewer Viewer) reads.Store

NewStore creates a store used to query time-series data.

Types

type Viewer

type Viewer interface {
	CreateCursorIterator(ctx context.Context) (tsdb.CursorIterator, error)
	CreateSeriesCursor(ctx context.Context, req storage.SeriesCursorRequest, cond influxql.Expr) (storage.SeriesCursor, error)
	TagKeys(ctx context.Context, orgID, bucketID influxdb.ID, start, end int64, predicate influxql.Expr) (cursors.StringIterator, error)
	TagValues(ctx context.Context, orgID, bucketID influxdb.ID, tagKey string, start, end int64, predicate influxql.Expr) (cursors.StringIterator, error)
}

Viewer is used by the store to query data from time-series files.