kafka

Documentation

Index

• Constants
• type Exporter
  • func NewKafkaTemplate(logger *slog.Logger, kafkaCfg config.KafkaConfig) *Exporter
  • func (p *Exporter) DataClass() metrics.DataClass
  • func (p *Exporter) Name() string
  • func (p *Exporter) Publish(_ context.Context, evt *events.Event) error
  • func (p *Exporter) ValidateConfig(settings map[string]interface{}) error
  • func (p *Exporter) WithSettings(settings map[string]interface{}) (appmetrics.Exporter, error)

Constants

const ExporterName = "kafka"

Types

type Exporter

type Exporter struct {
	infratelemetry.KafkaBase
}

func NewKafkaTemplate

func NewKafkaTemplate(logger *slog.Logger, kafkaCfg config.KafkaConfig) *Exporter

func (*Exporter) DataClass

func (p *Exporter) DataClass() metrics.DataClass

DataClass fixes this exporter to the metadata class; the pipeline routes only the sanitized metadata view here, so the full-event marshal never carries sensible bodies (ENG-1021).

func (*Exporter) Name

func (p *Exporter) Name() string

func (*Exporter) Publish

func (p *Exporter) Publish(_ context.Context, evt *events.Event) error

func (*Exporter) ValidateConfig

func (p *Exporter) ValidateConfig(settings map[string]interface{}) error

func (*Exporter) WithSettings

func (p *Exporter) WithSettings(settings map[string]interface{}) (appmetrics.Exporter, error)