opentsdbexporter

Documentation

Index

• func NewFactory() exporter.Factory
• func NewMetricsExporter(config component.Config, logger *zap.Logger, set exporter.CreateSettings) (exporter.Metrics, error)
• type Config
  • func (cfg *Config) Validate() error
• type HttpSerializer
  • func NewHttpSerializer(logger *zap.Logger, maxTags int, skipTags []string) *HttpSerializer
  • func (h *HttpSerializer) Marshal(metrics pmetric.Metrics) (sMetrics []*Metric, errs []error)
• type Metric
  • func (m Metric) String() string
• type OpenTSDBExporter
  • func NewOpenTSDBExporter(config *Config, set exporter.CreateSettings, logger *zap.Logger) *OpenTSDBExporter
  • func (e *OpenTSDBExporter) PushMetrics(ctx context.Context, md pmetric.Metrics) error

Functions

func NewFactory

func NewFactory() exporter.Factory

func NewMetricsExporter

func NewMetricsExporter(config component.Config, logger *zap.Logger, set exporter.CreateSettings) (exporter.Metrics, error)

Types

type Config

type Config struct {
	exporterhelper.TimeoutSettings `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct.

	// OpenTSDB Endpoint
	confighttp.HTTPClientSettings `mapstructure:",squash"`

	// The maximum number of datapoints to send to the OpenTSDB backend
	BatchSize int `mapstructure:"batch_size"`
	// The maximum number of tags per datapoint
	MaxTags int `mapstructure:"max_tags"`
	// Tags to skip
	SkipTags []string `mapstructure:"skip_tags"`

	// ResourceToTelemetrySettings is the option for converting resource attributes to telemetry attributes.
	// "Enabled" - A boolean field to enable/disable this option. Default is `false`.
	// If enabled, all the resource attributes will be converted to metric labels by default.
	ResourceToTelemetrySettings resourcetotelemetry.Settings `mapstructure:"resource_to_telemetry_conversion"`
}

func (*Config) Validate

func (cfg *Config) Validate() error

type HttpSerializer

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

func NewHttpSerializer

func NewHttpSerializer(logger *zap.Logger, maxTags int, skipTags []string) *HttpSerializer

func (*HttpSerializer) Marshal

func (h *HttpSerializer) Marshal(metrics pmetric.Metrics) (sMetrics []*Metric, errs []error)

type Metric

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

func (Metric) String

func (m Metric) String() string

type OpenTSDBExporter

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

func NewOpenTSDBExporter

func NewOpenTSDBExporter(config *Config, set exporter.CreateSettings, logger *zap.Logger) *OpenTSDBExporter

func (*OpenTSDBExporter) PushMetrics

func (e *OpenTSDBExporter) PushMetrics(ctx context.Context, md pmetric.Metrics) error