reads

package

Go to main page

Versions in this module

v1

v1.7.9

Oct 27, 2019

Changes in this version

type GroupResultSetStreamReader

+ func (r *GroupResultSetStreamReader) Peek()

type ResultSetStreamReader

+ func (r *ResultSetStreamReader) Peek()

v1.7.9-dev1

Jun 12, 2020

v1.7.8

Aug 20, 2019

Changes in this version

+ type MergedStringIterator struct

+ func NewMergedStringIterator(iterators []cursors.StringIterator) *MergedStringIterator

+ func (msi *MergedStringIterator) Next() bool

+ func (msi *MergedStringIterator) Stats() cursors.CursorStats

+ func (msi *MergedStringIterator) Value() string

type ResultSet

+ func NewFilteredResultSet(ctx context.Context, req *datatypes.ReadFilterRequest, cur SeriesCursor) ResultSet

+ func NewSequenceResultSet(results []ResultSet) ResultSet

type Store

+ ReadFilter func(ctx context.Context, req *datatypes.ReadFilterRequest) (ResultSet, error)

+ ReadGroup func(ctx context.Context, req *datatypes.ReadGroupRequest) (GroupResultSet, error)

+ TagKeys func(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error)

+ TagValues func(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error)

+ type StreamClient interface

+ type StringIteratorStream interface

+ Send func(*datatypes.StringValuesResponse) error

+ type StringIteratorStreamReader struct

+ func NewStringIteratorStreamReader(stream StringValuesStreamReader) *StringIteratorStreamReader

+ func (r *StringIteratorStreamReader) Err() error

+ func (r *StringIteratorStreamReader) Next() bool

+ func (r *StringIteratorStreamReader) Stats() cursors.CursorStats

+ func (r *StringIteratorStreamReader) Value() string

+ type StringIteratorWriter struct

+ func NewStringIteratorWriter(stream StringIteratorStream) *StringIteratorWriter

+ func (w *StringIteratorWriter) Err() error

+ func (w *StringIteratorWriter) Flush()

+ func (w *StringIteratorWriter) WriteStringIterator(si cursors.StringIterator) error

+ func (w *StringIteratorWriter) WrittenN() int

+ type StringValuesStreamReader interface

+ Recv func() (*datatypes.StringValuesResponse, error)

v1.7.7

Jun 26, 2019

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL