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.`
Click to show internal directories.
Click to hide internal directories.