kafkaexporter

Documentation

Index

• Constants
• func AddFlags(flags *flag.FlagSet)
• type Factory
  • func (f Factory) CreateDefaultConfig() configmodels.Exporter
  • func (f Factory) CreateLogsExporter(ctx context.Context, params component.ExporterCreateParams, ...) (component.LogsExporter, error)
  • func (f Factory) CreateMetricsExporter(ctx context.Context, params component.ExporterCreateParams, ...) (component.MetricsExporter, error)
  • func (f Factory) CreateTracesExporter(ctx context.Context, params component.ExporterCreateParams, ...) (component.TracesExporter, error)
  • func (f Factory) Type() configmodels.Type

Constants

const TypeStr = "kafka"

TypeStr defines exporter type.

Functions

func AddFlags

func AddFlags(flags *flag.FlagSet)

AddFlags adds Ingester flags.

Types

type Factory

type Factory struct {
	// Wrapped is kafka exporter
	Wrapped component.ExporterFactory
	// Viper is used to get configuration values for default configuration
	Viper *viper.Viper
}

Factory wraps kafkaexporter.Factory and makes the default config configurable via viper. For instance this enables using flags as default values in the config object.

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 (f Factory) CreateMetricsExporter(
	ctx context.Context,
	params component.ExporterCreateParams,
	cfg configmodels.Exporter,
) (component.MetricsExporter, error)

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

func (Factory) CreateTracesExporter

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

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

func (Factory) Type

func (f Factory) Type() configmodels.Type

Type returns the type of the exporter.