server

Documentation

Index

• func DecodeWriteRequest(r io.Reader) (*prompb.WriteRequest, error)
• func ErrBadData(err error) render.Renderer
• func ErrCanceled(err error) render.Renderer
• func ErrInternal(err error) render.Renderer
• func SuccessResponse(data interface{}) render.Renderer
• type ExemplarServer
  • func NewExemplarServer(logger log.Logger, reg *prometheus.Registry, store storage.ExemplarStore) *ExemplarServer
  • func (e *ExemplarServer) Exemplars(r *exemplarspb.ExemplarsRequest, s exemplarspb.Exemplars_ExemplarsServer) error
  • func (e *ExemplarServer) QueryExemplars(w http.ResponseWriter, r *http.Request)
  • func (e *ExemplarServer) RemoteWrite(w http.ResponseWriter, r *http.Request)

Functions

func DecodeWriteRequest

func DecodeWriteRequest(r io.Reader) (*prompb.WriteRequest, error)

DecodeWriteRequest from an io.Reader into a prompb.WriteRequest, handling snappy decompression.

func ErrBadData

func ErrBadData(err error) render.Renderer

func ErrCanceled

func ErrCanceled(err error) render.Renderer

func ErrInternal

func ErrInternal(err error) render.Renderer

func SuccessResponse

func SuccessResponse(data interface{}) render.Renderer

Types

type ExemplarServer

type ExemplarServer struct {
	Mux *chi.Mux
	// contains filtered or unexported fields
}

func NewExemplarServer

func NewExemplarServer(logger log.Logger, reg *prometheus.Registry, store storage.ExemplarStore) *ExemplarServer

func (*ExemplarServer) Exemplars

func (e *ExemplarServer) Exemplars(r *exemplarspb.ExemplarsRequest, s exemplarspb.Exemplars_ExemplarsServer) error

func (*ExemplarServer) QueryExemplars

func (e *ExemplarServer) QueryExemplars(w http.ResponseWriter, r *http.Request)

func (*ExemplarServer) RemoteWrite

func (e *ExemplarServer) RemoteWrite(w http.ResponseWriter, r *http.Request)