api

Documentation

Index

• func DecodeWriteRequest(r io.Reader) (*prompb.WriteRequest, error)
• func Start()
• type FalconMetric
  • func (m *FalconMetric) Clean(ts int64) error
  • func (m *FalconMetric) ToProm() (*prompb.TimeSeries, string, error)
• type Metric
  • func (m *Metric) Clean(ts int64) error
  • func (m *Metric) ToProm() (*prompb.TimeSeries, error)

Functions

func DecodeWriteRequest

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

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

func Start

func Start()

Types

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 Metric

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

func (*Metric) Clean

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

func (*Metric) ToProm

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