Documentation ¶
Index ¶
- func CreateTSDB(v3iocfg *config.V3ioConfig, schema *config.Schema) error
- type Appender
- type V3ioAdapter
- func (a *V3ioAdapter) Appender() (Appender, error)
- func (a *V3ioAdapter) Close() error
- func (a *V3ioAdapter) CountMetrics(part string) (int, error)
- func (a *V3ioAdapter) DeleteDB(configExists bool, force bool, fromTime int64, toTime int64) error
- func (a *V3ioAdapter) GetContainer() (*v3io.Container, string)
- func (a *V3ioAdapter) GetLogger(child string) logger.Logger
- func (a *V3ioAdapter) GetSchema() *config.Schema
- func (a *V3ioAdapter) InitAppenderCache() error
- func (a *V3ioAdapter) Querier(_ context.Context, mint, maxt int64) (*querier.V3ioQuerier, error)
- func (a *V3ioAdapter) StartTime() (int64, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTSDB ¶
func CreateTSDB(v3iocfg *config.V3ioConfig, schema *config.Schema) error
Types ¶
type Appender ¶
type Appender interface { Add(l utils.Labels, t int64, v float64) (uint64, error) AddFast(l utils.Labels, ref uint64, t int64, v float64) error WaitForCompletion(timeout time.Duration) (int, error) Commit() error Rollback() error }
Appender interface provides batched appends against a storage.
type V3ioAdapter ¶
type V3ioAdapter struct { MetricsCache *appender.MetricsCache // contains filtered or unexported fields }
func NewV3ioAdapter ¶
func NewV3ioAdapter(cfg *config.V3ioConfig, container *v3io.Container, logger logger.Logger) (*V3ioAdapter, error)
Create a new TSDB Adapter, similar to Prometheus TSDB Adapter with few extensions Prometheus compliant Adapter is under /promtsdb
func (*V3ioAdapter) Appender ¶
func (a *V3ioAdapter) Appender() (Appender, error)
Create an appender interface, for writing metrics
func (*V3ioAdapter) Close ¶
func (a *V3ioAdapter) Close() error
func (*V3ioAdapter) CountMetrics ¶
func (a *V3ioAdapter) CountMetrics(part string) (int, error)
return number of objects in a table
func (*V3ioAdapter) GetContainer ¶
func (a *V3ioAdapter) GetContainer() (*v3io.Container, string)
func (*V3ioAdapter) GetSchema ¶ added in v0.0.3
func (a *V3ioAdapter) GetSchema() *config.Schema
func (*V3ioAdapter) InitAppenderCache ¶ added in v0.0.3
func (a *V3ioAdapter) InitAppenderCache() error
func (*V3ioAdapter) Querier ¶
func (a *V3ioAdapter) Querier(_ context.Context, mint, maxt int64) (*querier.V3ioQuerier, error)
create a querier interface, used for time series queries
func (*V3ioAdapter) StartTime ¶
func (a *V3ioAdapter) StartTime() (int64, error)
Click to show internal directories.
Click to hide internal directories.