Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + type ArrayCursorMock struct + CloseFn func() + ErrFn func() error + StatsFn func() tsdb.CursorStats + func NewArrayCursorMock() *ArrayCursorMock + func (c *ArrayCursorMock) Close() + func (c *ArrayCursorMock) Err() error + func (c *ArrayCursorMock) Stats() tsdb.CursorStats + 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 + 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 struct + NextFn func() *tsdb.BooleanArray + func NewBooleanArrayCursorMock() *BooleanArrayCursorMock + func (c *BooleanArrayCursorMock) Next() *tsdb.BooleanArray + type FloatArrayCursorMock struct + NextFn func() *tsdb.FloatArray + func NewFloatArrayCursorMock() *FloatArrayCursorMock + func (c *FloatArrayCursorMock) Next() *tsdb.FloatArray + type FluxControllerMock struct + QueryFn func(ctx context.Context, compiler flux.Compiler) (flux.Query, error) + func NewFluxControllerMock() *FluxControllerMock + func (m *FluxControllerMock) PrometheusCollectors() []prometheus.Collector + func (m *FluxControllerMock) Query(ctx context.Context, compiler flux.Compiler) (flux.Query, error) + type IntegerArrayCursorMock struct + NextFn func() *tsdb.IntegerArray + func NewIntegerArrayCursorMock() *IntegerArrayCursorMock + func (c *IntegerArrayCursorMock) Next() *tsdb.IntegerArray + type MetaClientMock struct + AdminUserExistsFn func() bool + AuthenticateFn func(username, password string) (ui meta.User, err error) + 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) + DataFn func() meta.Data + DatabaseFn func(name string) *meta.DatabaseInfo + DatabasesFn func() []meta.DatabaseInfo + 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 + DropShardFn func(id uint64) error + DropSubscriptionFn func(database, rp, name string) 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) + 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 + UserFn func(username string) (meta.User, error) + UserPrivilegeFn func(username, database string) (*influxql.Privilege, error) + UserPrivilegesFn func(username string) (map[string]influxql.Privilege, error) + UsersFn func() []meta.UserInfo + 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 StorageResultsMock struct + CloseFn func() + CursorFn func() tsdb.Cursor + ErrFn func() error + NextFn func() bool + StatsFn func() tsdb.CursorStats + TagsFn func() models.Tags + func NewStorageResultsMock() *StorageResultsMock + func (r *StorageResultsMock) Close() + func (r *StorageResultsMock) Cursor() tsdb.Cursor + func (r *StorageResultsMock) Err() error + func (r *StorageResultsMock) Next() bool + func (r *StorageResultsMock) Stats() tsdb.CursorStats + func (r *StorageResultsMock) Tags() models.Tags + type StorageStoreMock struct + ReadFilterFn func(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error) + ReadGroupFn func(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error) + ResultSet *StorageResultsMock + TagKeysFn func(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error) + TagValuesFn func(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error) + WithLoggerFn func(log *zap.Logger) + func NewStorageStoreMock() *StorageStoreMock + func (s *StorageStoreMock) GetSource(db, rp string) proto.Message + func (s *StorageStoreMock) ReadFilter(ctx context.Context, req *datatypes.ReadFilterRequest) (reads.ResultSet, error) + func (s *StorageStoreMock) ReadGroup(ctx context.Context, req *datatypes.ReadGroupRequest) (reads.GroupResultSet, error) + func (s *StorageStoreMock) TagKeys(ctx context.Context, req *datatypes.TagKeysRequest) (cursors.StringIterator, error) + func (s *StorageStoreMock) TagValues(ctx context.Context, req *datatypes.TagValuesRequest) (cursors.StringIterator, error) + func (s *StorageStoreMock) WithLogger(log *zap.Logger) + type StringArrayCursorMock struct + NextFn func() *tsdb.StringArray + func NewStringArrayCursorMock() *StringArrayCursorMock + func (c *StringArrayCursorMock) Next() *tsdb.StringArray + type TSDBStoreMock struct + BackupSeriesFileFn func(database string, w io.Writer) error + BackupShardFn func(id uint64, since 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(database, name string) error + DeleteRetentionPolicyFn func(database, name string) error + DeleteSeriesFn func(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) + ExportShardFn func(id uint64, ExportStart time.Time, ExportEnd time.Time, w io.Writer) error + ImportShardFn func(id uint64, r io.Reader) error + MeasurementNamesFn func(auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error) + MeasurementSeriesCountsFn func(database string) (measuments int, series int) + MeasurementsCardinalityFn func(database string) (int64, 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 + ShardFn func(id uint64) *tsdb.Shard + ShardGroupFn func(ids []uint64) tsdb.ShardGroup + ShardIDsFn func() []uint64 + ShardNFn func() int + ShardRelativePathFn func(id uint64) (string, error) + ShardsFn func(ids []uint64) []*tsdb.Shard + StatisticsFn func(tags map[string]string) []models.Statistic + TagKeysFn func(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error) + TagValuesFn func(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, error) + WithLoggerFn func(log *zap.Logger) + WriteToShardFn func(shardID uint64, points []models.Point) error + 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(database string, name string) error + func (s *TSDBStoreMock) DeleteRetentionPolicy(database string, name string) error + func (s *TSDBStoreMock) DeleteSeries(database string, sources []influxql.Source, condition influxql.Expr) 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(auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error) + func (s *TSDBStoreMock) MeasurementSeriesCounts(database string) (measuments int, series int) + 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) Shard(id uint64) *tsdb.Shard + func (s *TSDBStoreMock) ShardGroup(ids []uint64) tsdb.ShardGroup + func (s *TSDBStoreMock) ShardIDs() []uint64 + func (s *TSDBStoreMock) ShardN() int + func (s *TSDBStoreMock) ShardRelativePath(id uint64) (string, error) + func (s *TSDBStoreMock) Shards(ids []uint64) []*tsdb.Shard + func (s *TSDBStoreMock) Statistics(tags map[string]string) []models.Statistic + func (s *TSDBStoreMock) TagKeys(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error) + func (s *TSDBStoreMock) TagValues(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, error) + func (s *TSDBStoreMock) WithLogger(log *zap.Logger) + func (s *TSDBStoreMock) WriteToShard(shardID uint64, points []models.Point) error + type UnsignedArrayCursorMock struct + NextFn func() *tsdb.UnsignedArray + func NewUnsignedArrayCursorMock() *UnsignedArrayCursorMock + func (c *UnsignedArrayCursorMock) Next() *tsdb.UnsignedArray