Support Async Profiler Feature

.github/workflows/CI.yaml

@@ -90,7 +90,7 @@ jobs:
           go-version: 1.18
 
       - name: golangci-lint
-        uses: golangci/golangci-lint-action@v3
+        uses: golangci/golangci-lint-action@v6
         with:
           version: v1.50.0
           args: --timeout 5m

CHANGES.md

@@ -7,6 +7,8 @@ Release Notes.
 
 ### Features
 
+* add the sub-command `profiling async` for async-profiler query API by @zhengziyi0117 in https://github.com/apache/skywalking-cli/pull/203
+
 ### Bug Fixes
 
 0.14.0

assets/graphqls/profiling/asyncprofiler/CreateTask.graphql

@@ -0,0 +1,24 @@
+# Licensed to 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. Apache Software Foundation (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.
+
+mutation ($condition: AsyncProfilerTaskCreationRequest!) {
+    result: createAsyncProfilerTask(asyncProfilerTaskCreationRequest: $condition) {
+        errorReason
+        code
+        id
+    }
+}

assets/graphqls/profiling/asyncprofiler/GetAnalysis.graphql

@@ -0,0 +1,31 @@
+# Licensed to 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. Apache Software Foundation (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.
+
+query ($condition: AsyncProfilerAnalyzationRequest!) {
+    result: queryAsyncProfilerAnalyze(request: $condition) {
+        tree {
+            type
+            elements {
+                id
+                parentId
+                codeSignature
+                total
+                self
+            }
+        }
+    }
+}

assets/graphqls/profiling/asyncprofiler/GetTaskList.graphql

@@ -0,0 +1,31 @@
+# Licensed to 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. Apache Software Foundation (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.
+
+query ($condition: AsyncProfilerTaskListRequest!) {
+    result: queryAsyncProfilerTaskList(request: $condition) {
+        errorReason
+        tasks {
+            serviceId
+            serviceInstanceIds
+            createTime
+            events
+            duration
+            execArgs
+            id
+        }
+    }
+}

assets/graphqls/profiling/asyncprofiler/GetTaskProgress.graphql

@@ -0,0 +1,30 @@
+# Licensed to 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. Apache Software Foundation (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.
+
+query ($taskId: String!){
+    result: queryAsyncProfilerTaskProgress(taskId: $taskId) {
+        errorInstanceIds
+        successInstanceIds
+        logs {
+            id
+            instanceId
+            instanceName
+            operationType
+            operationTime
+        }
+    }
+}

dist/LICENSE

@@ -213,7 +213,7 @@ The text of each license is also included at licenses/license-[project].txt.
     k8s.io/utils v0.0.0-20210802155522-efc7438f0176 Apache-2.0
     sigs.k8s.io/controller-runtime v0.10.0 Apache-2.0
     sigs.k8s.io/structured-merge-diff/v4 v4.1.2 Apache-2.0
-    skywalking.apache.org/repo/goapi v0.0.0-20240227092755-edee3273b361 Apache-2.0
+    skywalking.apache.org/repo/goapi v0.0.0-20241023080050-2514649a8007 Apache-2.0
 
 ========================================================================
 BSD-2-Clause licenses

go.mod

@@ -18,7 +18,7 @@ require (
 	gopkg.in/yaml.v2 v2.4.0
 	k8s.io/apimachinery v0.22.1
 	sigs.k8s.io/controller-runtime v0.10.0
-	skywalking.apache.org/repo/goapi v0.0.0-20240227092755-edee3273b361
+	skywalking.apache.org/repo/goapi v0.0.0-20241023080050-2514649a8007
 )
 
 require (

go.sum

@@ -879,5 +879,5 @@ sigs.k8s.io/structured-merge-diff/v4 v4.1.2 h1:Hr/htKFmJEbtMgS/UD0N+gtgctAqz81t3
 sigs.k8s.io/structured-merge-diff/v4 v4.1.2/go.mod h1:j/nl6xW8vLS49O8YvXW1ocPhZawJtm+Yrr7PPRQ0Vg4=
 sigs.k8s.io/yaml v1.2.0 h1:kr/MCeFWJWTwyaHoR9c8EjH9OumOmoF9YGiZd7lFm/Q=
 sigs.k8s.io/yaml v1.2.0/go.mod h1:yfXDCHCao9+ENCvLSE62v9VSji2MKu5jeNfTrofGhJc=
-skywalking.apache.org/repo/goapi v0.0.0-20240227092755-edee3273b361 h1:FCGGU4Tut3LI/zMRXSgJgUL/kmSQ4b7QktFgRBhqaDs=
-skywalking.apache.org/repo/goapi v0.0.0-20240227092755-edee3273b361/go.mod h1:+n8BMuS8eRdzdnGh15ElRGBXPi0eYZSs2TKySBDmRTE=
+skywalking.apache.org/repo/goapi v0.0.0-20241023080050-2514649a8007 h1:MQU9yOZxgbs7fU145wd400/E3ES/HWoxTtTCudaCBoA=
+skywalking.apache.org/repo/goapi v0.0.0-20241023080050-2514649a8007/go.mod h1:+n8BMuS8eRdzdnGh15ElRGBXPi0eYZSs2TKySBDmRTE=

internal/commands/interceptor/instance.go

@@ -26,10 +26,12 @@ import (
 )
 
 const (
-	instanceIDFlagName       = "instance-id"
-	instanceNameFlagName     = "instance-name"
-	destInstanceIDFlagName   = "dest-instance-id"
-	destInstanceNameFlagName = "dest-instance-name"
+	instanceIDFlagName        = "instance-id"
+	instanceNameFlagName      = "instance-name"
+	destInstanceIDFlagName    = "dest-instance-id"
+	destInstanceNameFlagName  = "dest-instance-name"
+	InstanceIDSliceFlagName   = "instance-id-slice"
+	instanceNameSliceFlagName = "instance-name-slice"
 )
 
 // ParseInstance parses the service instance id or service instance name,
@@ -44,6 +46,18 @@ func ParseInstance(required bool) func(*cli.Context) error {
 	}
 }
 
+// ParseInstanceSlice parses the service instance id slice or service instance name slice,
+// and converts the present one to the missing one.
+// See flags.InstanceSliceFlags.
+func ParseInstanceSlice(required bool) func(*cli.Context) error {
+	return func(ctx *cli.Context) error {
+		if err := ParseService(required)(ctx); err != nil {
+			return err
+		}
+		return parseInstanceSlice(required, InstanceIDSliceFlagName, instanceNameSliceFlagName, serviceIDFlagName)(ctx)
+	}
+}
+
 // ParseInstanceRelation parses the source and destination service instance id or service instance name,
 // and converts the present one to the missing one respectively.
 // See flags.InstanceRelationFlags.
@@ -72,26 +86,85 @@ func parseInstance(required bool, idFlagName, nameFlagName, serviceIDFlagName st
 			return nil
 		}
 
-		if id != "" {
-			parts := strings.Split(id, "_")
-			if len(parts) != 2 {
-				return fmt.Errorf("invalid instance id, cannot be splitted into 2 parts. %v", id)
+		id, name, err := encode(serviceID, nameFlagName, id, name)
+		if err != nil {
+			return err
+		}
+
+		if err := ctx.Set(idFlagName, id); err != nil {
+			return err
+		}
+		return ctx.Set(nameFlagName, name)
+	}
+}
+
+func parseInstanceSlice(required bool, idSliceFlagName, nameSliceFlagName, serviceIDFlagName string) func(*cli.Context) error {
+	return func(ctx *cli.Context) error {
+		idsArg := ctx.String(idSliceFlagName)
+		namesArgs := ctx.String(nameSliceFlagName)
+		serviceID := ctx.String(serviceIDFlagName)
+
+		if idsArg == "" && namesArgs == "" {
+			if required {
+				return fmt.Errorf(`either flags "--%s" or "--%s" must be given`, idSliceFlagName, nameSliceFlagName)
+			}
+			return nil
+		}
+
+		ids := strings.Split(idsArg, ",")
+		names := strings.Split(namesArgs, ",")
+		var sliceSize int
+		if l := len(ids); idsArg != "" && l != 0 {
+			sliceSize = l
+		} else {
+			sliceSize = len(names)
+		}
+		instanceIDSlice := make([]string, sliceSize)
+		instanceNameSlice := make([]string, sliceSize)
+		for i := 0; i < sliceSize; i++ {
+			id := ""
+			name := ""
+			if len(ids) > i {
+				id = ids[i]
+			}
+			if len(names) > i {
+				name = names[i]
 			}
-			s, err := base64.StdEncoding.DecodeString(parts[1])
+
+			id, name, err := encode(serviceID, nameSliceFlagName, id, name)
 			if err != nil {
 				return err
 			}
-			name = string(s)
-		} else if name != "" {
-			if serviceID == "" {
-				return fmt.Errorf(`"--%s" is specified but its related service name or id is not given`, nameFlagName)
-			}
-			id = serviceID + "_" + b64enc(name)
+
+			instanceIDSlice[i] = id
+			instanceNameSlice[i] = name
 		}
 
-		if err := ctx.Set(idFlagName, id); err != nil {
+		instanceIDSliceString := strings.Join(instanceIDSlice, ",")
+		instanceNameSliceString := strings.Join(instanceNameSlice, ",")
+		if err := ctx.Set(idSliceFlagName, instanceIDSliceString); err != nil {
 			return err
 		}
-		return ctx.Set(nameFlagName, name)
+		return ctx.Set(nameSliceFlagName, instanceNameSliceString)
+	}
+}
+
+func encode(serviceID, nameFlagName, id, name string) (encodedID, encodedName string, err error) {
+	if id != "" {
+		parts := strings.Split(id, "_")
+		if len(parts) != 2 {
+			return "", "", fmt.Errorf("invalid instance id, cannot be splitted into 2 parts. %v", id)
+		}
+		s, err := base64.StdEncoding.DecodeString(parts[1])
+		if err != nil {
+			return "", "", err
+		}
+		name = string(s)
+	} else if name != "" {
+		if serviceID == "" {
+			return "", "", fmt.Errorf(`"--%s" is specified but its related service name or id is not given`, nameFlagName)
+		}
+		id = serviceID + "_" + b64enc(name)
 	}
+	return id, name, nil
 }

internal/commands/profiling/asyncprofiler/asyncprofiler.go

@@ -0,0 +1,34 @@
+// Licensed to 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. Apache Software Foundation (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 asyncprofiler
+
+import "github.com/urfave/cli/v2"
+
+var Command = &cli.Command{
+	Name:  "async",
+	Usage: "async profiler related sub-command",
+	UsageText: `If your endpoint has performance issue and could not use tracing to find out what's happening,
+you could try it. You could get more information
+on https://skywalking.apache.org/docs/main/next/en/concepts-and-designs/profiling.`,
+	Subcommands: []*cli.Command{
+		createCommand,
+		getTaskListCommand,
+		getTaskProgressCommand,
+		analysisCommand,
+	},
+}