mock

Documentation

Index

• type FloatArrayCursor
  • 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
  • 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
• type StoreReader
  • 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)

Types

type FloatArrayCursor

type FloatArrayCursor struct {
	CloseFunc func()
	Errfunc   func() error
	StatsFunc func() cursors.CursorStats
	NextFunc  func() *cursors.FloatArray
}

func NewFloatArrayCursor

func NewFloatArrayCursor() *FloatArrayCursor

func (*FloatArrayCursor) Close

func (c *FloatArrayCursor) Close()

func (*FloatArrayCursor) Err

func (c *FloatArrayCursor) Err() error

func (*FloatArrayCursor) Next

func (c *FloatArrayCursor) Next() *cursors.FloatArray

func (*FloatArrayCursor) Stats

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

type StoreReader

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

func NewStoreReader() *StoreReader

func (*StoreReader) GetSource

func (*StoreReader) GetSource(db, rp string) proto.Message

func (*StoreReader) ReadFilter

func (s *StoreReader) ReadFilter(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error)

func (*StoreReader) ReadGroup

func (s *StoreReader) ReadGroup(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error)

func (*StoreReader) TagKeys

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

func (*StoreReader) TagValues

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