metrics

Documentation

Index

• func RunMetrics(...) (chan struct{}, error)
• func SendRemoteWrite(config *ConfigWrite) error
• func ServeMetrics(port int) error
• func ToTimeSeriesSlice(metricFamilies []*dto.MetricFamily) []prompb.TimeSeries
• type Client
  • func (c *Client) Store(ctx context.Context, req *prompb.WriteRequest) error
• type ConfigWrite

Functions

func RunMetrics

func RunMetrics(metricCount, labelCount, seriesCount, seriesChangeRate, maxSeriesCount, minSeriesCount, metricLength, labelLength, valueInterval, seriesInterval, metricInterval, seriesChangeInterval int, spikeMultiplier float64, seriesOperationMode string, constLabels []string, stop chan struct{}) (chan struct{}, error)

RunMetrics creates a set of Prometheus test series that update over time

func SendRemoteWrite

func SendRemoteWrite(config *ConfigWrite) error

SendRemoteWrite initializes a http client and sends metrics to a prometheus compatible remote endpoint.

func ServeMetrics

func ServeMetrics(port int) error

ServeMetrics serves a prometheus metrics endpoint with test series

func ToTimeSeriesSlice

func ToTimeSeriesSlice(metricFamilies []*dto.MetricFamily) []prompb.TimeSeries

ToTimeSeriesSlice converts a slice of metricFamilies containing samples into a slice of TimeSeries

Types

type Client

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

Client for the remote write requests.

func (*Client) Store

func (c *Client) Store(ctx context.Context, req *prompb.WriteRequest) error

Store sends a batch of samples to the HTTP endpoint.

type ConfigWrite

type ConfigWrite struct {
	URL             url.URL
	RequestInterval time.Duration
	BatchSize,
	RequestCount int
	UpdateNotify    chan struct{}
	PprofURLs       []*url.URL
	Tenant          string
	TLSClientConfig tls.Config
	TenantHeader    string
	OutOfOrder      bool
}

ConfigWrite for the remote write requests.