logsagentexporter

Documentation

Overview

Package logsagentexporter contains a logs exporter which forwards logs to a channel.

Index

• Constants
• func NewFactory(logsAgentChannel chan *message.Message) exp.Factory
• type Config
• type Exporter
  • func NewExporter(set component.TelemetrySettings, cfg *Config, logSource *sources.LogSource, ...) (*Exporter, error)
  • func (e *Exporter) ConsumeLogs(ctx context.Context, ld plog.Logs) (err error)

Constants

const (
	// TypeStr defines the logsagent exporter type string.
	TypeStr = "logsagent"

	// LogSourceName specifies the Datadog source tag value to be added to logs sent by the logs agent exporter.
	LogSourceName = "otlp_log_ingestion"
)

Functions

func NewFactory

func NewFactory(logsAgentChannel chan *message.Message) exp.Factory

NewFactory creates a new logsagentexporter factory.

Types

type Config

type Config struct {
	OtelSource    string
	LogSourceName string
}

Config defines configuration for the logs agent exporter.

type Exporter

type Exporter struct {
	// contains filtered or unexported fields
}

Exporter defines fields for the logs agent exporter

func NewExporter

func NewExporter(
	set component.TelemetrySettings,
	cfg *Config,
	logSource *sources.LogSource,
	logsAgentChannel chan *message.Message,
	attributesTranslator *attributes.Translator,
) (*Exporter, error)

NewExporter initializes a new logs agent exporter with the given parameters

func (*Exporter) ConsumeLogs

func (e *Exporter) ConsumeLogs(ctx context.Context, ld plog.Logs) (err error)

ConsumeLogs maps logs from OTLP to DD format and ingests them through the exporter channel