mock

Documentation

Index

• type GroupCursor
  • 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
  • func NewGroupResultSet() *GroupResultSet
  • func (rs *GroupResultSet) Close()
  • func (rs *GroupResultSet) Err() error
  • func (rs *GroupResultSet) Next() reads.GroupCursor
• type IntegerArrayCursor
  • 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
  • func NewResponseStream() *ResponseStream
  • func (s *ResponseStream) Send(r *datatypes.ReadResponse) error
  • func (s *ResponseStream) SetTrailer(m metadata.MD)
• type ResultSet
  • 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

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) Close

func (rs *ResultSet) Close()

func (*ResultSet) Cursor

func (rs *ResultSet) Cursor() cursors.Cursor

func (*ResultSet) Err

func (rs *ResultSet) Err() error

func (*ResultSet) Next

func (rs *ResultSet) Next() bool

func (*ResultSet) Stats

func (rs *ResultSet) Stats() cursors.CursorStats

func (*ResultSet) Tags

func (rs *ResultSet) Tags() models.Tags