prometheus

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

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 

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

ExpandWithExprs handles the request to /expand-with-exprs

func ExpandWithExprsJSONResponse 

func ExpandWithExprsJSONResponse(q string) string

func ExpandWithExprsResponse 

func ExpandWithExprsResponse(q string) string

func ExportCSVHandler 

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 

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 

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 

func ExportPromAPIFooter(qt *querytracer.Tracer) string

func ExportPromAPIHeader 

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 

func GetMaxUniqueTimeSeries() int

GetMaxUniqueTimeSeries returns the max metrics limit calculated by available resources.

func InitMaxUniqueTimeseries 

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 

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 

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 

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

func StreamExpandWithExprsResponse 

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

func StreamExportCSVLine 

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

func StreamExportJSONLine 

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

func StreamExportPromAPIFooter 

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

func StreamExportPromAPIHeader 

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 

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

func TSDBStatusHandler 

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 

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

func WriteExpandWithExprsJSONResponse 

func WriteExpandWithExprsJSONResponse(qq422016 qtio422016.Writer, q string)

func WriteExpandWithExprsResponse 

func WriteExpandWithExprsResponse(qq422016 qtio422016.Writer, q string)

func WriteExportCSVLine 

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

func WriteExportJSONLine 

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

func WriteExportPromAPIFooter 

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

func WriteExportPromAPIHeader 

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 

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.