mock

package
v1.7.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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 (*IntegerArrayCursor) Stats

type ResponseStream

type ResponseStream struct {
	SendFunc       func(*datatypes.ReadResponse) error
	SetTrailerFunc func(metadata.MD)
}

func NewResponseStream

func NewResponseStream() *ResponseStream

func (*ResponseStream) Send

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 (*StoreReader) ReadGroup

func (*StoreReader) TagKeys

func (*StoreReader) TagValues

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL