mock

package
v1.9.5 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2021 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.