Back to godoc.org

Package internal

v1.7.2
Latest Go to latest

The latest major version is .

Published: Dec 12, 2018 | License: MIT | Module: github.com/branthz/influxdb

Index

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

func (c *ArrayCursorMock) Close()

Close closes the cursor.

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

func (*FluxControllerMock) Query

func (m *FluxControllerMock) Query(ctx context.Context, compiler flux.Compiler) (flux.Query, error)

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

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

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 (c *MetaClientMock) CreateUser(name, password string, admin bool) (meta.User, error)

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

func (c *MetaClientMock) SetData(d *meta.Data) 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) User

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

func (*MetaClientMock) UserPrivilege

func (c *MetaClientMock) UserPrivilege(username, database string) (*influxql.Privilege, error)

func (*MetaClientMock) UserPrivileges

func (c *MetaClientMock) UserPrivileges(username string) (map[string]influxql.Privilege, error)

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 (s *TSDBStoreMock) BackupShard(id uint64, since time.Time, w io.Writer) error

func (*TSDBStoreMock) Close

func (s *TSDBStoreMock) Close() error

func (*TSDBStoreMock) CreateShard

func (s *TSDBStoreMock) CreateShard(database string, retentionPolicy string, shardID uint64, enabled bool) error

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 (s *TSDBStoreMock) DeleteSeries(database string, sources []influxql.Source, condition influxql.Expr) error

func (*TSDBStoreMock) DeleteShard

func (s *TSDBStoreMock) DeleteShard(shardID uint64) error

func (*TSDBStoreMock) DiskSize

func (s *TSDBStoreMock) DiskSize() (int64, error)

func (*TSDBStoreMock) ExpandSources

func (s *TSDBStoreMock) ExpandSources(sources influxql.Sources) (influxql.Sources, error)

func (*TSDBStoreMock) ExportShard

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

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

func (s *TSDBStoreMock) Shard(id uint64) *tsdb.Shard

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

func (s *TSDBStoreMock) Shards(ids []uint64) []*tsdb.Shard

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.

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier