prometheus

package
v1.102.6 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2024 License: Apache-2.0 Imports: 31 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteHandler 

func DeleteHandler(startTime time.Time, r *http.Request) error

DeleteHandler processes /api/v1/admin/tsdb/delete_series prometheus API request.

See https://prometheus.io/docs/prometheus/latest/querying/api/#delete-series

func ExpandWithExprs added in v1.85.2 

func ExpandWithExprs(w http.ResponseWriter, r *http.Request)

ExpandWithExprs handles the request to /expand-with-exprs

func ExpandWithExprsJSONResponse added in v1.91.0 

func ExpandWithExprsJSONResponse(q string) string

func ExpandWithExprsResponse added in v1.85.2 

func ExpandWithExprsResponse(q string) string

func ExportCSVHandler added in v1.44.0 

func ExportCSVHandler(startTime time.Time, w http.ResponseWriter, r *http.Request) error

ExportCSVHandler exports data in CSV format from /api/v1/export/csv

func ExportCSVLine added in v1.44.0 

func ExportCSVLine(xb *exportBlock, fieldNames []string) string

func ExportHandler 

func ExportHandler(startTime time.Time, w http.ResponseWriter, r *http.Request) error

ExportHandler exports data in raw format from /api/v1/export.

func ExportJSONLine 

func ExportJSONLine(xb *exportBlock) string

func ExportNativeHandler added in v1.42.0 

func ExportNativeHandler(startTime time.Time, w http.ResponseWriter, r *http.Request) error

ExportNativeHandler exports data in native format from /api/v1/export/native.

func ExportPromAPIFooter added in v1.82.0 

func ExportPromAPIFooter(qt *querytracer.Tracer) string

func ExportPromAPIHeader added in v1.82.0 

func ExportPromAPIHeader() string

func ExportPromAPILine 

func ExportPromAPILine(xb *exportBlock) string

func ExportPrometheusLine 

func ExportPrometheusLine(xb *exportBlock) string

func Federate 

func Federate(rs *netstorage.Result) string

func FederateHandler 

func FederateHandler(startTime time.Time, w http.ResponseWriter, r *http.Request) error

FederateHandler implements /federate . See https://prometheus.io/docs/prometheus/latest/federation/

func GetMaxUniqueTimeSeries added in v1.97.10 

func GetMaxUniqueTimeSeries() int

GetMaxUniqueTimeSeries returns the max metrics limit calculated by available resources.

func InitMaxUniqueTimeseries added in v1.97.10 

func InitMaxUniqueTimeseries(maxConcurrentRequests int)

InitMaxUniqueTimeseries init the max metrics limit calculated by available resources. The calculation is split into calculateMaxUniqueTimeSeriesForResource for unit testing.

func LabelValuesHandler 

func LabelValuesHandler(qt *querytracer.Tracer, startTime time.Time, labelName string, w http.ResponseWriter, r *http.Request) error

LabelValuesHandler processes /api/v1/label/<labelName>/values request.

See https://prometheus.io/docs/prometheus/latest/querying/api/#querying-label-values

func LabelValuesResponse 

func LabelValuesResponse(labelValues []string, qt *querytracer.Tracer) string

func LabelsHandler 

func LabelsHandler(qt *querytracer.Tracer, startTime time.Time, w http.ResponseWriter, r *http.Request) error

LabelsHandler processes /api/v1/labels request.

See https://prometheus.io/docs/prometheus/latest/querying/api/#getting-label-names

func LabelsResponse 

func LabelsResponse(labels []string, qt *querytracer.Tracer) string

func PrettifyQuery added in v1.94.0 

func PrettifyQuery(w http.ResponseWriter, r *http.Request)

PrettifyQuery handles the request /prettify-query

func QueryHandler 

func QueryHandler(qt *querytracer.Tracer, startTime time.Time, w http.ResponseWriter, r *http.Request) error

QueryHandler processes /api/v1/query request.

See https://prometheus.io/docs/prometheus/latest/querying/api/#instant-queries

func QueryRangeHandler 

func QueryRangeHandler(qt *querytracer.Tracer, startTime time.Time, w http.ResponseWriter, r *http.Request) error

QueryRangeHandler processes /api/v1/query_range request.

See https://prometheus.io/docs/prometheus/latest/querying/api/#range-queries

func QueryRangeResponse 

func QueryRangeResponse(rs []netstorage.Result, qt *querytracer.Tracer, qtDone func(), qs *promql.QueryStats) string

func QueryResponse 

func QueryResponse(rs []netstorage.Result, qt *querytracer.Tracer, qtDone func(), qs *promql.QueryStats) string

func QueryStatsHandler added in v1.51.0 

func QueryStatsHandler(w http.ResponseWriter, r *http.Request) error

QueryStatsHandler returns query stats at `/api/v1/status/top_queries`

func SeriesCountHandler 

func SeriesCountHandler(startTime time.Time, w http.ResponseWriter, r *http.Request) error

SeriesCountHandler processes /api/v1/series/count request.

func SeriesCountResponse 

func SeriesCountResponse(n uint64) string

func SeriesHandler 

func SeriesHandler(qt *querytracer.Tracer, startTime time.Time, w http.ResponseWriter, r *http.Request) error

SeriesHandler processes /api/v1/series request.

See https://prometheus.io/docs/prometheus/latest/querying/api/#finding-series-by-label-matchers

func SeriesResponse 

func SeriesResponse(metricNames []string, qt *querytracer.Tracer, qtDone func()) string

func StreamExpandWithExprsJSONResponse added in v1.91.0 

func StreamExpandWithExprsJSONResponse(qw422016 *qt422016.Writer, q string)

func StreamExpandWithExprsResponse added in v1.85.2 

func StreamExpandWithExprsResponse(qw422016 *qt422016.Writer, q string)

func StreamExportCSVLine added in v1.44.0 

func StreamExportCSVLine(qw422016 *qt422016.Writer, xb *exportBlock, fieldNames []string)

func StreamExportJSONLine 

func StreamExportJSONLine(qw422016 *qt422016.Writer, xb *exportBlock)

func StreamExportPromAPIFooter added in v1.82.0 

func StreamExportPromAPIFooter(qw422016 *qt422016.Writer, qt *querytracer.Tracer)

func StreamExportPromAPIHeader added in v1.82.0 

func StreamExportPromAPIHeader(qw422016 *qt422016.Writer)

func StreamExportPromAPILine 

func StreamExportPromAPILine(qw422016 *qt422016.Writer, xb *exportBlock)

func StreamExportPrometheusLine 

func StreamExportPrometheusLine(qw422016 *qt422016.Writer, xb *exportBlock)

func StreamFederate 

func StreamFederate(qw422016 *qt422016.Writer, rs *netstorage.Result)

func StreamLabelValuesResponse 

func StreamLabelValuesResponse(qw422016 *qt422016.Writer, labelValues []string, qt *querytracer.Tracer)

func StreamLabelsResponse 

func StreamLabelsResponse(qw422016 *qt422016.Writer, labels []string, qt *querytracer.Tracer)

func StreamQueryRangeResponse 

func StreamQueryRangeResponse(qw422016 *qt422016.Writer, rs []netstorage.Result, qt *querytracer.Tracer, qtDone func(), qs *promql.QueryStats)

func StreamQueryResponse 

func StreamQueryResponse(qw422016 *qt422016.Writer, rs []netstorage.Result, qt *querytracer.Tracer, qtDone func(), qs *promql.QueryStats)

func StreamSeriesCountResponse 

func StreamSeriesCountResponse(qw422016 *qt422016.Writer, n uint64)

func StreamSeriesResponse 

func StreamSeriesResponse(qw422016 *qt422016.Writer, metricNames []string, qt *querytracer.Tracer, qtDone func())

func StreamTSDBStatusResponse added in v1.35.0 

func StreamTSDBStatusResponse(qw422016 *qt422016.Writer, status *storage.TSDBStatus, qt *querytracer.Tracer)

func TSDBStatusHandler added in v1.35.0 

func TSDBStatusHandler(qt *querytracer.Tracer, startTime time.Time, w http.ResponseWriter, r *http.Request) error

TSDBStatusHandler processes /api/v1/status/tsdb request.

See https://prometheus.io/docs/prometheus/latest/querying/api/#tsdb-stats

It can accept `match[]` filters in order to narrow down the search.

func TSDBStatusResponse added in v1.35.0 

func TSDBStatusResponse(status *storage.TSDBStatus, qt *querytracer.Tracer) string

func WriteExpandWithExprsJSONResponse added in v1.91.0 

func WriteExpandWithExprsJSONResponse(qq422016 qtio422016.Writer, q string)

func WriteExpandWithExprsResponse added in v1.85.2 

func WriteExpandWithExprsResponse(qq422016 qtio422016.Writer, q string)

func WriteExportCSVLine added in v1.44.0 

func WriteExportCSVLine(qq422016 qtio422016.Writer, xb *exportBlock, fieldNames []string)

func WriteExportJSONLine 

func WriteExportJSONLine(qq422016 qtio422016.Writer, xb *exportBlock)

func WriteExportPromAPIFooter added in v1.82.0 

func WriteExportPromAPIFooter(qq422016 qtio422016.Writer, qt *querytracer.Tracer)

func WriteExportPromAPIHeader added in v1.82.0 

func WriteExportPromAPIHeader(qq422016 qtio422016.Writer)

func WriteExportPromAPILine 

func WriteExportPromAPILine(qq422016 qtio422016.Writer, xb *exportBlock)

func WriteExportPrometheusLine 

func WriteExportPrometheusLine(qq422016 qtio422016.Writer, xb *exportBlock)

func WriteFederate 

func WriteFederate(qq422016 qtio422016.Writer, rs *netstorage.Result)

func WriteLabelValuesResponse 

func WriteLabelValuesResponse(qq422016 qtio422016.Writer, labelValues []string, qt *querytracer.Tracer)

func WriteLabelsResponse 

func WriteLabelsResponse(qq422016 qtio422016.Writer, labels []string, qt *querytracer.Tracer)

func WriteQueryRangeResponse 

func WriteQueryRangeResponse(qq422016 qtio422016.Writer, rs []netstorage.Result, qt *querytracer.Tracer, qtDone func(), qs *promql.QueryStats)

func WriteQueryResponse 

func WriteQueryResponse(qq422016 qtio422016.Writer, rs []netstorage.Result, qt *querytracer.Tracer, qtDone func(), qs *promql.QueryStats)

func WriteSeriesCountResponse 

func WriteSeriesCountResponse(qq422016 qtio422016.Writer, n uint64)

func WriteSeriesResponse 

func WriteSeriesResponse(qq422016 qtio422016.Writer, metricNames []string, qt *querytracer.Tracer, qtDone func())

func WriteTSDBStatusResponse added in v1.35.0 

func WriteTSDBStatusResponse(qq422016 qtio422016.Writer, status *storage.TSDBStatus, qt *querytracer.Tracer)

Types

This section is empty.

Source Files

View all Source files

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.