Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFactory ¶
func NewFactory() component.ExporterFactory
NewFactory creates a factory for Kinesis exporter.
Types ¶
type AWSConfig ¶
type AWSConfig struct { StreamName string `mapstructure:"stream_name"` KinesisEndpoint string `mapstructure:"awskinesis_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:"-"` AWS AWSConfig `mapstructure:"aws"` KPL KPLConfig `mapstructure:"kpl"` QueueSize int `mapstructure:"queue_size"` NumWorkers int `mapstructure:"num_workers"` MaxBytesPerBatch int `mapstructure:"max_bytes_per_batch"` MaxBytesPerSpan int `mapstructure:"max_bytes_per_span"` FlushIntervalSeconds int `mapstructure:"flush_interval_seconds"` }
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) ConsumeTraces ¶
ConsumeTraceData receives a span batch and exports it to AWS Kinesis
type KPLConfig ¶
type KPLConfig struct { AggregateBatchCount int `mapstructure:"aggregate_batch_count"` AggregateBatchSize int `mapstructure:"aggregate_batch_size"` BatchSize int `mapstructure:"batch_size"` BatchCount int `mapstructure:"batch_count"` BacklogCount int `mapstructure:"backlog_count"` FlushIntervalSeconds int `mapstructure:"flush_interval_seconds"` MaxConnections int `mapstructure:"max_connections"` MaxRetries int `mapstructure:"max_retries"` MaxBackoffSeconds int `mapstructure:"max_backoff_seconds"` }
KPLConfig contains awskinesis producer library related config to controls things like aggregation, batching, connections, retries, etc.
Click to show internal directories.
Click to hide internal directories.