package mock

import "github.com/influxdata/influxdb/mock"

Index

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
	AggregateFunc        func() *datatypes.Aggregate
}

func NewGroupCursor 

func NewGroupCursor() *GroupCursor

func (*GroupCursor) Aggregate 

func (c *GroupCursor) Aggregate() *datatypes.Aggregate

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 Reader 

type Reader struct {
	ReadFilterFn          func(ctx context.Context, spec influxdb.ReadFilterSpec, alloc memory.Allocator) (influxdb.TableIterator, error)
	ReadGroupFn           func(ctx context.Context, spec influxdb.ReadGroupSpec, alloc memory.Allocator) (influxdb.TableIterator, error)
	ReadTagKeysFn         func(ctx context.Context, spec influxdb.ReadTagKeysSpec, alloc memory.Allocator) (influxdb.TableIterator, error)
	ReadTagValuesFn       func(ctx context.Context, spec influxdb.ReadTagValuesSpec, alloc memory.Allocator) (influxdb.TableIterator, error)
	ReadWindowAggregateFn func(ctx context.Context, spec influxdb.ReadWindowAggregateSpec, alloc memory.Allocator) (influxdb.TableIterator, error)
	CloseFn               func()
}

Reader is a mock implementation of flux/stdlib/influxdata/influxdb.Reader

func (Reader) Close 

func (m Reader) Close()

func (Reader) ReadFilter 

func (m Reader) ReadFilter(ctx context.Context, spec influxdb.ReadFilterSpec, alloc memory.Allocator) (influxdb.TableIterator, error)

func (Reader) ReadGroup 

func (m Reader) ReadGroup(ctx context.Context, spec influxdb.ReadGroupSpec, alloc memory.Allocator) (influxdb.TableIterator, error)

func (Reader) ReadTagKeys 

func (m Reader) ReadTagKeys(ctx context.Context, spec influxdb.ReadTagKeysSpec, alloc memory.Allocator) (influxdb.TableIterator, error)

func (Reader) ReadTagValues 

func (m Reader) ReadTagValues(ctx context.Context, spec influxdb.ReadTagValuesSpec, alloc memory.Allocator) (influxdb.TableIterator, error)

func (Reader) ReadWindowAggregate 

func (m Reader) ReadWindowAggregate(ctx context.Context, spec influxdb.ReadWindowAggregateSpec, alloc memory.Allocator) (influxdb.TableIterator, error)

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)
	WindowAggregateFunc func(ctx context.Context, req *datatypes.ReadWindowAggregateRequest) (reads.ResultSet, 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)

func (*StoreReader) WindowAggregate 

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

type Writer 

type Writer struct {
}

func (*Writer) WritePointsInto 

func (w *Writer) WritePointsInto(request *coordinator.IntoWriteRequest) error

Source Files

flux.go storage_reads.go

Version
v1.12.0 (latest)
Published
Apr 8, 2025
Platform
linux/amd64
Imports
11 packages
Last checked
2 days ago –

Tools for package owners.