Documentation ¶
Index ¶
- type ArrayCursorMock
- type AuthorizerMock
- func (a *AuthorizerMock) AuthorizeDatabase(p influxql.Privilege, name string) bool
- func (a *AuthorizerMock) AuthorizeQuery(database string, query *influxql.Query) error
- func (a *AuthorizerMock) AuthorizeSeriesRead(database string, measurement []byte, tags models.Tags) bool
- func (a *AuthorizerMock) AuthorizeSeriesWrite(database string, measurement []byte, tags models.Tags) bool
- type BooleanArrayCursorMock
- type FloatArrayCursorMock
- type IntegerArrayCursorMock
- type MetaClientMock
- func (c *MetaClientMock) AdminUserExists() bool
- func (c *MetaClientMock) Authenticate(username, password string) (meta.User, error)
- func (c *MetaClientMock) Close() error
- func (c *MetaClientMock) CreateContinuousQuery(database, name, query string) error
- func (c *MetaClientMock) CreateDatabase(name string) (*meta.DatabaseInfo, error)
- func (c *MetaClientMock) CreateDatabaseWithRetentionPolicy(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)
- func (c *MetaClientMock) CreateRetentionPolicy(database string, spec *meta.RetentionPolicySpec, makeDefault bool) (*meta.RetentionPolicyInfo, error)
- func (c *MetaClientMock) CreateShardGroup(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)
- func (c *MetaClientMock) CreateSubscription(database, rp, name, mode string, destinations []string) error
- func (c *MetaClientMock) CreateUser(name, password string, admin bool) (meta.User, error)
- func (c *MetaClientMock) Data() meta.Data
- func (c *MetaClientMock) Database(name string) *meta.DatabaseInfo
- func (c *MetaClientMock) Databases() []meta.DatabaseInfo
- func (c *MetaClientMock) DeleteShardGroup(database string, policy string, id uint64) error
- func (c *MetaClientMock) DropContinuousQuery(database, name string) error
- func (c *MetaClientMock) DropDatabase(name string) error
- func (c *MetaClientMock) DropRetentionPolicy(database, name string) error
- func (c *MetaClientMock) DropShard(id uint64) error
- func (c *MetaClientMock) DropSubscription(database, rp, name string) error
- func (c *MetaClientMock) DropUser(name string) error
- func (c *MetaClientMock) Open() error
- func (c *MetaClientMock) PrecreateShardGroups(from, to time.Time) error
- func (c *MetaClientMock) PruneShardGroups() error
- func (c *MetaClientMock) RetentionPolicy(database, name string) (rpi *meta.RetentionPolicyInfo, err error)
- func (c *MetaClientMock) SetAdminPrivilege(username string, admin bool) error
- func (c *MetaClientMock) SetData(d *meta.Data) error
- func (c *MetaClientMock) SetPrivilege(username, database string, p influxql.Privilege) error
- func (c *MetaClientMock) ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
- func (c *MetaClientMock) ShardOwner(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)
- func (c *MetaClientMock) TruncateShardGroups(t time.Time) error
- func (c *MetaClientMock) UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate, makeDefault bool) error
- func (c *MetaClientMock) UpdateUser(name, password string) error
- func (c *MetaClientMock) User(username string) (meta.User, error)
- func (c *MetaClientMock) UserPrivilege(username, database string) (*influxql.Privilege, error)
- func (c *MetaClientMock) UserPrivileges(username string) (map[string]influxql.Privilege, error)
- func (c *MetaClientMock) Users() []meta.UserInfo
- type StringArrayCursorMock
- type TSDBStoreMock
- func (s *TSDBStoreMock) BackupSeriesFile(database string, w io.Writer) error
- func (s *TSDBStoreMock) BackupShard(id uint64, since time.Time, w io.Writer) error
- func (s *TSDBStoreMock) Close() error
- func (s *TSDBStoreMock) CreateShard(database string, retentionPolicy string, shardID uint64, enabled bool) error
- func (s *TSDBStoreMock) CreateShardSnapshot(id uint64) (string, error)
- func (s *TSDBStoreMock) Databases() []string
- func (s *TSDBStoreMock) DeleteDatabase(name string) error
- func (s *TSDBStoreMock) DeleteMeasurement(ctx context.Context, database string, name string) error
- func (s *TSDBStoreMock) DeleteRetentionPolicy(database string, name string) error
- func (s *TSDBStoreMock) DeleteSeries(ctx context.Context, database string, sources []influxql.Source, ...) error
- func (s *TSDBStoreMock) DeleteShard(shardID uint64) error
- func (s *TSDBStoreMock) DiskSize() (int64, error)
- func (s *TSDBStoreMock) ExpandSources(sources influxql.Sources) (influxql.Sources, error)
- func (s *TSDBStoreMock) ExportShard(id uint64, ExportStart time.Time, ExportEnd time.Time, w io.Writer) error
- func (s *TSDBStoreMock) ImportShard(id uint64, r io.Reader) error
- func (s *TSDBStoreMock) MeasurementNames(ctx context.Context, auth query.Authorizer, database string, ...) ([][]byte, error)
- func (s *TSDBStoreMock) MeasurementsCardinality(database string) (int64, error)
- func (s *TSDBStoreMock) Open() error
- func (s *TSDBStoreMock) Path() string
- func (s *TSDBStoreMock) RestoreShard(id uint64, r io.Reader) error
- func (s *TSDBStoreMock) SeriesCardinality(database string) (int64, error)
- func (s *TSDBStoreMock) SetShardEnabled(shardID uint64, enabled bool) error
- func (s *TSDBStoreMock) SetShardNewReadersBlocked(shardID uint64, blocked bool) error
- func (s *TSDBStoreMock) Shard(id uint64) *tsdb.Shard
- func (s *TSDBStoreMock) ShardGroup(ids []uint64) tsdb.ShardGroup
- func (s *TSDBStoreMock) ShardIDs() []uint64
- func (s *TSDBStoreMock) ShardInUse(shardID uint64) (bool, error)
- func (s *TSDBStoreMock) ShardN() int
- func (s *TSDBStoreMock) ShardRelativePath(id uint64) (string, error)
- func (s *TSDBStoreMock) Shards(ids []uint64) []*tsdb.Shard
- func (s *TSDBStoreMock) TagKeys(ctx context.Context, auth query.Authorizer, shardIDs []uint64, ...) ([]tsdb.TagKeys, error)
- func (s *TSDBStoreMock) TagValues(ctx context.Context, auth query.Authorizer, shardIDs []uint64, ...) ([]tsdb.TagValues, error)
- func (s *TSDBStoreMock) WithLogger(log *zap.Logger)
- func (s *TSDBStoreMock) WriteToShard(shardID uint64, points []models.Point) error
- type UnsignedArrayCursorMock
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArrayCursorMock ¶
type ArrayCursorMock struct { CloseFn func() ErrFn func() error StatsFn func() tsdb.CursorStats }
ArrayCursorMock provides a mock base implementation for batch cursors.
func NewArrayCursorMock ¶
func NewArrayCursorMock() *ArrayCursorMock
NewArrayCursorMock returns an initialised ArrayCursorMock, which returns the zero value for all methods.
func (*ArrayCursorMock) Err ¶
func (c *ArrayCursorMock) Err() error
Err returns the latest error, if any.
func (*ArrayCursorMock) Stats ¶
func (c *ArrayCursorMock) Stats() tsdb.CursorStats
type AuthorizerMock ¶
type AuthorizerMock struct { AuthorizeDatabaseFn func(influxql.Privilege, string) bool AuthorizeQueryFn func(database string, query *influxql.Query) error AuthorizeSeriesReadFn func(database string, measurement []byte, tags models.Tags) bool AuthorizeSeriesWriteFn func(database string, measurement []byte, tags models.Tags) bool }
AuthorizerMock is a mockable implementation of a query.Authorizer.
func (*AuthorizerMock) AuthorizeDatabase ¶
func (a *AuthorizerMock) AuthorizeDatabase(p influxql.Privilege, name string) bool
AuthorizeDatabase determines if the provided privilege is sufficient to authorise access to the database.
func (*AuthorizerMock) AuthorizeQuery ¶
func (a *AuthorizerMock) AuthorizeQuery(database string, query *influxql.Query) error
AuthorizeQuery determines if the query can be executed against the provided database.
func (*AuthorizerMock) AuthorizeSeriesRead ¶
func (a *AuthorizerMock) AuthorizeSeriesRead(database string, measurement []byte, tags models.Tags) bool
AuthorizeSeriesRead determines if the series comprising measurement and tags can be read on the provided database.
func (*AuthorizerMock) AuthorizeSeriesWrite ¶
func (a *AuthorizerMock) AuthorizeSeriesWrite(database string, measurement []byte, tags models.Tags) bool
AuthorizeSeriesWrite determines if the series comprising measurement and tags can be written to, on the provided database.
type BooleanArrayCursorMock ¶
type BooleanArrayCursorMock struct { *ArrayCursorMock NextFn func() *tsdb.BooleanArray }
BooleanArrayCursorMock provides a mock implementation of a BooleanArrayCursor.
func NewBooleanArrayCursorMock ¶
func NewBooleanArrayCursorMock() *BooleanArrayCursorMock
NewBooleanArrayCursorMock returns an initialised BooleanArrayCursorMock, which returns the zero value for all methods.
func (*BooleanArrayCursorMock) Next ¶
func (c *BooleanArrayCursorMock) Next() *tsdb.BooleanArray
Next returns the next set of keys and values.
type FloatArrayCursorMock ¶
type FloatArrayCursorMock struct { *ArrayCursorMock NextFn func() *tsdb.FloatArray }
FloatArrayCursorMock provides a mock implementation of a FloatArrayCursor.
func NewFloatArrayCursorMock ¶
func NewFloatArrayCursorMock() *FloatArrayCursorMock
NewFloatArrayCursorMock returns an initialised FloatArrayCursorMock, which returns the zero value for all methods.
func (*FloatArrayCursorMock) Next ¶
func (c *FloatArrayCursorMock) Next() *tsdb.FloatArray
Next returns the next set of keys and values.
type IntegerArrayCursorMock ¶
type IntegerArrayCursorMock struct { *ArrayCursorMock NextFn func() *tsdb.IntegerArray }
IntegerArrayCursorMock provides a mock implementation of an IntegerArrayCursorMock.
func NewIntegerArrayCursorMock ¶
func NewIntegerArrayCursorMock() *IntegerArrayCursorMock
NewIntegerArrayCursorMock returns an initialised IntegerArrayCursorMock, which returns the zero value for all methods.
func (*IntegerArrayCursorMock) Next ¶
func (c *IntegerArrayCursorMock) Next() *tsdb.IntegerArray
Next returns the next set of keys and values.
type MetaClientMock ¶
type MetaClientMock struct { CloseFn func() error CreateContinuousQueryFn func(database, name, query string) error CreateDatabaseFn func(name string) (*meta.DatabaseInfo, error) CreateDatabaseWithRetentionPolicyFn func(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error) CreateRetentionPolicyFn func(database string, spec *meta.RetentionPolicySpec, makeDefault bool) (*meta.RetentionPolicyInfo, error) CreateShardGroupFn func(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error) CreateSubscriptionFn func(database, rp, name, mode string, destinations []string) error CreateUserFn func(name, password string, admin bool) (meta.User, error) DatabaseFn func(name string) *meta.DatabaseInfo DatabasesFn func() []meta.DatabaseInfo DataFn func() meta.Data DeleteShardGroupFn func(database string, policy string, id uint64) error DropContinuousQueryFn func(database, name string) error DropDatabaseFn func(name string) error DropRetentionPolicyFn func(database, name string) error DropSubscriptionFn func(database, rp, name string) error DropShardFn func(id uint64) error DropUserFn func(name string) error OpenFn func() error PrecreateShardGroupsFn func(from, to time.Time) error PruneShardGroupsFn func() error RetentionPolicyFn func(database, name string) (rpi *meta.RetentionPolicyInfo, err error) AuthenticateFn func(username, password string) (ui meta.User, err error) AdminUserExistsFn func() bool SetAdminPrivilegeFn func(username string, admin bool) error SetDataFn func(*meta.Data) error SetPrivilegeFn func(username, database string, p influxql.Privilege) error ShardGroupsByTimeRangeFn func(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error) ShardOwnerFn func(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo) TruncateShardGroupsFn func(t time.Time) error UpdateRetentionPolicyFn func(database, name string, rpu *meta.RetentionPolicyUpdate, makeDefault bool) error UpdateUserFn func(name, password string) error UserPrivilegeFn func(username, database string) (*influxql.Privilege, error) UserPrivilegesFn func(username string) (map[string]influxql.Privilege, error) UserFn func(username string) (meta.User, error) UsersFn func() []meta.UserInfo }
MetaClientMock is a mockable implementation of meta.MetaClient.
func (*MetaClientMock) AdminUserExists ¶
func (c *MetaClientMock) AdminUserExists() bool
func (*MetaClientMock) Authenticate ¶
func (c *MetaClientMock) Authenticate(username, password string) (meta.User, error)
func (*MetaClientMock) Close ¶
func (c *MetaClientMock) Close() error
func (*MetaClientMock) CreateContinuousQuery ¶
func (c *MetaClientMock) CreateContinuousQuery(database, name, query string) error
func (*MetaClientMock) CreateDatabase ¶
func (c *MetaClientMock) CreateDatabase(name string) (*meta.DatabaseInfo, error)
func (*MetaClientMock) CreateDatabaseWithRetentionPolicy ¶
func (c *MetaClientMock) CreateDatabaseWithRetentionPolicy(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)
func (*MetaClientMock) CreateRetentionPolicy ¶
func (c *MetaClientMock) CreateRetentionPolicy(database string, spec *meta.RetentionPolicySpec, makeDefault bool) (*meta.RetentionPolicyInfo, error)
func (*MetaClientMock) CreateShardGroup ¶
func (c *MetaClientMock) CreateShardGroup(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)
func (*MetaClientMock) CreateSubscription ¶
func (c *MetaClientMock) CreateSubscription(database, rp, name, mode string, destinations []string) error
func (*MetaClientMock) CreateUser ¶
func (*MetaClientMock) Data ¶
func (c *MetaClientMock) Data() meta.Data
func (*MetaClientMock) Database ¶
func (c *MetaClientMock) Database(name string) *meta.DatabaseInfo
func (*MetaClientMock) Databases ¶
func (c *MetaClientMock) Databases() []meta.DatabaseInfo
func (*MetaClientMock) DeleteShardGroup ¶
func (c *MetaClientMock) DeleteShardGroup(database string, policy string, id uint64) error
func (*MetaClientMock) DropContinuousQuery ¶
func (c *MetaClientMock) DropContinuousQuery(database, name string) error
func (*MetaClientMock) DropDatabase ¶
func (c *MetaClientMock) DropDatabase(name string) error
func (*MetaClientMock) DropRetentionPolicy ¶
func (c *MetaClientMock) DropRetentionPolicy(database, name string) error
func (*MetaClientMock) DropShard ¶
func (c *MetaClientMock) DropShard(id uint64) error
func (*MetaClientMock) DropSubscription ¶
func (c *MetaClientMock) DropSubscription(database, rp, name string) error
func (*MetaClientMock) DropUser ¶
func (c *MetaClientMock) DropUser(name string) error
func (*MetaClientMock) Open ¶
func (c *MetaClientMock) Open() error
func (*MetaClientMock) PrecreateShardGroups ¶
func (c *MetaClientMock) PrecreateShardGroups(from, to time.Time) error
func (*MetaClientMock) PruneShardGroups ¶
func (c *MetaClientMock) PruneShardGroups() error
func (*MetaClientMock) RetentionPolicy ¶
func (c *MetaClientMock) RetentionPolicy(database, name string) (rpi *meta.RetentionPolicyInfo, err error)
func (*MetaClientMock) SetAdminPrivilege ¶
func (c *MetaClientMock) SetAdminPrivilege(username string, admin bool) error
func (*MetaClientMock) SetPrivilege ¶
func (c *MetaClientMock) SetPrivilege(username, database string, p influxql.Privilege) error
func (*MetaClientMock) ShardGroupsByTimeRange ¶
func (c *MetaClientMock) ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
func (*MetaClientMock) ShardOwner ¶
func (c *MetaClientMock) ShardOwner(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)
func (*MetaClientMock) TruncateShardGroups ¶
func (c *MetaClientMock) TruncateShardGroups(t time.Time) error
func (*MetaClientMock) UpdateRetentionPolicy ¶
func (c *MetaClientMock) UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate, makeDefault bool) error
func (*MetaClientMock) UpdateUser ¶
func (c *MetaClientMock) UpdateUser(name, password string) error
func (*MetaClientMock) UserPrivilege ¶
func (c *MetaClientMock) UserPrivilege(username, database string) (*influxql.Privilege, error)
func (*MetaClientMock) UserPrivileges ¶
func (*MetaClientMock) Users ¶
func (c *MetaClientMock) Users() []meta.UserInfo
type StringArrayCursorMock ¶
type StringArrayCursorMock struct { *ArrayCursorMock NextFn func() *tsdb.StringArray }
StringArrayCursorMock provides a mock implementation of a StringArrayCursor.
func NewStringArrayCursorMock ¶
func NewStringArrayCursorMock() *StringArrayCursorMock
NewStringArrayCursorMock returns an initialised StringArrayCursorMock, which returns the zero value for all methods.
func (*StringArrayCursorMock) Next ¶
func (c *StringArrayCursorMock) Next() *tsdb.StringArray
Next returns the next set of keys and values.
type TSDBStoreMock ¶
type TSDBStoreMock struct { BackupShardFn func(id uint64, since time.Time, w io.Writer) error BackupSeriesFileFn func(database string, w io.Writer) error ExportShardFn func(id uint64, ExportStart time.Time, ExportEnd time.Time, w io.Writer) error CloseFn func() error CreateShardFn func(database, policy string, shardID uint64, enabled bool) error CreateShardSnapshotFn func(id uint64) (string, error) DatabasesFn func() []string DeleteDatabaseFn func(name string) error DeleteMeasurementFn func(ctx context.Context, database, name string) error DeleteRetentionPolicyFn func(database, name string) error DeleteSeriesFn func(ctx context.Context, database string, sources []influxql.Source, condition influxql.Expr) error DeleteShardFn func(id uint64) error DiskSizeFn func() (int64, error) ExpandSourcesFn func(sources influxql.Sources) (influxql.Sources, error) ImportShardFn func(id uint64, r io.Reader) error MeasurementsCardinalityFn func(database string) (int64, error) MeasurementNamesFn func(ctx context.Context, auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error) OpenFn func() error PathFn func() string RestoreShardFn func(id uint64, r io.Reader) error SeriesCardinalityFn func(database string) (int64, error) SetShardEnabledFn func(shardID uint64, enabled bool) error SetShardNewReadersBlockedFn func(shardID uint64, blocked bool) error ShardFn func(id uint64) *tsdb.Shard ShardGroupFn func(ids []uint64) tsdb.ShardGroup ShardIDsFn func() []uint64 ShardInUseFn func(shardID uint64) (bool, error) ShardNFn func() int ShardRelativePathFn func(id uint64) (string, error) ShardsFn func(ids []uint64) []*tsdb.Shard TagKeysFn func(ctx context.Context, auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error) TagValuesFn func(ctx context.Context, auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, error) WithLoggerFn func(log *zap.Logger) WriteToShardFn func(shardID uint64, points []models.Point) error }
TSDBStoreMock is a mockable implementation of tsdb.Store.
func (*TSDBStoreMock) BackupSeriesFile ¶
func (s *TSDBStoreMock) BackupSeriesFile(database string, w io.Writer) error
func (*TSDBStoreMock) BackupShard ¶
func (*TSDBStoreMock) Close ¶
func (s *TSDBStoreMock) Close() error
func (*TSDBStoreMock) CreateShard ¶
func (*TSDBStoreMock) CreateShardSnapshot ¶
func (s *TSDBStoreMock) CreateShardSnapshot(id uint64) (string, error)
func (*TSDBStoreMock) Databases ¶
func (s *TSDBStoreMock) Databases() []string
func (*TSDBStoreMock) DeleteDatabase ¶
func (s *TSDBStoreMock) DeleteDatabase(name string) error
func (*TSDBStoreMock) DeleteMeasurement ¶
func (*TSDBStoreMock) DeleteRetentionPolicy ¶
func (s *TSDBStoreMock) DeleteRetentionPolicy(database string, name string) error
func (*TSDBStoreMock) DeleteSeries ¶
func (*TSDBStoreMock) DeleteShard ¶
func (s *TSDBStoreMock) DeleteShard(shardID uint64) error
func (*TSDBStoreMock) DiskSize ¶
func (s *TSDBStoreMock) DiskSize() (int64, error)
func (*TSDBStoreMock) ExpandSources ¶
func (*TSDBStoreMock) ExportShard ¶
func (*TSDBStoreMock) ImportShard ¶
func (s *TSDBStoreMock) ImportShard(id uint64, r io.Reader) error
func (*TSDBStoreMock) MeasurementNames ¶
func (s *TSDBStoreMock) MeasurementNames(ctx context.Context, auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error)
func (*TSDBStoreMock) MeasurementsCardinality ¶
func (s *TSDBStoreMock) MeasurementsCardinality(database string) (int64, error)
func (*TSDBStoreMock) Open ¶
func (s *TSDBStoreMock) Open() error
func (*TSDBStoreMock) Path ¶
func (s *TSDBStoreMock) Path() string
func (*TSDBStoreMock) RestoreShard ¶
func (s *TSDBStoreMock) RestoreShard(id uint64, r io.Reader) error
func (*TSDBStoreMock) SeriesCardinality ¶
func (s *TSDBStoreMock) SeriesCardinality(database string) (int64, error)
func (*TSDBStoreMock) SetShardEnabled ¶
func (s *TSDBStoreMock) SetShardEnabled(shardID uint64, enabled bool) error
func (*TSDBStoreMock) SetShardNewReadersBlocked ¶ added in v2.7.7
func (s *TSDBStoreMock) SetShardNewReadersBlocked(shardID uint64, blocked bool) error
func (*TSDBStoreMock) ShardGroup ¶
func (s *TSDBStoreMock) ShardGroup(ids []uint64) tsdb.ShardGroup
func (*TSDBStoreMock) ShardIDs ¶
func (s *TSDBStoreMock) ShardIDs() []uint64
func (*TSDBStoreMock) ShardInUse ¶ added in v2.7.7
func (s *TSDBStoreMock) ShardInUse(shardID uint64) (bool, error)
func (*TSDBStoreMock) ShardN ¶
func (s *TSDBStoreMock) ShardN() int
func (*TSDBStoreMock) ShardRelativePath ¶
func (s *TSDBStoreMock) ShardRelativePath(id uint64) (string, error)
func (*TSDBStoreMock) WithLogger ¶
func (s *TSDBStoreMock) WithLogger(log *zap.Logger)
func (*TSDBStoreMock) WriteToShard ¶
func (s *TSDBStoreMock) WriteToShard(shardID uint64, points []models.Point) error
type UnsignedArrayCursorMock ¶
type UnsignedArrayCursorMock struct { *ArrayCursorMock NextFn func() *tsdb.UnsignedArray }
UnsignedArrayCursorMock provides a mock implementation of an UnsignedArrayCursorMock.
func NewUnsignedArrayCursorMock ¶
func NewUnsignedArrayCursorMock() *UnsignedArrayCursorMock
NewUnsignedArrayCursorMock returns an initialised UnsignedArrayCursorMock, which returns the zero value for all methods.
func (*UnsignedArrayCursorMock) Next ¶
func (c *UnsignedArrayCursorMock) Next() *tsdb.UnsignedArray
Next returns the next set of keys and values.