You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2020/07/30 03:56:18 UTC
[skywalking] branch query-labeled updated (e358683 -> 534cff4)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch query-labeled
in repository https://gitbox.apache.org/repos/asf/skywalking.git.
from e358683 Query all of labels once selected labels condition is absent.
add 5f769ca Add AvgLabeledFunction to ingest multiple labels (#5187)
add f9257f5 Provide kafka as collector/reporter (#4847)
add 534cff4 Merge branch 'master' into query-labeled
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 +-
.../meter/function/AvgLabeledFunction.java | 214 +++++++++++++++++++++
.../promethues/PrometheusMetricConverter.java | 38 +++-
.../metric/promethues/operation/MetricSource.java | 3 +
.../metric/promethues/rule/PrometheusMetric.java | 1 +
.../server/core/metric/promethues/rule/Rules.java | 1 +
.../meter/function/AvgLabeledFunctionTest.java | 112 +++++++++++
.../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 +
.../provider/PrometheusFetcherProvider.java | 3 +
.../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 +
153 files changed, 3968 insertions(+), 817 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%)
create mode 100644 oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/meter/function/AvgLabeledFunction.java
create mode 100644 oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/analysis/meter/function/AvgLabeledFunctionTest.java
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%)