Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + type FloatArrayCursor struct + CloseFunc func() + Errfunc func() error + NextFunc func() *cursors.FloatArray + StatsFunc func() cursors.CursorStats + func NewFloatArrayCursor() *FloatArrayCursor + func (c *FloatArrayCursor) Close() + func (c *FloatArrayCursor) Err() error + func (c *FloatArrayCursor) Next() *cursors.FloatArray + func (c *FloatArrayCursor) Stats() cursors.CursorStats + type GroupCursor struct + CloseFunc func() + CursorFunc func() cursors.Cursor + ErrFunc func() error + KeysFunc func() [][]byte + NextFunc func() bool + PartitionKeyValsFunc func() [][]byte + StatsFunc func() cursors.CursorStats + TagsFunc func() models.Tags + func NewGroupCursor() *GroupCursor + func (c *GroupCursor) Close() + func (c *GroupCursor) Cursor() cursors.Cursor + func (c *GroupCursor) Err() error + func (c *GroupCursor) Keys() [][]byte + func (c *GroupCursor) Next() bool + func (c *GroupCursor) PartitionKeyVals() [][]byte + func (c *GroupCursor) Stats() cursors.CursorStats + func (c *GroupCursor) Tags() models.Tags + type GroupResultSet struct + CloseFunc func() + ErrFunc func() error + NextFunc func() reads.GroupCursor + func NewGroupResultSet() *GroupResultSet + func (rs *GroupResultSet) Close() + func (rs *GroupResultSet) Err() error + func (rs *GroupResultSet) Next() reads.GroupCursor + type IntegerArrayCursor struct + CloseFunc func() + Errfunc func() error + NextFunc func() *cursors.IntegerArray + StatsFunc func() cursors.CursorStats + func NewIntegerArrayCursor() *IntegerArrayCursor + func (c *IntegerArrayCursor) Close() + func (c *IntegerArrayCursor) Err() error + func (c *IntegerArrayCursor) Next() *cursors.IntegerArray + func (c *IntegerArrayCursor) Stats() cursors.CursorStats + type ResponseStream struct + SendFunc func(*datatypes.ReadResponse) error + SetTrailerFunc func(metadata.MD) + func NewResponseStream() *ResponseStream + func (s *ResponseStream) Send(r *datatypes.ReadResponse) error + func (s *ResponseStream) SetTrailer(m metadata.MD) + type ResultSet struct + CloseFunc func() + CursorFunc func() cursors.Cursor + ErrFunc func() error + NextFunc func() bool + StatsFunc func() cursors.CursorStats + TagsFunc func() models.Tags + func NewResultSet() *ResultSet + func (rs *ResultSet) Close() + func (rs *ResultSet) Cursor() cursors.Cursor + func (rs *ResultSet) Err() error + func (rs *ResultSet) Next() bool + func (rs *ResultSet) Stats() cursors.CursorStats + func (rs *ResultSet) Tags() models.Tags + type StoreReader struct + ReadFilterFunc func(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error) + ReadGroupFunc func(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error) + TagKeysFunc func(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error) + TagValuesFunc func(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error) + func NewStoreReader() *StoreReader + func (*StoreReader) GetSource(db, rp string) proto.Message + func (s *StoreReader) ReadFilter(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error) + func (s *StoreReader) ReadGroup(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error) + func (s *StoreReader) TagKeys(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error) + func (s *StoreReader) TagValues(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error)
Go to main page