tsdb

Documentation

Index

• func CreateTSDB(v3iocfg *config.V3ioConfig, schema *config.Schema) error
• type Appender
• type V3ioAdapter
  • func NewV3ioAdapter(cfg *config.V3ioConfig, container *v3io.Container, logger logger.Logger) (*V3ioAdapter, error)
  • func (a *V3ioAdapter) Appender() (Appender, error)
  • func (a *V3ioAdapter) Close() error
  • func (a *V3ioAdapter) CountMetrics(part string) (int, error)
  • func (a *V3ioAdapter) DeleteDB(deleteAll bool, ignoreErrors 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)

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
}

The 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 but with a few extensions. The Prometheus compliant adapter is found under /promtsdb.

func (*V3ioAdapter) Appender

func (a *V3ioAdapter) Appender() (Appender, error)

Create an appender interface, for writing performance

func (*V3ioAdapter) Close

func (a *V3ioAdapter) Close() error

func (*V3ioAdapter) CountMetrics

func (a *V3ioAdapter) CountMetrics(part string) (int, error)

Return the number of items in a TSDB table

func (*V3ioAdapter) DeleteDB

func (a *V3ioAdapter) DeleteDB(deleteAll bool, ignoreErrors bool, fromTime int64, toTime int64) error

func (*V3ioAdapter) GetContainer

func (a *V3ioAdapter) GetContainer() (*v3io.Container, string)

func (*V3ioAdapter) GetLogger

func (a *V3ioAdapter) GetLogger(child string) logger.Logger

func (*V3ioAdapter) GetSchema

func (a *V3ioAdapter) GetSchema() *config.Schema

func (*V3ioAdapter) InitAppenderCache

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)