router

Documentation

Index

• func DecodeWriteRequest(r io.Reader) (*prompb.WriteRequest, error)
• func New(version string, reloadFunc func()) *gin.Engine
• type DatadogMetric
  • func (m *DatadogMetric) Clean() error
  • func (m *DatadogMetric) ToProm() (*prompb.TimeSeries, string, error)
• type DatadogPoint
• type FalconMetric
  • func (m *FalconMetric) Clean(ts int64) error
  • func (m *FalconMetric) ToProm() (*prompb.TimeSeries, string, error)
• type HTTPMetric
  • func (m *HTTPMetric) Clean(ts int64) error
  • func (m *HTTPMetric) ToProm() (*prompb.TimeSeries, error)
• type TimeSeries

Functions

func DecodeWriteRequest

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

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

func New

func New(version string, reloadFunc func()) *gin.Engine

Types

type DatadogMetric

type DatadogMetric struct {
	Metric string         `json:"metric"`
	Points []DatadogPoint `json:"points"`
	Host   string         `json:"host"`
	Tags   []string       `json:"tags,omitempty"`
}

func (*DatadogMetric) Clean

func (m *DatadogMetric) Clean() error

func (*DatadogMetric) ToProm

func (m *DatadogMetric) ToProm() (*prompb.TimeSeries, string, error)

type DatadogPoint

type DatadogPoint [2]float64

type FalconMetric

type FalconMetric struct {
	Metric       string      `json:"metric"`
	Endpoint     string      `json:"endpoint"`
	Timestamp    int64       `json:"timestamp"`
	ValueUnTyped interface{} `json:"value"`
	Value        float64     `json:"-"`
	Tags         string      `json:"tags"`
}

func (*FalconMetric) Clean

func (m *FalconMetric) Clean(ts int64) error

func (*FalconMetric) ToProm

func (m *FalconMetric) ToProm() (*prompb.TimeSeries, string, error)

type HTTPMetric

type HTTPMetric struct {
	Metric       string            `json:"metric"`
	Timestamp    int64             `json:"timestamp"`
	ValueUnTyped interface{}       `json:"value"`
	Value        float64           `json:"-"`
	Tags         map[string]string `json:"tags"`
}

func (*HTTPMetric) Clean

func (m *HTTPMetric) Clean(ts int64) error

func (*HTTPMetric) ToProm

func (m *HTTPMetric) ToProm() (*prompb.TimeSeries, error)

type TimeSeries

type TimeSeries struct {
	Series []*DatadogMetric `json:"series"`
}