awskinesisexporter

README

Kinesis Exporter

To be added.

Documentation

Index

• func NewFactory() component.ExporterFactory
• type AWSConfig
• type Config
• type Exporter
  • func (e Exporter) Capabilities() consumer.Capabilities
  • func (e Exporter) ConsumeTraces(_ context.Context, td pdata.Traces) error
  • func (e Exporter) Shutdown(context.Context) error
  • func (e Exporter) Start(_ context.Context, _ component.Host) error
• type KPLConfig

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:",squash"`

	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) Capabilities

func (e Exporter) Capabilities() consumer.Capabilities

Capabilities implements the consumer interface.

func (Exporter) ConsumeTraces

func (e Exporter) ConsumeTraces(_ context.Context, td pdata.Traces) error

ConsumeTraces receives a span batch and exports it to AWS Kinesis

func (Exporter) Shutdown

func (e Exporter) Shutdown(context.Context) error

Shutdown is invoked during exporter shutdown.

func (Exporter) Start

func (e Exporter) Start(_ context.Context, _ component.Host) error

Start tells the exporter to start. The exporter may prepare for exporting by connecting to the endpoint. Host parameter can be used for communicating with the host after Start() has already returned. If error is returned by Start() then the collector startup will be aborted.

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.