apptest

package
v1.149.0-cluster Latest Latest
Warning

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

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

README

App Integration Tests

The apptest package contains the integration tests for the VictoriaMetrics applications (such as vmstorage, vminsert, and vmselect).

An integration test aims at verifying the behavior of an application as a whole, as opposed to a unit test that verifies the behavior of a building block of an application.

To achieve that an integration test starts an application in a separate process and then issues HTTP requests to it and verifies the responses, examines the metrics the app exposes and/or files it creates, etc.

Note that an object of testing may be not just a single app, but several apps working together. A good example is VictoriaMetrics cluster. An integration test may reproduce an arbitrary cluster configuration and verify how the components work together as a system.

The package provides a collection of helpers to start applications and make queries to them:

  • app.go - contains the generic code for starting an application and should not be used by integration tests directly.
  • {vmstorage,vminsert,etc}.go - build on top of app.go and provide the code for starting a specific application.
  • client.go - provides helper functions for sending HTTP requests to applications.

The integration tests themselves reside in tests/*_test.go files. Apart from having the _test suffix, there are no strict rules of how to name a file, but the name should reflect the prevailing purpose of the tests located in that file. For example, sharding_test.go aims at testing data sharding.

Since integration tests start applications in a separate process, they require the application binary files to be built and put into the bin directory. The build rule used for running integration tests, make apptest, accounts for that, it builds all application binaries before running the tests. But if you want to run the tests without make, i.e. by executing go test ./apptest/tests, you will need to build the binaries first (for example, by executing make all).

Not all binaries can be built from master branch, cluster binaries can be built only from cluster branch. Hence, not all test cases suitable to run in both branches:

  • If test is using binaries from cluster branch, then test name should be prefixed with TestCluster word
  • If test is using binaries from master branch, then test name should be prefixed with TestSingle word.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssertGraphiteMetricsExpand added in v1.122.26 

func AssertGraphiteMetricsExpand(tc *TestCase, app PrometheusQuerier, query, tenantID string, want []string)

AssertGraphiteMetricsFind expands metric names by sending a request to /graphite/metrics/expand and compares the result with the expected one.

func AssertGraphiteMetricsFind added in v1.122.26 

func AssertGraphiteMetricsFind(tc *TestCase, app PrometheusQuerier, query, tenantID string, want []GraphiteMetric)

AssertGraphiteMetricsFind finds metric names by sending a request to /graphite/metrics/find and compares the result with the expected one.

func AssertGraphiteMetricsIndex added in v1.122.26 

func AssertGraphiteMetricsIndex(tc *TestCase, app PrometheusQuerier, tenantID string, want []string)

AssertGraphiteMetricsIndex retrieves all metrics by sending a request to /graphite/metrics/index.json and compares the result with the expected one.

func AssertGraphiteRender added in v1.122.26 

func AssertGraphiteRender(tc *TestCase, app PrometheusQuerier, target, tenantID string, from, until, step int64, want []GraphiteRenderedTarget)

AssertGraphiteRender retieves metric raw data by sending a request to /graphite/render and compares the result with the expected one.

func AssertLabelValues added in v1.122.26 

func AssertLabelValues(tc *TestCase, app PrometheusQuerier, metricNameRE, labelName, tenantID string, start, end int64, want []string)

AssertLabelValues retrieves values for the label whose name is labelName for the series whose name mathes metricNameRE, compares the result with the expected one.

func AssertLabels added in v1.122.26 

func AssertLabels(tc *TestCase, app PrometheusQuerier, metricNameRE, tenantID string, start, end int64, want []string)

AssertLabels retrieves label names from the storage and compares the result with the expected one.

func AssertMetadata added in v1.122.26 

func AssertMetadata(tc *TestCase, app PrometheusQuerier, metricName, tenantID string, want map[string][]MetadataEntry)

func AssertMetricNamesStats added in v1.122.26 

func AssertMetricNamesStats(tc *TestCase, app PrometheusQuerier, metricNameRE, tenantID string, want []MetricNamesStatsRecord)

func AssertQueryResults added in v1.122.26 

func AssertQueryResults(tc *TestCase, app PrometheusQuerier, metricNameRE, tenantID string, start, end, step int64, want []*QueryResult)

AssertQueryResults sends a data query to storage and compares the query result with the expected one.

func AssertSeries added in v1.122.26 

func AssertSeries(tc *TestCase, app PrometheusQuerier, metricNameRE, tenantID string, start, end int64, want []map[string]string)

AssertSeries retrieves metric names from the storage and compares the result with the expected one.

func AssertSeriesCount added in v1.122.26 

func AssertSeriesCount(tc *TestCase, app PrometheusQuerier, tenantID string, start, end int64, want uint64)

AssertSeriesCount retrieves series count and compares it with expected one.

func StartVmbackup added in v1.102.23 

func StartVmbackup(instance, storageDataPath, snapshotCreateURL, dst string, output io.Writer) error

StartVmbackup starts the latest version of vmbackup with the given flags and waits until it exits.

The path to the binary can be provided via VMBACKUP_PATH environment variable. If the variable is not set, ../../bin/vmbackup-race will be used.

func StartVmctl added in v1.102.23 

func StartVmctl(instance string, flags []string, output io.Writer) error

StartVmctl starts the latest version of vmctl with the given flags and waits until it exits.

The path to the binary can be provided via VMCTL_PATH environment variable. If the variable is not set, ../../bin/vmctl-race will be used.

func StartVmrestore added in v1.102.23 

func StartVmrestore(instance, src, storageDataPath string, output io.Writer) error

StartVmrestore starts the latest version of vmrestore with the given flags and waits until it exits.

The path to the binary can be provided via VMRESTORE_PATH environment variable. If the variable is not set, ../../bin/vmrestore-race will be used.

Types

type APIV1AdminTSDBSnapshotResponse added in v1.102.18 

type APIV1AdminTSDBSnapshotResponse struct {
	Status string
	Data   *SnapshotData
}

APIV1AdminTSDBSnapshotResponse is an in-memory representation of the json response returned by the /api/v1/admin/tsdb/snapshot endpoint.

type AdminTenantsResponse added in v1.102.24 

type AdminTenantsResponse struct {
	Status string
	Data   []string
}

AdminTenantsResponse is an in-memory representation of the json response returned by the /api/v1/admin/tenants endpoint.

type AssertOptions added in v1.97.13 

type AssertOptions struct {
	Msg        string
	Got        func() any
	Want       any
	CmpOpts    []cmp.Option
	DoNotRetry bool
	Retries    int
	Period     time.Duration
	FailNow    bool
}

AssertOptions hold the assertion params, such as got and wanted values as well as the message that should be included into the assertion error message in case of failure.

In VictoriaMetrics (especially the cluster version) the inserted data does not become visible for querying right away. Therefore, the first comparisons may fail. AssertOptions allow to configure how many times the actual result must be retrieved and compared with the expected one and for long to wait between the retries. If these two params (`Retries` and `Period`) are not set, the default values will be used.

If it is known that the data is available, then the retry functionality can be disabled by setting the `DoNotRetry` field.

AssertOptions are used by the TestCase.Assert() method, and this method uses cmp.Diff() from go-cmp package for comparing got and wanted values. AssertOptions, therefore, allows to pass cmp.Options to cmp.Diff() via `CmpOpts` field.

Finally the `FailNow` field controls whether the assertion should fail using `testing.T.Errorf()` or `testing.T.Fatalf()`.

type Client 

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

Client is used for interacting with the apps over the network.

func NewClient 

func NewClient() *Client

NewClient creates a new client.

func (*Client) CloseConnections 

func (c *Client) CloseConnections()

CloseConnections closes client connections.

func (*Client) Delete added in v1.102.18 

func (c *Client) Delete(t *testing.T, url string) (string, int)

Delete sends an HTTP DELETE request and returns the response body and status code to the caller.

func (*Client) Get 

func (c *Client) Get(t *testing.T, url string, headers http.Header) (string, int)

Get sends an HTTP GET request, returns the response body and status code to the caller.

func (*Client) Post 

func (c *Client) Post(t *testing.T, url string, data []byte, headers http.Header) (string, int)

Post sends an HTTP POST request, returns the response body and status code to the caller.

func (*Client) PostForm 

func (c *Client) PostForm(t *testing.T, url string, data url.Values, headers http.Header) (string, int)

PostForm sends an HTTP POST request containing the POST-form data with attached getHeaders, returns the response body and status code to the caller.

func (*Client) Write added in v1.102.20 

func (c *Client) Write(t *testing.T, address string, data []string)

type ClusterOptions added in v1.97.15 

type ClusterOptions struct {
	Vmstorage1Instance string
	Vmstorage1Flags    []string
	Vmstorage2Instance string
	Vmstorage2Flags    []string
	VminsertInstance   string
	VminsertFlags      []string
	VmselectInstance   string
	VmselectFlags      []string
}

ClusterOptions holds the params for simple cluster configuration suitable for most tests.

The cluster consists of two vmstorages, one vminsert and one vmselect, no data replication.

Such configuration is suitable for tests that don't verify the cluster-specific behavior (such as sharding, replication, or multilevel vmselect) but instead just need a typical cluster configuration to verify some business logic (such as API surface, or MetricsQL). Such cluster tests usually come paired with corresponding vmsingle tests.

type GraphiteMetric added in v1.122.23 

type GraphiteMetric struct {
	Id            string
	Text          string
	AllowChildren int
	Expandable    int
	Leaf          int
}

type GraphiteMetricsExpandResponse added in v1.122.23 

type GraphiteMetricsExpandResponse = []string

GraphiteMetricsExpandResponse is an in-memory representation of the json response returned by the /graphite/metrics/expand endpoint.

type GraphiteMetricsFindResponse added in v1.122.23 

type GraphiteMetricsFindResponse = []GraphiteMetric

GraphiteMetricsIndexResponse is an in-memory representation of the json response returned by the /graphite/metrics/find endpoint.

type GraphiteMetricsIndexResponse added in v1.102.25 

type GraphiteMetricsIndexResponse = []string

GraphiteMetricsIndexResponse is an in-memory representation of the json response returned by the /graphite/metrics/index.json endpoint.

type GraphiteRenderResponse added in v1.122.23 

type GraphiteRenderResponse = []GraphiteRenderedTarget

GraphiteRenderResponse is an in-memory representation of the json response returned by the /graphite/render endpoint.

type GraphiteRenderedTarget added in v1.122.23 

type GraphiteRenderedTarget struct {
	Target     string
	Datapoints [][2]float64
}

type GraphiteTestData added in v1.122.26 

type GraphiteTestData struct {
	Samples             []string
	Step                int64
	WantMetricsIndex    []string
	WantMetricsFind     []GraphiteMetric
	WantMetricsExpand   []string
	WantRenderedTargets []GraphiteRenderedTarget
}

GraphiteTestData holds the data samples in Graphite Pickle format, distance between samples in milliseconds and expected responses for various Graphite API endpoints.

func GenerateGraphiteTestData added in v1.122.26 

func GenerateGraphiteTestData(prefix string, numMetrics, start, end int64) GraphiteTestData

GenerateGraphiteTestData generates Graphite test data.

type MetadataEntry added in v1.110.24 

type MetadataEntry struct {
	Type string
	Help string
	Unit string
}

type MetricNamesStatsRecord added in v1.102.16 

type MetricNamesStatsRecord struct {
	MetricName         string
	QueryRequestsCount uint64
}

MetricNamesStatsRecord is a record item for MetricNamesStatsResponse

type MetricNamesStatsResponse added in v1.102.16 

type MetricNamesStatsResponse struct {
	Records []MetricNamesStatsRecord
}

MetricNamesStatsResponse is an inmemory representation of the /api/v1/status/metric_names_stats API response

type PrometheusAPIV1LabelValuesResponse added in v1.102.26 

type PrometheusAPIV1LabelValuesResponse struct {
	Status    string
	IsPartial bool
	Data      []string
	Trace     *Trace
	ErrorType string
	Error     string
}

PrometheusAPIV1LabelValuesResponse is an inmemory representation of the /prometheus/api/v1/labels/.../values response.

func NewPrometheusAPIV1LabelValuesResponse added in v1.102.26 

func NewPrometheusAPIV1LabelValuesResponse(t *testing.T, s string) *PrometheusAPIV1LabelValuesResponse

NewPrometheusAPIV1LabelValuesResponse is a test helper function that creates a new instance of PrometheusAPIV1LabelValuesResponse by unmarshalling a json string.

type PrometheusAPIV1LabelsResponse added in v1.102.26 

type PrometheusAPIV1LabelsResponse struct {
	Status    string
	IsPartial bool
	Data      []string
	Trace     *Trace
	ErrorType string
	Error     string
}

PrometheusAPIV1LabelsResponse is an inmemory representation of the /prometheus/api/v1/labels response.

func NewPrometheusAPIV1LabelsResponse added in v1.102.26 

func NewPrometheusAPIV1LabelsResponse(t *testing.T, s string) *PrometheusAPIV1LabelsResponse

NewPrometheusAPIV1LabelsResponse is a test helper function that creates a new instance of PrometheusAPIV1LabelsResponse by unmarshalling a json string.

type PrometheusAPIV1Metadata added in v1.110.24 

type PrometheusAPIV1Metadata struct {
	Status    string
	IsPartial bool
	Data      map[string][]MetadataEntry
	Trace     *Trace
}

PrometheusAPIV1Metadata is an inmemory representation of the /prometheus/api/v1/metadata response.

func NewPrometheusAPIV1Metadata added in v1.110.24 

func NewPrometheusAPIV1Metadata(t *testing.T, s string) *PrometheusAPIV1Metadata

NewPrometheusAPIV1Metadata is a test helper function that creates a new instance of PrometheusAPIV1Metadata by unmarshalling a json string.

type PrometheusAPIV1QueryResponse added in v1.97.12 

type PrometheusAPIV1QueryResponse struct {
	Status    string
	Data      *QueryData
	ErrorType string
	Error     string
	IsPartial bool
}

PrometheusAPIV1QueryResponse is an inmemory representation of the /prometheus/api/v1/query or /prometheus/api/v1/query_range response.

func NewPrometheusAPIV1QueryResponse added in v1.97.12 

func NewPrometheusAPIV1QueryResponse(t *testing.T, s string) *PrometheusAPIV1QueryResponse

NewPrometheusAPIV1QueryResponse is a test helper function that creates a new instance of PrometheusAPIV1QueryResponse by unmarshalling a json string.

func (*PrometheusAPIV1QueryResponse) Sort added in v1.97.15 

func (pqr *PrometheusAPIV1QueryResponse) Sort()

Sort performs data.Result sort by metric labels

type PrometheusAPIV1SeriesCountResponse added in v1.102.26 

type PrometheusAPIV1SeriesCountResponse struct {
	Status    string
	IsPartial bool
	Data      []uint64
	Trace     *Trace
	ErrorType string
	Error     string
}

PrometheusAPIV1SeriesCountResponse is an inmemory representation of the /prometheus/api/v1/series/count response.

func NewPrometheusAPIV1SeriesCountResponse added in v1.102.26 

func NewPrometheusAPIV1SeriesCountResponse(t *testing.T, s string) *PrometheusAPIV1SeriesCountResponse

NewPrometheusAPIV1SeriesCountResponse is a test helper function that creates a new instance of PrometheusAPIV1SeriesCountResponse by unmarshalling a json string.

type PrometheusAPIV1SeriesResponse 

type PrometheusAPIV1SeriesResponse struct {
	Status    string
	IsPartial bool
	Data      []map[string]string
	Trace     *Trace
	ErrorType string
	Error     string
}

PrometheusAPIV1SeriesResponse is an inmemory representation of the /prometheus/api/v1/series response.

func NewPrometheusAPIV1SeriesResponse added in v1.97.12 

func NewPrometheusAPIV1SeriesResponse(t *testing.T, s string) *PrometheusAPIV1SeriesResponse

NewPrometheusAPIV1SeriesResponse is a test helper function that creates a new instance of PrometheusAPIV1SeriesResponse by unmarshalling a json string.

func (*PrometheusAPIV1SeriesResponse) Sort added in v1.97.13 

func (r *PrometheusAPIV1SeriesResponse) Sort() *PrometheusAPIV1SeriesResponse

Sort sorts the response data.

type PrometheusQuerier added in v1.97.12 

type PrometheusQuerier interface {
	PrometheusAPIV1Export(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse
	PrometheusAPIV1Query(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse
	PrometheusAPIV1QueryRange(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse
	PrometheusAPIV1Series(t *testing.T, matchQuery string, opts QueryOpts) *PrometheusAPIV1SeriesResponse
	PrometheusAPIV1SeriesCount(t *testing.T, opts QueryOpts) *PrometheusAPIV1SeriesCountResponse
	PrometheusAPIV1Labels(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1LabelsResponse
	PrometheusAPIV1LabelValues(t *testing.T, labelName, query string, opts QueryOpts) *PrometheusAPIV1LabelValuesResponse
	PrometheusAPIV1ExportNative(t *testing.T, query string, opts QueryOpts) []byte
	PrometheusAPIV1Metadata(t *testing.T, metric string, limit int, opts QueryOpts) *PrometheusAPIV1Metadata
	PrometheusAPIV1StatusMetricNamesStats(t *testing.T, limit, le, matchPattern string, opts QueryOpts) MetricNamesStatsResponse
	PrometheusAPIV1AdminTSDBDeleteSeries(t *testing.T, matchQuery string, opts QueryOpts)

	// TODO(@rtm0): Prometheus does not provide this API. Either move it to a
	// separate interface or rename this interface to allow for multiple querier
	// types.
	GraphiteMetricsIndex(t *testing.T, opts QueryOpts) GraphiteMetricsIndexResponse
	GraphiteMetricsFind(t *testing.T, query string, opts QueryOpts) GraphiteMetricsFindResponse
	GraphiteMetricsExpand(t *testing.T, query string, opts QueryOpts) GraphiteMetricsExpandResponse
	GraphiteRender(t *testing.T, target string, opts QueryOpts) GraphiteRenderResponse
	GraphiteTagsTagSeries(t *testing.T, record string, opts QueryOpts)
	GraphiteTagsTagMultiSeries(t *testing.T, records []string, opts QueryOpts)
}

PrometheusQuerier contains methods available to Prometheus-like HTTP API for Querying

type PrometheusWriteQuerier added in v1.97.13 

type PrometheusWriteQuerier interface {
	Writer
	PrometheusQuerier
	StorageFlusher
	StorageMerger
}

PrometheusWriteQuerier encompasses the methods for writing, flushing and querying the data.

type QueryData added in v1.97.12 

type QueryData struct {
	ResultType string
	Result     []*QueryResult
}

QueryData holds the query result along with its type.

type QueryOpts added in v1.97.12 

type QueryOpts struct {
	Tenant              string
	Timeout             string
	Start               string
	End                 string
	Time                string
	Step                string
	ExtraFilters        []string
	ExtraLabels         []string
	Trace               string
	ReduceMemUsage      string
	MaxLookback         string
	LatencyOffset       string
	Format              string
	NoCache             string
	Headers             http.Header
	From                string
	Until               string
	StorageStep         string
	DenyPartialResponse string
}

QueryOpts contains various params used for querying or ingesting data

type QueryResult added in v1.97.12 

type QueryResult struct {
	Metric  map[string]string
	Sample  *Sample   `json:"value"`
	Samples []*Sample `json:"values"`
}

QueryResult holds the metric name (in the form of label name-value collection) and its samples.

Sample or Samples field is set for /prometheus/api/v1/query or /prometheus/api/v1/query_range response respectively.

type Sample added in v1.97.12 

type Sample struct {
	Timestamp int64
	Value     float64
}

Sample is a timeseries value at a given timestamp.

func NewSample added in v1.97.12 

func NewSample(t *testing.T, timeStr string, value float64) *Sample

NewSample is a test helper function that creates a new sample out of time in RFC3339 format and a value.

func (*Sample) UnmarshalJSON added in v1.97.12 

func (s *Sample) UnmarshalJSON(b []byte) error

UnmarshalJSON populates the sample fields from a JSON string.

type SnapshotCreateResponse added in v1.102.18 

type SnapshotCreateResponse struct {
	Status   string
	Snapshot string
}

SnapshotCreateResponse is an in-memory representation of the json response returned by the /snapshot/create endpoint.

type SnapshotData added in v1.102.18 

type SnapshotData struct {
	Name string
}

SnapshotData holds the info about the snapshot created via /api/v1/admin/tsdb/snapshot endpoint.

type SnapshotDeleteAllResponse added in v1.102.18 

type SnapshotDeleteAllResponse struct {
	Status string
}

SnapshotDeleteAllResponse is an in-memory representation of the json response returned by the /snapshot/delete_all endpoint.

type SnapshotDeleteResponse added in v1.102.18 

type SnapshotDeleteResponse struct {
	Status string
	Msg    string
}

SnapshotDeleteResponse is an in-memory representation of the json response returned by the /snapshot/delete endpoint.

type SnapshotListResponse added in v1.102.18 

type SnapshotListResponse struct {
	Status    string
	Snapshots []string
}

SnapshotListResponse is an in-memory representation of the json response returned by the /snapshot/list endpoint.

type Stopper added in v1.97.12 

type Stopper interface {
	Stop()
}

Stopper is an interface of objects that needs to be stopped via Stop() call

type StorageFlusher added in v1.97.13 

type StorageFlusher interface {
	ForceFlush(t *testing.T)
}

StorageFlusher defines a method that forces the flushing of data inserted into the storage, so it becomes available for searching immediately.

type StorageMerger added in v1.102.17 

type StorageMerger interface {
	ForceMerge(t *testing.T)
}

StorageMerger defines a method that forces the merging of data inserted into the storage.

type TSDBStatusResponse added in v1.102.19 

type TSDBStatusResponse struct {
	IsPartial bool
	Data      TSDBStatusResponseData
}

TSDBStatusResponse is an in-memory representation of the json response returned by the /prometheus/api/v1/status/tsdb endpoint.

func (*TSDBStatusResponse) Sort added in v1.102.19 

func (tsr *TSDBStatusResponse) Sort()

Sort performs sorting of stats entries

type TSDBStatusResponseData added in v1.102.19 

type TSDBStatusResponseData struct {
	TotalSeries                  int
	TotalLabelValuePairs         int
	SeriesCountByMetricName      []TSDBStatusResponseMetricNameEntry
	SeriesCountByLabelName       []TSDBStatusResponseEntry
	SeriesCountByFocusLabelValue []TSDBStatusResponseEntry
	SeriesCountByLabelValuePair  []TSDBStatusResponseEntry
	LabelValueCountByLabelName   []TSDBStatusResponseEntry
}

TSDBStatusResponseData is a part of TSDBStatusResponse

type TSDBStatusResponseEntry added in v1.102.19 

type TSDBStatusResponseEntry struct {
	Name  string
	Count int
}

TSDBStatusResponseEntry defines stats entry for TSDBStatusResponseData

type TSDBStatusResponseMetricNameEntry added in v1.102.19 

type TSDBStatusResponseMetricNameEntry struct {
	Name                 string
	Count                int
	RequestsCount        int
	LastRequestTimestamp int
}

TSDBStatusResponseMetricNameEntry defines metric names stats entry for TSDBStatusResponseData

type TestCase 

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

TestCase holds the state and defines clean-up procedure common for all test cases.

func NewTestCase 

func NewTestCase(t *testing.T) *TestCase

NewTestCase creates a new test case.

func (*TestCase) Assert added in v1.97.13 

func (tc *TestCase) Assert(opts *AssertOptions)

Assert compares the actual result with the expected one possibly multiple times in order to account for the fact that the inserted data does not become available for querying right away (especially in cluster version of VictoriaMetrics).

func (*TestCase) Client 

func (tc *TestCase) Client() *Client

Client returns an instance of the client that can be used for interacting with the app(s) under test.

func (*TestCase) Dir 

func (tc *TestCase) Dir() string

Dir returns the directory name that should be used by as the -storageDataDir.

func (*TestCase) ForceFlush added in v1.97.14 

func (tc *TestCase) ForceFlush(apps ...*Vmstorage)

ForceFlush flushes zero or more storages.

func (*TestCase) MustStartCluster added in v1.97.15 

func (tc *TestCase) MustStartCluster(opts *ClusterOptions) *Vmcluster

MustStartCluster starts a typical cluster configuration with custom flags.

func (*TestCase) MustStartCluster_v1_132_0 added in v1.122.24 

func (tc *TestCase) MustStartCluster_v1_132_0(opts *ClusterOptions) *Vmcluster

MustStartCluster_v1_132_0 starts a cluster with vmstorage-v1.132.0 with custom flags.

func (*TestCase) MustStartDefaultCluster added in v1.97.13 

func (tc *TestCase) MustStartDefaultCluster() *Vmcluster

MustStartDefaultCluster starts a typical cluster configuration with default flags.

func (*TestCase) MustStartDefaultRWVmagent added in v1.122.22 

func (tc *TestCase) MustStartDefaultRWVmagent(instance string, flags []string) *Vmagent

MustStartDefaultRWVmagent is a test helper function that starts an instance of vmagent with defaults suitable for remote-write tests.

func (*TestCase) MustStartDefaultVmsingle added in v1.97.13 

func (tc *TestCase) MustStartDefaultVmsingle() *Vmsingle

MustStartDefaultVmsingle is a test helper function that starts an instance of vmsingle with defaults suitable for most tests.

func (*TestCase) MustStartVmagent added in v1.102.19 

func (tc *TestCase) MustStartVmagent(instance string, flags []string, promScrapeConfigFileYAML string) *Vmagent

MustStartVmagent is a test helper function that starts an instance of vmagent and fails the test if the app fails to start.

func (*TestCase) MustStartVmauth added in v1.102.13 

func (tc *TestCase) MustStartVmauth(instance string, flags []string, configFileYAML string) *Vmauth

MustStartVmauth is a test helper function that starts an instance of vmauth and fails the test if the app fails to start.

func (*TestCase) MustStartVmbackup added in v1.102.23 

func (tc *TestCase) MustStartVmbackup(instance, storageDataPath, snapshotCreateURL, dst string)

MustStartVmbackup is a test helper that starts an instance of vmbackup and waits until the app exits. It fails the test if the app fails to start or exits with non zero code.

func (*TestCase) MustStartVmctl added in v1.102.23 

func (tc *TestCase) MustStartVmctl(instance string, flags []string)

MustStartVmctl is a test helper function that starts an instance of vmctl

func (*TestCase) MustStartVminsert added in v1.97.12 

func (tc *TestCase) MustStartVminsert(instance string, flags []string) *Vminsert

MustStartVminsert is a test helper function that starts an instance of vminsert and fails the test if the app fails to start.

func (*TestCase) MustStartVmrestore added in v1.102.23 

func (tc *TestCase) MustStartVmrestore(instance, src, storageDataPath string)

MustStartVmrestore is a test helper that starts an instance of vmrestore and waits until the app exits. It fails the test if the app fails to start or exits with non zero code.

func (*TestCase) MustStartVmselect added in v1.97.12 

func (tc *TestCase) MustStartVmselect(instance string, flags []string) *Vmselect

MustStartVmselect is a test helper function that starts an instance of vmselect (latest version) and fails the test if the app fails to start.

func (*TestCase) MustStartVmsingle added in v1.97.12 

func (tc *TestCase) MustStartVmsingle(instance string, flags []string) *Vmsingle

MustStartVmsingle is a test helper function that starts an instance of vmsingle (latest version) and fails the test if the app fails to start.

func (*TestCase) MustStartVmsingle_v1_132_0 added in v1.122.24 

func (tc *TestCase) MustStartVmsingle_v1_132_0(instance string, flags []string) *Vmsingle

MustStartVmsingle_v1_132_0 is a test helper function that starts an instance of vmsingle-v1.132.0 (last version that uses legacy index) and fails the test if the app fails to start.

func (*TestCase) MustStartVmstorage added in v1.97.12 

func (tc *TestCase) MustStartVmstorage(instance string, flags []string) *Vmstorage

MustStartVmstorage is a test helper function that starts an instance of vmstorage (latest version) and fails the test if the app fails to start.

func (*TestCase) MustStartVmstorage_v1_132_0 added in v1.122.24 

func (tc *TestCase) MustStartVmstorage_v1_132_0(instance string, flags []string) *Vmstorage

MustStartVmstorage_v1_132_0 is a test helper function that starts an instance of vmstorage-v1.132.0 (last version that uses legacy index) and fails the test if the app fails to start.

func (*TestCase) Stop added in v1.97.12 

func (tc *TestCase) Stop()

Stop performs the test case clean up, such as closing all client connections and removing the -storageDataDir directory.

Note that the -storageDataDir is not removed in case of test case failure to allow for further manual debugging.

func (*TestCase) StopApp added in v1.97.14 

func (tc *TestCase) StopApp(instance string)

StopApp stops the app identified by the `instance` name and removes it from the collection of started apps.

func (*TestCase) StopPrometheusWriteQuerier added in v1.102.14 

func (tc *TestCase) StopPrometheusWriteQuerier(pwq PrometheusWriteQuerier)

StopPrometheusWriteQuerier stop all apps that are a part of the pwq.

func (*TestCase) T added in v1.97.14 

func (tc *TestCase) T() *testing.T

T returns the test state.

type TestData added in v1.122.26 

type TestData struct {
	Samples              []string
	Step                 int64
	WantSeries           []map[string]string
	WantLabels           []string
	WantLabelValues      []string
	WantQueryResults     []*QueryResult
	WantMetadata         map[string][]MetadataEntry
	WantMetricNamesStats []MetricNamesStatsRecord
}

func GenerateTestData added in v1.122.26 

func GenerateTestData(prefix string, numMetrics, start, end int64) TestData

type Trace added in v1.97.14 

type Trace struct {
	DurationMsec float64 `json:"duration_msec"`
	Message      string
	Children     []*Trace
}

Trace provides the description and the duration of some unit of work that has been performed during the request processing.

func (*Trace) Contains added in v1.97.14 

func (t *Trace) Contains(s string) int

Contains counts how many trace messages contain substring s.

func (*Trace) String added in v1.97.14 

func (t *Trace) String() string

String returns string representation of the trace.

type Vmagent added in v1.102.19 

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

Vmagent holds the state of a vmagent app and provides vmagent-specific functions.

func StartVmagent added in v1.102.19 

func StartVmagent(instance string, flags []string, cli *Client, promScrapeConfigFilePath string, output io.Writer) (*Vmagent, error)

StartVmagent starts the latest version of vmagent.

The path to the binary can be provided via VMAGENT_PATH environment variable. If the variable is not set, ../../bin/vmagent-race will be used.

func (*Vmagent) APIV1ImportPrometheus added in v1.102.19 

func (app *Vmagent) APIV1ImportPrometheus(t *testing.T, records []string, opts QueryOpts)

APIV1ImportPrometheus is a test helper function that inserts a collection of records in Prometheus text exposition format for the given tenant by sending a HTTP POST request to /api/v1/import/prometheus vmagent endpoint.

The call is blocked until the data is flushed to vmstorage or the timeout is reached.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1importprometheus

func (*Vmagent) APIV1ImportPrometheusNoWaitFlush added in v1.102.19 

func (app *Vmagent) APIV1ImportPrometheusNoWaitFlush(t *testing.T, records []string, opts QueryOpts)

APIV1ImportPrometheusNoWaitFlush is a test helper function that inserts a collection of records in Prometheus text exposition format for the given tenant by sending a HTTP POST request to /api/v1/import/prometheus vmagent endpoint.

The call accepts the records but does not guarantee successful flush to vmstorage. Flushing may still be in progress on the function return.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1importprometheus

func (Vmagent) GetIntMetric added in v1.122.23 

func (c Vmagent) GetIntMetric(t *testing.T, metricName string) int

GetIntMetric retrieves the value of a metric served by an app at /metrics URL. The value is then converted to int.

func (Vmagent) GetMetric added in v1.122.23 

func (c Vmagent) GetMetric(t *testing.T, metricName string) float64

GetMetric retrieves the value of a metric served by an app at /metrics URL.

func (Vmagent) GetMetricsByPrefix added in v1.122.23 

func (c Vmagent) GetMetricsByPrefix(t *testing.T, prefix string) []float64

GetMetricsByPrefix retrieves the values of all metrics that start with given prefix.

func (Vmagent) GetMetricsByRegexp added in v1.122.23 

func (c Vmagent) GetMetricsByRegexp(t *testing.T, re *regexp.Regexp) []float64

func (*Vmagent) HTTPAddr added in v1.110.22 

func (app *Vmagent) HTTPAddr() string

HTTPAddr returns the address at which the vmagent process is listening for http connections.

func (Vmagent) Name added in v1.102.19 

func (app Vmagent) Name() string

Name returns the application instance name.

func (*Vmagent) PrometheusAPIV1Write added in v1.122.21 

func (app *Vmagent) PrometheusAPIV1Write(t *testing.T, wr prompb.WriteRequest, opts QueryOpts)

PrometheusAPIV1Write is a test helper function that inserts a collection of records in Prometheus remote-write format by sending a HTTP POST request to /prometheus/api/v1/write vmagent endpoint.

func (*Vmagent) ReloadRelabelConfigs added in v1.102.24 

func (app *Vmagent) ReloadRelabelConfigs(t *testing.T)

ReloadRelabelConfigs sends SIGHUP to trigger relabel config reload and waits until vmagent_relabel_config_reloads_total increases. Fails the test if no reload is detected within 3 seconds.

func (*Vmagent) RemoteWritePacketsDroppedTotal added in v1.102.19 

func (app *Vmagent) RemoteWritePacketsDroppedTotal(t *testing.T) int

RemoteWritePacketsDroppedTotal sums up the total number of dropped remote write packets.

func (*Vmagent) RemoteWritePendingInmemoryBlocks added in v1.110.16 

func (app *Vmagent) RemoteWritePendingInmemoryBlocks(t *testing.T, url string) int

RemoteWritePendingInmemoryBlocks sums up the total number of pending in-memory blocks for given remote write URL.

func (*Vmagent) RemoteWriteRequests added in v1.110.16 

func (app *Vmagent) RemoteWriteRequests(t *testing.T, url string) int

RemoteWriteRequests sums up the total number of sending requests for given remote write URL.

func (*Vmagent) RemoteWriteRequestsRetriesCountTotal added in v1.102.19 

func (app *Vmagent) RemoteWriteRequestsRetriesCountTotal(t *testing.T) int

RemoteWriteRequestsRetriesCountTotal sums up the total retries for remote write requests.

func (*Vmagent) RemoteWriteSamplesDropped added in v1.110.16 

func (app *Vmagent) RemoteWriteSamplesDropped(t *testing.T, url string) int

RemoteWriteSamplesDropped sums up the total number of dropped remote write samples for given remote write URL.

func (Vmagent) Stop added in v1.102.19 

func (app Vmagent) Stop()

Stop sends the app process a SIGINT signal and waits until it terminates gracefully.

func (Vmagent) String added in v1.102.19 

func (app Vmagent) String() string

String returns the string representation of the app state.

type Vmauth added in v1.102.13 

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

Vmauth holds the state of a vmauth app and provides vmauth-specific functions.

func StartVmauth added in v1.102.13 

func StartVmauth(instance string, flags []string, cli *Client, configFilePath string, output io.Writer) (*Vmauth, error)

StartVmauth starts the latest version of vmauth.

The path to the binary can be provided via VMAUTH_PATH environment variable. If the variable is not set, ../../bin/vmauth-race will be used.

func (*Vmauth) GetHTTPListenAddr added in v1.102.13 

func (app *Vmauth) GetHTTPListenAddr() string

GetHTTPListenAddr returns listen http addr

func (Vmauth) GetIntMetric added in v1.122.23 

func (c Vmauth) GetIntMetric(t *testing.T, metricName string) int

GetIntMetric retrieves the value of a metric served by an app at /metrics URL. The value is then converted to int.

func (Vmauth) GetMetric added in v1.122.23 

func (c Vmauth) GetMetric(t *testing.T, metricName string) float64

GetMetric retrieves the value of a metric served by an app at /metrics URL.

func (Vmauth) GetMetricsByPrefix added in v1.122.23 

func (c Vmauth) GetMetricsByPrefix(t *testing.T, prefix string) []float64

GetMetricsByPrefix retrieves the values of all metrics that start with given prefix.

func (Vmauth) GetMetricsByRegexp added in v1.122.23 

func (c Vmauth) GetMetricsByRegexp(t *testing.T, re *regexp.Regexp) []float64

func (Vmauth) Name added in v1.102.13 

func (app Vmauth) Name() string

Name returns the application instance name.

func (Vmauth) Stop added in v1.102.13 

func (app Vmauth) Stop()

Stop sends the app process a SIGINT signal and waits until it terminates gracefully.

func (Vmauth) String added in v1.102.13 

func (app Vmauth) String() string

String returns the string representation of the app state.

func (*Vmauth) UpdateConfiguration added in v1.102.13 

func (app *Vmauth) UpdateConfiguration(t *testing.T, configFileYAML string)

UpdateConfiguration updates the vmauth configuration file with the provided YAML content, sends SIGHUP to trigger config reload and waits until vmauth_config_last_reload_total increases. Fails the test if no reload is detected within 2 seconds.

type Vmcluster added in v1.102.14 

type Vmcluster struct {
	*Vminsert
	*Vmselect
	Vmstorages []*Vmstorage
}

Vmcluster represents a typical cluster setup: several vmstorage replicas, one vminsert, and one vmselect.

Both Vmsingle and Vmcluster implement the PrometheusWriteQuerier used in business logic tests to abstract out the infrastructure.

This type is not suitable for infrastructure tests where custom cluster setups are often required.

func (Vmcluster) APIV1AdminTenants added in v1.122.23 

func (c Vmcluster) APIV1AdminTenants(t *testing.T, opts QueryOpts) *AdminTenantsResponse

APIV1AdminTenants retrieves the list of tenants by sending a request to /admin/tenants endpoint.

func (*Vmcluster) ForceFlush added in v1.102.14 

func (c *Vmcluster) ForceFlush(t *testing.T)

ForceFlush forces the ingested data to become visible for searching immediately.

func (*Vmcluster) ForceMerge added in v1.102.17 

func (c *Vmcluster) ForceMerge(t *testing.T)

ForceMerge is a test helper function that forces the merging of parts.

func (Vmcluster) GraphiteMetricsExpand added in v1.122.23 

func (c Vmcluster) GraphiteMetricsExpand(t *testing.T, query string, opts QueryOpts) GraphiteMetricsExpandResponse

GraphiteMetricsExpand expands the given query with matching paths by sending a request to /graphite/metrics/expand endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api and https://graphite.readthedocs.io/en/latest/metrics_api.html#metrics-expand

func (Vmcluster) GraphiteMetricsFind added in v1.122.23 

func (c Vmcluster) GraphiteMetricsFind(t *testing.T, query string, opts QueryOpts) GraphiteMetricsFindResponse

GraphiteMetricsFind finds metrics under a given path by sending a request to /metrics/find endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api and https://graphite.readthedocs.io/en/latest/metrics_api.html#metrics-find

func (Vmcluster) GraphiteMetricsIndex added in v1.122.23 

func (c Vmcluster) GraphiteMetricsIndex(t *testing.T, opts QueryOpts) GraphiteMetricsIndexResponse

GraphiteMetricsIndex retrieves the list of all metrics by sending a request to /graphite/metrics/index.json endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api

func (Vmcluster) GraphiteRender added in v1.122.23 

func (c Vmcluster) GraphiteRender(t *testing.T, target string, opts QueryOpts) GraphiteRenderResponse

GraphiteRender retrieves the raw metric data by sending a request to /graphite/render endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#render-api and https://graphite-api.readthedocs.io/en/latest/api.html#the-render-api-render

func (Vmcluster) GraphiteTagsTagMultiSeries added in v1.122.23 

func (c Vmcluster) GraphiteTagsTagMultiSeries(t *testing.T, records []string, opts QueryOpts)

GraphiteTagsTagMultiSeries is a test helper function that registers Graphite tags for a multiple time series by sending a request to /graphite/tags/tagSeries endpoint.

func (Vmcluster) GraphiteTagsTagSeries added in v1.122.23 

func (c Vmcluster) GraphiteTagsTagSeries(t *testing.T, record string, opts QueryOpts)

GraphiteTagsTagSeries is a test helper function that registers Graphite tags for a single time series by sending a request to /graphite/tags/tagSeries endpoint.

func (Vmcluster) GraphiteWrite added in v1.122.23 

func (c Vmcluster) GraphiteWrite(t *testing.T, records []string, _ QueryOpts)

GraphiteWrite is a test helper function that sends a collection of records to graphiteListenAddr port.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#ingesting

func (Vmcluster) InfluxWrite added in v1.122.23 

func (c Vmcluster) InfluxWrite(t *testing.T, records []string, opts QueryOpts)

InfluxWrite is a test helper function that inserts a collection of records in Influx line format by sending a HTTP POST request to /influx/write endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#influxwrite

func (Vmcluster) OpenTSDBAPIPut added in v1.122.23 

func (c Vmcluster) OpenTSDBAPIPut(t *testing.T, records []string, opts QueryOpts)

OpenTSDBAPIPut is a test helper function that inserts a collection of records in OpenTSDB format for the given tenant by sending an HTTP POST request to /opentsdb/api/put vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vmcluster) OpentelemetryV1Metrics added in v1.122.23 

func (c Vmcluster) OpentelemetryV1Metrics(t *testing.T, md otlppb.MetricsData, opts QueryOpts)

OpentelemetryV1Metrics is a test helper function that inserts a collection of records in Opentelemetry protocol format by sending a HTTP POST request to /opentelemetry/v1/metrics vminsert endpoint.

func (Vmcluster) PrometheusAPIV1AdminStatusMetricNamesStatsReset added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1AdminStatusMetricNamesStatsReset(t *testing.T, opts QueryOpts)

PrometheusAPIV1AdminStatusMetricNamesStatsReset resets the metric name usage stats by sending a request to /prometheus/api/v1/admin/status/metric_names_stats/reset endpoint

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#track-ingested-metrics-usage

func (Vmcluster) PrometheusAPIV1AdminTSDBDeleteSeries added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1AdminTSDBDeleteSeries(t *testing.T, matchQuery string, opts QueryOpts)

PrometheusAPIV1AdminTSDBDeleteSeries deletes the series that match the query by sending a request to /prometheus/api/v1/admin/tsdb/delete_series.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1admintsdbdelete_series

func (Vmcluster) PrometheusAPIV1Export added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1Export(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1Export is a test helper function that performs the export of raw samples in JSON line format by sending a request to /prometheus/api/v1/export endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1export

func (Vmcluster) PrometheusAPIV1ExportNative added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1ExportNative(t *testing.T, query string, opts QueryOpts) []byte

PrometheusAPIV1ExportNative is a test helper function that performs the export of raw samples in native binary format by sending a request to /prometheus/api/v1/export/native endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1exportnative

func (Vmcluster) PrometheusAPIV1ImportCSV added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1ImportCSV(t *testing.T, records []string, opts QueryOpts)

PrometheusAPIV1ImportCSV is a test helper function that inserts a collection of records in CSV format for the given tenant by sending an HTTP POST request to prometheus/api/v1/import/csv vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vmcluster) PrometheusAPIV1ImportNative added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1ImportNative(t *testing.T, data []byte, opts QueryOpts)

PrometheusAPIV1ImportNative is a test helper function that inserts a collection of records in Native format for the given tenant by sending an HTTP POST request to prometheus/api/v1/import/native vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vmcluster) PrometheusAPIV1ImportPrometheus added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1ImportPrometheus(t *testing.T, records []string, opts QueryOpts)

PrometheusAPIV1ImportPrometheus is a test helper function that inserts a collection of records in Prometheus text exposition format for the given tenant by sending a HTTP POST request to /prometheus/api/v1/import/prometheus vminsert endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1importprometheus

func (Vmcluster) PrometheusAPIV1LabelValues added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1LabelValues(t *testing.T, labelName, matchQuery string, opts QueryOpts) *PrometheusAPIV1LabelValuesResponse

PrometheusAPIV1LabelValues retrieves the labels values for the metrics that match the query by sending a request to /prometheus/api/v1/label/.../values endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1labelvalues

func (Vmcluster) PrometheusAPIV1Labels added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1Labels(t *testing.T, matchQuery string, opts QueryOpts) *PrometheusAPIV1LabelsResponse

PrometheusAPIV1Labels retrieves the label names for time series that match a query by sending a request to /prometheus/api/v1/labels endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1labels

func (Vmcluster) PrometheusAPIV1Metadata added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1Metadata(t *testing.T, metric string, limit int, opts QueryOpts) *PrometheusAPIV1Metadata

PrometheusAPIV1Metadata retrieves metadata for the given metric by sending a request to /prometheus/api/v1/metadata endpoint.

func (Vmcluster) PrometheusAPIV1Query added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1Query(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1Query is a test helper function that performs PromQL/MetricsQL instant query by sending a request to /prometheus/api/v1/query endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1query

func (Vmcluster) PrometheusAPIV1QueryRange added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1QueryRange(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1QueryRange is a test helper function that performs PromQL/MetricsQL range query by sending a request to /prometheus/api/v1/query_range endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1query_range

func (Vmcluster) PrometheusAPIV1Series added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1Series(t *testing.T, matchQuery string, opts QueryOpts) *PrometheusAPIV1SeriesResponse

PrometheusAPIV1Series retrieves list of time series that match the query by sending a request to /prometheus/api/v1/series endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1series

func (Vmcluster) PrometheusAPIV1SeriesCount added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1SeriesCount(t *testing.T, opts QueryOpts) *PrometheusAPIV1SeriesCountResponse

PrometheusAPIV1SeriesCount retrieves the total number of time series by sending a request to /prometheus/api/v1/series/count endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1series

func (Vmcluster) PrometheusAPIV1StatusMetricNamesStats added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1StatusMetricNamesStats(t *testing.T, limit, le, matchPattern string, opts QueryOpts) MetricNamesStatsResponse

PrometheusAPIV1StatusMetricNamesStats sends a query to /prometheus/api/v1/status/metric_names_stats endpoint and returns the metric usage stats response for given params.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#track-ingested-metrics-usage

func (Vmcluster) PrometheusAPIV1StatusTSDB added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1StatusTSDB(t *testing.T, matchQuery string, date string, topN string, opts QueryOpts) TSDBStatusResponse

PrometheusAPIV1StatusTSDB retrieves the TSDB status for the time series that match the query on the given date by sending a request to /prometheus/api/v1/status/tsdb endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#tsdb-stats

func (Vmcluster) PrometheusAPIV1Write added in v1.122.23 

func (c Vmcluster) PrometheusAPIV1Write(t *testing.T, wr prompb.WriteRequest, opts QueryOpts)

PrometheusAPIV1Write is a test helper function that inserts a collection of records in Prometheus remote-write format by sending a HTTP POST request to /prometheus/api/v1/write vminsert endpoint.

func (Vmcluster) ZabbixConnectorHistory added in v1.122.23 

func (c Vmcluster) ZabbixConnectorHistory(t *testing.T, records []string, opts QueryOpts)

ZabbixConnectorHistory is a test helper function that inserts a collection of records in zabbixconnector format by sending a HTTP POST request to /zabbixconnector/api/v1/history vmsingle endpoint.

type Vminsert 

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

Vminsert holds the state of a vminsert app and provides vminsert-specific functions.

func StartVminsert 

func StartVminsert(instance string, flags []string, cli *Client, output io.Writer) (*Vminsert, error)

StartVminsert starts the latest version of vminsert.

The path to the binary can be provided via VMINSERT_PATH environment variable. If the variable is not set, ../../bin/vminsert-race will be used.

func (*Vminsert) ClusternativeListenAddr added in v1.97.14 

func (app *Vminsert) ClusternativeListenAddr() string

ClusternativeListenAddr returns the address at which the vminsert process is listening for connections from other vminsert apps.

func (Vminsert) GetIntMetric added in v1.122.23 

func (c Vminsert) GetIntMetric(t *testing.T, metricName string) int

GetIntMetric retrieves the value of a metric served by an app at /metrics URL. The value is then converted to int.

func (Vminsert) GetMetric added in v1.122.23 

func (c Vminsert) GetMetric(t *testing.T, metricName string) float64

GetMetric retrieves the value of a metric served by an app at /metrics URL.

func (Vminsert) GetMetricsByPrefix added in v1.122.23 

func (c Vminsert) GetMetricsByPrefix(t *testing.T, prefix string) []float64

GetMetricsByPrefix retrieves the values of all metrics that start with given prefix.

func (Vminsert) GetMetricsByRegexp added in v1.122.23 

func (c Vminsert) GetMetricsByRegexp(t *testing.T, re *regexp.Regexp) []float64

func (Vminsert) GraphiteWrite added in v1.102.20 

func (c Vminsert) GraphiteWrite(t *testing.T, records []string, _ QueryOpts)

GraphiteWrite is a test helper function that sends a collection of records to graphiteListenAddr port.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#ingesting

func (*Vminsert) HTTPAddr added in v1.102.23 

func (app *Vminsert) HTTPAddr() string

HTTPAddr returns the address at which the vminsert process is listening for incoming HTTP requests.

func (Vminsert) InfluxWrite added in v1.97.15 

func (c Vminsert) InfluxWrite(t *testing.T, records []string, opts QueryOpts)

InfluxWrite is a test helper function that inserts a collection of records in Influx line format by sending a HTTP POST request to /influx/write endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#influxwrite

func (Vminsert) Name added in v1.97.14 

func (app Vminsert) Name() string

Name returns the application instance name.

func (Vminsert) OpenTSDBAPIPut added in v1.102.20 

func (c Vminsert) OpenTSDBAPIPut(t *testing.T, records []string, opts QueryOpts)

OpenTSDBAPIPut is a test helper function that inserts a collection of records in OpenTSDB format for the given tenant by sending an HTTP POST request to /opentsdb/api/put vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vminsert) OpentelemetryV1Metrics added in v1.122.22 

func (c Vminsert) OpentelemetryV1Metrics(t *testing.T, md otlppb.MetricsData, opts QueryOpts)

OpentelemetryV1Metrics is a test helper function that inserts a collection of records in Opentelemetry protocol format by sending a HTTP POST request to /opentelemetry/v1/metrics vminsert endpoint.

func (Vminsert) PrometheusAPIV1ImportCSV added in v1.102.20 

func (c Vminsert) PrometheusAPIV1ImportCSV(t *testing.T, records []string, opts QueryOpts)

PrometheusAPIV1ImportCSV is a test helper function that inserts a collection of records in CSV format for the given tenant by sending an HTTP POST request to prometheus/api/v1/import/csv vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vminsert) PrometheusAPIV1ImportNative added in v1.102.23 

func (c Vminsert) PrometheusAPIV1ImportNative(t *testing.T, data []byte, opts QueryOpts)

PrometheusAPIV1ImportNative is a test helper function that inserts a collection of records in Native format for the given tenant by sending an HTTP POST request to prometheus/api/v1/import/native vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vminsert) PrometheusAPIV1ImportPrometheus 

func (c Vminsert) PrometheusAPIV1ImportPrometheus(t *testing.T, records []string, opts QueryOpts)

PrometheusAPIV1ImportPrometheus is a test helper function that inserts a collection of records in Prometheus text exposition format for the given tenant by sending a HTTP POST request to /prometheus/api/v1/import/prometheus vminsert endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1importprometheus

func (Vminsert) PrometheusAPIV1Write added in v1.97.13 

func (c Vminsert) PrometheusAPIV1Write(t *testing.T, wr prompb.WriteRequest, opts QueryOpts)

PrometheusAPIV1Write is a test helper function that inserts a collection of records in Prometheus remote-write format by sending a HTTP POST request to /prometheus/api/v1/write vminsert endpoint.

func (Vminsert) Stop 

func (app Vminsert) Stop()

Stop sends the app process a SIGINT signal and waits until it terminates gracefully.

func (*Vminsert) String 

func (app *Vminsert) String() string

String returns the string representation of the vminsert app state.

func (Vminsert) ZabbixConnectorHistory added in v1.110.28 

func (c Vminsert) ZabbixConnectorHistory(t *testing.T, records []string, opts QueryOpts)

ZabbixConnectorHistory is a test helper function that inserts a collection of records in zabbixconnector format by sending a HTTP POST request to /zabbixconnector/api/v1/history vmsingle endpoint.

type Vmselect 

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

Vmselect holds the state of a vmselect app and provides vmselect-specific functions.

func StartVmselect 

func StartVmselect(instance string, flags []string, cli *Client, output io.Writer) (*Vmselect, error)

StartVmselect starts the latest version of vmselect.

The path to the binary can be provided via VMSELECT_PATH environment variable. If the variable is not set, ../../bin/vmselect-race will be used.

func (Vmselect) APIV1AdminTenants added in v1.102.24 

func (c Vmselect) APIV1AdminTenants(t *testing.T, opts QueryOpts) *AdminTenantsResponse

APIV1AdminTenants retrieves the list of tenants by sending a request to /admin/tenants endpoint.

func (*Vmselect) ClusternativeListenAddr 

func (app *Vmselect) ClusternativeListenAddr() string

ClusternativeListenAddr returns the address at which the vmselect process is listening for connections from other vmselect apps.

func (Vmselect) GetIntMetric added in v1.122.23 

func (c Vmselect) GetIntMetric(t *testing.T, metricName string) int

GetIntMetric retrieves the value of a metric served by an app at /metrics URL. The value is then converted to int.

func (Vmselect) GetMetric added in v1.122.23 

func (c Vmselect) GetMetric(t *testing.T, metricName string) float64

GetMetric retrieves the value of a metric served by an app at /metrics URL.

func (Vmselect) GetMetricsByPrefix added in v1.122.23 

func (c Vmselect) GetMetricsByPrefix(t *testing.T, prefix string) []float64

GetMetricsByPrefix retrieves the values of all metrics that start with given prefix.

func (Vmselect) GetMetricsByRegexp added in v1.122.23 

func (c Vmselect) GetMetricsByRegexp(t *testing.T, re *regexp.Regexp) []float64

func (Vmselect) GraphiteMetricsExpand added in v1.122.23 

func (c Vmselect) GraphiteMetricsExpand(t *testing.T, query string, opts QueryOpts) GraphiteMetricsExpandResponse

GraphiteMetricsExpand expands the given query with matching paths by sending a request to /graphite/metrics/expand endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api and https://graphite.readthedocs.io/en/latest/metrics_api.html#metrics-expand

func (Vmselect) GraphiteMetricsFind added in v1.122.23 

func (c Vmselect) GraphiteMetricsFind(t *testing.T, query string, opts QueryOpts) GraphiteMetricsFindResponse

GraphiteMetricsFind finds metrics under a given path by sending a request to /metrics/find endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api and https://graphite.readthedocs.io/en/latest/metrics_api.html#metrics-find

func (Vmselect) GraphiteMetricsIndex added in v1.102.25 

func (c Vmselect) GraphiteMetricsIndex(t *testing.T, opts QueryOpts) GraphiteMetricsIndexResponse

GraphiteMetricsIndex retrieves the list of all metrics by sending a request to /graphite/metrics/index.json endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api

func (Vmselect) GraphiteRender added in v1.122.23 

func (c Vmselect) GraphiteRender(t *testing.T, target string, opts QueryOpts) GraphiteRenderResponse

GraphiteRender retrieves the raw metric data by sending a request to /graphite/render endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#render-api and https://graphite-api.readthedocs.io/en/latest/api.html#the-render-api-render

func (Vmselect) GraphiteTagsTagMultiSeries added in v1.122.17 

func (c Vmselect) GraphiteTagsTagMultiSeries(t *testing.T, records []string, opts QueryOpts)

GraphiteTagsTagMultiSeries is a test helper function that registers Graphite tags for a multiple time series by sending a request to /graphite/tags/tagSeries endpoint.

func (Vmselect) GraphiteTagsTagSeries added in v1.122.17 

func (c Vmselect) GraphiteTagsTagSeries(t *testing.T, record string, opts QueryOpts)

GraphiteTagsTagSeries is a test helper function that registers Graphite tags for a single time series by sending a request to /graphite/tags/tagSeries endpoint.

func (*Vmselect) HTTPAddr added in v1.102.24 

func (app *Vmselect) HTTPAddr() string

HTTPAddr returns the address at which the vmselect process is listening for incoming HTTP requests.

func (Vmselect) Name added in v1.97.14 

func (app Vmselect) Name() string

Name returns the application instance name.

func (Vmselect) PrometheusAPIV1AdminStatusMetricNamesStatsReset added in v1.122.23 

func (c Vmselect) PrometheusAPIV1AdminStatusMetricNamesStatsReset(t *testing.T, opts QueryOpts)

PrometheusAPIV1AdminStatusMetricNamesStatsReset resets the metric name usage stats by sending a request to /prometheus/api/v1/admin/status/metric_names_stats/reset endpoint

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#track-ingested-metrics-usage

func (Vmselect) PrometheusAPIV1AdminTSDBDeleteSeries added in v1.122.23 

func (c Vmselect) PrometheusAPIV1AdminTSDBDeleteSeries(t *testing.T, matchQuery string, opts QueryOpts)

PrometheusAPIV1AdminTSDBDeleteSeries deletes the series that match the query by sending a request to /prometheus/api/v1/admin/tsdb/delete_series.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1admintsdbdelete_series

func (Vmselect) PrometheusAPIV1Export added in v1.97.13 

func (c Vmselect) PrometheusAPIV1Export(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1Export is a test helper function that performs the export of raw samples in JSON line format by sending a request to /prometheus/api/v1/export endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1export

func (Vmselect) PrometheusAPIV1ExportNative added in v1.102.23 

func (c Vmselect) PrometheusAPIV1ExportNative(t *testing.T, query string, opts QueryOpts) []byte

PrometheusAPIV1ExportNative is a test helper function that performs the export of raw samples in native binary format by sending a request to /prometheus/api/v1/export/native endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1exportnative

func (Vmselect) PrometheusAPIV1LabelValues added in v1.102.26 

func (c Vmselect) PrometheusAPIV1LabelValues(t *testing.T, labelName, matchQuery string, opts QueryOpts) *PrometheusAPIV1LabelValuesResponse

PrometheusAPIV1LabelValues retrieves the labels values for the metrics that match the query by sending a request to /prometheus/api/v1/label/.../values endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1labelvalues

func (Vmselect) PrometheusAPIV1Labels added in v1.102.26 

func (c Vmselect) PrometheusAPIV1Labels(t *testing.T, matchQuery string, opts QueryOpts) *PrometheusAPIV1LabelsResponse

PrometheusAPIV1Labels retrieves the label names for time series that match a query by sending a request to /prometheus/api/v1/labels endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1labels

func (Vmselect) PrometheusAPIV1Metadata added in v1.110.24 

func (c Vmselect) PrometheusAPIV1Metadata(t *testing.T, metric string, limit int, opts QueryOpts) *PrometheusAPIV1Metadata

PrometheusAPIV1Metadata retrieves metadata for the given metric by sending a request to /prometheus/api/v1/metadata endpoint.

func (Vmselect) PrometheusAPIV1Query added in v1.97.12 

func (c Vmselect) PrometheusAPIV1Query(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1Query is a test helper function that performs PromQL/MetricsQL instant query by sending a request to /prometheus/api/v1/query endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1query

func (Vmselect) PrometheusAPIV1QueryRange added in v1.97.12 

func (c Vmselect) PrometheusAPIV1QueryRange(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1QueryRange is a test helper function that performs PromQL/MetricsQL range query by sending a request to /prometheus/api/v1/query_range endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1query_range

func (Vmselect) PrometheusAPIV1Series 

func (c Vmselect) PrometheusAPIV1Series(t *testing.T, matchQuery string, opts QueryOpts) *PrometheusAPIV1SeriesResponse

PrometheusAPIV1Series retrieves list of time series that match the query by sending a request to /prometheus/api/v1/series endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1series

func (Vmselect) PrometheusAPIV1SeriesCount added in v1.102.26 

func (c Vmselect) PrometheusAPIV1SeriesCount(t *testing.T, opts QueryOpts) *PrometheusAPIV1SeriesCountResponse

PrometheusAPIV1SeriesCount retrieves the total number of time series by sending a request to /prometheus/api/v1/series/count endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1series

func (Vmselect) PrometheusAPIV1StatusMetricNamesStats added in v1.122.23 

func (c Vmselect) PrometheusAPIV1StatusMetricNamesStats(t *testing.T, limit, le, matchPattern string, opts QueryOpts) MetricNamesStatsResponse

PrometheusAPIV1StatusMetricNamesStats sends a query to /prometheus/api/v1/status/metric_names_stats endpoint and returns the metric usage stats response for given params.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#track-ingested-metrics-usage

func (Vmselect) PrometheusAPIV1StatusTSDB added in v1.122.23 

func (c Vmselect) PrometheusAPIV1StatusTSDB(t *testing.T, matchQuery string, date string, topN string, opts QueryOpts) TSDBStatusResponse

PrometheusAPIV1StatusTSDB retrieves the TSDB status for the time series that match the query on the given date by sending a request to /prometheus/api/v1/status/tsdb endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#tsdb-stats

func (Vmselect) Stop 

func (app Vmselect) Stop()

Stop sends the app process a SIGINT signal and waits until it terminates gracefully.

func (*Vmselect) String 

func (app *Vmselect) String() string

String returns the string representation of the vmselect app state.

type Vmsingle added in v1.97.12 

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

Vmsingle holds the state of a vmsingle app and provides vmsingle-specific functions.

func StartVmsingle added in v1.97.12 

func StartVmsingle(instance string, flags []string, cli *Client, output io.Writer) (*Vmsingle, error)

StartVmsingle starts the latest version of vmsingle.

The path to the binary can be provided via VMSINGLE_PATH environment variable. If the variable is not set, ../../bin/victoria-metrics-race will be used.

func StartVmsingle_v1_132_0 added in v1.122.24 

func StartVmsingle_v1_132_0(instance string, flags []string, cli *Client, output io.Writer) (*Vmsingle, error)

StartVmsingle_v1_132_0 starts vmsingle-v1.132.0 (the last version that uses legacy index).

The path to the binary must be provided via VMSINGLE_V1_132_0_PATH environment variable.

func (Vmsingle) APIV1AdminTSDBSnapshot added in v1.102.18 

func (c Vmsingle) APIV1AdminTSDBSnapshot(t *testing.T) *APIV1AdminTSDBSnapshotResponse

APIV1AdminTSDBSnapshot creates a database snapshot by sending a query to the /api/v1/admin/tsdb/snapshot endpoint.

See https://prometheus.io/docs/prometheus/latest/querying/api/#snapshot.

func (Vmsingle) APIV1AdminTenants added in v1.122.23 

func (c Vmsingle) APIV1AdminTenants(t *testing.T, opts QueryOpts) *AdminTenantsResponse

APIV1AdminTenants retrieves the list of tenants by sending a request to /admin/tenants endpoint.

func (Vmsingle) ForceFlush added in v1.97.12 

func (c Vmsingle) ForceFlush(t *testing.T)

ForceFlush is a test helper function that forces the flushing of inserted data, so it becomes available for searching immediately.

func (Vmsingle) ForceMerge added in v1.102.17 

func (c Vmsingle) ForceMerge(t *testing.T)

ForceMerge is a test helper function that forces the merging of parts.

func (Vmsingle) GetIntMetric added in v1.122.23 

func (c Vmsingle) GetIntMetric(t *testing.T, metricName string) int

GetIntMetric retrieves the value of a metric served by an app at /metrics URL. The value is then converted to int.

func (Vmsingle) GetMetric added in v1.122.23 

func (c Vmsingle) GetMetric(t *testing.T, metricName string) float64

GetMetric retrieves the value of a metric served by an app at /metrics URL.

func (Vmsingle) GetMetricsByPrefix added in v1.122.23 

func (c Vmsingle) GetMetricsByPrefix(t *testing.T, prefix string) []float64

GetMetricsByPrefix retrieves the values of all metrics that start with given prefix.

func (Vmsingle) GetMetricsByRegexp added in v1.122.23 

func (c Vmsingle) GetMetricsByRegexp(t *testing.T, re *regexp.Regexp) []float64

func (Vmsingle) GraphiteMetricsExpand added in v1.122.23 

func (c Vmsingle) GraphiteMetricsExpand(t *testing.T, query string, opts QueryOpts) GraphiteMetricsExpandResponse

GraphiteMetricsExpand expands the given query with matching paths by sending a request to /graphite/metrics/expand endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api and https://graphite.readthedocs.io/en/latest/metrics_api.html#metrics-expand

func (Vmsingle) GraphiteMetricsFind added in v1.122.23 

func (c Vmsingle) GraphiteMetricsFind(t *testing.T, query string, opts QueryOpts) GraphiteMetricsFindResponse

GraphiteMetricsFind finds metrics under a given path by sending a request to /metrics/find endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api and https://graphite.readthedocs.io/en/latest/metrics_api.html#metrics-find

func (Vmsingle) GraphiteMetricsIndex added in v1.102.25 

func (c Vmsingle) GraphiteMetricsIndex(t *testing.T, opts QueryOpts) GraphiteMetricsIndexResponse

GraphiteMetricsIndex retrieves the list of all metrics by sending a request to /graphite/metrics/index.json endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#metrics-api

func (Vmsingle) GraphiteRender added in v1.122.23 

func (c Vmsingle) GraphiteRender(t *testing.T, target string, opts QueryOpts) GraphiteRenderResponse

GraphiteRender retrieves the raw metric data by sending a request to /graphite/render endpoint.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#render-api and https://graphite-api.readthedocs.io/en/latest/api.html#the-render-api-render

func (Vmsingle) GraphiteTagsTagMultiSeries added in v1.122.17 

func (c Vmsingle) GraphiteTagsTagMultiSeries(t *testing.T, records []string, opts QueryOpts)

GraphiteTagsTagMultiSeries is a test helper function that registers Graphite tags for a multiple time series by sending a request to /graphite/tags/tagSeries endpoint.

func (Vmsingle) GraphiteTagsTagSeries added in v1.122.17 

func (c Vmsingle) GraphiteTagsTagSeries(t *testing.T, record string, opts QueryOpts)

GraphiteTagsTagSeries is a test helper function that registers Graphite tags for a single time series by sending a request to /graphite/tags/tagSeries endpoint.

func (Vmsingle) GraphiteWrite added in v1.102.20 

func (c Vmsingle) GraphiteWrite(t *testing.T, records []string, _ QueryOpts)

GraphiteWrite is a test helper function that sends a collection of records to graphiteListenAddr port.

See https://docs.victoriametrics.com/victoriametrics/integrations/graphite/#ingesting

func (*Vmsingle) HTTPAddr added in v1.102.19 

func (app *Vmsingle) HTTPAddr() string

HTTPAddr returns the address at which the vminsert process is listening for incoming HTTP requests.

func (Vmsingle) InfluxWrite added in v1.97.15 

func (c Vmsingle) InfluxWrite(t *testing.T, records []string, opts QueryOpts)

InfluxWrite is a test helper function that inserts a collection of records in Influx line format by sending a HTTP POST request to /influx/write endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#influxwrite

func (Vmsingle) Name added in v1.97.14 

func (app Vmsingle) Name() string

Name returns the application instance name.

func (Vmsingle) OpenTSDBAPIPut added in v1.102.20 

func (c Vmsingle) OpenTSDBAPIPut(t *testing.T, records []string, opts QueryOpts)

OpenTSDBAPIPut is a test helper function that inserts a collection of records in OpenTSDB format for the given tenant by sending an HTTP POST request to /opentsdb/api/put vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vmsingle) OpentelemetryV1Metrics added in v1.122.22 

func (c Vmsingle) OpentelemetryV1Metrics(t *testing.T, md otlppb.MetricsData, opts QueryOpts)

OpentelemetryV1Metrics is a test helper function that inserts a collection of records in Opentelemetry protocol format by sending a HTTP POST request to /opentelemetry/v1/metrics vminsert endpoint.

func (Vmsingle) PrometheusAPIV1AdminStatusMetricNamesStatsReset added in v1.122.23 

func (c Vmsingle) PrometheusAPIV1AdminStatusMetricNamesStatsReset(t *testing.T, opts QueryOpts)

PrometheusAPIV1AdminStatusMetricNamesStatsReset resets the metric name usage stats by sending a request to /prometheus/api/v1/admin/status/metric_names_stats/reset endpoint

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#track-ingested-metrics-usage

func (Vmsingle) PrometheusAPIV1AdminTSDBDeleteSeries added in v1.122.23 

func (c Vmsingle) PrometheusAPIV1AdminTSDBDeleteSeries(t *testing.T, matchQuery string, opts QueryOpts)

PrometheusAPIV1AdminTSDBDeleteSeries deletes the series that match the query by sending a request to /prometheus/api/v1/admin/tsdb/delete_series.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1admintsdbdelete_series

func (Vmsingle) PrometheusAPIV1Export added in v1.97.13 

func (c Vmsingle) PrometheusAPIV1Export(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1Export is a test helper function that performs the export of raw samples in JSON line format by sending a request to /prometheus/api/v1/export endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1export

func (Vmsingle) PrometheusAPIV1ExportNative added in v1.102.23 

func (c Vmsingle) PrometheusAPIV1ExportNative(t *testing.T, query string, opts QueryOpts) []byte

PrometheusAPIV1ExportNative is a test helper function that performs the export of raw samples in native binary format by sending a request to /prometheus/api/v1/export/native endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1exportnative

func (Vmsingle) PrometheusAPIV1ImportCSV added in v1.102.20 

func (c Vmsingle) PrometheusAPIV1ImportCSV(t *testing.T, records []string, opts QueryOpts)

PrometheusAPIV1ImportCSV is a test helper function that inserts a collection of records in CSV format for the given tenant by sending an HTTP POST request to prometheus/api/v1/import/csv vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vmsingle) PrometheusAPIV1ImportNative added in v1.102.23 

func (c Vmsingle) PrometheusAPIV1ImportNative(t *testing.T, data []byte, opts QueryOpts)

PrometheusAPIV1ImportNative is a test helper function that inserts a collection of records in Native format for the given tenant by sending an HTTP POST request to prometheus/api/v1/import/native vminsert endpoint.

See https://docs.victoriametrics.com/cluster-victoriametrics/#url-format

func (Vmsingle) PrometheusAPIV1ImportPrometheus added in v1.97.12 

func (c Vmsingle) PrometheusAPIV1ImportPrometheus(t *testing.T, records []string, opts QueryOpts)

PrometheusAPIV1ImportPrometheus is a test helper function that inserts a collection of records in Prometheus text exposition format for the given tenant by sending a HTTP POST request to /prometheus/api/v1/import/prometheus vminsert endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1importprometheus

func (Vmsingle) PrometheusAPIV1LabelValues added in v1.102.26 

func (c Vmsingle) PrometheusAPIV1LabelValues(t *testing.T, labelName, matchQuery string, opts QueryOpts) *PrometheusAPIV1LabelValuesResponse

PrometheusAPIV1LabelValues retrieves the labels values for the metrics that match the query by sending a request to /prometheus/api/v1/label/.../values endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1labelvalues

func (Vmsingle) PrometheusAPIV1Labels added in v1.102.26 

func (c Vmsingle) PrometheusAPIV1Labels(t *testing.T, matchQuery string, opts QueryOpts) *PrometheusAPIV1LabelsResponse

PrometheusAPIV1Labels retrieves the label names for time series that match a query by sending a request to /prometheus/api/v1/labels endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1labels

func (Vmsingle) PrometheusAPIV1Metadata added in v1.110.24 

func (c Vmsingle) PrometheusAPIV1Metadata(t *testing.T, metric string, limit int, opts QueryOpts) *PrometheusAPIV1Metadata

PrometheusAPIV1Metadata retrieves metadata for the given metric by sending a request to /prometheus/api/v1/metadata endpoint.

func (Vmsingle) PrometheusAPIV1Query added in v1.97.12 

func (c Vmsingle) PrometheusAPIV1Query(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1Query is a test helper function that performs PromQL/MetricsQL instant query by sending a request to /prometheus/api/v1/query endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1query

func (Vmsingle) PrometheusAPIV1QueryRange added in v1.97.12 

func (c Vmsingle) PrometheusAPIV1QueryRange(t *testing.T, query string, opts QueryOpts) *PrometheusAPIV1QueryResponse

PrometheusAPIV1QueryRange is a test helper function that performs PromQL/MetricsQL range query by sending a request to /prometheus/api/v1/query_range endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1query_range

func (Vmsingle) PrometheusAPIV1Series added in v1.97.12 

func (c Vmsingle) PrometheusAPIV1Series(t *testing.T, matchQuery string, opts QueryOpts) *PrometheusAPIV1SeriesResponse

PrometheusAPIV1Series retrieves list of time series that match the query by sending a request to /prometheus/api/v1/series endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1series

func (Vmsingle) PrometheusAPIV1SeriesCount added in v1.102.26 

func (c Vmsingle) PrometheusAPIV1SeriesCount(t *testing.T, opts QueryOpts) *PrometheusAPIV1SeriesCountResponse

PrometheusAPIV1SeriesCount retrieves the total number of time series by sending a request to /prometheus/api/v1/series/count endpoint.

See https://docs.victoriametrics.com/victoriametrics/url-examples/#apiv1series

func (Vmsingle) PrometheusAPIV1StatusMetricNamesStats added in v1.122.23 

func (c Vmsingle) PrometheusAPIV1StatusMetricNamesStats(t *testing.T, limit, le, matchPattern string, opts QueryOpts) MetricNamesStatsResponse

PrometheusAPIV1StatusMetricNamesStats sends a query to /prometheus/api/v1/status/metric_names_stats endpoint and returns the metric usage stats response for given params.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#track-ingested-metrics-usage

func (Vmsingle) PrometheusAPIV1StatusTSDB added in v1.122.23 

func (c Vmsingle) PrometheusAPIV1StatusTSDB(t *testing.T, matchQuery string, date string, topN string, opts QueryOpts) TSDBStatusResponse

PrometheusAPIV1StatusTSDB retrieves the TSDB status for the time series that match the query on the given date by sending a request to /prometheus/api/v1/status/tsdb endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#tsdb-stats

func (Vmsingle) PrometheusAPIV1Write added in v1.97.13 

func (c Vmsingle) PrometheusAPIV1Write(t *testing.T, wr prompb.WriteRequest, opts QueryOpts)

PrometheusAPIV1Write is a test helper function that inserts a collection of records in Prometheus remote-write format by sending a HTTP POST request to /prometheus/api/v1/write vminsert endpoint.

func (Vmsingle) SnapshotCreate added in v1.102.18 

func (c Vmsingle) SnapshotCreate(t *testing.T) *SnapshotCreateResponse

SnapshotCreate creates a database snapshot by sending a query to the /snapshot/create endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmsingle) SnapshotCreateURL added in v1.102.23 

func (c Vmsingle) SnapshotCreateURL() string

SnapshotCreateURL returns the URL for creating snapshots.

func (Vmsingle) SnapshotDelete added in v1.102.18 

func (c Vmsingle) SnapshotDelete(t *testing.T, snapshotName string) *SnapshotDeleteResponse

SnapshotDelete deletes a snapshot by sending a query to the /snapshot/delete endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmsingle) SnapshotDeleteAll added in v1.102.18 

func (c Vmsingle) SnapshotDeleteAll(t *testing.T) *SnapshotDeleteAllResponse

SnapshotDeleteAll deletes all snapshots by sending a query to the /snapshot/delete_all endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmsingle) SnapshotList added in v1.102.18 

func (c Vmsingle) SnapshotList(t *testing.T) *SnapshotListResponse

SnapshotList lists existing database snapshots by sending a query to the /snapshot/list endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmsingle) Stop added in v1.97.12 

func (app Vmsingle) Stop()

Stop sends the app process a SIGINT signal and waits until it terminates gracefully.

func (*Vmsingle) String added in v1.97.12 

func (app *Vmsingle) String() string

String returns the string representation of the vmsingle app state.

func (*Vmsingle) VmselectAddr added in v1.122.26 

func (app *Vmsingle) VmselectAddr() string

VmselectAddr returns the address at which the vmsingle process is listening for vmselect connections.

func (Vmsingle) ZabbixConnectorHistory added in v1.110.28 

func (c Vmsingle) ZabbixConnectorHistory(t *testing.T, records []string, opts QueryOpts)

ZabbixConnectorHistory is a test helper function that inserts a collection of records in zabbixconnector format by sending a HTTP POST request to /zabbixconnector/api/v1/history vmsingle endpoint.

type Vmstorage 

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

Vmstorage holds the state of a vmstorage app and provides vmstorage-specific functions.

func StartVmstorage 

func StartVmstorage(instance string, flags []string, cli *Client, output io.Writer) (*Vmstorage, error)

StartVmstorage starts the latest version of vmstorage.

The path to the binary can be provided via VMSTORAGE_PATH environment variable. If the variable is not set, ../../bin/vmstorage-race will be used.

func StartVmstorage_v1_132_0 added in v1.122.24 

func StartVmstorage_v1_132_0(instance string, flags []string, cli *Client, output io.Writer) (*Vmstorage, error)

StartVmstorage_v1_132_0 starts vmstorage-v1.132.0 (the last version that uses legacy index).

The path to the binary must be provided via VMSTORAGE_V1_132_0_PATH environment variable.

func (Vmstorage) APIV1AdminTSDBSnapshot added in v1.122.23 

func (c Vmstorage) APIV1AdminTSDBSnapshot(t *testing.T) *APIV1AdminTSDBSnapshotResponse

APIV1AdminTSDBSnapshot creates a database snapshot by sending a query to the /api/v1/admin/tsdb/snapshot endpoint.

See https://prometheus.io/docs/prometheus/latest/querying/api/#snapshot.

func (Vmstorage) ForceFlush added in v1.97.12 

func (c Vmstorage) ForceFlush(t *testing.T)

ForceFlush is a test helper function that forces the flushing of inserted data, so it becomes available for searching immediately.

func (Vmstorage) ForceMerge added in v1.102.17 

func (c Vmstorage) ForceMerge(t *testing.T)

ForceMerge is a test helper function that forces the merging of parts.

func (Vmstorage) GetIntMetric added in v1.122.23 

func (c Vmstorage) GetIntMetric(t *testing.T, metricName string) int

GetIntMetric retrieves the value of a metric served by an app at /metrics URL. The value is then converted to int.

func (Vmstorage) GetMetric added in v1.122.23 

func (c Vmstorage) GetMetric(t *testing.T, metricName string) float64

GetMetric retrieves the value of a metric served by an app at /metrics URL.

func (Vmstorage) GetMetricsByPrefix added in v1.122.23 

func (c Vmstorage) GetMetricsByPrefix(t *testing.T, prefix string) []float64

GetMetricsByPrefix retrieves the values of all metrics that start with given prefix.

func (Vmstorage) GetMetricsByRegexp added in v1.122.23 

func (c Vmstorage) GetMetricsByRegexp(t *testing.T, re *regexp.Regexp) []float64

func (Vmstorage) Name added in v1.97.14 

func (app Vmstorage) Name() string

Name returns the application instance name.

func (Vmstorage) SnapshotCreate added in v1.102.18 

func (c Vmstorage) SnapshotCreate(t *testing.T) *SnapshotCreateResponse

SnapshotCreate creates a database snapshot by sending a query to the /snapshot/create endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmstorage) SnapshotCreateURL added in v1.102.23 

func (c Vmstorage) SnapshotCreateURL() string

SnapshotCreateURL returns the URL for creating snapshots.

func (Vmstorage) SnapshotDelete added in v1.102.18 

func (c Vmstorage) SnapshotDelete(t *testing.T, snapshotName string) *SnapshotDeleteResponse

SnapshotDelete deletes a snapshot by sending a query to the /snapshot/delete endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmstorage) SnapshotDeleteAll added in v1.102.18 

func (c Vmstorage) SnapshotDeleteAll(t *testing.T) *SnapshotDeleteAllResponse

SnapshotDeleteAll deletes all snapshots by sending a query to the /snapshot/delete_all endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmstorage) SnapshotList added in v1.102.18 

func (c Vmstorage) SnapshotList(t *testing.T) *SnapshotListResponse

SnapshotList lists existing database snapshots by sending a query to the /snapshot/list endpoint.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#how-to-work-with-snapshots

func (Vmstorage) Stop 

func (app Vmstorage) Stop()

Stop sends the app process a SIGINT signal and waits until it terminates gracefully.

func (*Vmstorage) String 

func (app *Vmstorage) String() string

String returns the string representation of the vmstorage app state.

func (*Vmstorage) VminsertAddr 

func (app *Vmstorage) VminsertAddr() string

VminsertAddr returns the address at which the vmstorage process is listening for vminsert connections.

func (*Vmstorage) VmselectAddr 

func (app *Vmstorage) VmselectAddr() string

VmselectAddr returns the address at which the vmstorage process is listening for vmselect connections.

type Writer added in v1.102.20 

type Writer interface {
	// Prometheus APIs
	PrometheusAPIV1Write(t *testing.T, wr prompb.WriteRequest, opts QueryOpts)
	PrometheusAPIV1ImportPrometheus(t *testing.T, records []string, opts QueryOpts)
	PrometheusAPIV1ImportCSV(t *testing.T, records []string, opts QueryOpts)
	PrometheusAPIV1ImportNative(t *testing.T, data []byte, opts QueryOpts)

	// Graphit APIs
	GraphiteWrite(t *testing.T, records []string, opts QueryOpts)

	// OpenTSDB APIs
	OpenTSDBAPIPut(t *testing.T, records []string, opts QueryOpts)
}

Writer contains methods for writing new data

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.