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 DeleteMetrics(tfss []*storage.TagFilters) (int, error)
• func GetSeriesCount() (uint64, error)
• func Init()
• func InitWithoutMetrics()
• func RequestHandler(w http.ResponseWriter, r *http.Request) bool
• func SearchTagEntries(maxTagKeys, maxTagValues int) ([]storage.TagEntry, error)
• func SearchTagKeys(maxTagKeys int) ([]string, error)
• func SearchTagValues(tagKey []byte, maxTagValues int) ([]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 DeleteMetrics

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

DeleteMetrics deletes metrics matching tfss.

Returns the number of deleted metrics.

func GetSeriesCount

func GetSeriesCount() (uint64, error)

GetSeriesCount returns the number of time series in the storage.

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) ([]storage.TagEntry, error)

SearchTagEntries searches for tag entries.

func SearchTagKeys

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

SearchTagKeys searches for tag keys

func SearchTagValues

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

SearchTagValues searches for tag values for the given tagKey

func Stop

func Stop()

Stop stops the vmstorage