Documentation ¶
Index ¶
- func NewFactory() component.ExporterFactory
- func NewLogsExporter(ctx context.Context, params component.ExporterCreateSettings, ...) (component.LogsExporter, error)
- func NewMetricsExporter(ctx context.Context, params component.ExporterCreateSettings, ...) (component.MetricsExporter, error)
- func NewTracesExporter(ctx context.Context, params component.ExporterCreateSettings, ...) (component.TracesExporter, error)
- type AWSConfig
- type Config
- type Encoding
- type Exporter
- func (e Exporter) Capabilities() consumer.Capabilities
- func (e Exporter) ConsumeLogs(ctx context.Context, ld pdata.Logs) error
- func (e Exporter) ConsumeMetrics(ctx context.Context, md pdata.Metrics) error
- func (e Exporter) ConsumeTraces(ctx context.Context, td pdata.Traces) error
- func (e Exporter) Shutdown(context.Context) error
- func (e Exporter) Start(ctx context.Context, _ component.Host) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFactory ¶
func NewFactory() component.ExporterFactory
NewFactory creates a factory for Kinesis exporter.
func NewLogsExporter ¶ added in v0.36.0
func NewLogsExporter(ctx context.Context, params component.ExporterCreateSettings, conf config.Exporter) (component.LogsExporter, error)
func NewMetricsExporter ¶ added in v0.36.0
func NewMetricsExporter(ctx context.Context, params component.ExporterCreateSettings, conf config.Exporter) (component.MetricsExporter, error)
func NewTracesExporter ¶ added in v0.36.0
func NewTracesExporter(ctx context.Context, params component.ExporterCreateSettings, conf config.Exporter) (component.TracesExporter, error)
Types ¶
type AWSConfig ¶
type AWSConfig struct { StreamName string `mapstructure:"stream_name"` KinesisEndpoint string `mapstructure:"kinesis_endpoint"` Region string `mapstructure:"region"` Role string `mapstructure:"role"` }
AWSConfig contains AWS specific configuration such as awskinesis stream, region, etc.
type Config ¶
type Config struct { config.ExporterSettings `mapstructure:",squash"` exporterhelper.TimeoutSettings `mapstructure:",squash"` exporterhelper.QueueSettings `mapstructure:"sending_queue"` exporterhelper.RetrySettings `mapstructure:"retry_on_failure"` Encoding `mapstructure:"encoding"` AWS AWSConfig `mapstructure:"aws"` MaxRecordsPerBatch int `mapstructure:"max_records_per_batch"` MaxRecordSize int `mapstructure:"max_record_size"` }
Config contains the main configuration options for the awskinesis exporter
type Exporter ¶
type Exporter struct {
// contains filtered or unexported fields
}
Exporter implements an OpenTelemetry trace exporter that exports all spans to AWS Kinesis
func (Exporter) Capabilities ¶ added in v0.27.0
func (e Exporter) Capabilities() consumer.Capabilities
Capabilities implements the consumer interface.
func (Exporter) ConsumeLogs ¶ added in v0.36.0
func (Exporter) ConsumeMetrics ¶ added in v0.36.0
func (Exporter) ConsumeTraces ¶
ConsumeTraces receives a span batch and exports it to AWS Kinesis
Click to show internal directories.
Click to hide internal directories.