remote

package
v1.4.1 Latest Latest
Warning

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

Go to latest
Published: Nov 20, 2021 License: Apache-2.0 Imports: 46 Imported by: 4

Documentation

Index

Constants

View Source
const (

	// TagValuesURL is the url for tag values.
	TagValuesURL = route.LabelValuesURL

	// TagValuesHTTPMethod is the HTTP method used with this resource.
	TagValuesHTTPMethod = http.MethodGet
)
View Source
const (
	// PromWriteURL is the url for the prom write handler
	PromWriteURL = route.Prefix + "/prom/remote/write"

	// PromWriteHTTPMethod is the HTTP method used with this resource.
	PromWriteHTTPMethod = http.MethodPost
)
View Source
const (
	// PromReadURL is the url for remote prom read handler
	PromReadURL = route.Prefix + "/prom/remote/read"
)

Variables

View Source
var PromReadHTTPMethods = []string{http.MethodPost, http.MethodGet}

PromReadHTTPMethods are the HTTP methods used with this resource.

View Source
var PromSeriesMatchHTTPMethods = []string{http.MethodGet, http.MethodPost}

PromSeriesMatchHTTPMethods are the HTTP methods for this handler.

Functions

func NewPromReadHandler

func NewPromReadHandler(opts options.HandlerOptions) http.Handler

NewPromReadHandler returns a new instance of handler.

func NewPromSeriesMatchHandler added in v0.5.0

func NewPromSeriesMatchHandler(opts options.HandlerOptions) http.Handler

NewPromSeriesMatchHandler returns a new instance of handler. TODO: Remove series match handler, not part of Prometheus HTTP API and not used anywhere or documented.

func NewPromWriteHandler

func NewPromWriteHandler(options options.HandlerOptions) (http.Handler, error)

NewPromWriteHandler returns a new instance of handler.

func NewTagValuesHandler added in v0.5.0

func NewTagValuesHandler(opts options.HandlerOptions) http.Handler

NewTagValuesHandler returns a new instance of handler.

func ParseExpr added in v0.15.0

func ParseExpr(
	r *http.Request,
	opts xpromql.ParseOptions,
) (*prompb.ReadRequest, error)

ParseExpr parses a prometheus request expression into the constituent fetches, rather than the full query application.

func ParseRequest added in v0.15.0

ParseRequest parses the compressed request

func WriteSnappyCompressed added in v0.15.0

func WriteSnappyCompressed(
	w http.ResponseWriter,
	readResult ReadResult,
	logger *zap.Logger,
) error

WriteSnappyCompressed writes snappy compressed results to the given writer.

Types

type PromSeriesMatchHandler added in v0.5.0

type PromSeriesMatchHandler struct {
	// contains filtered or unexported fields
}

PromSeriesMatchHandler represents a handler for the prometheus series matcher endpoint.

func (*PromSeriesMatchHandler) ServeHTTP added in v0.5.0

type PromWriteHandler

type PromWriteHandler struct {
	// contains filtered or unexported fields
}

PromWriteHandler represents a handler for prometheus write endpoint.

func (*PromWriteHandler) ServeHTTP

func (h *PromWriteHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ReadResult added in v0.15.0

type ReadResult struct {
	Meta   block.ResultMetadata
	Result []*prompb.QueryResult
}

ReadResult is a read result.

func Read added in v0.15.0

Read performs a remote read on the given engine.

type TagValuesHandler added in v0.5.0

type TagValuesHandler struct {
	// contains filtered or unexported fields
}

TagValuesHandler represents a handler for search tags endpoint.

func (*TagValuesHandler) ServeHTTP added in v0.5.0

func (h *TagValuesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type TagValuesResponse added in v0.5.0

type TagValuesResponse struct {
	Results consolidators.CompleteTagsResult `json:"results,omitempty"`
}

TagValuesResponse is the response that gets returned to the user

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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