elasticsearchexporter

Documentation

Overview

Package elasticsearchexporter implements Jaeger Elasticsearch storage as OpenTelemetry exporter.

Index

• Constants
• func DefaultOptions() *es.Options
• type Config
• type Factory
  • func (f Factory) CreateDefaultConfig() configmodels.Exporter
  • func (f Factory) CreateLogsExporter(ctx context.Context, params component.ExporterCreateParams, ...) (component.LogsExporter, error)
  • func (Factory) CreateMetricsExporter(context.Context, component.ExporterCreateParams, configmodels.Exporter) (component.MetricsExporter, error)
  • func (Factory) CreateTracesExporter(ctx context.Context, params component.ExporterCreateParams, ...) (component.TracesExporter, error)
  • func (Factory) Type() configmodels.Type
• type OptionsFactory
• type StorageFactory
  • func NewStorageFactory(opts *es.Options, logger *zap.Logger, name string) *StorageFactory
  • func (s *StorageFactory) CreateArchiveSpanReader() (spanstore.Reader, error)
  • func (s *StorageFactory) CreateArchiveSpanWriter() (spanstore.Writer, error)
  • func (s *StorageFactory) CreateDependencyReader() (dependencystore.Reader, error)
  • func (s *StorageFactory) CreateSpanReader() (spanstore.Reader, error)
  • func (s *StorageFactory) CreateSpanWriter() (spanstore.Writer, error)
  • func (s *StorageFactory) Initialize(_ metrics.Factory, logger *zap.Logger) error

Constants

const (
	// TypeStr defines type of the Elasticsearch exporter.
	TypeStr = "jaeger_elasticsearch"
)

Functions

func DefaultOptions

func DefaultOptions() *es.Options

DefaultOptions creates Elasticsearch options supported by this exporter.

Types

type Config

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

	es.Options `mapstructure:",squash"`
}

Config holds configuration of Jaeger Elasticsearch exporter/storage.

type Factory

type Factory struct {
	OptionsFactory OptionsFactory
}

Factory is the factory for Jaeger Elasticsearch exporter.

func (Factory) CreateDefaultConfig

func (f Factory) CreateDefaultConfig() configmodels.Exporter

CreateDefaultConfig returns default configuration of Factory. This function implements OTEL component.ExporterFactoryBase interface.

func (Factory) CreateLogsExporter

func (f Factory) CreateLogsExporter(
	ctx context.Context,
	params component.ExporterCreateParams,
	cfg configmodels.Exporter,
) (component.LogsExporter, error)

CreateLogsExporter creates a metrics exporter based on provided config. This function implements component.ExporterFactory.

func (Factory) CreateMetricsExporter

func (Factory) CreateMetricsExporter(
	context.Context,
	component.ExporterCreateParams,
	configmodels.Exporter,
) (component.MetricsExporter, error)

CreateMetricsExporter is not implemented. This function implements OTEL component.ExporterFactory interface.

func (Factory) CreateTracesExporter

func (Factory) CreateTracesExporter(
	ctx context.Context,
	params component.ExporterCreateParams,
	cfg configmodels.Exporter,
) (component.TracesExporter, error)

CreateTracesExporter creates Jaeger Elasticsearch trace exporter. This function implements OTEL component.ExporterFactory interface.

func (Factory) Type

func (Factory) Type() configmodels.Type

Type gets the type of exporter.

type OptionsFactory

type OptionsFactory func() *es.Options

OptionsFactory returns initialized es.OptionsFactory structure.

type StorageFactory

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

StorageFactory implements storage.Factory and storage.ArchiveFactory

func NewStorageFactory

func NewStorageFactory(opts *es.Options, logger *zap.Logger, name string) *StorageFactory

NewStorageFactory creates StorageFactory

func (*StorageFactory) CreateArchiveSpanReader

func (s *StorageFactory) CreateArchiveSpanReader() (spanstore.Reader, error)

CreateArchiveSpanReader creates archive spanstore.Reader

func (*StorageFactory) CreateArchiveSpanWriter

func (s *StorageFactory) CreateArchiveSpanWriter() (spanstore.Writer, error)

CreateArchiveSpanWriter creates archive spanstore.Writer

func (*StorageFactory) CreateDependencyReader

func (s *StorageFactory) CreateDependencyReader() (dependencystore.Reader, error)

CreateDependencyReader creates dependencystore.Reader

func (*StorageFactory) CreateSpanReader

func (s *StorageFactory) CreateSpanReader() (spanstore.Reader, error)

CreateSpanReader creates spanstore.Reader

func (*StorageFactory) CreateSpanWriter

func (s *StorageFactory) CreateSpanWriter() (spanstore.Writer, error)

CreateSpanWriter creates spanstore.Writer

func (*StorageFactory) Initialize

func (s *StorageFactory) Initialize(_ metrics.Factory, logger *zap.Logger) error

Initialize initializes StorageFactory