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 FluxControllerMock
- type FluxQueryMock
- type FluxResultMock
- 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 StorageResultsMock
- type StorageStoreMock
- 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(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
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 determins 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 FluxControllerMock ¶
type FluxControllerMock struct {
QueryFn func(ctx context.Context, compiler flux.Compiler) (flux.Query, error)
}
func NewFluxControllerMock ¶
func NewFluxControllerMock() *FluxControllerMock
func (*FluxControllerMock) PrometheusCollectors ¶
func (m *FluxControllerMock) PrometheusCollectors() []prometheus.Collector
type FluxQueryMock ¶
type FluxQueryMock struct { SpecFn func(*FluxQueryMock) *flux.Spec ReadyFn func(*FluxQueryMock) <-chan map[string]flux.Result DoneFn func(*FluxQueryMock) CancelFn func(*FluxQueryMock) ErrFn func(*FluxQueryMock) error }
func NewFluxQueryMock ¶
func NewFluxQueryMock() *FluxQueryMock
func (*FluxQueryMock) Cancel ¶
func (m *FluxQueryMock) Cancel()
func (*FluxQueryMock) Done ¶
func (m *FluxQueryMock) Done()
func (*FluxQueryMock) Err ¶
func (m *FluxQueryMock) Err() error
func (*FluxQueryMock) Spec ¶
func (m *FluxQueryMock) Spec() *flux.Spec
func (*FluxQueryMock) Statistics ¶
func (m *FluxQueryMock) Statistics() flux.Statistics
type FluxResultMock ¶
type FluxResultMock struct { }
func (*FluxResultMock) Name ¶
func (*FluxResultMock) Name() string
func (*FluxResultMock) Tables ¶
func (*FluxResultMock) Tables() flux.TableIterator
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 StorageResultsMock ¶
type StorageResultsMock struct { CloseFn func() NextFn func() bool CursorFn func() tsdb.Cursor TagsFn func() models.Tags ErrFn func() error StatsFn func() tsdb.CursorStats }
StorageResultsMock implements the storage.Results interface providing the ability to emit mock results from calls to the StorageStoreMock.Read method.
func NewStorageResultsMock ¶
func NewStorageResultsMock() *StorageResultsMock
NewStorageResultsMock initialises a StorageResultsMock whose methods all return their zero value.
func (*StorageResultsMock) Close ¶
func (r *StorageResultsMock) Close()
Close closes the result set.
func (*StorageResultsMock) Cursor ¶
func (r *StorageResultsMock) Cursor() tsdb.Cursor
Cursor returns the cursor for the result set.
func (*StorageResultsMock) Err ¶
func (r *StorageResultsMock) Err() error
func (*StorageResultsMock) Next ¶
func (r *StorageResultsMock) Next() bool
Next returns true if there are more results available.
func (*StorageResultsMock) Stats ¶
func (r *StorageResultsMock) Stats() tsdb.CursorStats
func (*StorageResultsMock) Tags ¶
func (r *StorageResultsMock) Tags() models.Tags
Tags returns the series' tag set.
type StorageStoreMock ¶
type StorageStoreMock struct { ReadFn func(ctx context.Context, req *datatypes.ReadRequest) (reads.ResultSet, error) WithLoggerFn func(log *zap.Logger) ResultSet *StorageResultsMock }
TSDBStoreMock is a mockable implementation of storage.Store.
It's currently a partial implementation as one of a store's exported methods returns an unexported type.
func NewStorageStoreMock ¶
func NewStorageStoreMock() *StorageStoreMock
NewStorageStoreMock initialises a StorageStoreMock with methods that return their zero values. It also initialises a StorageResultsMock, which can be configured via the ResultSet field.
func (*StorageStoreMock) Read ¶
func (s *StorageStoreMock) Read(ctx context.Context, req *datatypes.ReadRequest) (reads.ResultSet, error)
Read reads the storage request and returns a cursor to access results.
func (*StorageStoreMock) WithLogger ¶
func (s *StorageStoreMock) WithLogger(log *zap.Logger)
WithLogger sets the logger.
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(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) ImportShardFn func(id uint64, r io.Reader) error MeasurementSeriesCountsFn func(database string) (measuments int, series int) MeasurementsCardinalityFn func(database string) (int64, error) MeasurementNamesFn func(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 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 }
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 (s *TSDBStoreMock) DeleteMeasurement(database string, name string) error
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(auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error)
func (*TSDBStoreMock) MeasurementSeriesCounts ¶
func (s *TSDBStoreMock) MeasurementSeriesCounts(database string) (measuments int, series int)
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) ShardGroup ¶
func (s *TSDBStoreMock) ShardGroup(ids []uint64) tsdb.ShardGroup
func (*TSDBStoreMock) ShardIDs ¶
func (s *TSDBStoreMock) ShardIDs() []uint64
func (*TSDBStoreMock) ShardN ¶
func (s *TSDBStoreMock) ShardN() int
func (*TSDBStoreMock) ShardRelativePath ¶
func (s *TSDBStoreMock) ShardRelativePath(id uint64) (string, error)
func (*TSDBStoreMock) Statistics ¶
func (s *TSDBStoreMock) Statistics(tags map[string]string) []models.Statistic
func (*TSDBStoreMock) TagKeys ¶
func (s *TSDBStoreMock) TagKeys(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error)
func (*TSDBStoreMock) TagValues ¶
func (s *TSDBStoreMock) TagValues(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, 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.