prometheus

Documentation

Index

• func DecodeWriteRequest(r io.Reader) (*prompb.WriteRequest, error)
• func ProcessMetrics(r io.Reader) (*pb.MetricsBatch, error)
• type MetricsHandler
  • func NewMetricsHandler(options Options, store []byte) *MetricsHandler
  • func (mh *MetricsHandler) RemoteWriteHandler(w http.ResponseWriter, r *http.Request)
• type MetricsStatus
• type MetricsStore
• type Options

Functions

func DecodeWriteRequest

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

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

func ProcessMetrics

func ProcessMetrics(r io.Reader) (*pb.MetricsBatch, error)

Types

type MetricsHandler

type MetricsHandler struct {
	Options Options
	Store   MetricsStore
}

func NewMetricsHandler

func NewMetricsHandler(options Options, store []byte) *MetricsHandler

func (*MetricsHandler) RemoteWriteHandler

func (mh *MetricsHandler) RemoteWriteHandler(w http.ResponseWriter, r *http.Request)

type MetricsStatus

type MetricsStatus struct {
	Msg          string    `json:"message"`
	LastModified time.Time `json:"last_modified"`
}

type MetricsStore

type MetricsStore []byte

type Options

type Options map[string]string