internal

Nov 7, 2018

Changes in this version

+ type ArrayCursorMock struct

+ CloseFn func()

+ ErrFn func() error

+ func NewArrayCursorMock() *ArrayCursorMock

+ func (c *ArrayCursorMock) Close()

+ func (c *ArrayCursorMock) Err() error

+ 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 FluxQueryMock struct

+ CancelFn func(*FluxQueryMock)

+ DoneFn func(*FluxQueryMock)

+ ErrFn func(*FluxQueryMock) error

+ ReadyFn func(*FluxQueryMock) <-chan map[string]flux.Result

+ SpecFn func(*FluxQueryMock) *flux.Spec

+ func NewFluxQueryMock() *FluxQueryMock

+ func (m *FluxQueryMock) Cancel()

+ func (m *FluxQueryMock) Done()

+ func (m *FluxQueryMock) Err() error

+ func (m *FluxQueryMock) Ready() <-chan map[string]flux.Result

+ func (m *FluxQueryMock) Spec() *flux.Spec

+ func (m *FluxQueryMock) Statistics() flux.Statistics

+ type FluxResultMock struct

+ func (*FluxResultMock) Name() string

+ func (*FluxResultMock) Tables() flux.TableIterator

+ type IntegerArrayCursorMock struct

+ NextFn func() *tsdb.IntegerArray

+ func NewIntegerArrayCursorMock() *IntegerArrayCursorMock

+ func (c *IntegerArrayCursorMock) Next() *tsdb.IntegerArray

+ type StringArrayCursorMock struct

+ NextFn func() *tsdb.StringArray

+ func NewStringArrayCursorMock() *StringArrayCursorMock

+ func (c *StringArrayCursorMock) Next() *tsdb.StringArray

+ type UnsignedArrayCursorMock struct

+ NextFn func() *tsdb.UnsignedArray

+ func NewUnsignedArrayCursorMock() *UnsignedArrayCursorMock

+ func (c *UnsignedArrayCursorMock) Next() *tsdb.UnsignedArray

Jun 28, 2018

Changes in this version

+ type BatchCursorMock struct

+ CloseFn func()

+ ErrFn func() error

+ func NewBatchCursorMock() *BatchCursorMock

+ func (c *BatchCursorMock) Close()

+ func (c *BatchCursorMock) Err() error

+ type BooleanBatchCursorMock struct

+ NextFn func() (keys []int64, values []bool)

+ func NewBooleanBatchCursorMock() *BooleanBatchCursorMock

+ func (c *BooleanBatchCursorMock) Next() (keys []int64, values []bool)

+ type FloatBatchCursorMock struct

+ NextFn func() (keys []int64, values []float64)

+ func NewFloatBatchCursorMock() *FloatBatchCursorMock

+ func (c *FloatBatchCursorMock) Next() (keys []int64, values []float64)

+ type IntegerBatchCursorMock struct

+ NextFn func() (keys []int64, values []int64)

+ func NewIntegerBatchCursorMock() *IntegerBatchCursorMock

+ func (c *IntegerBatchCursorMock) Next() (keys []int64, values []int64)

+ type StorageResultsMock struct

+ CloseFn func()

+ CursorFn func() tsdb.Cursor

+ NextFn func() bool

+ TagsFn func() models.Tags

+ func NewStorageResultsMock() *StorageResultsMock

+ func (r *StorageResultsMock) Close()

+ func (r *StorageResultsMock) Cursor() tsdb.Cursor

+ func (r *StorageResultsMock) Next() bool

+ func (r *StorageResultsMock) Tags() models.Tags

+ type StorageStoreMock struct

+ ReadFn func(ctx context.Context, req *storage.ReadRequest) (storage.Results, error)

+ ResultSet *StorageResultsMock

+ WithLoggerFn func(log *zap.Logger)

+ func NewStorageStoreMock() *StorageStoreMock

+ func (s *StorageStoreMock) Read(ctx context.Context, req *storage.ReadRequest) (storage.Results, error)

+ func (s *StorageStoreMock) WithLogger(log *zap.Logger)

+ type StringBatchCursorMock struct

+ NextFn func() (keys []int64, values []string)

+ func NewStringBatchCursorMock() *StringBatchCursorMock

+ func (c *StringBatchCursorMock) Next() (keys []int64, values []string)

+ type UnsignedBatchCursorMock struct

+ NextFn func() (keys []int64, values []uint64)

+ func NewUnsignedBatchCursorMock() *UnsignedBatchCursorMock

+ func (c *UnsignedBatchCursorMock) Next() (keys []int64, values []uint64)

Mar 6, 2018

Changes in this version

type MetaClientMock

+ PrecreateShardGroupsFn func(from, to time.Time) error

+ TruncateShardGroupsFn func(t time.Time) error

+ func (c *MetaClientMock) PrecreateShardGroups(from, to time.Time) error

+ func (c *MetaClientMock) TruncateShardGroups(t time.Time) error

type TSDBStoreMock

+ BackupSeriesFileFn func(database string, w io.Writer) error

+ ExportShardFn func(id uint64, ExportStart time.Time, ExportEnd time.Time, w io.Writer) error

+ func (s *TSDBStoreMock) BackupSeriesFile(database string, w io.Writer) error

+ func (s *TSDBStoreMock) ExportShard(id uint64, ExportStart time.Time, ExportEnd time.Time, w io.Writer) error

Nov 13, 2017

Changes in this version

type MetaClientMock

+ PruneShardGroupsFn func() error

+ func (c *MetaClientMock) PruneShardGroups() error

+ type TSDBStoreMock struct

+ 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)

+ ImportShardFn func(id uint64, r io.Reader) error

+ MeasurementNamesFn func(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) 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) ImportShard(id uint64, r io.Reader) error

+ func (s *TSDBStoreMock) MeasurementNames(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

Jun 21, 2017

Changes in this version

type MetaClientMock

+ AdminUserExistsFn func() bool

+ AuthenticateFn func(username, password string) (ui meta.User, err error)

+ UserFn func(username string) (meta.User, error)

+ func (c *MetaClientMock) AdminUserExists() bool

+ func (c *MetaClientMock) Authenticate(username, password string) (meta.User, error)

+ func (c *MetaClientMock) User(username string) (meta.User, error)

Jan 24, 2017

Changes in this version

type MetaClientMock

+ ShardGroupsByTimeRangeFn func(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)

+ func (c *MetaClientMock) ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)

Nov 11, 2016

Changes in this version

+ 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) (*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.UserInfo, 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

+ RetentionPolicyFn func(database, name string) (rpi *meta.RetentionPolicyInfo, err error)

+ SetAdminPrivilegeFn func(username string, admin bool) error

+ SetDataFn func(*meta.Data) error

+ SetDefaultRetentionPolicyFn func(database, name string) error

+ SetPrivilegeFn func(username, database string, p influxql.Privilege) error

+ ShardOwnerFn func(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)

+ ShardsByTimeRangeFn func(sources influxql.Sources, tmin, tmax time.Time) (a []meta.ShardInfo, err error)

+ UpdateRetentionPolicyFn func(database, name string, rpu *meta.RetentionPolicyUpdate) error

+ UpdateUserFn func(name, password string) 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) 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) (*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.UserInfo, 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) 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) SetDefaultRetentionPolicy(database, name string) error

+ func (c *MetaClientMock) SetPrivilege(username, database string, p influxql.Privilege) error

+ func (c *MetaClientMock) ShardOwner(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)

+ func (c *MetaClientMock) ShardsByTimeRange(sources influxql.Sources, tmin, tmax time.Time) (a []meta.ShardInfo, err error)

+ func (c *MetaClientMock) UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate) error

+ func (c *MetaClientMock) UpdateUser(name, password string) 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