pulsarexporter

README

Pulsar Exporter

Pulsar exporter exports logs, metrics, and traces to Pulsar.

Documentation

Overview

Package pulsarexporter exports trace data to Pulsar.

Index

• func NewFactory(options ...FactoryOption) component.ExporterFactory
• type Config
  • func (cfg *Config) Validate() error
• type FactoryOption
• type Metadata
• type MetadataRetry
• type MetricsMarshaler
• type Producer

Functions

func NewFactory

func NewFactory(options ...FactoryOption) component.ExporterFactory

NewFactory creates pulsar exporter factory.

Types

type Config

type Config struct {
	config.ExporterSettings        `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct
	exporterhelper.TimeoutSettings `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct.
	exporterhelper.QueueSettings   `mapstructure:"sending_queue"`
	exporterhelper.RetrySettings   `mapstructure:"retry_on_failure"`

	//// The list of pulsar brokers (default localhost:9092)
	Brokers string `mapstructure:"brokers"`
	//// The name of the pulsar topic to export to (default otlp_spans for traces, otlp_metrics for metrics)
	Topic string `mapstructure:"topic"`

	// Encoding of messages (default "otlp_proto")
	Encoding string `mapstructure:"encoding"`

	// Metadata is the namespace for metadata management properties used by the
	// Client, and shared by the Producer/Consumer.
	Metadata Metadata `mapstructure:"metadata"`

	// Producer is the namespaces for producer properties used only by the Producer
	Producer Producer `mapstructure:"producer"`
}

Config defines configuration for pulsar exporter.

func (*Config) Validate

func (cfg *Config) Validate() error

Validate checks if the exporter configuration is valid

type FactoryOption

type FactoryOption func(factory *pulsarExporterFactory)

FactoryOption applies changes to pulsarExporterFactory.

type Metadata

type Metadata struct {
}

Metadata defines configuration for retrieving metadata from the broker.

type MetadataRetry

type MetadataRetry struct {
}

MetadataRetry defines retry configuration for Metadata.

type MetricsMarshaler

type MetricsMarshaler interface {
	// Marshal serializes metrics into pulsar's ProducerMessage
	Marshal(metrics pmetric.Metrics) ([]*pulsar.ProducerMessage, error)

	// Encoding returns encoding name
	Encoding() string
}

MetricsMarshaler marshals metrics into Message array

type Producer

type Producer struct {
}

Producer defines configuration for producer