metrictbl

package
v0.0.0-...-034a78d Latest Latest
Warning

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

Go to latest
Published: Jul 31, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type TableFlusher

type TableFlusher interface {
	// FlushField writes a compressed field data to writer.
	FlushField(fieldID uint16, fieldType field.Type, data []byte, startSlot, endSlot int)
	// FlushSeries writes a full series, this will be called after writing all fields of this entry.
	FlushSeries(seriesID uint32)
	// FlushMetric writes a full metric-block, this will be called after writing all entries of this metric.
	FlushMetric(metricID uint32) error
	// Commit closes the writer, this will be called after writing all metric-blocks.
	Commit() error
}

TableFlusher is a wrapper of kv.Builder, provides ability to build a metric-table file to disk. Level1: metric-block Level2: TSEntry Level3: compressed field data

func NewTableFlusher

func NewTableFlusher(flusher kv.Flusher, interval int64) TableFlusher

NewTableFlusher returns a new TableWriter, interval is used to calculate the time-range of field data slots.`

type TableReader

type TableReader interface {
	ContainsMetric(metricID uint32, startTime, endTime int) bool
	ContainsTSEntry(uint32) bool
}

TableReader reads metrics from sstable.

Jump to

Keyboard shortcuts

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