tsdb

package
v0.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 30, 2018 License: Apache-2.0 Imports: 13 Imported by: 28

Documentation

Index

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

func (a *V3ioAdapter) DeleteDB(configExists bool, force 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 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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL