This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git.
from 5f769ca Add AvgLabeledFunction to ingest multiple labels (#5187)
add f9257f5 Provide kafka as collector/reporter (#4847)
No new revisions were added by this update.
Summary of changes:
.github/workflows/e2e.kafka.yaml | 97 ++++++++++++
apm-protocol/apm-network/src/main/proto | 2 +-
.../skywalking/apm/agent/core/conf/Config.java | 1 +
.../apm/agent/core/jvm/JVMMetricsSender.java | 109 ++++++++++++++
.../skywalking/apm/agent/core/jvm/JVMService.java | 78 +---------
.../apm/agent/core/meter/MeterSender.java | 154 ++++++++++++++++++++
.../apm/agent/core/meter/MeterService.java | 121 ++-------------
.../agent/core/profile/ProfileSnapshotSender.java | 126 ++++++++++++++++
.../core/profile/ProfileTaskChannelService.java | 81 ++---------
...ache.skywalking.apm.agent.core.boot.BootService | 5 +-
.../apm/agent/core/boot/ServiceManagerTest.java | 4 +-
.../apm/agent/core/meter/MeterServiceTest.java | 9 +-
apm-sniffer/config/agent.config | 3 +
.../kafka-reporter-plugin/pom.xml | 162 +++++++++++++++++++++
.../kafka/KafkaContextManagerExtendService.java | 23 +--
.../agent/core/kafka/KafkaJVMMetricsSender.java | 99 +++++++++++++
.../apm/agent/core/kafka/KafkaMeterSender.java | 69 +++++++++
.../apm/agent/core/kafka/KafkaProducerManager.java | 104 +++++++++++++
.../core/kafka/KafkaProfileSnapshotSender.java | 72 +++++++++
.../core/kafka/KafkaReporterPluginConfig.java | 48 ++++++
.../kafka/KafkaServiceManagementServiceClient.java | 121 +++++++++++++++
.../core/kafka/KafkaTraceSegmentServiceClient.java | 84 +++++++++++
...ache.skywalking.apm.agent.core.boot.BootService | 21 +--
apm-sniffer/optional-reporter-plugins/pom.xml | 70 +++++++++
apm-sniffer/pom.xml | 1 +
dist-material/release-docs/LICENSE | 5 +
dist-material/release-docs/NOTICE | 17 +++
.../release-docs/licenses/LICENSE-zstd-jni.txt | 26 ++++
docs/en/guides/Java-Plugin-Development-Guide.md | 4 +-
docs/en/setup/backend/backend-fetcher.md | 50 ++++++-
docs/en/setup/backend/backend-meter.md | 12 ++
docs/en/setup/backend/backend-receivers.md | 5 +-
docs/en/setup/backend/configuration-vocabulary.md | 18 ++-
docs/en/setup/backend/dynamic-config.md | 6 +-
docs/en/setup/backend/trace-sampling.md | 4 +-
.../java-agent/How-to-enable-kafka-reporter.md | 18 +++
docs/en/setup/service-agent/java-agent/README.md | 7 +
.../agent-analyzer}/pom.xml | 13 +-
.../server/analyzer/module/AnalyzerModule.java} | 16 +-
.../analyzer/provider/AnalyzerModuleConfig.java} | 10 +-
.../analyzer/provider/AnalyzerModuleProvider.java} | 68 ++++-----
.../provider/jvm}/JVMSourceDispatcher.java | 6 +-
.../provider/meter}/config/MeterConfig.java | 2 +-
.../provider/meter}/config/MeterConfigs.java | 2 +-
.../provider/meter}/config/MeterDataConfig.java | 2 +-
.../analyzer/provider/meter}/config/Scope.java | 2 +-
.../analyzer/provider/meter}/process/EvalData.java | 2 +-
.../provider/meter}/process/EvalHistogramData.java | 2 +-
.../provider/meter}/process/EvalMultipleData.java | 2 +-
.../provider/meter}/process/EvalSingleData.java | 2 +-
.../meter/process/IMeterProcessService.java} | 16 +-
.../provider/meter}/process/MeterBuilder.java | 6 +-
.../meter}/process/MeterEvalOperation.java | 2 +-
.../meter/process/MeterProcessService.java} | 35 +++--
.../provider/meter}/process/MeterProcessor.java | 10 +-
.../analyzer/provider/meter}/process/Window.java | 2 +-
.../trace}/DBLatencyThresholdsAndWatcher.java | 9 +-
.../provider/trace}/TraceSampleRateWatcher.java | 12 +-
.../trace}/UninstrumentedGatewaysConfig.java | 9 +-
.../parser/ISegmentParserListenerManager.java | 4 +-
.../trace}/parser/ISegmentParserService.java | 2 +-
.../parser/SegmentParserListenerManager.java | 5 +-
.../trace}/parser/SegmentParserServiceImpl.java | 6 +-
.../analyzer/provider/trace}/parser/SpanTags.java | 2 +-
.../provider/trace}/parser/TraceAnalyzer.java | 18 +--
.../trace}/parser/listener/AnalysisListener.java | 2 +-
.../parser/listener/AnalysisListenerFactory.java | 6 +-
.../parser/listener/EntryAnalysisListener.java | 2 +-
.../parser/listener/ExitAnalysisListener.java | 2 +-
.../parser/listener/FirstAnalysisListener.java | 2 +-
.../parser/listener/LocalAnalysisListener.java | 2 +-
.../listener/MultiScopesAnalysisListener.java | 14 +-
.../NetworkAddressAliasMappingListener.java | 8 +-
.../parser/listener/SegmentAnalysisListener.java | 8 +-
.../trace}/parser/listener/SegmentListener.java | 2 +-
.../trace}/parser/listener/SourceBuilder.java | 2 +-
.../parser/listener/TraceSegmentSampler.java | 4 +-
...ywalking.oap.server.library.module.ModuleDefine | 13 +-
...alking.oap.server.library.module.ModuleProvider | 13 +-
.../provider/meter}/process/EvalDataBaseTest.java | 2 +-
.../provider/meter}/process/EvalDataTest.java | 2 +-
.../meter}/process/EvalHistogramDataTest.java | 2 +-
.../meter}/process/EvalMultipleDataTest.java | 7 +-
.../meter}/process/EvalSingleDataTest.java | 2 +-
.../provider/meter}/process/MeterBaseTest.java | 20 +--
.../provider/meter}/process/MeterBuilderTest.java | 10 +-
.../meter}/process/MeterEvalOperationTest.java | 5 +-
.../meter}/process/MeterProcessContextTest.java | 29 ++--
.../meter}/process/MeterProcessorTest.java | 4 +-
.../trace}/TraceSampleRateWatcherTest.java | 34 +++--
.../resources/meter-receive-config/config.yaml | 0
.../pom.xml | 22 ++-
oap-server/pom.xml | 4 +-
oap-server/server-bootstrap/pom.xml | 5 +
.../src/main/resources/application.yml | 20 ++-
.../plugin/zookeeper/ZookeeperCoordinator.java | 10 +-
.../kafka-fetcher-plugin}/pom.xml | 18 ++-
.../agent/kafka/KafkaFetcherHandlerRegister.java | 146 +++++++++++++++++++
.../agent/kafka/module/KafkaFetcherConfig.java | 82 +++++++++++
.../agent/kafka/module/KafkaFetcherModule.java} | 11 +-
.../agent/kafka/provider/KafkaFetcherProvider.java | 99 +++++++++++++
.../kafka/provider/handler/JVMMetricsHandler.java | 84 +++++++++++
.../agent/kafka/provider/handler/KafkaHandler.java | 65 +++++++++
.../provider/handler/MeterServiceHandler.java | 68 +++++++++
.../kafka/provider/handler/ProfileTaskHandler.java | 79 ++++++++++
.../provider/handler/ServiceManagementHandler.java | 135 +++++++++++++++++
.../provider/handler/TraceSegmentHandler.java | 106 ++++++++++++++
...ywalking.oap.server.library.module.ModuleDefine | 13 +-
...alking.oap.server.library.module.ModuleProvider | 13 +-
.../agent/kafka/mock/MockModuleManager.java | 50 +++++++
.../agent/kafka/mock/MockModuleProvider.java | 46 ++++++
.../kafka/provider/KafkaFetcherProviderTest.java | 52 +++++++
.../provider/handler/JVMMetricsHandlerTest.java | 110 ++++++++++++++
.../handler/ServiceManagementHandlerTest.java | 102 +++++++++++++
.../provider/handler/SourceReceiverRule.java} | 30 ++--
oap-server/server-fetcher-plugin/pom.xml | 1 +
.../skywalking-jvm-receiver-plugin/pom.xml | 5 +
.../handler/JVMMetricReportServiceHandler.java | 1 +
.../skywalking-meter-receiver-plugin/pom.xml | 5 +-
.../meter/provider/MeterReceiverProvider.java | 39 ++---
.../provider/handler/MeterServiceHandler.java | 12 +-
.../meter/provider/config/MeterConfigsTest.java | 6 +-
.../skywalking-trace-receiver-plugin/pom.xml | 5 +
.../server/receiver/trace/module/TraceModule.java | 3 +-
.../trace/provider/TraceModuleProvider.java | 71 +--------
.../v8/grpc/TraceSegmentReportServiceHandler.java | 23 ++-
.../rest/TraceSegmentReportBaseServletHandler.java | 20 +--
.../rest/TraceSegmentReportListServletHandler.java | 15 +-
.../TraceSegmentReportSingleServletHandler.java | 6 +-
.../rest/TraceSegmentReportServletHandlerTest.java | 30 +++-
.../listener/MultiScopesAnalysisListenerTest.java | 12 +-
.../receiver/zipkin/ZipkinReceiverProvider.java | 2 +-
.../zipkin/analysis/Receiver2AnalysisBridge.java | 2 +-
test/e2e/e2e-test/docker/kafka/Dockerfile.provider | 37 +++++
.../e2e-test/docker/kafka/docker-compose.base.yml | 69 +++++++++
.../e2e-test/docker/kafka/docker-compose.meter.yml | 68 +++++++++
.../docker/kafka/docker-compose.profiling.yml | 82 +++++++++++
test/e2e/e2e-test/docker/kafka/docker-compose.yml | 83 +++++++++++
.../{simple/SimpleE2E.java => kafka/KafkaE2E.java} | 76 +++-------
.../MeterE2E.java => kafka/KafkaMeterE2E.java} | 27 ++--
.../ProfileE2E.java => kafka/KafkaProfileE2E.java} | 23 +--
.../org/apache/skywalking/e2e/meter/MeterE2E.java | 4 +-
.../apache/skywalking/e2e/profile/ProfileE2E.java | 4 +-
.../apache/skywalking/e2e/simple/SimpleE2E.java | 4 +-
.../known-oap-backend-dependencies-es7.txt | 4 +
.../known-oap-backend-dependencies.txt | 4 +
146 files changed, 3600 insertions(+), 813 deletions(-)
create mode 100644 .github/workflows/e2e.kafka.yaml
create mode 100644
apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/jvm/JVMMetricsSender.java
create mode 100644
apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/meter/MeterSender.java
create mode 100644
apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/profile/ProfileSnapshotSender.java
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/pom.xml
copy
oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/module/TraceModule.java
=>
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaContextManagerExtendService.java
(57%)
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaJVMMetricsSender.java
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaMeterSender.java
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProducerManager.java
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProfileSnapshotSender.java
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaReporterPluginConfig.java
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaServiceManagementServiceClient.java
create mode 100644
apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaTraceSegmentServiceClient.java
copy apm-sniffer/{apm-agent-core =>
optional-reporter-plugins/kafka-reporter-plugin}/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService
(50%)
create mode 100644 apm-sniffer/optional-reporter-plugins/pom.xml
create mode 100644 dist-material/release-docs/licenses/LICENSE-zstd-jni.txt
create mode 100644
docs/en/setup/service-agent/java-agent/How-to-enable-kafka-reporter.md
copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin =>
analyzer/agent-analyzer}/pom.xml (82%)
copy
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/module/TraceModule.java
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/module/AnalyzerModule.java}
(67%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/TraceServiceModuleConfig.java
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/AnalyzerModuleConfig.java}
(83%)
mode change 100755 => 100644
copy
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/TraceModuleProvider.java
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/AnalyzerModuleProvider.java}
(66%)
mode change 100755 => 100644
rename
oap-server/{server-receiver-plugin/skywalking-jvm-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/jvm/provider/handler
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/jvm}/JVMSourceDispatcher.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/MeterConfig.java
(93%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/MeterConfigs.java
(97%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/MeterDataConfig.java
(95%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/config/Scope.java
(94%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalData.java
(97%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalHistogramData.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalMultipleData.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalSingleData.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider/MeterReceiverConfig.java
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter/process/IMeterProcessService.java}
(71%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterBuilder.java
(97%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterEvalOperation.java
(97%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider/process/MeterProcessContext.java
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter/process/MeterProcessService.java}
(64%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterProcessor.java
(95%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/Window.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/DBLatencyThresholdsAndWatcher.java
(87%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/TraceSampleRateWatcher.java
(80%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/UninstrumentedGatewaysConfig.java
(93%)
mode change 100755 => 100644
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/ISegmentParserListenerManager.java
(88%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/ISegmentParserService.java
(94%)
copy
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/SegmentParserListenerManager.java
(91%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/SegmentParserServiceImpl.java
(87%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/SpanTags.java
(96%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/TraceAnalyzer.java
(89%)
mode change 100755 => 100644
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/AnalysisListener.java
(95%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/AnalysisListenerFactory.java
(81%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/EntryAnalysisListener.java
(94%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/ExitAnalysisListener.java
(94%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/FirstAnalysisListener.java
(94%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/LocalAnalysisListener.java
(94%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/MultiScopesAnalysisListener.java
(97%)
mode change 100755 => 100644
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/NetworkAddressAliasMappingListener.java
(95%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/SegmentAnalysisListener.java
(96%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/SegmentListener.java
(94%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/SourceBuilder.java
(99%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/parser/listener/TraceSegmentSampler.java
(91%)
copy
apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService
=>
oap-server/analyzer/agent-analyzer/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleDefine
(50%)
copy
apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService
=>
oap-server/analyzer/agent-analyzer/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleProvider
(50%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalDataBaseTest.java
(97%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalDataTest.java
(97%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalHistogramDataTest.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalMultipleDataTest.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/EvalSingleDataTest.java
(98%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterBaseTest.java
(90%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterBuilderTest.java
(96%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterEvalOperationTest.java
(97%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterProcessContextTest.java
(69%)
rename
oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/meter/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/meter}/process/MeterProcessorTest.java
(96%)
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/provider
=>
analyzer/agent-analyzer/src/test/java/org/apache/skywalking/oap/server/analyzer/provider/trace}/TraceSampleRateWatcherTest.java
(81%)
copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin =>
analyzer/agent-analyzer}/src/test/resources/meter-receive-config/config.yaml
(100%)
copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin =>
analyzer}/pom.xml (73%)
copy oap-server/{server-receiver-plugin/skywalking-meter-receiver-plugin =>
server-fetcher-plugin/kafka-fetcher-plugin}/pom.xml (72%)
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/KafkaFetcherHandlerRegister.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/module/KafkaFetcherConfig.java
copy
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/module/TraceModule.java
=>
server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/module/KafkaFetcherModule.java}
(73%)
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/KafkaFetcherProvider.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/JVMMetricsHandler.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/KafkaHandler.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/MeterServiceHandler.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/ProfileTaskHandler.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/ServiceManagementHandler.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/TraceSegmentHandler.java
copy
apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService
=>
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleDefine
(50%)
copy
apm-sniffer/apm-agent-core/src/main/resources/META-INF/services/org.apache.skywalking.apm.agent.core.boot.BootService
=>
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleProvider
(50%)
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/mock/MockModuleManager.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/mock/MockModuleProvider.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/KafkaFetcherProviderTest.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/JVMMetricsHandlerTest.java
create mode 100644
oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/ServiceManagementHandlerTest.java
rename
oap-server/{server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/SegmentParserListenerManager.java
=>
server-fetcher-plugin/kafka-fetcher-plugin/src/test/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/SourceReceiverRule.java}
(50%)
create mode 100644 test/e2e/e2e-test/docker/kafka/Dockerfile.provider
create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.base.yml
create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.meter.yml
create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.profiling.yml
create mode 100644 test/e2e/e2e-test/docker/kafka/docker-compose.yml
copy
test/e2e/e2e-test/src/test/java/org/apache/skywalking/e2e/{simple/SimpleE2E.java
=> kafka/KafkaE2E.java} (92%)
copy
test/e2e/e2e-test/src/test/java/org/apache/skywalking/e2e/{meter/MeterE2E.java
=> kafka/KafkaMeterE2E.java} (88%)
copy
test/e2e/e2e-test/src/test/java/org/apache/skywalking/e2e/{profile/ProfileE2E.java
=> kafka/KafkaProfileE2E.java} (95%)
