common

Documentation

Index

• Constants
• func ConvertToM3(fileName string, workers int, f func(*M3Metric))
• func ConvertToProm(fileName string, workers int, batchSize int, f func(*bytes.Reader))
• func PostEncodedSnappy(url string, body io.Reader) (*http.Response, error)
• type M3Metric
• type Metrics

Constants

const (
	// MetricsLen is used to create the objects that store the parsed metrics
	MetricsLen = 100000
)

Functions

func ConvertToM3

func ConvertToM3(fileName string, workers int, f func(*M3Metric))

ConvertToM3 parses the json file that is generated from InfluxDB's bulk_data_gen tool

func ConvertToProm

func ConvertToProm(fileName string, workers int, batchSize int, f func(*bytes.Reader))

ConvertToProm parses the json file that is generated from InfluxDB's bulk_data_gen tool into Prom format

func PostEncodedSnappy

func PostEncodedSnappy(url string, body io.Reader) (*http.Response, error)

PostEncodedSnappy wraps request with content headers then POSTs to url with given body

Types

type M3Metric

type M3Metric struct {
	ID    string
	Time  time.Time
	Value float64
}

M3Metric is a lighterweight Metrics struct

type Metrics

type Metrics struct {
	Name  string            `json:"metric"`
	Time  int64             `json:"timestamp"`
	Tags  map[string]string `json:"tags"`
	Value float64           `json:"value"`
}

Metrics is the OpenTSDB style metrics