internal

Documentation

Index

• func IsTimestampSeconds(timestamp FlexUInt64) bool
• type FlexUInt64
  • func (i *FlexUInt64) UnmarshalJSON(payload []byte) error
• type HttpHandler
  • func NewHttpHandler(logger *zap.Logger, consumer consumer.Metrics, ...) *HttpHandler
  • func (h *HttpHandler) HandleWrite(w http.ResponseWriter, req *http.Request)
  • func (h *HttpHandler) NewHttpRouter() *http.ServeMux
• type JsonDeserializationUnrecoverableError
  • func (j *JsonDeserializationUnrecoverableError) Error() string
• type JsonSerializer
  • func NewJsonSerializer(logger *zap.Logger) *JsonSerializer
  • func (j *JsonSerializer) Serialize(input io.ReadCloser) (metrics []*OpenTSDBMetric, errs []error)
• type OpenTSDBMetric
  • func (o *OpenTSDBMetric) ToOtel() pmetric.Metric

Functions

func IsTimestampSeconds

func IsTimestampSeconds(timestamp FlexUInt64) bool

Types

type FlexUInt64

type FlexUInt64 uint64

func (*FlexUInt64) UnmarshalJSON

func (i *FlexUInt64) UnmarshalJSON(payload []byte) error

UnmarshalJSON decodes JSON

implements json.Unmarshaler interface

from: https://github.com/gildas/go-core/blob/master/flexint.go

type HttpHandler

type HttpHandler struct {
	// contains filtered or unexported fields
}

func NewHttpHandler

func NewHttpHandler(logger *zap.Logger, consumer consumer.Metrics, obsrecv *receiverhelper.ObsReport) *HttpHandler

func (*HttpHandler) HandleWrite

func (h *HttpHandler) HandleWrite(w http.ResponseWriter, req *http.Request)

func (*HttpHandler) NewHttpRouter

func (h *HttpHandler) NewHttpRouter() *http.ServeMux

type JsonDeserializationUnrecoverableError

type JsonDeserializationUnrecoverableError struct {
	// contains filtered or unexported fields
}

func (*JsonDeserializationUnrecoverableError) Error

func (j *JsonDeserializationUnrecoverableError) Error() string

type JsonSerializer

type JsonSerializer struct {
	// contains filtered or unexported fields
}

func NewJsonSerializer

func NewJsonSerializer(logger *zap.Logger) *JsonSerializer

func (*JsonSerializer) Serialize

func (j *JsonSerializer) Serialize(input io.ReadCloser) (metrics []*OpenTSDBMetric, errs []error)

type OpenTSDBMetric

type OpenTSDBMetric struct {
	Metric    string            `json:"metric"`
	Timestamp FlexUInt64        `json:"timestamp"`
	Value     json.Number       `json:"value"`
	Tags      map[string]string `json:"tags"`
}

func (*OpenTSDBMetric) ToOtel

func (o *OpenTSDBMetric) ToOtel() pmetric.Metric