CI test

.github/workflows/skywalking.yaml

@@ -17,6 +17,9 @@
 name: CI
 
 on:
+  push:
+    branches:
+      - citest
   pull_request:
   schedule:
     - cron: "0 18 * * *" # TimeZone: UTC 0
@@ -32,7 +35,7 @@ env:
 
 jobs:
   license-header:
-    if: (github.event_name == 'schedule' && github.repository == 'apache/skywalking') || (github.event_name != 'schedule')
+    if: (github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || (github.event_name != 'schedule')
     name: License header
     runs-on: ubuntu-latest
     timeout-minutes: 10
@@ -45,7 +48,7 @@ jobs:
         uses: apache/skywalking-eyes@5b7ee1731d036b5aac68f8bd3fc9e6f98ada082e
 
   code-style:
-    if: (github.event_name == 'schedule' && github.repository == 'apache/skywalking') || (github.event_name != 'schedule')
+    if: (github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || (github.event_name != 'schedule')
     name: Code style
     runs-on: ubuntu-latest
     timeout-minutes: 10
@@ -60,7 +63,7 @@ jobs:
   dependency-license:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.pom == 'true' || needs.changes.outputs.ui == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.pom == 'true' || needs.changes.outputs.ui == 'true')
     name: Dependency licenses
     needs: [changes]
     runs-on: ubuntu-latest
@@ -90,7 +93,7 @@ jobs:
           fi
 
   sanity-check:
-    if: ( always() && ! cancelled() ) && (github.event_name == 'schedule' && github.repository == 'apache/skywalking') || (github.event_name != 'schedule')
+    if: ( always() && ! cancelled() ) && (github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || (github.event_name != 'schedule')
     name: Sanity check results
     needs: [license-header, code-style, dependency-license]
     runs-on: ubuntu-latest
@@ -159,7 +162,7 @@ jobs:
   dist-tar:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: Build dist tar
     needs: [changes]
     runs-on: ubuntu-latest
@@ -191,7 +194,7 @@ jobs:
   docker:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: Docker images
     needs: [sanity-check, dist-tar, changes]
     runs-on: ubuntu-latest
@@ -230,7 +233,7 @@ jobs:
   unit-test:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: Unit test
     needs: [sanity-check, changes]
     runs-on: ${{ matrix.os }}
@@ -265,7 +268,7 @@ jobs:
   integration-test:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: Integration test
     needs: [sanity-check, changes]
     runs-on: ubuntu-latest
@@ -298,7 +301,7 @@ jobs:
   slow-integration-test:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: Slow Integration Tests
     needs: [sanity-check, changes]
     runs-on: ubuntu-latest
@@ -331,7 +334,7 @@ jobs:
   e2e-test:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: E2E test
     needs: [docker, dist-tar]
     runs-on: ${{ matrix.test.runs-on || 'ubuntu-latest' }}
@@ -723,6 +726,13 @@ jobs:
             config: test/e2e-v2/cases/profiling/async-profiler/banyandb/e2e.yaml
           - name: Async Profiler MySQL
             config: test/e2e-v2/cases/profiling/async-profiler/mysql/e2e.yaml
+
+          - name: Pprof ES
+            config: test/e2e-v2/cases/profiling/pprof/es/e2e.yaml
+          - name: Pprof BanyanDB
+            config: test/e2e-v2/cases/profiling/pprof/banyandb/e2e.yaml
+          - name: Pprof MySQL
+            config: test/e2e-v2/cases/profiling/pprof/mysql/e2e.yaml
     steps:
       - uses: actions/checkout@v4
         with:
@@ -786,7 +796,7 @@ jobs:
   e2e-test-istio:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: E2E test
     needs: [docker]
     runs-on: ubuntu-24.04
@@ -854,7 +864,7 @@ jobs:
   e2e-test-istio-ambient:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: E2E test
     needs: [docker]
     runs-on: ubuntu-24.04
@@ -915,7 +925,7 @@ jobs:
   e2e-test-java-versions:
     if: |
       ( always() && ! cancelled() ) &&
-      ((github.event_name == 'schedule' && github.repository == 'apache/skywalking') || needs.changes.outputs.oap == 'true')
+      ((github.event_name == 'schedule' && github.repository == 'JophieQu/skywalking') || needs.changes.outputs.oap == 'true')
     name: E2E test
     needs: [docker]
     runs-on: ubuntu-latest

apm-protocol/apm-network/src/main/java/org/apache/skywalking/oap/server/network/trace/component/command/CommandDeserializer.java

@@ -29,6 +29,8 @@ public static BaseCommand deserialize(final Command command) {
             return ConfigurationDiscoveryCommand.DESERIALIZER.deserialize(command);
         } else if (AsyncProfilerTaskCommand.NAME.equals(commandName)) {
             return AsyncProfilerTaskCommand.DESERIALIZER.deserialize(command);
+        } else if (PprofTaskCommand.NAME.equals(commandName)) {
+            return PprofTaskCommand.DESERIALIZER.deserialize(command);
         }
         throw new UnsupportedCommandException(command);
     }

apm-protocol/apm-network/src/main/java/org/apache/skywalking/oap/server/network/trace/component/command/PprofTaskCommand.java

@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.skywalking.oap.server.network.trace.component.command;
+
+import org.apache.skywalking.apm.network.common.v3.Command;
+import org.apache.skywalking.apm.network.common.v3.KeyStringValuePair;
+import java.util.List;
+import lombok.Getter;
+
+@Getter
+public class PprofTaskCommand extends BaseCommand implements Serializable, Deserializable<PprofTaskCommand> {
+    public static final Deserializable<PprofTaskCommand> DESERIALIZER = new PprofTaskCommand("", "", "", 0, 0, 0);
+    public static final String NAME = "PprofTaskQuery";
+    /**
+     * pprof taskId
+     */
+    private String taskId;
+    // Type of profiling (CPU/Heap/Block/Mutex/Goroutine/Threadcreate/Allocs)
+    private String events;
+    /**
+     * run profiling for duration (minute)
+     */
+    private long duration;
+    /**
+     * task create time
+     */
+    private long createTime;
+    /**
+     * pprof dump period parameters. There are different dumpperiod configurations for different events. 
+     * Here is a table of parameters.
+     *
+     * <p>For Block - sample an average of one blocking event per rate nanoseconds spent blocked. (default: 0)</p>
+     * <p>For Mutex - sample an average of 1/rate events are reported. (default: 0)</p>
+     * details @see <a href="https://pkg.go.dev/runtime/pprof">pprof argument</a>
+     */
+    private int dumpPeriod;
+
+    public PprofTaskCommand(String serialNumber, String taskId, String events,
+                            long duration, long createTime, int dumpPeriod) {
+        super(NAME, serialNumber);
+        this.taskId = taskId;
+        this.duration = duration;
+        this.createTime = createTime;
+        this.dumpPeriod = dumpPeriod;
+        this.events = events;
+    }
+
+    @Override
+    public PprofTaskCommand deserialize(Command command) {
+        final List<KeyStringValuePair> argsList = command.getArgsList();
+        String taskId = null;
+        String events = null;
+        long duration = 0;
+        long createTime = 0;
+        int dumpPeriod = 0;
+        String serialNumber = null;
+        for (final KeyStringValuePair pair : argsList) {
+            if ("SerialNumber".equals(pair.getKey())) {
+                serialNumber = pair.getValue();
+            } else if ("TaskId".equals(pair.getKey())) {
+                taskId = pair.getValue();
+            } else if ("Events".equals(pair.getKey())) {
+                events = pair.getValue();
+            } else if ("Duration".equals(pair.getKey())) {
+                duration = Long.parseLong(pair.getValue());
+            } else if ("CreateTime".equals(pair.getKey())) {
+                createTime = Long.parseLong(pair.getValue());
+            } else if ("DumpPeriod".equals(pair.getKey())) {
+                dumpPeriod = Integer.parseInt(pair.getValue());
+            }
+        }
+        return new PprofTaskCommand(serialNumber, taskId, events, duration, createTime, dumpPeriod);
+    }
+
+    @Override
+    public Command.Builder serialize() {
+        final Command.Builder builder = commandBuilder();
+        builder.addArgs(KeyStringValuePair.newBuilder().setKey("TaskId").setValue(taskId))
+                .addArgs(KeyStringValuePair.newBuilder().setKey("Events").setValue(events))
+                .addArgs(KeyStringValuePair.newBuilder().setKey("Duration").setValue(String.valueOf(duration)))
+                .addArgs(KeyStringValuePair.newBuilder().setKey("CreateTime").setValue(String.valueOf(createTime)))
+                .addArgs(KeyStringValuePair.newBuilder().setKey("DumpPeriod").setValue(String.valueOf(dumpPeriod)));
+        return builder;
+    }
+}

dist-material/release-docs/LICENSE

@@ -477,20 +477,21 @@ The text of each license is also included in licenses/LICENSE-[project].txt.
     https://npmjs.com/package/@floating-ui/core/v/1.6.9 1.6.9 MIT
     https://npmjs.com/package/@floating-ui/dom/v/1.6.13 1.6.13 MIT
     https://npmjs.com/package/@floating-ui/utils/v/0.2.9 0.2.9 MIT
-    https://npmjs.com/package/@interactjs/actions/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/auto-scroll/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/auto-start/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/core/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/dev-tools/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/inertia/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/interact/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/interactjs/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/modifiers/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/offset/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/pointer-events/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/reflow/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/snappers/v/1.10.27 1.10.27 MIT
-    https://npmjs.com/package/@interactjs/utils/v/1.10.27 1.10.27 MIT
+    https://npmjs.com/package/@interactjs/actions/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/auto-scroll/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/auto-start/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/core/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/dev-tools/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/inertia/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/interact/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/interactjs/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/modifiers/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/offset/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/pointer-events/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/reflow/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/snappers/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/types/v/1.10.17 1.10.17 MIT
+    https://npmjs.com/package/@interactjs/utils/v/1.10.17 1.10.17 MIT
     https://npmjs.com/package/@intlify/core-base/v/9.14.5 9.14.5 MIT
     https://npmjs.com/package/@intlify/message-compiler/v/9.14.5 9.14.5 MIT
     https://npmjs.com/package/@intlify/shared/v/9.14.5 9.14.5 MIT
@@ -528,7 +529,7 @@ The text of each license is also included in licenses/LICENSE-[project].txt.
     https://npmjs.com/package/d3-dsv/node_modules/commander/v/7.2.0 7.2.0 MIT
     https://npmjs.com/package/d3-tip/v/0.9.1 0.9.1 MIT
     https://npmjs.com/package/dayjs/v/1.11.13 1.11.13 MIT
-    https://npmjs.com/package/element-plus/v/2.11.0 2.11.0 MIT
+    https://npmjs.com/package/element-plus/v/2.9.4 2.9.4 MIT
     https://npmjs.com/package/element-resize-detector/v/1.2.4 1.2.4 MIT
     https://npmjs.com/package/escape-html/v/1.0.3 1.0.3 MIT
     https://npmjs.com/package/estree-walker/v/2.0.2 2.0.2 MIT

docs/en/changes/changes.md

@@ -49,6 +49,7 @@
 * Add UI dashboard for Ruby runtime metrics.
 * Tracing Query Execution HTTP APIs: make the argument `service layer` optional.
 * GraphQL API: metadata, topology, log and trace support query by name.
+* Support pprof profiling feature
 * [Break Change] MQE function `sort_values` sorts according to the aggregation result and labels rather than the simple time series values.
 * Self Observability: add `metrics_aggregation_queue_used_percentage` and `metrics_persistent_collection_cached_size` metrics for the OAP server.
 * Optimize metrics aggregate/persistent worker: separate `OAL` and `MAL` workers and consume pools. The dataflow signal drives the new MAL consumer, 

docs/en/concepts-and-designs/profiling.md

@@ -47,6 +47,20 @@ Async Profiler can trace the following kinds of events:
 
 Only Java agent support this.
 
+### Go App Profiling
+
+Go App Profiling uses the [Pprof](https://github.com/google/pprof) for sampling.
+
+pprof is a profiling tool by Google for visualizing and analyzing sampled performance data.
+It reads samples in profile.proto format and generates text or graphical reports (via the dot visualization) to highlight performance hotspots. 
+
+pprof supports profiling of:
+
+- CPU.
+- Memory allocs / heap.
+- Block / mutex.
+- Gouroutine / threadcreate.
+
 ## Out-of-process profiling
 
 Out-of-process profiling leverage [eBPF](https://ebpf.io/) technology with origins in the Linux kernel.

oap-server/server-core/pom.xml

@@ -44,6 +44,11 @@
             <artifactId>library-async-profiler-jfr-parser</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.skywalking</groupId>
+            <artifactId>library-pprof-parser</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.apache.skywalking</groupId>
             <artifactId>telemetry-api</artifactId>

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/CoreModule.java

@@ -22,6 +22,7 @@
 import java.util.List;
 import org.apache.skywalking.oap.server.core.analysis.meter.MeterSystem;
 import org.apache.skywalking.oap.server.core.cache.AsyncProfilerTaskCache;
+import org.apache.skywalking.oap.server.core.cache.PprofTaskCache;
 import org.apache.skywalking.oap.server.core.cache.NetworkAddressAliasCache;
 import org.apache.skywalking.oap.server.core.cache.ProfileTaskCache;
 import org.apache.skywalking.oap.server.core.command.CommandService;
@@ -41,6 +42,8 @@
 import org.apache.skywalking.oap.server.core.profiling.continuous.ContinuousProfilingQueryService;
 import org.apache.skywalking.oap.server.core.profiling.ebpf.EBPFProfilingMutationService;
 import org.apache.skywalking.oap.server.core.profiling.ebpf.EBPFProfilingQueryService;
+import org.apache.skywalking.oap.server.core.profiling.pprof.PprofMutationService;
+import org.apache.skywalking.oap.server.core.profiling.pprof.PprofQueryService;
 import org.apache.skywalking.oap.server.core.profiling.trace.ProfileTaskMutationService;
 import org.apache.skywalking.oap.server.core.profiling.trace.ProfileTaskQueryService;
 import org.apache.skywalking.oap.server.core.query.AggregationQueryService;
@@ -106,6 +109,7 @@ public Class[] services() {
         addManagementService(classes);
         addEBPFProfilingService(classes);
         addAsyncProfilerService(classes);
+        addPprofService(classes);
 
         classes.add(CommandService.class);
         classes.add(HierarchyService.class);
@@ -137,6 +141,12 @@ private void addAsyncProfilerService(List<Class> classes) {
         classes.add(AsyncProfilerTaskCache.class);
     }
 
+    private void addPprofService(List<Class> classes) {
+        classes.add(PprofMutationService.class);
+        classes.add(PprofQueryService.class);
+        classes.add(PprofTaskCache.class);
+    }
+
     private void addOALService(List<Class> classes) {
         classes.add(OALEngineLoaderService.class);
     }