pulsarexporter

README

Pulsar Exporter

Status
Stability	deprecated
Supported pipeline types	metrics

The Pulsar exporter is used to export metrics to Apache Pulsar.

The exporter is deprecated and will be replaced by the OpenTelemetry Collector upstream exporter.

Documentation

Overview

Deprecated: This exporter will be replaced by github.com/open-telemetry/opentelemetry-collector-contrib/exporter/pulsarexporter Package pulsarexporter exports trace data to Pulsar.

Index

• func NewFactory(options ...FactoryOption) exporter.Factory
• type Authentication
• type Config
  • func (cfg *Config) Validate() error
• type FactoryOption
• type MetricsMarshaler
• type Producer

Functions

func NewFactory

func NewFactory(options ...FactoryOption) exporter.Factory

Deprecated: This exporter will be replaced by github.com/open-telemetry/opentelemetry-collector-contrib/exporter/pulsarexporter NewFactory creates pulsar exporter factory.

Types

type Authentication

type Authentication struct {
	TLS *configtls.TLSClientSetting `mapstructure:"tls"`
}

type Config

type Config struct {
	exporterhelper.QueueSettings   `mapstructure:"sending_queue"`
	Authentication                 Authentication `mapstructure:"auth"`
	Broker                         string         `mapstructure:"broker"`
	Topic                          string         `mapstructure:"topic"`
	Encoding                       string         `mapstructure:"encoding"`
	Producer                       Producer       `mapstructure:"producer"`
	exporterhelper.RetrySettings   `mapstructure:"retry_on_failure"`
	exporterhelper.TimeoutSettings `mapstructure:",squash"`
	OperationTimeout               time.Duration `mapstructure:"operation_timeout"`
	ConnectionTimeout              time.Duration `mapstructure:"connection_timeout"`
}

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 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 {
	Properties                      map[string]string `mapstructure:"producer_properties"`
	MaxReconnectToBroker            *uint             `mapstructure:"max_reconnect_broker"`
	SendTimeout                     *time.Duration    `mapstructure:"send_timeout"`
	BatcherBuilderType              string            `mapstructure:"batch_builder_type"`
	CompressionType                 string            `mapstructure:"compression_type"`
	CompressionLevel                string            `mapstructure:"compression_level"`
	HashingScheme                   string            `mapstructure:"hashing_scheme"`
	MaxPendingMessages              int               `mapstructure:"max_pending_messages"`
	PartitionsAutoDiscoveryInterval time.Duration     `mapstructure:"partitions_auto_discovery_interval"`
	BatchingMaxPublishDelay         time.Duration     `mapstructure:"batching_max_publish_delay"`
	BatchingMaxMessages             uint              `mapstructure:"batching_max_messages"`
	BatchingMaxSize                 uint              `mapstructure:"batching_max_size"`
	DisableBlockIfQueueFull         bool              `mapstructure:"disable_block_if_queue_full"`
	DisableBatching                 bool              `mapstructure:"disable_batching"`
}

Producer defines configuration for producer