otlp

Documentation

Index

• type DiodeKafkaRecv
  • func (d *DiodeKafkaRecv) Start() error
  • func (d *DiodeKafkaRecv) Stop() error
• type DiodeLogConsumer
  • func (dlc *DiodeLogConsumer) Capabilities() consumer.Capabilities
  • func (dlc *DiodeLogConsumer) ConsumeLogs(ctx context.Context, ld plog.Logs) error
• type DiodeOtlpRecv
  • func (d *DiodeOtlpRecv) Start() error
  • func (d *DiodeOtlpRecv) Stop() error
• type Otlp
  • func New(ctx context.Context, logger *zap.Logger, config *config.Config, ...) Otlp

Types

type DiodeKafkaRecv

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

func (*DiodeKafkaRecv) Start

func (d *DiodeKafkaRecv) Start() error

func (*DiodeKafkaRecv) Stop

func (d *DiodeKafkaRecv) Stop() error

type DiodeLogConsumer

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

func (*DiodeLogConsumer) Capabilities

func (dlc *DiodeLogConsumer) Capabilities() consumer.Capabilities

func (*DiodeLogConsumer) ConsumeLogs

func (dlc *DiodeLogConsumer) ConsumeLogs(ctx context.Context, ld plog.Logs) error

type DiodeOtlpRecv

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

func (*DiodeOtlpRecv) Start

func (d *DiodeOtlpRecv) Start() error

func (*DiodeOtlpRecv) Stop

func (d *DiodeOtlpRecv) Stop() error

type Otlp

type Otlp interface {
	Start() error
	Stop() error
}

func New

func New(ctx context.Context, logger *zap.Logger, config *config.Config, channel chan []byte) Otlp