logs

Documentation

Index

• type Processor
  • func NewProcessor(ctx context.Context, logger *zap.Logger, code, entry string, ...) *Processor
  • func (p *Processor) Capabilities() consumer.Capabilities
  • func (p *Processor) ConsumeLogs(ctx context.Context, ld plog.Logs) error
  • func (p *Processor) Shutdown(context.Context) error
  • func (p *Processor) Start(ctx context.Context, _ component.Host) error

Types

type Processor

type Processor struct {
	plog.JSONMarshaler
	plog.JSONUnmarshaler
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(ctx context.Context, logger *zap.Logger,
	code, entry string, consumer consumer.Logs) *Processor

func (*Processor) Capabilities

func (p *Processor) Capabilities() consumer.Capabilities

func (*Processor) ConsumeLogs

func (p *Processor) ConsumeLogs(ctx context.Context, ld plog.Logs) error

func (*Processor) Shutdown

func (p *Processor) Shutdown(context.Context) error

func (*Processor) Start

func (p *Processor) Start(ctx context.Context, _ component.Host) error