otlplogstest

Documentation

Index

• func RunEndToEndTest(ctx context.Context, t *testing.T, exp *otlplogs.Exporter, ...)
• func RunExporterShutdownTest(t *testing.T, factory func() otlplogs.Client)
• func SingleReadableLogRecord() []logssdk.ReadableLogRecord
• type LogsCollector
• type LogsStorage
  • func NewLogsStorage() LogsStorage
  • func (s *LogsStorage) AddLogs(request *collectorlogspb.ExportLogsServiceRequest)
  • func (s *LogsStorage) GetLogRecords() []*logspb.LogRecord
  • func (s *LogsStorage) GetResourceLogs() []*logspb.ResourceLogs

Functions

func RunEndToEndTest

func RunEndToEndTest(ctx context.Context, t *testing.T, exp *otlplogs.Exporter, logsCollector LogsCollector)

RunEndToEndTest can be used by otlplogs.Client tests to validate themselves.

func RunExporterShutdownTest

func RunExporterShutdownTest(t *testing.T, factory func() otlplogs.Client)

func SingleReadableLogRecord

func SingleReadableLogRecord() []logssdk.ReadableLogRecord

Types

type LogsCollector

type LogsCollector interface {
	Stop() error
	GetResourceLogs() []*logspb.ResourceLogs
}

LogsCollector mocks a collector for the end-to-end testing.

type LogsStorage

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

LogsStorage stores the Logs. Mock collectors can use it to store logs they have received.

func NewLogsStorage

func NewLogsStorage() LogsStorage

NewLogsStorage creates a new logs storage.

func (*LogsStorage) AddLogs

func (s *LogsStorage) AddLogs(request *collectorlogspb.ExportLogsServiceRequest)

AddLogs adds logs to the logs storage.

func (*LogsStorage) GetLogRecords

func (s *LogsStorage) GetLogRecords() []*logspb.LogRecord

GetLogRecords returns the stored logs.

func (*LogsStorage) GetResourceLogs

func (s *LogsStorage) GetResourceLogs() []*logspb.ResourceLogs

GetResourceLogs returns the stored resource logs.