processor

Documentation

Index

• type InstrumentingProcessor
  • func NewInstrumentingProcessor(processor Processor, instrumentor *telemetry.Instrumentor, tracer trace.Tracer) *InstrumentingProcessor
  • func (p *InstrumentingProcessor) ProcessRecord(ctx context.Context, record *kgo.Record, producer *internalKgo.Producer) (err error)
• type Processor

Types

type InstrumentingProcessor

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

InstrumentingProcessor is a decorator that adds instrumentation to a Processor.

func NewInstrumentingProcessor

func NewInstrumentingProcessor(processor Processor, instrumentor *telemetry.Instrumentor, tracer trace.Tracer) *InstrumentingProcessor

NewInstrumentingProcessor creates a new InstrumentingProcessor.

func (*InstrumentingProcessor) ProcessRecord

func (p *InstrumentingProcessor) ProcessRecord(ctx context.Context, record *kgo.Record, producer *internalKgo.Producer) (err error)

ProcessRecord processes a Kafka record and instruments the operation.

type Processor

type Processor interface {
	ProcessRecord(ctx context.Context, record *kgo.Record, producer *internalKgo.Producer) error
}

Processor defines the interface for processing Kafka records.