Versions in this module Expand all Collapse all v1 v1.7.6 Apr 16, 2019 Changes in this version + const MaxPointsPerBlock + var BooleanEmptyArrayCursor cursors.BooleanArrayCursor = &booleanEmptyArrayCursor + var ErrPartitionKeyOrder = errors.New("invalid partition key order") + var ErrSeriesKeyOrder = errors.New("invalid series key order") + var ErrStreamNoData = errors.New("peekFrame: no data") + var FloatEmptyArrayCursor cursors.FloatArrayCursor = &floatEmptyArrayCursor + var IntegerEmptyArrayCursor cursors.IntegerArrayCursor = &integerEmptyArrayCursor + var StringEmptyArrayCursor cursors.StringArrayCursor = &stringEmptyArrayCursor + var UnsignedEmptyArrayCursor cursors.UnsignedArrayCursor = &unsignedEmptyArrayCursor + func EvalExprBool(expr influxql.Expr, m Valuer) bool + func HasFieldValueKey(expr influxql.Expr) bool + func IsTrueBooleanLiteral(expr influxql.Expr) bool + func NewReader(s Store) influxdb.Reader + func NodeToExpr(node *datatypes.Node, remap map[string]string) (influxql.Expr, error) + func PredicateToExprString(p *datatypes.Predicate) string + func RewriteExprRemoveFieldValue(expr influxql.Expr) influxql.Expr + func WalkChildren(v NodeVisitor, node *datatypes.Node) + func WalkNode(v NodeVisitor, node *datatypes.Node) + type GroupCursor interface + Close func() + Cursor func() cursors.Cursor + Err func() error + Keys func() [][]byte + Next func() bool + PartitionKeyVals func() [][]byte + Stats func() cursors.CursorStats + Tags func() models.Tags + type GroupOption func(g *groupResultSet) + func GroupOptionNilSortLo() GroupOption + type GroupResultSet interface + Close func() + Err func() error + Next func() GroupCursor + func NewGroupByMergedGroupResultSet(g []GroupResultSet) GroupResultSet + func NewGroupNoneMergedGroupResultSet(g []GroupResultSet) GroupResultSet + func NewGroupResultSet(ctx context.Context, req *datatypes.ReadRequest, ...) GroupResultSet + type GroupResultSetStreamReader struct + func NewGroupResultSetStreamReader(stream StreamReader) *GroupResultSetStreamReader + func (r *GroupResultSetStreamReader) Close() + func (r *GroupResultSetStreamReader) Err() error + func (r *GroupResultSetStreamReader) Next() GroupCursor + type NodeVisitor interface + Visit func(*datatypes.Node) NodeVisitor + type ResponseStream interface + Send func(*datatypes.ReadResponse) error + SetTrailer func(metadata.MD) + type ResponseWriter struct + func NewResponseWriter(stream ResponseStream, hints datatypes.HintFlags) *ResponseWriter + func (w *ResponseWriter) Err() error + func (w *ResponseWriter) Flush() + func (w *ResponseWriter) WriteGroupResultSet(rs GroupResultSet) error + func (w *ResponseWriter) WriteResultSet(rs ResultSet) error + func (w *ResponseWriter) WrittenN() int + type ResultSet interface + Close func() + Cursor func() cursors.Cursor + Err func() error + Next func() bool + Stats func() cursors.CursorStats + Tags func() models.Tags + func NewMergedResultSet(results []ResultSet) ResultSet + func NewResultSet(ctx context.Context, req *datatypes.ReadRequest, cur SeriesCursor) ResultSet + type ResultSetStreamReader struct + func NewResultSetStreamReader(stream StreamReader) *ResultSetStreamReader + func (r *ResultSetStreamReader) Close() + func (r *ResultSetStreamReader) Cursor() cursors.Cursor + func (r *ResultSetStreamReader) Err() error + func (r *ResultSetStreamReader) Next() bool + func (r *ResultSetStreamReader) Stats() cursors.CursorStats + func (r *ResultSetStreamReader) Tags() models.Tags + type SeriesCursor interface + Close func() + Err func() error + Next func() *SeriesRow + func NewLimitSeriesCursor(ctx context.Context, cur SeriesCursor, n, o int64) SeriesCursor + type SeriesRow struct + Field string + Name []byte + Query cursors.CursorIterators + SeriesTags models.Tags + SortKey []byte + Tags models.Tags + ValueCond influxql.Expr + type StorageReadClient struct + func NewStorageReadClient(c datatypes.Storage_ReadClient) *StorageReadClient + func (rc *StorageReadClient) Recv() (res *datatypes.ReadResponse, err error) + func (rc *StorageReadClient) Stats() (stats cursors.CursorStats) + type Store interface + GetSource func(rs influxdb.ReadSpec) (proto.Message, error) + GroupRead func(ctx context.Context, req *datatypes.ReadRequest) (GroupResultSet, error) + Read func(ctx context.Context, req *datatypes.ReadRequest) (ResultSet, error) + type StreamReader interface + Recv func() (*datatypes.ReadResponse, error) + type Valuer interface + Value func(key string) (interface{}, bool)