internal

Documentation

Index

• type MockExporter
  • func NewMockExporter() *MockExporter
  • func (e *MockExporter) AcceptedLogCount() int
  • func (e *MockExporter) Capabilities() consumer.Capabilities
  • func (e *MockExporter) ConsumeLogs(ctx context.Context, ld plog.Logs) error
  • func (e *MockExporter) DeliveredLogCount() int
  • func (e *MockExporter) SetDestAvailable(available bool)
• type MockReceiver
  • func (m *MockReceiver) LastConsumeResult() error
  • func (m *MockReceiver) Start()

Types

type MockExporter

type MockExporter struct {
	Logs consumertest.LogsSink
	// contains filtered or unexported fields
}

func NewMockExporter

func NewMockExporter() *MockExporter

func (*MockExporter) AcceptedLogCount

func (e *MockExporter) AcceptedLogCount() int

func (*MockExporter) Capabilities

func (e *MockExporter) Capabilities() consumer.Capabilities

func (*MockExporter) ConsumeLogs

func (e *MockExporter) ConsumeLogs(ctx context.Context, ld plog.Logs) error

func (*MockExporter) DeliveredLogCount

func (e *MockExporter) DeliveredLogCount() int

func (*MockExporter) SetDestAvailable

func (e *MockExporter) SetDestAvailable(available bool)

type MockReceiver

type MockReceiver struct {
	ProduceCount int
	NextConsumer consumer.Logs
	// contains filtered or unexported fields
}

func (*MockReceiver) LastConsumeResult

func (m *MockReceiver) LastConsumeResult() error

func (*MockReceiver) Start

func (m *MockReceiver) Start()