Documentation
¶
Index ¶
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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
Click to show internal directories.
Click to hide internal directories.