prometheus

package

v1.32.1-cluster Latest Latest Go to latest Published: Jan 9, 2020 License: Apache-2.0 Imports: 20 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/VictoriaMetrics/VictoriaMetrics

Documentation ¶

Index ¶

func DeleteHandler(at *auth.Token, r *http.Request) error
func ErrorResponse(statusCode int, err error) string
func ExportHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func ExportJSONLine(rs *netstorage.Result) string
func ExportPromAPILine(rs *netstorage.Result) string
func ExportPromAPIResponse(resultsCh <-chan *quicktemplate.ByteBuffer) string
func ExportPrometheusLine(rs *netstorage.Result) string
func ExportStdResponse(resultsCh <-chan *quicktemplate.ByteBuffer) string
func Federate(rs *netstorage.Result) string
func FederateHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func LabelValuesHandler(at *auth.Token, labelName string, w http.ResponseWriter, r *http.Request) error
func LabelValuesResponse(labelValues []string) string
func LabelsCountHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func LabelsCountResponse(labelEntries []storage.TagEntry) string
func LabelsHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func LabelsResponse(labels []string) string
func QueryHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func QueryRangeHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func QueryRangeResponse(rs []netstorage.Result) string
func QueryResponse(rs []netstorage.Result) string
func SeriesCountHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func SeriesCountResponse(n uint64) string
func SeriesHandler(at *auth.Token, w http.ResponseWriter, r *http.Request) error
func SeriesResponse(resultsCh <-chan *quicktemplate.ByteBuffer) string
func StreamErrorResponse(qw422016 *qt422016.Writer, statusCode int, err error)
func StreamExportJSONLine(qw422016 *qt422016.Writer, rs *netstorage.Result)
func StreamExportPromAPILine(qw422016 *qt422016.Writer, rs *netstorage.Result)
func StreamExportPromAPIResponse(qw422016 *qt422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)
func StreamExportPrometheusLine(qw422016 *qt422016.Writer, rs *netstorage.Result)
func StreamExportStdResponse(qw422016 *qt422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)
func StreamFederate(qw422016 *qt422016.Writer, rs *netstorage.Result)
func StreamLabelValuesResponse(qw422016 *qt422016.Writer, labelValues []string)
func StreamLabelsCountResponse(qw422016 *qt422016.Writer, labelEntries []storage.TagEntry)
func StreamLabelsResponse(qw422016 *qt422016.Writer, labels []string)
func StreamQueryRangeResponse(qw422016 *qt422016.Writer, rs []netstorage.Result)
func StreamQueryResponse(qw422016 *qt422016.Writer, rs []netstorage.Result)
func StreamSeriesCountResponse(qw422016 *qt422016.Writer, n uint64)
func StreamSeriesResponse(qw422016 *qt422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)
func WriteErrorResponse(qq422016 qtio422016.Writer, statusCode int, err error)
func WriteExportJSONLine(qq422016 qtio422016.Writer, rs *netstorage.Result)
func WriteExportPromAPILine(qq422016 qtio422016.Writer, rs *netstorage.Result)
func WriteExportPromAPIResponse(qq422016 qtio422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)
func WriteExportPrometheusLine(qq422016 qtio422016.Writer, rs *netstorage.Result)
func WriteExportStdResponse(qq422016 qtio422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)
func WriteFederate(qq422016 qtio422016.Writer, rs *netstorage.Result)
func WriteLabelValuesResponse(qq422016 qtio422016.Writer, labelValues []string)
func WriteLabelsCountResponse(qq422016 qtio422016.Writer, labelEntries []storage.TagEntry)
func WriteLabelsResponse(qq422016 qtio422016.Writer, labels []string)
func WriteQueryRangeResponse(qq422016 qtio422016.Writer, rs []netstorage.Result)
func WriteQueryResponse(qq422016 qtio422016.Writer, rs []netstorage.Result)
func WriteSeriesCountResponse(qq422016 qtio422016.Writer, n uint64)
func WriteSeriesResponse(qq422016 qtio422016.Writer, resultsCh <-chan *quicktemplate.ByteBuffer)

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 SeriesHandler ¶

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

Source Files ¶

View all Source files

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