Versions in this module Expand all Collapse all v1 v1.19.1 Jan 27, 2021 v0 v0.19.1 Jan 27, 2021 Changes in this version + const DefaultHost + const DefaultJaegerPort + const DefaultOCPort + const DefaultOTLPPort + const DefaultZipkinAddressPort + var GlobalConfig = struct{ ... } + func DoTestMain(m *testing.M, resultsSummary TestResultsSummary) + func GenerateSequentialSpanID(id uint64) pdata.SpanID + func GenerateSequentialTraceID(id uint64) pdata.TraceID + func GetAvailablePort(t *testing.T) int + func SaveResults(resultsSummary TestResultsSummary) + func Start(resultsSummary TestResultsSummary) error + type ChildProcess struct + AgentExePath string + func (cp *ChildProcess) GetProcessMon() *process.Process + func (cp *ChildProcess) GetResourceConsumption() string + func (cp *ChildProcess) GetTotalConsumption() *ResourceConsumption + func (cp *ChildProcess) PrepareConfig(configStr string) (configCleanup func(), err error) + func (cp *ChildProcess) Start(params StartParams) error + func (cp *ChildProcess) Stop() (stopped bool, err error) + func (cp *ChildProcess) WatchResourceConsumption() error + type CorrectnessResults struct + func (r *CorrectnessResults) Add(_ string, result interface{}) + func (r *CorrectnessResults) Init(resultsDir string) + func (r *CorrectnessResults) Save() + type CorrectnessTestResult struct + type CorrectnessTestValidator struct + func NewCorrectTestValidator(provider DataProvider) *CorrectnessTestValidator + func (v *CorrectnessTestValidator) RecordResults(tc *TestCase) + func (v *CorrectnessTestValidator) Validate(tc *TestCase) + type DataProvider interface + GenerateLogs func() (pdata.Logs, bool) + GenerateMetrics func() (pdata.Metrics, bool) + GenerateTraces func() (pdata.Traces, bool) + GetGeneratedSpan func(traceID pdata.TraceID, spanID pdata.SpanID) *otlptrace.Span + SetLoadGeneratorCounters func(batchesGenerated *atomic.Uint64, dataItemsGenerated *atomic.Uint64) + type DataReceiver interface + GenConfigYAMLStr func() string + ProtocolName func() string + Start func(tc consumer.TracesConsumer, mc consumer.MetricsConsumer, ...) error + Stop func() error + func NewOTLPDataReceiver(port int) DataReceiver + func NewOTLPHTTPDataReceiver(port int) DataReceiver + type DataReceiverBase struct + Port int + func (mb *DataReceiverBase) GetExporters() map[configmodels.DataType]map[configmodels.Exporter]component.Exporter + func (mb *DataReceiverBase) GetExtensions() map[configmodels.Extension]component.ServiceExtension + func (mb *DataReceiverBase) GetFactory(_ component.Kind, _ configmodels.Type) component.Factory + func (mb *DataReceiverBase) ReportFatalError(err error) + type DataSender interface + Flush func() + GenConfigYAMLStr func() string + GetEndpoint func() string + ProtocolName func() string + Start func() error + type DataSenderBase struct + Host string + Port int + func (dsb *DataSenderBase) Flush() + func (dsb *DataSenderBase) GetEndpoint() string + func (dsb *DataSenderBase) GetExporters() map[configmodels.DataType]map[configmodels.Exporter]component.Exporter + func (dsb *DataSenderBase) GetExtensions() map[configmodels.Extension]component.ServiceExtension + func (dsb *DataSenderBase) GetFactory(_ component.Kind, _ configmodels.Type) component.Factory + func (dsb *DataSenderBase) ReportFatalError(err error) + type FluentBitFileLogWriter struct + func NewFluentBitFileLogWriter(host string, port int) *FluentBitFileLogWriter + func (f *FluentBitFileLogWriter) ConsumeLogs(_ context.Context, logs pdata.Logs) error + func (f *FluentBitFileLogWriter) Extensions() map[string]string + func (f *FluentBitFileLogWriter) Flush() + func (f *FluentBitFileLogWriter) GenConfigYAMLStr() string + func (f *FluentBitFileLogWriter) ProtocolName() string + func (f *FluentBitFileLogWriter) Start() error + type GoldenDataProvider struct + func NewGoldenDataProvider(tracePairsFile string, spanPairsFile string, metricPairsFile string, ...) *GoldenDataProvider + func (dp *GoldenDataProvider) GenerateLogs() (pdata.Logs, bool) + func (dp *GoldenDataProvider) GenerateMetrics() (pdata.Metrics, bool) + func (dp *GoldenDataProvider) GenerateTraces() (pdata.Traces, bool) + func (dp *GoldenDataProvider) GetGeneratedSpan(traceID pdata.TraceID, spanID pdata.SpanID) *otlptrace.Span + func (dp *GoldenDataProvider) SetLoadGeneratorCounters(batchesGenerated *atomic.Uint64, dataItemsGenerated *atomic.Uint64) + type InProcessCollector struct + func NewInProcessCollector(factories component.Factories) *InProcessCollector + func (ipp *InProcessCollector) GetProcessMon() *process.Process + func (ipp *InProcessCollector) GetResourceConsumption() string + func (ipp *InProcessCollector) GetTotalConsumption() *ResourceConsumption + func (ipp *InProcessCollector) PrepareConfig(configStr string) (configCleanup func(), err error) + func (ipp *InProcessCollector) Start(args StartParams) error + func (ipp *InProcessCollector) Stop() (stopped bool, err error) + func (ipp *InProcessCollector) WatchResourceConsumption() error + type JaegerDataReceiver struct + func NewJaegerDataReceiver(port int) *JaegerDataReceiver + func (jr *JaegerDataReceiver) GenConfigYAMLStr() string + func (jr *JaegerDataReceiver) ProtocolName() string + func (jr *JaegerDataReceiver) Start(tc consumer.TracesConsumer, _ consumer.MetricsConsumer, ...) error + func (jr *JaegerDataReceiver) Stop() error + type JaegerGRPCDataSender struct + func NewJaegerGRPCDataSender(host string, port int) *JaegerGRPCDataSender + func (je *JaegerGRPCDataSender) GenConfigYAMLStr() string + func (je *JaegerGRPCDataSender) ProtocolName() string + func (je *JaegerGRPCDataSender) Start() error + type LoadGenerator struct + func NewLoadGenerator(dataProvider DataProvider, sender DataSender) (*LoadGenerator, error) + func (lg *LoadGenerator) DataItemsSent() uint64 + func (lg *LoadGenerator) GetStats() string + func (lg *LoadGenerator) IncDataItemsSent() + func (lg *LoadGenerator) Start(options LoadOptions) + func (lg *LoadGenerator) Stop() + type LoadOptions struct + Attributes map[string]string + DataItemsPerSecond int + ItemsPerBatch int + Parallel int + type LogDataSender interface + type MetricDataSender interface + type MockBackend struct + ReceivedLogs []pdata.Logs + ReceivedMetrics []pdata.Metrics + ReceivedTraces []pdata.Traces + func NewMockBackend(logFilePath string, receiver DataReceiver) *MockBackend + func (mb *MockBackend) ClearReceivedItems() + func (mb *MockBackend) ConsumeLogs(ld pdata.Logs) + func (mb *MockBackend) ConsumeMetric(md pdata.Metrics) + func (mb *MockBackend) ConsumeTrace(td pdata.Traces) + func (mb *MockBackend) DataItemsReceived() uint64 + func (mb *MockBackend) EnableRecording() + func (mb *MockBackend) GetStats() string + func (mb *MockBackend) ReportFatalError(err error) + func (mb *MockBackend) Start() error + func (mb *MockBackend) Stop() + type MockLogConsumer struct + func (mc *MockLogConsumer) ConsumeLogs(_ context.Context, ld pdata.Logs) error + type MockMetricConsumer struct + func (mc *MockMetricConsumer) ConsumeMetrics(_ context.Context, md pdata.Metrics) error + func (mc *MockMetricConsumer) MockConsumeMetricData(metricsCount int) error + type MockMetricDataConsumer interface + MockConsumeMetricData func(metricsCount int) error + type MockTraceConsumer struct + func (tc *MockTraceConsumer) ConsumeTraces(_ context.Context, td pdata.Traces) error + func (tc *MockTraceConsumer) MockConsumeTraceData(spansCount int) error + type MockTraceDataConsumer interface + MockConsumeTraceData func(spansCount int) error + type OCDataReceiver struct + func NewOCDataReceiver(port int) *OCDataReceiver + func (or *OCDataReceiver) GenConfigYAMLStr() string + func (or *OCDataReceiver) ProtocolName() string + func (or *OCDataReceiver) Start(tc consumer.TracesConsumer, mc consumer.MetricsConsumer, ...) error + func (or *OCDataReceiver) Stop() error + type OCMetricsDataSender struct + func NewOCMetricDataSender(host string, port int) *OCMetricsDataSender + func (ods *OCMetricsDataSender) GenConfigYAMLStr() string + func (ods *OCMetricsDataSender) ProtocolName() string + func (ome *OCMetricsDataSender) Start() error + type OCTraceDataSender struct + func NewOCTraceDataSender(host string, port int) *OCTraceDataSender + func (ods *OCTraceDataSender) GenConfigYAMLStr() string + func (ods *OCTraceDataSender) ProtocolName() string + func (ote *OCTraceDataSender) Start() error + type OTLPHTTPLogsDataSender struct + func NewOTLPHTTPLogsDataSender(host string, port int) *OTLPHTTPLogsDataSender + func (ods *OTLPHTTPLogsDataSender) GenConfigYAMLStr() string + func (ods *OTLPHTTPLogsDataSender) ProtocolName() string + func (olds *OTLPHTTPLogsDataSender) Start() error + type OTLPHTTPMetricsDataSender struct + func NewOTLPHTTPMetricDataSender(host string, port int) *OTLPHTTPMetricsDataSender + func (ods *OTLPHTTPMetricsDataSender) GenConfigYAMLStr() string + func (ods *OTLPHTTPMetricsDataSender) ProtocolName() string + func (ome *OTLPHTTPMetricsDataSender) Start() error + type OTLPHTTPTraceDataSender struct + func NewOTLPHTTPTraceDataSender(host string, port int) *OTLPHTTPTraceDataSender + func (ods *OTLPHTTPTraceDataSender) GenConfigYAMLStr() string + func (ods *OTLPHTTPTraceDataSender) ProtocolName() string + func (ote *OTLPHTTPTraceDataSender) Start() error + type OTLPLogsDataSender struct + func NewOTLPLogsDataSender(host string, port int) *OTLPLogsDataSender + func (ods *OTLPLogsDataSender) GenConfigYAMLStr() string + func (ods *OTLPLogsDataSender) ProtocolName() string + func (olds *OTLPLogsDataSender) Start() error + type OTLPMetricsDataSender struct + func NewOTLPMetricDataSender(host string, port int) *OTLPMetricsDataSender + func (ods *OTLPMetricsDataSender) GenConfigYAMLStr() string + func (ods *OTLPMetricsDataSender) ProtocolName() string + func (ome *OTLPMetricsDataSender) Start() error + type OTLPTraceDataSender struct + func NewOTLPTraceDataSender(host string, port int) *OTLPTraceDataSender + func (ods *OTLPTraceDataSender) GenConfigYAMLStr() string + func (ods *OTLPTraceDataSender) ProtocolName() string + func (ote *OTLPTraceDataSender) Start() error + type OtelcolRunner interface + GetProcessMon func() *process.Process + GetResourceConsumption func() string + GetTotalConsumption func() *ResourceConsumption + PrepareConfig func(configStr string) (configCleanup func(), err error) + Start func(args StartParams) error + Stop func() (stopped bool, err error) + WatchResourceConsumption func() error + type PerfTestDataProvider struct + func NewPerfTestDataProvider(options LoadOptions) *PerfTestDataProvider + func (dp *PerfTestDataProvider) GenerateLogs() (pdata.Logs, bool) + func (dp *PerfTestDataProvider) GenerateMetrics() (pdata.Metrics, bool) + func (dp *PerfTestDataProvider) GenerateTraces() (pdata.Traces, bool) + func (dp *PerfTestDataProvider) GetGeneratedSpan(pdata.TraceID, pdata.SpanID) *otlptrace.Span + func (dp *PerfTestDataProvider) SetLoadGeneratorCounters(batchesGenerated *atomic.Uint64, dataItemsGenerated *atomic.Uint64) + type PerfTestValidator struct + func (v *PerfTestValidator) RecordResults(tc *TestCase) + func (v *PerfTestValidator) Validate(tc *TestCase) + type PerformanceResults struct + func (r *PerformanceResults) Add(_ string, result interface{}) + func (r *PerformanceResults) Init(resultsDir string) + func (r *PerformanceResults) Save() + type PerformanceTestResult struct + type PrometheusDataReceiver struct + func NewPrometheusDataReceiver(port int) *PrometheusDataReceiver + func (dr *PrometheusDataReceiver) GenConfigYAMLStr() string + func (dr *PrometheusDataReceiver) ProtocolName() string + func (dr *PrometheusDataReceiver) Start(_ consumer.TracesConsumer, mc consumer.MetricsConsumer, ...) error + func (dr *PrometheusDataReceiver) Stop() error + type PrometheusDataSender struct + func NewPrometheusDataSender(host string, port int) *PrometheusDataSender + func (pds *PrometheusDataSender) GenConfigYAMLStr() string + func (pds *PrometheusDataSender) ProtocolName() string + func (pds *PrometheusDataSender) Start() error + type ResourceConsumption struct + CPUPercentAvg float64 + CPUPercentMax float64 + RAMMiBAvg uint32 + RAMMiBMax uint32 + type ResourceSpec struct + ExpectedMaxCPU uint32 + ExpectedMaxRAM uint32 + ResourceCheckPeriod time.Duration + type StartParams struct + CmdArgs []string + LogFilePath string + Name string + type TestCase struct + Duration time.Duration + ErrorSignal chan struct{} + LoadGenerator *LoadGenerator + MockBackend *MockBackend + Receiver DataReceiver + Sender DataSender + func NewTestCase(t *testing.T, dataProvider DataProvider, sender DataSender, ...) *TestCase + func (tc *TestCase) AgentMemoryInfo() (uint32, uint32, error) + func (tc *TestCase) EnableRecording() + func (tc *TestCase) SetResourceLimits(resourceSpec ResourceSpec) + func (tc *TestCase) Sleep(d time.Duration) + func (tc *TestCase) StartAgent(args ...string) + func (tc *TestCase) StartBackend() + func (tc *TestCase) StartLoad(options LoadOptions) + func (tc *TestCase) Stop() + func (tc *TestCase) StopAgent() + func (tc *TestCase) StopBackend() + func (tc *TestCase) StopLoad() + func (tc *TestCase) ValidateData() + func (tc *TestCase) WaitFor(cond func() bool, errMsg ...interface{}) bool + func (tc *TestCase) WaitForN(cond func() bool, duration time.Duration, errMsg ...interface{}) bool + type TestCaseOption struct + func WithConfigFile(file string) TestCaseOption + func WithSkipResults() TestCaseOption + func (o TestCaseOption) Apply(t *TestCase) + type TestCaseValidator interface + RecordResults func(tc *TestCase) + Validate func(tc *TestCase) + type TestResultsSummary interface + Add func(testName string, result interface{}) + Init func(resultsDir string) + Save func() + type TraceAssertionFailure struct + func (af TraceAssertionFailure) String() string + type TraceDataSender interface + type ZipkinDataReceiver struct + func NewZipkinDataReceiver(port int) *ZipkinDataReceiver + func (zr *ZipkinDataReceiver) GenConfigYAMLStr() string + func (zr *ZipkinDataReceiver) ProtocolName() string + func (zr *ZipkinDataReceiver) Start(tc consumer.TracesConsumer, _ consumer.MetricsConsumer, ...) error + func (zr *ZipkinDataReceiver) Stop() error + type ZipkinDataSender struct + func NewZipkinDataSender(host string, port int) *ZipkinDataSender + func (zs *ZipkinDataSender) GenConfigYAMLStr() string + func (zs *ZipkinDataSender) ProtocolName() string + func (zs *ZipkinDataSender) Start() error