dataplane

Documentation

Index

• type Exporter
• type OTLPExporter
  • func NewOTLPExporter(c consumer.Logs) *OTLPExporter
  • func (e *OTLPExporter) Close(context.Context) error
  • func (e *OTLPExporter) Export(ctx context.Context, otlpLogs sample.OTLPLogs) error
• type Processor
  • func NewProcessor(logger logging.Logger, cpServer *server.Server, exporter Exporter) *Processor
  • func (p *Processor) Process(ctx context.Context, logs sample.OTLPLogs) error
  • func (p *Processor) Start() error
  • func (p *Processor) Stop() error
  • func (p *Processor) UpdateConfig(resource, sampler string, config *control.SamplerConfig, logger logging.Logger)

Types

type Exporter

type Exporter interface {
	Export(ctx context.Context, otlpLogs sample.OTLPLogs) error
	Close(context.Context) error
}

type OTLPExporter

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

func NewOTLPExporter

func NewOTLPExporter(c consumer.Logs) *OTLPExporter

func (*OTLPExporter) Close

func (e *OTLPExporter) Close(context.Context) error

func (*OTLPExporter) Export

func (e *OTLPExporter) Export(ctx context.Context, otlpLogs sample.OTLPLogs) error

type Processor

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

func NewProcessor

func NewProcessor(logger logging.Logger, cpServer *server.Server, exporter Exporter) *Processor

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, logs sample.OTLPLogs) error

func (*Processor) Start

func (p *Processor) Start() error

func (*Processor) Stop

func (p *Processor) Stop() error

func (*Processor) UpdateConfig

func (p *Processor) UpdateConfig(resource, sampler string, config *control.SamplerConfig, logger logging.Logger)