pulsarexporter

Jun 15, 2022

Changes in this version

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

+ type Authentication struct

+ TLS *configtls.TLSClientSetting

+ type Config struct

+ Authentication Authentication

+ Broker string

+ ConnectionTimeout time.Duration

+ Encoding string

+ OperationTimeout time.Duration

+ Producer Producer

+ Topic string

+ func (cfg *Config) Validate() error

+ type FactoryOption func(factory *pulsarExporterFactory)

+ type MetricsMarshaler interface

+ Encoding func() string

+ Marshal func(metrics pmetric.Metrics) ([]*pulsar.ProducerMessage, error)

+ type Producer struct

+ BatcherBuilderType int

+ BatchingMaxMessages uint

+ BatchingMaxPublishDelay time.Duration

+ BatchingMaxSize uint

+ CompressionLevel string

+ CompressionType string

+ DisableBatching bool

+ DisableBlockIfQueueFull bool

+ HashingScheme string

+ MaxPendingMessages int

+ MaxReconnectToBroker *uint

+ Name string

+ PartitionsAutoDiscoveryInterval time.Duration

+ Properties map[string]string

+ SendTimeout time.Duration