vmstorage

README

vmstorage performs the following tasks:

• Accepts inserts from vminsert and stores them to local storage.

• Performs select requests from vmselect.

Documentation

Index

• Variables
• func AddRows(mrs []storage.MetricRow) error
• func CheckTimeRange(tr storage.TimeRange) error
• func DeleteMetrics(tfss []*storage.TagFilters) (int, error)
• func GetSeriesCount(deadline uint64) (uint64, error)
• func GetTSDBStatusForDate(date uint64, topN int, deadline uint64) (*storage.TSDBStatus, error)
• func Init()
• func InitWithoutMetrics()
• func RequestHandler(w http.ResponseWriter, r *http.Request) bool
• func SearchTagEntries(maxTagKeys, maxTagValues int, deadline uint64) ([]storage.TagEntry, error)
• func SearchTagKeys(maxTagKeys int, deadline uint64) ([]string, error)
• func SearchTagValueSuffixes(tr storage.TimeRange, tagKey, tagValuePrefix []byte, delimiter byte, ...) ([]string, error)
• func SearchTagValues(tagKey []byte, maxTagValues int, deadline uint64) ([]string, error)
• func Stop()

Variables

var (

	// DataPath is a path to storage data.
	DataPath = flag.String("storageDataPath", "victoria-metrics-data", "Path to storage data")
)

var Storage *storage.Storage

Storage is a storage.

Every storage call must be wrapped into WG.Add(1) ... WG.Done() for proper graceful shutdown when Stop is called.

var WG syncwg.WaitGroup

WG must be incremented before Storage call.

Use syncwg instead of sync, since Add is called from concurrent goroutines.

Functions

func AddRows

func AddRows(mrs []storage.MetricRow) error

AddRows adds mrs to the storage.

func CheckTimeRange

func CheckTimeRange(tr storage.TimeRange) error

CheckTimeRange returns true if the given tr is denied for querying.

func DeleteMetrics

func DeleteMetrics(tfss []*storage.TagFilters) (int, error)

DeleteMetrics deletes metrics matching tfss.

Returns the number of deleted metrics.

func GetSeriesCount

func GetSeriesCount(deadline uint64) (uint64, error)

GetSeriesCount returns the number of time series in the storage.

func GetTSDBStatusForDate

func GetTSDBStatusForDate(date uint64, topN int, deadline uint64) (*storage.TSDBStatus, error)

GetTSDBStatusForDate returns TSDB status for the given date.

func Init

func Init()

Init initializes vmstorage.

func InitWithoutMetrics

func InitWithoutMetrics()

InitWithoutMetrics must be called instead of Init inside tests.

This allows multiple Init / Stop cycles.

func RequestHandler

func RequestHandler(w http.ResponseWriter, r *http.Request) bool

RequestHandler is a storage request handler.

func SearchTagEntries

func SearchTagEntries(maxTagKeys, maxTagValues int, deadline uint64) ([]storage.TagEntry, error)

SearchTagEntries searches for tag entries.

func SearchTagKeys

func SearchTagKeys(maxTagKeys int, deadline uint64) ([]string, error)

SearchTagKeys searches for tag keys

func SearchTagValueSuffixes

func SearchTagValueSuffixes(tr storage.TimeRange, tagKey, tagValuePrefix []byte, delimiter byte, maxTagValueSuffixes int, deadline uint64) ([]string, error)

SearchTagValueSuffixes returns all the tag value suffixes for the given tagKey and tagValuePrefix on the given tr.

This allows implementing https://graphite-api.readthedocs.io/en/latest/api.html#metrics-find or similar APIs.

func SearchTagValues

func SearchTagValues(tagKey []byte, maxTagValues int, deadline uint64) ([]string, error)

SearchTagValues searches for tag values for the given tagKey

func Stop

func Stop()

Stop stops the vmstorage