prometheus

package
v1.53.0 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2021 License: Apache-2.0 Imports: 28 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 ErrorResponse 

func ErrorResponse(statusCode int, err error) 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 ExportPromAPILine 

func ExportPromAPILine(xb *exportBlock) string

func ExportPromAPIResponse 

func ExportPromAPIResponse(resultsCh <-chan *quicktemplate.ByteBuffer) string

func ExportPrometheusLine 

func ExportPrometheusLine(xb *exportBlock) string

func ExportStdResponse 

func ExportStdResponse(resultsCh <-chan *quicktemplate.ByteBuffer) 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 LabelValuesHandler 

func LabelValuesHandler(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) string

func LabelsCountHandler added in v1.19.0 

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

LabelsCountHandler processes /api/v1/labels/count request.

func LabelsCountResponse added in v1.19.0 

func LabelsCountResponse(labelEntries []storage.TagEntry) string

func LabelsHandler 

func LabelsHandler(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) string

func QueryHandler 

func QueryHandler(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(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) string

func QueryResponse 

func QueryResponse(rs []netstorage.Result) string

func QueryStatsHandler added in v1.51.0 

func QueryStatsHandler(startTime time.Time, 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(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(resultsCh <-chan *quicktemplate.ByteBuffer) string

func StreamErrorResponse 

func StreamErrorResponse(qw422016 *qt422016.Writer, statusCode int, err error)

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 StreamExportPromAPILine 

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

func StreamExportPromAPIResponse 

func StreamExportPromAPIResponse(qw422016 *qt422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)

func StreamExportPrometheusLine 

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

func StreamExportStdResponse 

func StreamExportStdResponse(qw422016 *qt422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)

func StreamFederate 

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

func StreamLabelValuesResponse 

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

func StreamLabelsCountResponse added in v1.19.0 

func StreamLabelsCountResponse(qw422016 *qt422016.Writer, labelEntries []storage.TagEntry)

func StreamLabelsResponse 

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

func StreamQueryRangeResponse 

func StreamQueryRangeResponse(qw422016 *qt422016.Writer, rs []netstorage.Result)

func StreamQueryResponse 

func StreamQueryResponse(qw422016 *qt422016.Writer, rs []netstorage.Result)

func StreamSeriesCountResponse 

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

func StreamSeriesResponse 

func StreamSeriesResponse(qw422016 *qt422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)

func StreamTSDBStatusResponse added in v1.35.0 

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

func TSDBStatusHandler added in v1.35.0 

func TSDBStatusHandler(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

func TSDBStatusResponse added in v1.35.0 

func TSDBStatusResponse(status *storage.TSDBStatus) string

func WriteErrorResponse 

func WriteErrorResponse(qq422016 qtio422016.Writer, statusCode int, err error)

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 WriteExportPromAPILine 

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

func WriteExportPromAPIResponse 

func WriteExportPromAPIResponse(qq422016 qtio422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)

func WriteExportPrometheusLine 

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

func WriteExportStdResponse 

func WriteExportStdResponse(qq422016 qtio422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)

func WriteFederate 

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

func WriteLabelValuesResponse 

func WriteLabelValuesResponse(qq422016 qtio422016.Writer, labelValues []string)

func WriteLabelsCountResponse added in v1.19.0 

func WriteLabelsCountResponse(qq422016 qtio422016.Writer, labelEntries []storage.TagEntry)

func WriteLabelsResponse 

func WriteLabelsResponse(qq422016 qtio422016.Writer, labels []string)

func WriteQueryRangeResponse 

func WriteQueryRangeResponse(qq422016 qtio422016.Writer, rs []netstorage.Result)

func WriteQueryResponse 

func WriteQueryResponse(qq422016 qtio422016.Writer, rs []netstorage.Result)

func WriteSeriesCountResponse 

func WriteSeriesCountResponse(qq422016 qtio422016.Writer, n uint64)

func WriteSeriesResponse 

func WriteSeriesResponse(qq422016 qtio422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)

func WriteTSDBStatusResponse added in v1.35.0 

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

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.