prometheus

package
v1.29.0-cluster Latest Latest
Warning

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

Go to latest
Published: Nov 11, 2019 License: Apache-2.0 Imports: 19 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteHandler

func DeleteHandler(at *auth.Token, 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 ExportHandler

func ExportHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error

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

func ExportJSONLine

func ExportJSONLine(rs *netstorage.Result) string

func ExportPromAPILine

func ExportPromAPILine(rs *netstorage.Result) string

func ExportPromAPIResponse

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

func ExportPrometheusLine

func ExportPrometheusLine(rs *netstorage.Result) string

func ExportStdResponse

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

func Federate

func Federate(rs *netstorage.Result) string

func FederateHandler

func FederateHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error

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

func LabelValuesHandler

func LabelValuesHandler(at *auth.Token, 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(at *auth.Token, 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(at *auth.Token, 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(at *auth.Token, 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(at *auth.Token, 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 SeriesCountHandler

func SeriesCountHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error

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

func SeriesCountResponse

func SeriesCountResponse(n uint64) string

func SeriesResponse

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

func StreamErrorResponse

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

func StreamExportJSONLine

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

func StreamExportPromAPILine

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

func StreamExportPromAPIResponse

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

func StreamExportPrometheusLine

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

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 WriteErrorResponse

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

func WriteExportJSONLine

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

func WriteExportPromAPILine

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

func WriteExportPromAPIResponse

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

func WriteExportPrometheusLine

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

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)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL