netstorage

Documentation

Index

• func DeleteSeries(at *auth.Token, sq *storage.SearchQuery, deadline Deadline) (int, error)
• func GetLabelEntries(at *auth.Token, deadline Deadline) ([]storage.TagEntry, bool, error)
• func GetLabelValues(at *auth.Token, labelName string, deadline Deadline) ([]string, bool, error)
• func GetLabels(at *auth.Token, deadline Deadline) ([]string, bool, error)
• func GetSeriesCount(at *auth.Token, deadline Deadline) (uint64, bool, error)
• func InitStorageNodes(addrs []string)
• func InitTmpBlocksDir(tmpDirPath string)
• func Stop()
• type Deadline
  • func NewDeadline(timeout time.Duration) Deadline
• type Result
• type Results
  • func ProcessSearchQuery(at *auth.Token, sq *storage.SearchQuery, fetchData bool, deadline Deadline) (*Results, bool, error)
  • func (rss *Results) Cancel()
  • func (rss *Results) Len() int
  • func (rss *Results) RunParallel(f func(rs *Result, workerID uint)) error

Functions

func DeleteSeries

func DeleteSeries(at *auth.Token, sq *storage.SearchQuery, deadline Deadline) (int, error)

DeleteSeries deletes time series matching the given sq.

func GetLabelEntries

func GetLabelEntries(at *auth.Token, deadline Deadline) ([]storage.TagEntry, bool, error)

GetLabelEntries returns all the label entries for at until the given deadline.

func GetLabelValues

func GetLabelValues(at *auth.Token, labelName string, deadline Deadline) ([]string, bool, error)

GetLabelValues returns label values for the given labelName until the given deadline.

func GetLabels

func GetLabels(at *auth.Token, deadline Deadline) ([]string, bool, error)

GetLabels returns labels until the given deadline.

func GetSeriesCount

func GetSeriesCount(at *auth.Token, deadline Deadline) (uint64, bool, error)

GetSeriesCount returns the number of unique series for the given at.

func InitStorageNodes

func InitStorageNodes(addrs []string)

InitStorageNodes initializes storage nodes' connections to the given addrs.

func InitTmpBlocksDir

func InitTmpBlocksDir(tmpDirPath string)

InitTmpBlocksDir initializes directory to store temporary search results.

It stores data in system-defined temporary directory if tmpDirPath is empty.

func Stop

func Stop()

Stop gracefully stops netstorage.

Types

type Deadline

type Deadline struct {
	Deadline time.Time
	Timeout  time.Duration
}

Deadline contains deadline with the corresponding timeout for pretty error messages.

func NewDeadline

func NewDeadline(timeout time.Duration) Deadline

NewDeadline returns deadline for the given timeout.

type Result

type Result struct {
	// The name of the metric.
	MetricName storage.MetricName

	// Values are sorted by Timestamps.
	Values     []float64
	Timestamps []int64

	// Marshaled MetricName. Used only for results sorting
	// in app/vmselect/promql
	MetricNameMarshaled []byte
}

Result is a single timeseries result.

ProcessSearchQuery returns Result slice.

type Results

type Results struct {
	// contains filtered or unexported fields
}

Results holds results returned from ProcessSearchQuery.

func ProcessSearchQuery

func ProcessSearchQuery(at *auth.Token, sq *storage.SearchQuery, fetchData bool, deadline Deadline) (*Results, bool, error)

ProcessSearchQuery performs sq on storage nodes until the given deadline.

func (*Results) Cancel

func (rss *Results) Cancel()

Cancel cancels rss work.

func (*Results) Len

func (rss *Results) Len() int

Len returns the number of results in rss.

func (*Results) RunParallel

func (rss *Results) RunParallel(f func(rs *Result, workerID uint)) error

RunParallel runs in parallel f for all the results from rss.

f shouldn't hold references to rs after returning. workerID is the id of the worker goroutine that calls f.

rss becomes unusable after the call to RunParallel.