tsdb

Documentation

Index

• Constants
• func CreateTSDB(v3iocfg *config.V3ioConfig, dbconfig *config.DBPartConfig) 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(config bool, force bool) error
  • func (a *V3ioAdapter) GetContainer() (*v3io.Container, string)
  • func (a *V3ioAdapter) GetDBConfig() *config.DBPartConfig
  • func (a *V3ioAdapter) GetLogger(child string) logger.Logger
  • func (a *V3ioAdapter) Querier(_ context.Context, mint, maxt int64) (*querier.V3ioQuerier, error)
  • func (a *V3ioAdapter) StartTime() (int64, error)

Constants

const DB_CONFIG_PATH = "/dbconfig.json"

const DB_VERSION = "1.0"

Functions

func CreateTSDB

func CreateTSDB(v3iocfg *config.V3ioConfig, dbconfig *config.DBPartConfig) 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
	WaitForReady(ref uint64) 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) DeleteDB

func (a *V3ioAdapter) DeleteDB(config bool, force bool) error

func (*V3ioAdapter) GetContainer

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

func (*V3ioAdapter) GetDBConfig

func (a *V3ioAdapter) GetDBConfig() *config.DBPartConfig

func (*V3ioAdapter) GetLogger

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

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)