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 2023/04/26 04:06:51 UTC
[skywalking-go] branch main updated: Setup plugin tests and add gin plugin test (#15)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-go.git
The following commit(s) were added to refs/heads/main by this push:
new 191ee52 Setup plugin tests and add gin plugin test (#15)
191ee52 is described below
commit 191ee520f376a71d6a91b14747862bcd9498157b
Author: mrproliu <74...@qq.com>
AuthorDate: Wed Apr 26 12:06:46 2023 +0800
Setup plugin tests and add gin plugin test (#15)
---
.github/workflows/plugin-tests.yaml | 81 ++++++++
.gitignore | 6 +-
test/plugins/Makefile | 31 +++
test/plugins/run.sh | 188 +++++++++++++++++
test/plugins/runner-helper/context.go | 113 ++++++++++
test/plugins/runner-helper/go.mod | 5 +
test/plugins/runner-helper/go.sum | 3 +
test/plugins/runner-helper/main.go | 117 +++++++++++
.../runner-helper/templates/docker-compose.tpl | 59 ++++++
.../plugins/runner-helper/templates/dockerfile.tpl | 26 +++
test/plugins/runner-helper/templates/render.go | 44 ++++
test/plugins/runner-helper/templates/scenarios.tpl | 43 ++++
test/plugins/runner-helper/templates/validator.tpl | 67 ++++++
test/plugins/scenarios/gin/bin/startup.sh | 22 ++
test/plugins/scenarios/gin/config/excepted.yml | 92 ++++++++
test/plugins/scenarios/gin/go.mod | 42 ++++
test/plugins/scenarios/gin/go.sum | 231 +++++++++++++++++++++
test/plugins/scenarios/gin/main.go | 58 ++++++
test/plugins/scenarios/gin/plugin.yml | 30 +++
test/plugins/validator/Dockerfile | 19 ++
tools/go-agent/cmd/main.go | 14 --
tools/go-agent/instrument/instrument.go | 1 +
tools/go-agent/instrument/plugins/instrument.go | 55 +++--
23 files changed, 1310 insertions(+), 37 deletions(-)
diff --git a/.github/workflows/plugin-tests.yaml b/.github/workflows/plugin-tests.yaml
new file mode 100644
index 0000000..7ffe11d
--- /dev/null
+++ b/.github/workflows/plugin-tests.yaml
@@ -0,0 +1,81 @@
+# 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.
+
+name: Plugin Tests
+
+concurrency:
+ group: plugins-${{ github.event.pull_request.number || github.ref }}
+ cancel-in-progress: true
+
+on:
+ pull_request:
+
+jobs:
+ build:
+ name: Build Plugin Test
+ runs-on: ubuntu-latest
+ timeout-minutes: 60
+ steps:
+ - name: Set up Go 1.18
+ uses: actions/setup-go@v2
+ with:
+ go-version: 1.18
+ - name: Check out code into the Go module directory
+ uses: actions/checkout@v2
+ with:
+ submodules: true
+ - name: Build
+ run: make -C test/plugins build
+ - uses: actions/upload-artifact@v2
+ name: Upload Test Base
+ with:
+ name: test-tools
+ path: |
+ test/plugins/dist
+
+ test:
+ if: always()
+ name: ${{ matrix.case }}
+ needs:
+ - build
+ runs-on: ubuntu-latest
+ timeout-minutes: 90
+ strategy:
+ matrix:
+ case:
+ - gin
+ steps:
+ - uses: actions/checkout@v2
+ with:
+ submodules: true
+ - uses: actions/download-artifact@v2
+ with:
+ name: test-tools
+ path: test/plugins/dist
+ - name: Setup Tools
+ run: |
+ chmod +x test/plugins/dist/*
+ if ls test/plugins/dist/skywalking-agent-test-validator-1.0.0.tgz; then
+ docker load -i test/plugins/dist/skywalking-agent-test-validator-1.0.0.tgz
+ fi
+ - name: Run Test
+ run: bash test/plugins/run.sh ${{ matrix.case }}
+ - uses: actions/upload-artifact@v2
+ name: Upload Agent
+ if: ${{ failure() }}
+ with:
+ path: test/plugins/workspace
+ name: test-plugins-workspace-${{ matrix.case }}
\ No newline at end of file
diff --git a/.gitignore b/.gitignore
index a7ceb1e..6235565 100644
--- a/.gitignore
+++ b/.gitignore
@@ -3,5 +3,7 @@
.DS_Store
*~
.cache/
-bin/
-coverage.txt
\ No newline at end of file
+/bin
+coverage.txt
+/test/plugins/workspace
+/test/plugins/dist/
\ No newline at end of file
diff --git a/test/plugins/Makefile b/test/plugins/Makefile
new file mode 100644
index 0000000..e67b505
--- /dev/null
+++ b/test/plugins/Makefile
@@ -0,0 +1,31 @@
+#
+# 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.
+#
+
+GO = go
+GO_BUILD = $(GO) build
+
+.PHONY: build
+build:
+ mkdir -p dist
+ # go agent
+ @make -C ../../tools/go-agent linux
+ cp ../../bin/skywalking-go-agent--linux-amd64 dist/skywalking-go-agent
+ # runner helper
+ cd runner-helper && $(GO_BUILD) -o ../dist/runner-helper
+ # validator container
+ cd validator && docker build . -t skywalking/agent-test-validator:1.0.0
+ docker save -o dist/skywalking-agent-test-validator-1.0.0.tgz skywalking/agent-test-validator:1.0.0
\ No newline at end of file
diff --git a/test/plugins/run.sh b/test/plugins/run.sh
new file mode 100755
index 0000000..54b947c
--- /dev/null
+++ b/test/plugins/run.sh
@@ -0,0 +1,188 @@
+#!/bin/bash
+#
+# 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.
+
+set -ex
+
+home="$(cd "$(dirname $0)"; pwd)"
+scenario_name=
+debug_mode=
+cleanup="off"
+
+scenarios_home="${home}/scenarios"
+num_of_testcases=0
+
+start_stamp=`date +%s`
+
+print_help() {
+ echo "Usage: run.sh [OPTION] SCENARIO_NAME"
+ echo -e "\t--clean, \t\t\t remove the related images and directories"
+ echo -e "\t--debug, \t\t\t to save the log files and actualData.yaml"
+}
+
+remove_dir() {
+ dir=$1
+ if [[ "${os}" == "Darwin" ]]; then
+ find ${dir} -type d -exec chmod -a "$(whoami) deny delete" {} \;
+ fi
+ rm -rf $dir
+}
+
+exitAndClean() {
+ elapsed=$(( `date +%s` - $start_stamp ))
+ printf "Scenarios: ${scenario_name}, Testcases: ${num_of_testcases}, Elapsed: %02d:%02d:%02d \n" \
+ $(( ${elapsed}/3600 )) $(( ${elapsed}%3600/60 )) $(( ${elapsed}%60 ))
+ exit $1
+}
+
+exitWithMessage() {
+ echo -e "\033[31m[ERROR] $1\033[0m">&2
+ exitAndClean 1
+}
+
+# parse command line
+parse_commandline() {
+ while test $# -gt 0; do
+ _key="$1"
+ case "$_key" in
+ --debug)
+ debug_mode="on"
+ ;;
+ --clean)
+ cleanup="on"
+ ;;
+ -h|--help)
+ print_help
+ exit 0
+ ;;
+ *)
+ scenario_name=$1
+ ;;
+ esac
+ shift
+ done
+}
+parse_commandline "$@"
+
+do_cleanup() {
+ images=$(docker images -qf "dangling=true")
+ [[ -n "${images}" ]] && docker rmi -f ${images}
+
+ docker network prune -f
+ docker volume prune -f
+
+ [[ -d ${home}/dist ]] && rm -rf ${home}/dist
+ [[ -d ${home}/workspace ]] && rm -rf ${home}/workspace
+ return
+}
+
+if [[ "$cleanup" == "on" ]]; then
+ do_cleanup
+ [[ -z "${scenario_name}" ]] && exit 0
+fi
+
+test -z "$scenario_name" && exitWithMessage "Missing value for the scenario argument"
+
+scenario_home=${scenarios_home}/${scenario_name}
+
+# reading versions from plugin configuration
+configuration=${scenario_home}/plugin.yml
+if [[ ! -f $configuration ]]; then
+ exitWithMessage "cannot found 'plugin.yml' in directory ${scenario_name}"
+fi
+
+# support go, framework versions
+framework_name=$(yq e '.framework' $configuration)
+if [ -z "$framework_name" ]; then
+ exitWithMessage "Missing framework name in configuration"
+fi
+support_version_count=$(yq e '.support-version | length' $configuration)
+if [ "$support_version_count" -eq 0 ]; then
+ exitWithMessage "Missing support-version list in configuration"
+fi
+index=0
+while [ $index -lt $support_version_count ]; do
+ go_version=$(yq e ".support-version[$index].go" $configuration)
+ framework_count=$(yq e ".support-version[$index].framework | length" $configuration)
+
+ if [ -z "$go_version" ] || [ "$framework_count" -eq 0 ]; then
+ exitWithMessage "Missing go or framework in list entry $index."
+ fi
+
+ index=$((index+1))
+done
+
+workspace="${home}/workspace/${scenario_name}"
+[[ -d ${workspace} ]] && rm -rf $workspace
+
+plugin_runner_helper="${home}/dist/runner-helper"
+if [[ ! -f $plugin_runner_helper ]]; then
+ exitWithMessage "cannot found 'runner-helper' in directory ${home}/dist"
+fi
+go_agent="${home}/dist/skywalking-go-agent"
+if [[ ! -f $go_agent ]]; then
+ exitWithMessage "cannot found 'go-agent' in directory ${home}/dist"
+fi
+
+yq e '.support-version[].go' $configuration | while read -r go_version; do
+frameworks=$(yq e ".support-version[] | select(.go == \"$go_version\") | .framework[]" $configuration)
+for framework_version in $frameworks; do
+ echo "ready to run test case: ${scenario_name} with go version: ${go_version} and framework version: ${framework_version}"
+ case_name="go${go_version}-${framework_version}"
+
+ # copy test case to workspace
+ case_home="${workspace}/${case_name}"
+ case_logs="${case_home}/logs"
+ mkdir -p ${case_home}
+ mkdir -p ${case_logs}
+ cp -rf ${scenario_home}/* ${case_home}
+ cd ${case_home}
+
+ # replace go version
+ sed -i "s/^go [0-9]*\.[0-9]*/go ${go_version}/" go.mod
+
+ # ajust the plugin replace path
+ sed -i -E '/^replace/ s#(\.\./)#\1../#' go.mod
+
+ # replace framework version
+ go get "$framework_name@$framework_version"
+ go mod tidy
+
+ # run runner helper for prepare running docker-compose
+ ${plugin_runner_helper} \
+ -workspace ${case_home} \
+ -project ${home}/../../ \
+ -go-version ${go_version} \
+ -scenario ${scenario_name} \
+ -case ${case_name} \
+ -go-agent ${go_agent} > ${case_logs}/runner-helper.log
+
+ echo "staring the testcase ${scenario_name}, ${case_name}"
+
+ bash ${case_home}/scenarios.sh > ${case_logs}/scenarios.log
+ status=$?
+ if [[ $status == 0 ]]; then
+ [[ -z $debug_mode ]] && remove_dir ${case_home}
+ else
+ exitWithMessage "Testcase ${case_name} failed!"
+ fi
+ num_of_testcases=$(($num_of_testcases+1))
+
+done
+done
+
+exitAndClean 0
\ No newline at end of file
diff --git a/test/plugins/runner-helper/context.go b/test/plugins/runner-helper/context.go
new file mode 100644
index 0000000..4231153
--- /dev/null
+++ b/test/plugins/runner-helper/context.go
@@ -0,0 +1,113 @@
+// 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 main
+
+import (
+ "errors"
+ "flag"
+ "os"
+ "path/filepath"
+
+ "gopkg.in/yaml.v3"
+)
+
+var workSpaceDir = flag.String("workspace", "", "testcase workspace directory")
+var projectDir = flag.String("project", "", "project directory")
+var goVersion = flag.String("go-version", "", "go version")
+var scenarioName = flag.String("scenario", "", "scenario name")
+var caseName = flag.String("case", "", "case name")
+var goAgentPath = flag.String("go-agent", "", "go agent file path")
+var debugMode = flag.Bool("debug", false, "is debug mode")
+
+func BuildContext() (*Context, error) {
+ flag.Parse()
+ var err error
+ err = flagValueCannotBeEmpty(err, workSpaceDir, "workspace directory cannot be empty")
+ err = flagValueCannotBeEmpty(err, projectDir, "project directory cannot be empty")
+ err = flagValueCannotBeEmpty(err, goVersion, "go version cannot be empty")
+ err = flagValueCannotBeEmpty(err, scenarioName, "scenario name cannot be empty")
+ err = flagValueCannotBeEmpty(err, caseName, "case name cannot be empty")
+ err = flagValueCannotBeEmpty(err, goAgentPath, "go agent path cannot be empty")
+ if err != nil {
+ return nil, err
+ }
+
+ config, err := loadConfig(filepath.Join(*workSpaceDir, "plugin.yml"))
+ if err != nil {
+ return nil, err
+ }
+
+ return &Context{
+ WorkSpaceDir: filepath.Clean(*workSpaceDir),
+ ProjectDir: filepath.Clean(*projectDir),
+ GoVersion: *goVersion,
+ ScenarioName: *scenarioName,
+ CaseName: *caseName,
+ GoAgentPath: filepath.Clean(*goAgentPath),
+ DebugMode: *debugMode,
+ Config: config,
+ }, nil
+}
+
+type Context struct {
+ WorkSpaceDir string
+ ProjectDir string
+ GoVersion string
+ ScenarioName string
+ CaseName string
+ GoAgentPath string
+ DebugMode bool
+ Config *Config
+}
+
+type Config struct {
+ EntryService string `yaml:"entry-service"`
+ HealthChecker string `yaml:"health-checker"`
+ StartScript string `yaml:"start-script"`
+ FrameworkName string `yaml:"framework"`
+ ExportPort int `yaml:"export-port"`
+ SupportVersion []SupportVersion `yaml:"support-version"`
+}
+
+type SupportVersion struct {
+ GoVersion string `yaml:"go"`
+ Frameworks []string `yaml:"framework"`
+}
+
+func loadConfig(path string) (config *Config, err error) {
+ content, err := os.ReadFile(path)
+ if err != nil {
+ return nil, err
+ }
+ c := &Config{}
+ err = yaml.Unmarshal(content, c)
+ if err != nil {
+ return nil, err
+ }
+ return c, nil
+}
+
+func flagValueCannotBeEmpty(err error, val *string, msg string) error {
+ if err != nil {
+ return err
+ }
+ if *val == "" {
+ return errors.New(msg)
+ }
+ return nil
+}
diff --git a/test/plugins/runner-helper/go.mod b/test/plugins/runner-helper/go.mod
new file mode 100644
index 0000000..8c34199
--- /dev/null
+++ b/test/plugins/runner-helper/go.mod
@@ -0,0 +1,5 @@
+module plugin-runner-helper
+
+go 1.18
+
+require gopkg.in/yaml.v3 v3.0.1 // indirect
\ No newline at end of file
diff --git a/test/plugins/runner-helper/go.sum b/test/plugins/runner-helper/go.sum
new file mode 100644
index 0000000..4bc0337
--- /dev/null
+++ b/test/plugins/runner-helper/go.sum
@@ -0,0 +1,3 @@
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
diff --git a/test/plugins/runner-helper/main.go b/test/plugins/runner-helper/main.go
new file mode 100644
index 0000000..b592b69
--- /dev/null
+++ b/test/plugins/runner-helper/main.go
@@ -0,0 +1,117 @@
+// 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 main
+
+import (
+ "log"
+ "os"
+ "path/filepath"
+ "strings"
+
+ "plugin-runner-helper/templates"
+)
+
+func main() {
+ log.Printf("helper execute args: %v", os.Args)
+ context, err := BuildContext()
+ if err != nil {
+ log.Fatalf("building context failure: %v", err)
+ }
+
+ // generate Dockerfile to build the plugin
+ err = RenderDockerFile(context)
+ if err != nil {
+ log.Fatalf("build dockerfile failure: %v", err)
+ }
+
+ // generate docker-compose.yml to run the plugin
+ err = RenderDockerCompose(context)
+ if err != nil {
+ log.Fatalf("build docker-compose failure: %v", err)
+ }
+
+ // generate validator.sh to validate the plugin
+ err = RenderValidatorScript(context)
+ if err != nil {
+ log.Fatalf("build validator failure: %v", err)
+ }
+
+ // generate scenarios.sh to start the plugin test case
+ err = RenderScenariosScript(context)
+ if err != nil {
+ log.Fatalf("build scenarios failure: %v", err)
+ }
+}
+
+func RenderDockerFile(context *Context) error {
+ render, err := templates.Render("dockerfile.tpl", struct {
+ ToolExecPath string
+ Context *Context
+ }{
+ ToolExecPath: strings.TrimPrefix(context.GoAgentPath, context.ProjectDir),
+ Context: context,
+ })
+ if err != nil {
+ return err
+ }
+ return os.WriteFile(filepath.Join(context.WorkSpaceDir, "Dockerfile"), []byte(render), 0o600)
+}
+
+func RenderDockerCompose(context *Context) error {
+ rel, err := filepath.Rel(context.ProjectDir, filepath.Join(context.WorkSpaceDir, "Dockerfile"))
+ if err != nil {
+ return err
+ }
+ render, err := templates.Render("docker-compose.tpl", struct {
+ DockerFilePathRelateToProject string
+ Context *Context
+ }{
+ DockerFilePathRelateToProject: rel,
+ Context: context,
+ })
+ if err != nil {
+ return err
+ }
+ return os.WriteFile(filepath.Join(context.WorkSpaceDir, "docker-compose.yml"), []byte(render), 0o600)
+}
+
+func RenderValidatorScript(context *Context) error {
+ render, err := templates.Render("validator.tpl", struct {
+ Context *Context
+ }{
+ Context: context,
+ })
+ if err != nil {
+ return err
+ }
+ return os.WriteFile(filepath.Join(context.WorkSpaceDir, "validator.sh"), []byte(render), 0o600)
+}
+
+func RenderScenariosScript(context *Context) error {
+ render, err := templates.Render("scenarios.tpl", struct {
+ DockerComposeFilePath string
+ Context *Context
+ }{
+ DockerComposeFilePath: filepath.Join(context.WorkSpaceDir, "docker-compose.yml"),
+ Context: context,
+ })
+ if err != nil {
+ return err
+ }
+ return os.WriteFile(filepath.Join(context.WorkSpaceDir, "scenarios.sh"), []byte(render), 0o600)
+}
diff --git a/test/plugins/runner-helper/templates/docker-compose.tpl b/test/plugins/runner-helper/templates/docker-compose.tpl
new file mode 100644
index 0000000..0222c89
--- /dev/null
+++ b/test/plugins/runner-helper/templates/docker-compose.tpl
@@ -0,0 +1,59 @@
+# 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.
+
+version: '2.1'
+
+networks:
+ default:
+ name: {{.Context.ScenarioName}}
+
+services:
+ oap:
+ image: ghcr.io/apache/skywalking-agent-test-tool/mock-collector:cf62c1b733fe2861229201a67b9cc0075ac3e236
+ expose:
+ - 19876
+ - 12800
+ ports:
+ - 12800
+ healthcheck:
+ test: ["CMD", "bash", "-c", "cat < /dev/null > /dev/tcp/127.0.0.1/12800"]
+ interval: 5s
+ timeout: 60s
+ retries: 120
+ service:
+ build:
+ context: {{.Context.ProjectDir}}
+ dockerfile: {{.DockerFilePathRelateToProject}}
+ depends_on:
+ oap:
+ condition: service_healthy
+ ports:
+ - {{.Context.Config.ExportPort}}
+ environment:
+ SW_AGENT_NAME: {{.Context.ScenarioName}}
+ SW_AGENT_REPORTER_GRPC_BACKEND_SERVICE: oap:19876
+ healthcheck:
+ test: ["CMD", "bash", "-c", "cat < /dev/null > /dev/tcp/127.0.0.1/{{.Context.Config.ExportPort}}"]
+ interval: 5s
+ timeout: 60s
+ retries: 120
+ validator:
+ image: skywalking/agent-test-validator:1.0.0
+ depends_on:
+ service:
+ condition: service_healthy
+ volumes:
+ - {{.Context.WorkSpaceDir}}:/workspace
+ command: ["/bin/bash", "/workspace/validator.sh"]
diff --git a/test/plugins/runner-helper/templates/dockerfile.tpl b/test/plugins/runner-helper/templates/dockerfile.tpl
new file mode 100644
index 0000000..60f30f3
--- /dev/null
+++ b/test/plugins/runner-helper/templates/dockerfile.tpl
@@ -0,0 +1,26 @@
+# 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.
+
+FROM golang:{{.Context.GoVersion}}
+
+WORKDIR /skywalking-go
+COPY . .
+
+WORKDIR /skywalking-go/test/plugins/workspace/{{.Context.ScenarioName}}/{{.Context.CaseName}}/
+
+ENV GO_BUILD_OPTS=" -toolexec \"/skywalking-go{{.ToolExecPath}}\" -a -work "
+
+CMD ["bash", "{{.Context.Config.StartScript}}"]
diff --git a/test/plugins/runner-helper/templates/render.go b/test/plugins/runner-helper/templates/render.go
new file mode 100644
index 0000000..c33742a
--- /dev/null
+++ b/test/plugins/runner-helper/templates/render.go
@@ -0,0 +1,44 @@
+// 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 templates
+
+import (
+ "bytes"
+ "embed"
+ "text/template"
+)
+
+//go:embed *
+var templates embed.FS
+
+func Render(name string, data interface{}) (string, error) {
+ file, err := templates.ReadFile(name)
+ if err != nil {
+ return "", err
+ }
+ tmpl, err := template.New(name).Parse(string(file))
+ if err != nil {
+ return "", err
+ }
+ var buf bytes.Buffer
+ err = tmpl.Execute(&buf, data)
+ if err != nil {
+ return "", err
+ }
+ return buf.String(), nil
+}
diff --git a/test/plugins/runner-helper/templates/scenarios.tpl b/test/plugins/runner-helper/templates/scenarios.tpl
new file mode 100644
index 0000000..0780f23
--- /dev/null
+++ b/test/plugins/runner-helper/templates/scenarios.tpl
@@ -0,0 +1,43 @@
+#!/bin/bash
+#
+# 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.
+
+set -ex
+
+project_name=$(echo "{{.Context.ScenarioName}}" |sed -e "s/\.//g" |awk '{print tolower($0)}')
+service_container_name="${project_name}_service_1"
+validator_container_name="${project_name}_validator_1"
+docker-compose -p "${project_name}" -f "{{.DockerComposeFilePath}}" up -d --build
+
+sleep 3
+
+validator_container_id=`docker ps -aqf "name=${validator_container_name}"`
+status=$(docker wait ${validator_container_id})
+
+if [[ -z ${validator_container_id} ]]; then
+ docker logs ${service_container_name} > {{.Context.WorkSpaceDir}}/logs/service.log
+ echo "docker startup failure!" >&2
+ status=1
+else
+ [[ $status -ne 0 ]] && docker logs ${validator_container_id} >&2
+ docker logs ${service_container_name} > {{.Context.WorkSpaceDir}}/logs/service.log
+
+ docker-compose -p ${project_name} -f {{.DockerComposeFilePath}} kill
+ docker-compose -p ${project_name} -f {{.DockerComposeFilePath}} rm -f
+fi
+
+exit $status
\ No newline at end of file
diff --git a/test/plugins/runner-helper/templates/validator.tpl b/test/plugins/runner-helper/templates/validator.tpl
new file mode 100644
index 0000000..daed0ad
--- /dev/null
+++ b/test/plugins/runner-helper/templates/validator.tpl
@@ -0,0 +1,67 @@
+#!/bin/bash
+#
+# 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.
+
+set -ex
+
+exitOnError() {
+ echo -e "\033[31m[ERROR] $1\033[0m">&2
+ exit 1
+}
+
+healthCheck() {
+ HEALTH_CHECK_URL=$1
+ STATUS=""
+ TIMES=${TIMES:-60}
+ i=1
+ while [[ $i -lt ${TIMES} ]];
+ do
+ STATUS=$(curl --max-time 3 -is ${HEALTH_CHECK_URL} | grep -oE "HTTP/.*\s+200")
+ if [[ -n "$STATUS" ]]; then
+ echo "${HEALTH_CHECK_URL}: ${STATUS}"
+ return 0
+ fi
+ sleep 3
+ i=$(($i + 1))
+ done
+
+ exitOnError "{{.Context.ScenarioName}}-{{.Context.CaseName}} url=${HEALTH_CHECK_URL}, status=${STATUS} health check failed!"
+}
+
+HTTP_HOST=service
+HTTP_PORT={{.Context.Config.ExportPort}}
+
+echo "Checking the service health status..."
+healthCheck "{{.Context.Config.HealthChecker}}"
+
+echo "Visiting entry service..."
+`echo curl -s --max-time 3 {{.Context.Config.EntryService}}` || true
+sleep 5
+
+echo "Receiving actual data..."
+curl -s --max-time 3 http://oap:12800/receiveData > /workspace/config/actual.yaml
+[[ ! -f /workspace/config/actual.yaml ]] && exitOnError "{{.Context.ScenarioName}}-{{.Context.CaseName}}, 'actual.yaml' Not Found!"
+
+echo "Validating actual data..."
+response=$(curl -X POST --data-binary "@/workspace/config/excepted.yml" -s -w "\n%{http_code}" http://oap:12800/dataValidate)
+status_code=$(echo "$response" | tail -n1)
+response_body=$(echo "$response" | head -n -1)
+if [ "$status_code" -ne 200 ]; then
+ exitOnError "{{.Context.ScenarioName}}-{{.Context.CaseName}}, validate actual data failed! \n$response_body"
+fi
+
+exit 0
\ No newline at end of file
diff --git a/test/plugins/scenarios/gin/bin/startup.sh b/test/plugins/scenarios/gin/bin/startup.sh
new file mode 100755
index 0000000..84a29aa
--- /dev/null
+++ b/test/plugins/scenarios/gin/bin/startup.sh
@@ -0,0 +1,22 @@
+#!/bin/bash
+#
+# 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.
+
+home="$(cd "$(dirname $0)"; pwd)"
+go build ${GO_BUILD_OPTS} -o gin
+
+./gin
\ No newline at end of file
diff --git a/test/plugins/scenarios/gin/config/excepted.yml b/test/plugins/scenarios/gin/config/excepted.yml
new file mode 100644
index 0000000..32451fd
--- /dev/null
+++ b/test/plugins/scenarios/gin/config/excepted.yml
@@ -0,0 +1,92 @@
+# 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.
+
+segmentItems:
+ - serviceName: gin
+ segmentSize: ge 3
+ segments:
+ - segmentId: not null
+ spans:
+ - operationName: GET:/health
+ parentSpanId: -1
+ spanId: 0
+ spanLayer: Http
+ startTime: nq 0
+ endTime: nq 0
+ componentId: 5006
+ isError: false
+ spanType: Entry
+ peer: ''
+ skipAnalysis: false
+ tags:
+ - {key: http.method, value: GET}
+ - {key: url, value: 'service:8080/health'}
+ - {key: status_code, value: '200'}
+ - segmentId: not null
+ spans:
+ - operationName: GET:/provider
+ parentSpanId: -1
+ spanId: 0
+ spanLayer: Http
+ startTime: nq 0
+ endTime: nq 0
+ componentId: 5006
+ isError: false
+ spanType: Entry
+ peer: ''
+ skipAnalysis: false
+ tags:
+ - {key: http.method, value: GET}
+ - {key: url, value: 'localhost:8080/provider'}
+ - {key: status_code, value: '200'}
+ refs:
+ - {parentEndpoint: 'GET:/consumer', networkAddress: 'localhost:8080', refType: CrossProcess,
+ parentSpanId: 1, parentTraceSegmentId: not null, parentServiceInstance: not null,
+ parentService: gin, traceId: not null}
+ - segmentId: not null
+ spans:
+ - operationName: GET:/provider
+ parentSpanId: 0
+ spanId: 1
+ spanLayer: Http
+ startTime: gt 0
+ endTime: gt 0
+ componentId: 5005
+ isError: false
+ spanType: Exit
+ peer: localhost:8080
+ skipAnalysis: false
+ tags:
+ - {key: http.method, value: GET}
+ - {key: url, value: 'localhost:8080/provider'}
+ - {key: status_code, value: '200'}
+ - operationName: GET:/consumer
+ parentSpanId: -1
+ spanId: 0
+ spanLayer: Http
+ startTime: gt 0
+ endTime: gt 0
+ componentId: 5006
+ isError: false
+ spanType: Entry
+ peer: ''
+ skipAnalysis: false
+ tags:
+ - {key: http.method, value: GET}
+ - {key: url, value: 'service:8080/consumer'}
+ - {key: status_code, value: '200'}
+meterItems: []
+logItems: []
\ No newline at end of file
diff --git a/test/plugins/scenarios/gin/go.mod b/test/plugins/scenarios/gin/go.mod
new file mode 100644
index 0000000..c0f0a25
--- /dev/null
+++ b/test/plugins/scenarios/gin/go.mod
@@ -0,0 +1,42 @@
+module test
+
+go 1.18
+
+replace github.com/apache/skywalking-go => ../../../../
+
+require (
+ github.com/apache/skywalking-go v0.0.0-00010101000000-000000000000
+ github.com/gin-gonic/gin v1.9.0
+)
+
+require (
+ github.com/bytedance/sonic v1.8.0 // indirect
+ github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311 // indirect
+ github.com/gin-contrib/sse v0.1.0 // indirect
+ github.com/go-playground/locales v0.14.1 // indirect
+ github.com/go-playground/universal-translator v0.18.1 // indirect
+ github.com/go-playground/validator/v10 v10.11.2 // indirect
+ github.com/goccy/go-json v0.10.0 // indirect
+ github.com/golang/protobuf v1.5.2 // indirect
+ github.com/google/uuid v1.3.0 // indirect
+ github.com/json-iterator/go v1.1.12 // indirect
+ github.com/klauspost/cpuid/v2 v2.0.9 // indirect
+ github.com/leodido/go-urn v1.2.1 // indirect
+ github.com/mattn/go-isatty v0.0.17 // indirect
+ github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect
+ github.com/modern-go/reflect2 v1.0.2 // indirect
+ github.com/pelletier/go-toml/v2 v2.0.6 // indirect
+ github.com/pkg/errors v0.9.1 // indirect
+ github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
+ github.com/ugorji/go/codec v1.2.9 // indirect
+ golang.org/x/arch v0.0.0-20210923205945-b76863e36670 // indirect
+ golang.org/x/crypto v0.5.0 // indirect
+ golang.org/x/net v0.8.0 // indirect
+ golang.org/x/sys v0.6.0 // indirect
+ golang.org/x/text v0.8.0 // indirect
+ google.golang.org/genproto v0.0.0-20230110181048-76db0878b65f // indirect
+ google.golang.org/grpc v1.54.0 // indirect
+ google.golang.org/protobuf v1.29.0 // indirect
+ gopkg.in/yaml.v3 v3.0.1 // indirect
+ skywalking.apache.org/repo/goapi v0.0.0-20230314034821-0c5a44bb767a // indirect
+)
diff --git a/test/plugins/scenarios/gin/go.sum b/test/plugins/scenarios/gin/go.sum
new file mode 100644
index 0000000..5cfe0bd
--- /dev/null
+++ b/test/plugins/scenarios/gin/go.sum
@@ -0,0 +1,231 @@
+cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
+cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
+github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
+github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
+github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY=
+github.com/bytedance/sonic v1.5.0/go.mod h1:ED5hyg4y6t3/9Ku1R6dU/4KyJ48DZ4jPhfY1O2AihPM=
+github.com/bytedance/sonic v1.8.0 h1:ea0Xadu+sHlu7x5O3gKhRpQ1IKiMrSiHttPF0ybECuA=
+github.com/bytedance/sonic v1.8.0/go.mod h1:i736AoUSYt75HyZLoJW9ERYxcy6eaN6h4BZXU064P/U=
+github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
+github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
+github.com/chenzhuoyu/base64x v0.0.0-20211019084208-fb5309c8db06/go.mod h1:DH46F32mSOjUmXrMHnKwZdA8wcEefY7UVqBKYGjpdQY=
+github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311 h1:qSGYFH7+jGhDF8vLC+iwCD4WpbV1EBDSzWkJODFLams=
+github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311/go.mod h1:b583jCggY9gE99b6G5LEC39OIiVsWj+R97kbl5odCEk=
+github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
+github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
+github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
+github.com/cncf/xds/go v0.0.0-20210312221358-fbca930ec8ed/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
+github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
+github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98=
+github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk=
+github.com/envoyproxy/go-control-plane v0.9.9-0.20210217033140-668b12f5399d/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk=
+github.com/envoyproxy/go-control-plane v0.9.9-0.20210512163311-63b5d3c536b0/go.mod h1:hliV/p42l8fGbc6Y9bQ70uLwIvmJyVE5k4iMKlh8wCQ=
+github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
+github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
+github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE=
+github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI=
+github.com/gin-gonic/gin v1.9.0 h1:OjyFBKICoexlu99ctXNR2gg+c5pKrKMuyjgARg9qeY8=
+github.com/gin-gonic/gin v1.9.0/go.mod h1:W1Me9+hsUSyj3CePGrd1/QrKJMSJ1Tu/0hFEH89961k=
+github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
+github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
+github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY=
+github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY=
+github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY=
+github.com/go-playground/validator/v10 v10.11.2 h1:q3SHpufmypg+erIExEKUmsgmhDTyhcJ38oeKGACXohU=
+github.com/go-playground/validator/v10 v10.11.2/go.mod h1:NieE624vt4SCTJtD87arVLvdmjPAeV8BQlHtMnw9D7s=
+github.com/goccy/go-json v0.10.0 h1:mXKd9Qw4NuzShiRlOXKews24ufknHO7gx30lsDyokKA=
+github.com/goccy/go-json v0.10.0/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
+github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
+github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
+github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.3.3/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw=
+github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
+github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
+github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=
+github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w=
+github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0=
+github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8=
+github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
+github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
+github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
+github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw=
+github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
+github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
+github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
+github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
+github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
+github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
+github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw=
+github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
+github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
+github.com/klauspost/cpuid/v2 v2.0.9 h1:lgaqFMSdTdQYdZ04uHyN2d/eKdOMyi2YLSvlQIBFYa4=
+github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
+github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/leodido/go-urn v1.2.1 h1:BqpAaACuzVSgi/VLzGZIobT2z4v53pjosyNd9Yv6n/w=
+github.com/leodido/go-urn v1.2.1/go.mod h1:zt4jvISO2HfUBqxjfIshjdMTYS56ZS/qv49ictyFfxY=
+github.com/mattn/go-isatty v0.0.17 h1:BTarxUcIeDqL27Mc+vyvdWYSL28zpIhv3RoTdsLMPng=
+github.com/mattn/go-isatty v0.0.17/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
+github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 h1:ZqeYNhU3OHLH3mGKHDcjJRFFRrJa6eAM5H+CtDdOsPc=
+github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
+github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M=
+github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
+github.com/pelletier/go-toml/v2 v2.0.6 h1:nrzqCb7j9cDFj2coyLNLaZuJTLjWjlaz6nvTvIwycIU=
+github.com/pelletier/go-toml/v2 v2.0.6/go.mod h1:eumQOmlWiOPt5WriQQqoM5y18pDHwha2N+QD+EUNTek=
+github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
+github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
+github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
+github.com/rogpeppe/go-internal v1.8.0 h1:FCbCCtXNOY3UtUuHUYaghJg4y7Fd14rXifAYUAtL9R8=
+github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
+github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk=
+github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
+github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
+github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
+github.com/ugorji/go/codec v1.2.9 h1:rmenucSohSTiyL09Y+l2OCk+FrMxGMzho2+tjr5ticU=
+github.com/ugorji/go/codec v1.2.9/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg=
+github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
+github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
+go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI=
+golang.org/x/arch v0.0.0-20210923205945-b76863e36670 h1:18EFjUmQOcUvxNYSkA6jO9VAiXCnxFY6NyDX0bHDmkU=
+golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
+golang.org/x/crypto v0.5.0 h1:U/0M97KRkSFvyD/3FSmdP5W5swImpNgle/EHFhOsQPE=
+golang.org/x/crypto v0.5.0/go.mod h1:NK/OQwhpMQP3MwtdjgLlYHnH9ebylxKWv3e0fK+mkQU=
+golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
+golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
+golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
+golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
+golang.org/x/lint v0.0.0-20210508222113-6edffad5e616/go.mod h1:3xt1FjdF8hUf6vQPIChWIBhFzV8gjjsPE/fR3IyQdNY=
+golang.org/x/mod v0.1.1-0.20191105210325-c90efee705ee/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg=
+golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
+golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
+golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
+golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
+golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM=
+golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
+golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
+golang.org/x/net v0.8.0 h1:Zrh2ngAOFYneWTAIAPethzeaQLuHwhuBkuV6ZiRnUaQ=
+golang.org/x/net v0.8.0/go.mod h1:QVkue5JL9kW//ek3r6jTKnTFis1tRmNAW2P1shuFdJc=
+golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
+golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
+golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.6.0 h1:MVltZSvRTcU2ljQOhs94SXPftV6DCNnZViHeQps87pQ=
+golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
+golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
+golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
+golang.org/x/text v0.8.0 h1:57P1ETyNKtuIjB4SRd15iJxuhj8Gc416Y78H3qgMh68=
+golang.org/x/text v0.8.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
+golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
+golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
+golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.1.3/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=
+golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
+google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
+google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
+google.golang.org/genproto v0.0.0-20200513103714-09dca8ec2884/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo=
+google.golang.org/genproto v0.0.0-20210624195500-8bfb893ecb84/go.mod h1:SzzZ/N+nwJDaO1kznhnlzqS8ocJICar6hYhVyhi++24=
+google.golang.org/genproto v0.0.0-20230110181048-76db0878b65f h1:BWUVssLB0HVOSY78gIdvk1dTVYtT1y8SBWtPYuTJ/6w=
+google.golang.org/genproto v0.0.0-20230110181048-76db0878b65f/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM=
+google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
+google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg=
+google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY=
+google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
+google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0=
+google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU=
+google.golang.org/grpc v1.38.0/go.mod h1:NREThFqKR1f3iQ6oBuvc5LadQuXVGo9rkm5ZGrQdJfM=
+google.golang.org/grpc v1.40.0/go.mod h1:ogyxbiOoUXAkP+4+xa6PZSE9DZgIHtSpzjDTB9KAK34=
+google.golang.org/grpc v1.54.0 h1:EhTqbhiYeixwWQtAEZAxmV9MGqcjEU2mFx52xCzNyag=
+google.golang.org/grpc v1.54.0/go.mod h1:PUSEXI6iWghWaB6lXM4knEgpJNu2qUcKfDtNci3EC2g=
+google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
+google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
+google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
+google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE=
+google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo=
+google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
+google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
+google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
+google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c=
+google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
+google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
+google.golang.org/protobuf v1.29.0 h1:44S3JjaKmLEE4YIkjzexaP+NzZsudE3Zin5Njn/pYX0=
+google.golang.org/protobuf v1.29.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.2.3/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=
+skywalking.apache.org/repo/goapi v0.0.0-20230314034821-0c5a44bb767a h1:m8DTnaSEOEnPXRWmA6g7isbdqw7WPZP6SnaEHz1Sx7s=
+skywalking.apache.org/repo/goapi v0.0.0-20230314034821-0c5a44bb767a/go.mod h1:LcZMcxDjdJPn5yetydFnxe0l7rmiv8lvHEnzRbsey14=
diff --git a/test/plugins/scenarios/gin/main.go b/test/plugins/scenarios/gin/main.go
new file mode 100644
index 0000000..b44133e
--- /dev/null
+++ b/test/plugins/scenarios/gin/main.go
@@ -0,0 +1,58 @@
+// 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 main
+
+import (
+ "io"
+ "log"
+ "net/http"
+
+ "github.com/gin-gonic/gin"
+
+ _ "github.com/apache/skywalking-go"
+)
+
+func main() {
+ engine := gin.New()
+ engine.Handle("GET", "/consumer", func(context *gin.Context) {
+ resp, err := http.Get("http://localhost:8080/provider")
+ if err != nil {
+ log.Print(err)
+ context.Status(http.StatusInternalServerError)
+ return
+ }
+ defer resp.Body.Close()
+ body, err := io.ReadAll(resp.Body)
+ if err != nil {
+ log.Print(err)
+ context.Status(http.StatusInternalServerError)
+ return
+ }
+ context.String(200, string(body))
+ })
+
+ engine.Handle("GET", "/provider", func(context *gin.Context) {
+ context.String(200, "success")
+ })
+
+ engine.Handle("GET", "health", func(context *gin.Context) {
+ context.Status(http.StatusOK)
+ })
+
+ _ = engine.Run(":8080")
+}
diff --git a/test/plugins/scenarios/gin/plugin.yml b/test/plugins/scenarios/gin/plugin.yml
new file mode 100644
index 0000000..9a836ae
--- /dev/null
+++ b/test/plugins/scenarios/gin/plugin.yml
@@ -0,0 +1,30 @@
+# 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.
+
+entry-service: http://${HTTP_HOST}:${HTTP_PORT}/consumer
+health-checker: http://${HTTP_HOST}:${HTTP_PORT}/health
+start-script: ./bin/startup.sh
+framework: github.com/gin-gonic/gin
+export-port: 8080
+support-version:
+ - go: 1.17
+ framework:
+ - v1.7.0
+ - v1.8.0
+ - v1.8.2
+ - go: 1.18
+ framework:
+ - v1.9.0
\ No newline at end of file
diff --git a/test/plugins/validator/Dockerfile b/test/plugins/validator/Dockerfile
new file mode 100644
index 0000000..7cf9634
--- /dev/null
+++ b/test/plugins/validator/Dockerfile
@@ -0,0 +1,19 @@
+# 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.
+
+FROM ubuntu
+
+RUN apt-get update && apt-get install -y curl
diff --git a/tools/go-agent/cmd/main.go b/tools/go-agent/cmd/main.go
index 2c721af..467e263 100644
--- a/tools/go-agent/cmd/main.go
+++ b/tools/go-agent/cmd/main.go
@@ -32,7 +32,6 @@ import (
var toolFlags = &EnhancementToolFlags{}
func main() {
- writeArgs()
args := os.Args[1:]
var err error
var firstNonOptionIndex int
@@ -82,19 +81,6 @@ func main() {
executeDelegateCommand(args[firstNonOptionIndex:])
}
-func writeArgs() {
- homeDir, err := os.UserHomeDir()
- if err != nil {
- panic(err)
- }
- file, err := os.OpenFile(homeDir+"/Desktop/skywalking-go.txt", os.O_APPEND|os.O_WRONLY|os.O_CREATE, 0o666)
- if err != nil {
- os.Exit(1)
- }
- defer file.Close()
- _, _ = fmt.Fprintf(file, "%v\n", os.Args[1:])
-}
-
func executeDelegateCommand(args []string) {
path := args[0]
args = args[1:]
diff --git a/tools/go-agent/instrument/instrument.go b/tools/go-agent/instrument/instrument.go
index 0c70d60..fe00c3f 100644
--- a/tools/go-agent/instrument/instrument.go
+++ b/tools/go-agent/instrument/instrument.go
@@ -58,6 +58,7 @@ func Execute(opts *api.CompileOptions, args []string) ([]string, error) {
return nil, err
}
defer loggerFile.Close()
+ logrus.Infof("executing instrument with args: %v", args)
return execute0(opts, args)
}
diff --git a/tools/go-agent/instrument/plugins/instrument.go b/tools/go-agent/instrument/plugins/instrument.go
index 5fffebb..c5620ae 100644
--- a/tools/go-agent/instrument/plugins/instrument.go
+++ b/tools/go-agent/instrument/plugins/instrument.go
@@ -95,17 +95,25 @@ func (i *Instrument) FilterAndEdit(path string, cursor *dstutil.Cursor, allFiles
switch n := cursor.Node().(type) {
case *dst.TypeSpec:
for _, filter := range i.structFilters {
- if i.verifyPackageIsMatch(path, filter) && i.validateStructIsMatch(filter.At, n, allFiles) {
- i.enhanceStruct(i.realInst, filter, n, path)
- return true
+ if !(i.verifyPackageIsMatch(path, filter) && i.validateStructIsMatch(filter.At, n, allFiles)) {
+ continue
}
+ i.enhanceStruct(i.realInst, filter, n, path)
+ tools.LogWithStructEnhance(i.compileOpts.Package, n.Name.Name, "", "adding enhanced instance field")
+ return true
}
case *dst.FuncDecl:
for _, filter := range i.methodFilters {
- if i.verifyPackageIsMatch(path, filter) && i.validateMethodInsMatch(filter.At, n, allFiles) {
- i.enhanceMethod(i.realInst, filter, n, path)
- return true
+ if !(i.verifyPackageIsMatch(path, filter) && i.validateMethodInsMatch(filter.At, n, allFiles)) {
+ continue
+ }
+ i.enhanceMethod(i.realInst, filter, n, path)
+ var receiver string
+ if n.Recv != nil && len(n.Recv.List) > 0 {
+ receiver = i.buildReceiverName(n.Recv.List[0].Type)
}
+ tools.LogWithMethodEnhance(i.compileOpts.Package, receiver, n.Name.Name, "adding enhanced method")
+ return true
}
}
return false
@@ -338,21 +346,8 @@ func (i *Instrument) validateMethodInsMatch(matcher *instrument.EnhanceMatcher,
if node.Recv == nil || len(node.Recv.List) == 0 {
return false
}
- var data dst.Expr
- switch t := node.Recv.List[0].Type.(type) {
- case *dst.StarExpr:
- data = t.X
- case *dst.TypeAssertExpr:
- data = t.X
- default:
- return false
- }
-
- if id, ok := data.(*dst.Ident); !ok {
- return false
- } else if id.Name != matcher.Receiver {
- return false
- }
+ var name = i.buildReceiverName(node.Recv.List[0].Type)
+ return name == matcher.Receiver
}
for _, filter := range matcher.MethodFilters {
if !filter(node, allFiles) {
@@ -362,6 +357,24 @@ func (i *Instrument) validateMethodInsMatch(matcher *instrument.EnhanceMatcher,
return true
}
+func (i *Instrument) buildReceiverName(receiver dst.Expr) string {
+ var data dst.Expr
+ switch t := receiver.(type) {
+ case *dst.StarExpr:
+ data = t.X
+ case *dst.TypeAssertExpr:
+ data = t.X
+ default:
+ return ""
+ }
+
+ id, ok := data.(*dst.Ident)
+ if !ok {
+ return ""
+ }
+ return id.Name
+}
+
func (i *Instrument) tryToFindThePluginVersion(opts *api.CompileOptions, ins instrument.Instrument) (string, error) {
for _, arg := range opts.AllArgs {
// find the go file