mock

package
v1.11.1 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2023 License: MIT Imports: 11 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FloatArrayCursor added in v1.7.9 

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

func NewFloatArrayCursor added in v1.7.9 

func NewFloatArrayCursor() *FloatArrayCursor

func (*FloatArrayCursor) Close added in v1.7.9 

func (c *FloatArrayCursor) Close()

func (*FloatArrayCursor) Err added in v1.7.9 

func (c *FloatArrayCursor) Err() error

func (*FloatArrayCursor) Next added in v1.7.9 

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

func (*FloatArrayCursor) Stats added in v1.7.9 

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 added in v1.9.0 

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 added in v1.8.4 

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 added in v1.8.4 

func (m Reader) Close()

func (Reader) ReadFilter added in v1.8.4 

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

func (Reader) ReadGroup added in v1.8.4 

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

func (Reader) ReadTagKeys added in v1.8.4 

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

func (Reader) ReadTagValues added in v1.8.4 

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

func (Reader) ReadWindowAggregate added in v1.9.0 

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 added in v1.7.9 

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 added in v1.7.9 

func NewStoreReader() *StoreReader

func (*StoreReader) GetSource added in v1.7.9 

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

func (*StoreReader) ReadFilter added in v1.7.9 

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

func (*StoreReader) ReadGroup added in v1.7.9 

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

func (*StoreReader) TagKeys added in v1.7.9 

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

func (*StoreReader) TagValues added in v1.7.9 

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

func (*StoreReader) WindowAggregate added in v1.9.0 

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

type Writer added in v1.9.0 

type Writer struct {
}

func (*Writer) WritePointsInto added in v1.9.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.