Documentation
¶
Index ¶
- func CreateTSDB(cfg *config.V3ioConfig, schema *config.Schema, container v3io.Container) error
- func NewContainer(v3ioURL string, numWorkers int, accessKey string, username string, ...) (v3io.Container, error)
- type Appender
- type DeleteParams
- 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(deleteParams DeleteParams) error
- func (a *V3ioAdapter) DeletePartitionsData(deleteParams *DeleteParams) 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) QuerierV2() (*pquerier.V3ioQuerier, error)
- func (a *V3ioAdapter) StartTime() (int64, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTSDB ¶
func CreateTSDB(cfg *config.V3ioConfig, schema *config.Schema, container v3io.Container) error
Types ¶
type Appender ¶
type Appender interface {
Add(l utils.Labels, t int64, v interface{}) (uint64, error)
AddFast(ref uint64, t int64, v interface{}) error
WaitForCompletion(timeout time.Duration) (int, error)
Commit() error
Rollback() error
Close()
}
The Appender interface provides batched appends against a storage.
type DeleteParams ¶ added in v0.9.17
type V3ioAdapter ¶
type V3ioAdapter struct {
HTTPTimeout time.Duration
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(deleteParams DeleteParams) error
Delete by time range can optionally specify metrics and filter by labels
func (*V3ioAdapter) DeletePartitionsData ¶ added in v0.9.17
func (a *V3ioAdapter) DeletePartitionsData(deleteParams *DeleteParams) error
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) QuerierV2 ¶ added in v0.8.3
func (a *V3ioAdapter) QuerierV2() (*pquerier.V3ioQuerier, error)
Create a Querier interface, used for time-series queries
func (*V3ioAdapter) StartTime ¶
func (a *V3ioAdapter) StartTime() (int64, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.