api

package

v0.0.0-...-5655933 Latest Latest Go to latest Published: Oct 20, 2023 License: MIT Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/F1997/categraf

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

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