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 (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"
)
Variables ¶
This section is empty.
Functions ¶
func DefaultOptions ¶
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.
type OptionsFactory ¶
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 ¶
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 ¶
Initialize initializes StorageFactory
Source Files
Directories