testconsumer

Documentation

Index

• type BlockingConsumer
  • func NewBlockingConsumer() *BlockingConsumer
  • func (bc *BlockingConsumer) Capabilities() consumer.Capabilities
  • func (bc *BlockingConsumer) ConsumeLogs(_ context.Context, _ plog.Logs) error
  • func (bc *BlockingConsumer) ConsumeMetrics(_ context.Context, _ pmetric.Metrics) error
  • func (bc *BlockingConsumer) ConsumeTraces(_ context.Context, _ ptrace.Traces) error
  • func (bc *BlockingConsumer) Unblock()

Types

type BlockingConsumer

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

func NewBlockingConsumer

func NewBlockingConsumer() *BlockingConsumer

func (*BlockingConsumer) Capabilities

func (bc *BlockingConsumer) Capabilities() consumer.Capabilities

func (*BlockingConsumer) ConsumeLogs

func (bc *BlockingConsumer) ConsumeLogs(_ context.Context, _ plog.Logs) error

func (*BlockingConsumer) ConsumeMetrics

func (bc *BlockingConsumer) ConsumeMetrics(_ context.Context, _ pmetric.Metrics) error

func (*BlockingConsumer) ConsumeTraces

func (bc *BlockingConsumer) ConsumeTraces(_ context.Context, _ ptrace.Traces) error

func (*BlockingConsumer) Unblock

func (bc *BlockingConsumer) Unblock()