Versions in this module Expand all Collapse all v0 v0.13.1 Nov 28, 2019 v0.13.0 Sep 17, 2019 Changes in this version + func CreateMsg(metrics []*schema.MetricData, id int64, version Format) ([]byte, error) + func ReadPointMsg(data []byte, defaultOrg uint32) ([]byte, schema.MetricPoint, error) + func WritePointMsg(point schema.MetricPoint, buf []byte, version Format) (o []byte, err error) + type Format uint8 + const FormatMetricDataArrayJson + const FormatMetricDataArrayMsgp + const FormatMetricPoint + const FormatMetricPointWithoutOrg + func IsPointMsg(data []byte) (Format, bool) + func (i Format) String() string + type MetricData struct + Format Format + Id int64 + Metrics []*schema.MetricData + Msg []byte + Produced time.Time + func (m *MetricData) DecodeMetricData() error + func (m *MetricData) InitFromMsg(msg []byte) error
Go to main page