Documentation
¶
Index ¶
- type FloatArrayCursor
- type 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
- type IntegerArrayCursor
- type ResponseStream
- type ResultSet
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FloatArrayCursor ¶ added in v1.7.9
type FloatArrayCursor struct {
CloseFunc func()
Errfunc func() error
StatsFunc func() cursors.CursorStats
NextFunc func() *cursors.FloatArray
}
func NewFloatArrayCursor ¶ added in v1.7.9
func NewFloatArrayCursor() *FloatArrayCursor
func (*FloatArrayCursor) Close ¶ added in v1.7.9
func (c *FloatArrayCursor) Close()
func (*FloatArrayCursor) Err ¶ added in v1.7.9
func (c *FloatArrayCursor) Err() error
func (*FloatArrayCursor) Next ¶ added in v1.7.9
func (c *FloatArrayCursor) Next() *cursors.FloatArray
func (*FloatArrayCursor) Stats ¶ added in v1.7.9
func (c *FloatArrayCursor) Stats() cursors.CursorStats
type GroupCursor ¶
type GroupCursor struct {
NextFunc func() bool
CursorFunc func() cursors.Cursor
TagsFunc func() models.Tags
KeysFunc func() [][]byte
PartitionKeyValsFunc func() [][]byte
CloseFunc func()
ErrFunc func() error
StatsFunc func() cursors.CursorStats
}
func NewGroupCursor ¶
func NewGroupCursor() *GroupCursor
func (*GroupCursor) Close ¶
func (c *GroupCursor) Close()
func (*GroupCursor) Cursor ¶
func (c *GroupCursor) Cursor() cursors.Cursor
func (*GroupCursor) Err ¶
func (c *GroupCursor) Err() error
func (*GroupCursor) Keys ¶
func (c *GroupCursor) Keys() [][]byte
func (*GroupCursor) Next ¶
func (c *GroupCursor) Next() bool
func (*GroupCursor) PartitionKeyVals ¶
func (c *GroupCursor) PartitionKeyVals() [][]byte
func (*GroupCursor) Stats ¶
func (c *GroupCursor) Stats() cursors.CursorStats
func (*GroupCursor) Tags ¶
func (c *GroupCursor) Tags() models.Tags
type GroupResultSet ¶
type GroupResultSet struct {
NextFunc func() reads.GroupCursor
CloseFunc func()
ErrFunc func() error
}
func NewGroupResultSet ¶
func NewGroupResultSet() *GroupResultSet
func (*GroupResultSet) Close ¶
func (rs *GroupResultSet) Close()
func (*GroupResultSet) Err ¶
func (rs *GroupResultSet) Err() error
func (*GroupResultSet) Next ¶
func (rs *GroupResultSet) Next() reads.GroupCursor
type IntegerArrayCursor ¶
type IntegerArrayCursor struct {
CloseFunc func()
Errfunc func() error
StatsFunc func() cursors.CursorStats
NextFunc func() *cursors.IntegerArray
}
func NewIntegerArrayCursor ¶
func NewIntegerArrayCursor() *IntegerArrayCursor
func (*IntegerArrayCursor) Close ¶
func (c *IntegerArrayCursor) Close()
func (*IntegerArrayCursor) Err ¶
func (c *IntegerArrayCursor) Err() error
func (*IntegerArrayCursor) Next ¶
func (c *IntegerArrayCursor) Next() *cursors.IntegerArray
func (*IntegerArrayCursor) Stats ¶
func (c *IntegerArrayCursor) Stats() cursors.CursorStats
type ResponseStream ¶
type ResponseStream struct {
SendFunc func(*datatypes.ReadResponse) error
SetTrailerFunc func(metadata.MD)
}
func NewResponseStream ¶
func NewResponseStream() *ResponseStream
func (*ResponseStream) Send ¶
func (s *ResponseStream) Send(r *datatypes.ReadResponse) error
func (*ResponseStream) SetTrailer ¶
func (s *ResponseStream) SetTrailer(m metadata.MD)
type ResultSet ¶
type ResultSet struct {
NextFunc func() bool
CursorFunc func() cursors.Cursor
TagsFunc func() models.Tags
CloseFunc func()
ErrFunc func() error
StatsFunc func() cursors.CursorStats
}
func NewResultSet ¶
func NewResultSet() *ResultSet
func (*ResultSet) Stats ¶
func (rs *ResultSet) Stats() cursors.CursorStats
type StoreReader ¶ added in v1.7.9
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 ¶ added in v1.7.9
func NewStoreReader() *StoreReader
func (*StoreReader) GetSource ¶ added in v1.7.9
func (*StoreReader) GetSource(db, rp string) proto.Message
func (*StoreReader) ReadFilter ¶ added in v1.7.9
func (s *StoreReader) ReadFilter(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error)
func (*StoreReader) ReadGroup ¶ added in v1.7.9
func (s *StoreReader) ReadGroup(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error)
func (*StoreReader) TagKeys ¶ added in v1.7.9
func (s *StoreReader) TagKeys(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error)
func (*StoreReader) TagValues ¶ added in v1.7.9
func (s *StoreReader) TagValues(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error)
Click to show internal directories.
Click to hide internal directories.