This is an automated email from the ASF dual-hosted git repository.
liuhan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git
The following commit(s) were added to refs/heads/main by this push:
new bd8ac7a Add Kubernetes process detector support (#16)
bd8ac7a is described below
commit bd8ac7a46e6dbfdc2ea3541835eeb6b80719da13
Author: mrproliu <[email protected]>
AuthorDate: Tue Apr 26 13:36:05 2022 +0800
Add Kubernetes process detector support (#16)
---
.github/workflows/rover.yaml | 9 +-
configs/rover_configs.yaml | 36 ++-
.../configuration/process_discovery/kubernetes.md | 93 ++++++
.../configuration/process_discovery/overview.md | 3 +-
.../configuration/process_discovery/scanner.md | 2 +-
.../examples/cases/kubernetes-process/readme.md | 20 ++
.../cases/kubernetes-process/rover-darmonset.yml | 92 ++++++
docs/en/setup/overview.md | 1 +
docs/menu.yml | 8 +-
go.mod | 28 +-
go.sum | 123 +++++++-
pkg/process/config.go | 5 +-
pkg/process/finders/base/config.go | 51 ++++
pkg/process/finders/base/finder.go | 2 -
pkg/process/finders/base/template.go | 18 +-
pkg/process/finders/base/tool.go | 68 +++++
pkg/process/finders/kubernetes/config.go | 85 ++++++
pkg/process/finders/kubernetes/container.go | 148 ++++++++++
pkg/process/finders/kubernetes/finder.go | 312 +++++++++++++++++++++
pkg/process/finders/kubernetes/process.go | 68 +++++
pkg/process/finders/kubernetes/registry.go | 118 ++++++++
pkg/process/finders/kubernetes/template.go | 175 ++++++++++++
pkg/process/finders/manager.go | 6 +-
pkg/process/finders/register.go | 3 +
pkg/process/finders/scanner/config.go | 4 +
pkg/process/finders/scanner/finder.go | 99 ++-----
pkg/process/finders/scanner/template.go | 2 +-
pkg/process/finders/storage.go | 114 +++++---
pkg/process/module.go | 2 +-
pkg/tools/profiling/objdump.go | 7 +-
scripts/build/docker.mk | 2 -
31 files changed, 1556 insertions(+), 148 deletions(-)
diff --git a/.github/workflows/rover.yaml b/.github/workflows/rover.yaml
index abe1c15..b5794ae 100644
--- a/.github/workflows/rover.yaml
+++ b/.github/workflows/rover.yaml
@@ -66,6 +66,7 @@ jobs:
e2e-test:
name: E2E test
+ if: ${{ false }} # disable for temporary, it would activate after OAP
side finished
needs: [ docker ]
runs-on: ubuntu-latest
timeout-minutes: 60
@@ -113,7 +114,7 @@ jobs:
name: Required
needs:
- build
- - e2e-test
+# - e2e-test
runs-on: ubuntu-latest
timeout-minutes: 10
steps:
@@ -122,6 +123,6 @@ jobs:
if [[ ${{ needs.build.result }} != 'success' ]]; then
exit -1
fi
- if [[ ${{ needs.e2e-test.result }} != 'success' ]]; then
- exit -1
- fi
\ No newline at end of file
+# if [[ ${{ needs.e2e-test.result }} != 'success' ]]; then
+# exit -1
+# fi
\ No newline at end of file
diff --git a/configs/rover_configs.yaml b/configs/rover_configs.yaml
index 931c3d2..f28b906 100644
--- a/configs/rover_configs.yaml
+++ b/configs/rover_configs.yaml
@@ -44,7 +44,7 @@ process_discovery:
# The process detection modes of the scanner. Support "REGEX",
"AGENT_SENSOR"
mode: ${ROVER_PROCESS_DISCOVERY_SCAN_MODE:AGENT_SENSOR}
agent:
- # Supports scanning for how long ago of the active agent
+ # Set the agent refresh period
process_status_refresh_period:
${ROVER_PROCESS_DISCOVERY_AGENT_PROCESS_STATUS_REFRESH_PERIOD:1m}
regex:
# Use regex string to locate the processes
@@ -64,6 +64,40 @@ process_discovery:
# The Process Labels, used to aggregate similar process from service
entity
# Multiple labels split by ","
labels: ${ROVER_PROCESS_DISCOVERY_REGEX_SCANNER_LABELS:}
+ kubernetes:
+ # Is active the kubernetes process detector
+ active: ${ROVER_PROCESS_DISCOVERY_KUBERNETES_ACTIVE:false}
+ # Current node name in kubernetes environment
+ node_name: ${ROVER_PROCESS_DISCOVERY_KUBERNETES_NODE_NAME:}
+ # include namespaces, multiple namespace split by ",", if empty means
including all namespaces
+ namespaces: ${ROVER_PROCESS_DISCOVERY_KUBERNETES_NAMESPACES:}
+ analyzers:
+ - active:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_ACTIVE:true}
+ filters:
+ -
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_HAS_ENVOY:.Pod.HasContainer
"istio-proxy"}
+ -
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_CONTAINER_IS_ENVOY:eq
.Container.Name "istio-proxy"}
+ layer:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_LAYER:MESH_DP}
+ service_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_SERVICE_NAME:{{.Pod.Namespace}}::{{.Pod.LabelValue
"service.istio.io/canonical-name,app.kubernetes.io/name,app" }}}
+ instance_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_INSTANCE_NAME:{{.Pod.Name}}}
+ process_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_PROCESS_NAME:{{.Process.ExeName}}}
+ labels:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_ENVOY_LABELS:mesh-envoy}
+ - active:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_ACTIVE:true}
+ filters:
+ -
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_HAS_ENVOY:.Pod.HasContainer
"istio-proxy"}
+ -
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_CONTAINER_NOT_ENVOY:ne
.Container.Name "istio-proxy"}
+ layer:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_LAYER:MESH}
+ service_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_SERVICE_NAME:{{.Pod.Namespace}}::{{.Pod.LabelValue
"service.istio.io/canonical-name,app.kubernetes.io/name,app" }}}
+ instance_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_INSTANCE_NAME:{{.Pod.Name}}}
+ process_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_PROCESS_NAME:{{.Process.ExeName}}}
+ labels:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_ISTIO_APPLICATION_LABELS:mesh-application}
+ - active:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_K8S_SERVICE_ACTIVE:true}
+ filters:
+ -
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_K8S_SERVICE_HAS_SERVICE:.Pod.HasServiceName}
+ layer:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_K8S_SERVICE_LAYER:K8S_SERVICE}
+ service_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_K8S_SERVICE_NAME:{{.Pod.Namespace}}::{{.Pod.ServiceName}}}
+ instance_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_K8S_SERVICE_INSTANCE_NAME:{{.Pod.Name}}}
+ process_name:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_K8S_SERVICE_PROCESS_NAME:{{.Process.ExeName}}}
+ labels:
${ROVER_PROCESS_DISCOVERY_KUBERNETES_ANALYZER_K8S_SERVICE_LABLES:k8s-service}
profiling:
# Is active the process profiling
diff --git a/docs/en/setup/configuration/process_discovery/kubernetes.md
b/docs/en/setup/configuration/process_discovery/kubernetes.md
new file mode 100644
index 0000000..b70eda4
--- /dev/null
+++ b/docs/en/setup/configuration/process_discovery/kubernetes.md
@@ -0,0 +1,93 @@
+# Kubernetes Process Detector
+
+The Kubernetes process detector could detect any process under the Kubernetes
container.
+If active the kubernetes process detector, the rover must be deployed in the
kubernetes cluster.
+After find the process, it would be collect the metadata of the process when
the report to the backend.
+
+## Configuration
+
+| Name | Default | Environment Key | Description |
+|------|---------|-----------------|-------------|
+| process_discovery.kubernetes.active | false |
ROVER_PROCESS_DISCOVERY_KUBERNETES_ACTIVE | Is active the kubernetes process
discovery. |
+| process_discovery.kubernetes.node_name | |
ROVER_PROCESS_DISCOVERY_KUBERNETES_NODE_NAME | Current deployed node name, it
could be inject by `spec.nodeName`. |
+| process_discovery.kubernetes.namespaces | |
ROVER_PROCESS_DISCOVERY_KUBERNETES_NAMESPACES | Including pod by namespaces, if
empty means including all namespaces. Multiple namespaces split by ",". |
+| process_discovery.kubernetes.analyzers | | | Declare how to build the
process. The istio and k8s resources are active by default. |
+| process_discovery.kubernetes.analyzers.active | | | Set is active analyzer. |
+| process_discovery.kubernetes.analyzers.filters | | | Define which process is
match to current process builder. |
+| process_discovery.kubernetes.analyzers.service_name | | | The Service Name
of the process entity. |
+| process_discovery.kubernetes.analyzers.instance_name | | | The Service
Instance Name of the process entity, by default, the instance name is the host
IP v4 address from "en0" net interface. |
+| process_discovery.kubernetes.analyzers.process_name | | | The Process Name
of the process entity, by default, the process name is the executable name of
the process. |
+| process_discovery.kubernetes.analyzers.labels | | | The Process Labels, used
to aggregate similar process from service entity. Multiple labels split by ",".
|
+
+## Process Analyze
+
+The process analyze declares which process could be profiled and how to build
the process entity.
+The istio and kuberentes resources is active on default.
+
+### Filter
+
+The filter provide expression(go template) mechanism to match process that can
build the entity. Multiple expressions work together to determine whether the
process can create entity.
+Each expression must be return the boolean value. Otherwise, the decision
throws an error.
+
+The context is similar to the entity builder. Use context could help rover
understanding which process could build entity.
+
+#### Process Context
+
+Is same with the [process context in scanner](./scanner.md#process), but don't
need to add the `{{` and `}}` in prefix and suffix.
+
+#### Pod Context
+
+Provide current pod information and judgements.
+
+| Name | Argument | Example | Description |
+|------|--------- |-----------|-------------|
+| Name | None | `eq .Pod.Name "test-pod-name"` | The name of current pod. The
example shows the pod name is equals to `test-pod-name`. |
+| Namespace | None | `eq .Pod.Namespace "test-namesapce"` | The name of
current pod namespace. The example shows the pod namespace name is equals to
`test-namespace`. |
+| Node | None | `eq .Pod.Node "test-node"` | The name of node which deployed.
The example shows the pod node name is equals to `test-node`. |
+| LabelValue | KeyNames | `eq .Pod.LavelValue "a,b" "v"` | The label value of
the label keys, If provide multiple keys, if any key has value, then don't need
to get other values. The examples shows the pod has any one `a` or `b` label
key, and the value matches to `v`. |
+| ServiceName | None | `eq .Pod.ServiceName "test-service"` | The service name
of the pod. The example shows current pods matched service name is
`test-service`. |
+| HasContainer | Container name | `.Pod.HasContainer "istio-proxy"` | The pod
is have the appoint container name. |
+| LabelSelector | selector | `.Pod.LabelSelector` | The pod is matches the
label selector. For more details, please read the [official
documentation](https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors).
|
+| HasServiceName | None | `.Pod.HasServiceName` | The pod has the matched
service. |
+
+#### Container Context
+
+Provide current container(under the pod) information.
+
+| Name | Argument | Example | Description |
+|------|--------- |-----------|-------------|
+| Name | None | `eq .Container.Name "istio-proxy"`| The name of current
container under the pod. The examples shows the container name is equals to
`istio-proxy`. |
+
+### Entity
+The entity including `layer`, `serviceName`, `instanceName`, `processName` and
`labels` properties.
+
+The entity also could use expression to build(`serviceName`, `instanceName`
and `processName`).
+
+#### Rover
+
+Same with the [rover context in the scanner](./scanner.md#rover).
+
+#### Process
+
+Same with the [process context in the scanner](./scanner.md#process).
+
+#### Pod
+
+The information of the current pod.
+
+| Name | Argument | Example | Description |
+|------|--------- |-----------|-------------|
+| Name | None | `{{.Pod.Name}}` | The name of current pod. |
+| Namespace | None | `{{.Pod.Namespace}}` | The name of current pod namespace.
|
+| Node | None | `{{.Pod.Node}}` | The name of node which deployed. |
+| LabelValue | KeyNames | `{{.Pod.LavelValue "a,b"}}` | The label value of the
label keys, If provide multiple keys, if any key has value, then don't need to
get other values. |
+| ServiceName | None | `{{.Pod.ServiceName}}` | The service name of the pod.
If the pod haven't matched service, then return empty string. |
+
+#### Container
+
+The information of the current container under the pod.
+
+| Name | Argument | Example | Description |
+|------|--------- |-----------|-------------|
+| Name | None | `{{.Container.Name}}`| The name of current container under the
pod. |
+| ID | None | `{{.Container.ID}}`| The id of current container under the pod. |
\ No newline at end of file
diff --git a/docs/en/setup/configuration/process_discovery/overview.md
b/docs/en/setup/configuration/process_discovery/overview.md
index 35fd845..07944c4 100644
--- a/docs/en/setup/configuration/process_discovery/overview.md
+++ b/docs/en/setup/configuration/process_discovery/overview.md
@@ -12,4 +12,5 @@ After the process upload is completed, the other modules
could perform more oper
## Process Detector
Process Detector is used to detect the process from the VM with the different
environment:
-1. [Linux Process Scanner](./scanner.md)
\ No newline at end of file
+1. [Linux Process Scanner](./scanner.md)
+2. [Kubernetes Process Detector](./kubernetes.md)
\ No newline at end of file
diff --git a/docs/en/setup/configuration/process_discovery/scanner.md
b/docs/en/setup/configuration/process_discovery/scanner.md
index af2c3e7..0628dbd 100644
--- a/docs/en/setup/configuration/process_discovery/scanner.md
+++ b/docs/en/setup/configuration/process_discovery/scanner.md
@@ -13,7 +13,7 @@ After find the process, it would be collect the metadata of
the process when the
| process_discovery.scanner.period | 3s | ROVER_PROCESS_DISCOVERY_SCAN_PERIOD
| The period to detect the process. |
| process_discovery.scanner.mode | AGENT_SENSOR |
ROVER_PROCESS_DISCOVERY_SCAN_MODE | The process detection modes of the scanner.
Support "REGEX", "AGENT_SENSOR". |
| process_discovery.scanner.agent | | | Active when using the "AGENT_SENSOR"
mode scanner. |
-| process_discovery.scanner.agent.process_status_refresh_period | 1m |
ROVER_PROCESS_DISCOVERY_AGENT_PROCESS_STATUS_REFRESH_PERIOD | Supports scanning
for how long ago of the active agent. |
+| process_discovery.scanner.agent.process_status_refresh_period | 1m |
ROVER_PROCESS_DISCOVERY_AGENT_PROCESS_STATUS_REFRESH_PERIOD | Set the agent
refresh period. |
| process_discovery.scanner.regex | | | Active when using the "REGEX" mode
scanner, it supports using multiple regex to matches difference processes. |
| process_discovery.scanner.regex.match_cmd | |
ROVER_PROCESS_DISCOVERY_REGEX_SCANNER_MATCH_CMD | Use regex string to locate
the process from the command line of the process. |
| process_discovery.scanner.regex.layer | OS_LINUX |
ROVER_PROCESS_DISCOVERY_REGEX_SCANNER_LAYER | The Layer of the process entity |
diff --git a/docs/en/setup/examples/cases/kubernetes-process/readme.md
b/docs/en/setup/examples/cases/kubernetes-process/readme.md
new file mode 100644
index 0000000..2cf276f
--- /dev/null
+++ b/docs/en/setup/examples/cases/kubernetes-process/readme.md
@@ -0,0 +1,20 @@
+# Detect Process by Kubernetes
+
+This documentation helps you to set up the rover in the kubernetes environment
and detect kubernetes process automaticlly.
+
+## Startup Kubernetes
+
+Make sure that you already have a Kubernetes cluster.
+
+If you don't have a running cluster, you can also leverage [KinD (Kubernetes
in Docker)](https://kind.sigs.k8s.io)
+or [minikube](https://minikube.sigs.k8s.io) to create a cluster.
+
+## Deploy Rover
+
+Please following the [rover-darmonset.yml](./rover-darmonset.yml) to deploy
the rover in your kubernetes cluster.
+Update the comment in the file, which including two config:
+1. **Rover docker image**: You could use `make docker` to build an image and
upload to your private registry.
+2. **OAP address**: Update the OAP address.
+
+Then, you could use `kuberctl apply -f rover-darmonset.yml` to deploy the
skywalking-rover into your cluster.
+It would deploy in each node as a DaemonSet.
\ No newline at end of file
diff --git
a/docs/en/setup/examples/cases/kubernetes-process/rover-darmonset.yml
b/docs/en/setup/examples/cases/kubernetes-process/rover-darmonset.yml
new file mode 100644
index 0000000..89bcdc4
--- /dev/null
+++ b/docs/en/setup/examples/cases/kubernetes-process/rover-darmonset.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.
+#
+
+apiVersion: v1
+kind: ServiceAccount
+metadata:
+ name: skywalking-rover
+---
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRoleBinding
+metadata:
+ name: skywalking-rover
+roleRef:
+ apiGroup: rbac.authorization.k8s.io
+ kind: ClusterRole
+ name: skywalking-rover
+subjects:
+ - kind: ServiceAccount
+ name: skywalking-rover
+ namespace: default
+---
+kind: ClusterRole
+apiVersion: rbac.authorization.k8s.io/v1
+metadata:
+ name: skywalking-rover
+rules:
+ - apiGroups: [""]
+ resources: ["pods", "nodes", "services"]
+ verbs: ["get", "watch", "list"]
+---
+
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+ name: skywalking-rover
+spec:
+ selector:
+ matchLabels:
+ name: skywalking-rover
+ template:
+ metadata:
+ labels:
+ name: skywalking-rover
+ spec:
+ serviceAccountName: skywalking-rover
+ serviceAccount: skywalking-rover
+ containers:
+ - name: skywalking-rover
+ # SkyWalking Rover image path
+ image: apache/skywalking-rover:latest
+ securityContext:
+ capabilities:
+ add:
+ - SYS_PTRACE
+ - SYS_ADMIN
+ privileged: true
+ volumeMounts:
+ - name: host
+ mountPath: /host
+ readOnly: true
+ env:
+ - name: ROVER_PROCESS_DISCOVERY_KUBERNETES_ACTIVE
+ value: "true"
+ - name: ROVER_PROCESS_DISCOVERY_KUBERNETES_NODE_NAME
+ valueFrom:
+ fieldRef:
+ fieldPath: spec.nodeName
+ - name: ROVER_BACKEND_ADDR
+ # backend OAP address
+ value: oap:11800
+ hostPID: true
+ hostNetwork: true
+ dnsPolicy: ClusterFirstWithHostNet
+ volumes:
+ - name: host
+ hostPath:
+ path: /
+ type: Directory
\ No newline at end of file
diff --git a/docs/en/setup/overview.md b/docs/en/setup/overview.md
index a7efcf4..f94579d 100644
--- a/docs/en/setup/overview.md
+++ b/docs/en/setup/overview.md
@@ -27,6 +27,7 @@ You can quickly build your Rover according to the following
examples:
1. [Profiling a Golang/C service on
Linux](examples/cases/profiling-process/readme.md)
1. [Detect Process by Agent Sensor](examples/cases/agent-sensor/readme.md)
+1. [Detect Process in Kubernetes
Environemnt](examples/cases/kubernetes-process/readme.md)
## Configuration
diff --git a/docs/menu.yml b/docs/menu.yml
index 42c9eae..640a6f4 100644
--- a/docs/menu.yml
+++ b/docs/menu.yml
@@ -41,8 +41,10 @@ catalog:
catalog:
- name: Overview
path: /en/setup/configuration/process_discovery/overview
- - name: Linux Process Detector
- path: /en/setup/configuration/process_discovery/linux
+ - name: Linux Process Scanner
+ path: /en/setup/configuration/process_discovery/scanner
+ - name: Kubernetes Process Detector
+ path: /en/setup/configuration/process_discovery/kubernetes
- name: Profiling Module
path: /en/setup/configuration/profiling
- name: Examples
@@ -57,6 +59,8 @@ catalog:
path: /en/setup/examples/cases/profiling-process/readme
- name: Detect Process by Agent Sensor
path: /en/setup/examples/cases/agent-sensor/readme
+ - name: Detect Process in Kubernetes Environemnt
+ path: /en/setup/examples/cases/kubernetes-process/readme
- name: Guides
catalog:
- name: Contribution
diff --git a/go.mod b/go.mod
index 8d39ab1..be11424 100644
--- a/go.mod
+++ b/go.mod
@@ -13,18 +13,30 @@ require (
github.com/spf13/viper v1.10.1
golang.org/x/sys v0.0.0-20211210111614-af8b64212486
google.golang.org/grpc v1.44.0
- skywalking.apache.org/repo/goapi v0.0.0-20220407130404-69485e13dbb3
+ k8s.io/api v0.23.5
+ k8s.io/apimachinery v0.23.5
+ k8s.io/client-go v0.23.5
+ skywalking.apache.org/repo/goapi v0.0.0-20220421134447-34b3d2780c61
)
require (
+ github.com/davecgh/go-spew v1.1.1 // indirect
github.com/fsnotify/fsnotify v1.5.1 // indirect
+ github.com/go-logr/logr v1.2.0 // indirect
github.com/go-ole/go-ole v1.2.6 // indirect
+ github.com/gogo/protobuf v1.3.2 // indirect
github.com/golang/protobuf v1.5.2 // indirect
+ github.com/google/go-cmp v0.5.6 // indirect
+ github.com/google/gofuzz v1.1.0 // indirect
+ github.com/googleapis/gnostic v0.5.5 // indirect
github.com/hashicorp/errwrap v1.0.0 // indirect
github.com/hashicorp/hcl v1.0.0 // indirect
github.com/inconshreveable/mousetrap v1.0.0 // indirect
+ github.com/json-iterator/go v1.1.12 // indirect
github.com/magiconair/properties v1.8.5 // indirect
github.com/mitchellh/mapstructure v1.4.3 // indirect
+ github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd //
indirect
+ github.com/modern-go/reflect2 v1.0.2 // indirect
github.com/pelletier/go-toml v1.9.4 // indirect
github.com/spf13/afero v1.6.0 // indirect
github.com/spf13/cast v1.4.1 // indirect
@@ -34,10 +46,22 @@ require (
github.com/tklauser/go-sysconf v0.3.9 // indirect
github.com/tklauser/numcpus v0.3.0 // indirect
github.com/yusufpapurcu/wmi v1.2.2 // indirect
- golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f // indirect
+ golang.org/x/net v0.0.0-20211209124913-491a49abca63 // indirect
+ golang.org/x/oauth2 v0.0.0-20211104180415-d3ed0bb246c8 // indirect
+ golang.org/x/term v0.0.0-20210615171337-6886f2dfbf5b // indirect
golang.org/x/text v0.3.7 // indirect
+ golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac // indirect
+ google.golang.org/appengine v1.6.7 // indirect
google.golang.org/genproto v0.0.0-20211208223120-3a66f561d7aa //
indirect
google.golang.org/protobuf v1.28.0 // indirect
+ gopkg.in/inf.v0 v0.9.1 // indirect
gopkg.in/ini.v1 v1.66.2 // indirect
gopkg.in/yaml.v2 v2.4.0 // indirect
+ gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect
+ k8s.io/klog/v2 v2.30.0 // indirect
+ k8s.io/kube-openapi v0.0.0-20211115234752-e816edb12b65 // indirect
+ k8s.io/utils v0.0.0-20211116205334-6203023598ed // indirect
+ sigs.k8s.io/json v0.0.0-20211020170558-c049b76a60c6 // indirect
+ sigs.k8s.io/structured-merge-diff/v4 v4.2.1 // indirect
+ sigs.k8s.io/yaml v1.2.0 // indirect
)
diff --git a/go.sum b/go.sum
index 3447fb4..b81cdcf 100644
--- a/go.sum
+++ b/go.sum
@@ -46,10 +46,20 @@ cloud.google.com/go/storage v1.6.0/go.mod
h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohl
cloud.google.com/go/storage v1.8.0/go.mod
h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs=
cloud.google.com/go/storage v1.10.0/go.mod
h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0=
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod
h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
+github.com/Azure/go-autorest v14.2.0+incompatible/go.mod
h1:r+4oMnoxhatjLLJ6zxSWATqVooLgysK6ZNox3g/xq24=
+github.com/Azure/go-autorest/autorest v0.11.18/go.mod
h1:dSiJPy22c3u0OtOKDNttNgqpNFY/GeWa7GH/Pz56QRA=
+github.com/Azure/go-autorest/autorest/adal v0.9.13/go.mod
h1:W/MM4U6nLxnIskrw4UwWzlHfGjwUS50aOsc/I3yuU8M=
+github.com/Azure/go-autorest/autorest/date v0.3.0/go.mod
h1:BI0uouVdmngYNUzGWeSYnokU+TrmwEsOqdt8Y6sso74=
+github.com/Azure/go-autorest/autorest/mocks v0.4.1/go.mod
h1:LTp+uSrOhSkaKrUy935gNZuuIPPVsHlr9DSOxSayd+k=
+github.com/Azure/go-autorest/logger v0.2.1/go.mod
h1:T9E3cAhj2VqvPOtCYAvby9aBXkZmbF5NWuPV8+WeEW8=
+github.com/Azure/go-autorest/tracing v0.6.0/go.mod
h1:+vhtPC754Xsa23ID7GlGsrdKBpUA79WCAKPPZVC2DeU=
github.com/BurntSushi/toml v0.3.1/go.mod
h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod
h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
github.com/DataDog/datadog-go v3.2.0+incompatible/go.mod
h1:LButxg5PwREeZtORoXG3tL4fMGNddJ+vMq1mwgfaqoQ=
+github.com/NYTimes/gziphandler v0.0.0-20170623195520-56545f4a5d46/go.mod
h1:3wb06e3pkSAbeQ52E9H9iFoQsEEwGN64994WTCIhntQ=
github.com/OneOfOne/xxhash v1.2.2/go.mod
h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
+github.com/PuerkitoBio/purell v1.1.1/go.mod
h1:c11w/QuzBsJSee3cPx9rAFu61PvFxuPbtSwDGJws/X0=
+github.com/PuerkitoBio/urlesc v0.0.0-20170810143723-de5bf2ad4578/go.mod
h1:uGdkoq3SwY9Y+13GIhn11/XLaGBb4BfwItxLd5jeuXE=
github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod
h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751/go.mod
h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod
h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
@@ -60,6 +70,7 @@ github.com/armon/go-metrics
v0.0.0-20180917152333-f0300d1749da/go.mod h1:Q73ZrmV
github.com/armon/go-metrics v0.3.10/go.mod
h1:4O98XIr/9W0sxpJ8UaYkvjk10Iff7SnFrb4QAOwNTFc=
github.com/armon/go-radix v0.0.0-20180808171621-7fddfc383310/go.mod
h1:ufUuZ+zHj4x4TnLV4JWEpy2hxWSpsRywHrMgIH9cCH8=
github.com/armon/go-radix v1.0.0/go.mod
h1:ufUuZ+zHj4x4TnLV4JWEpy2hxWSpsRywHrMgIH9cCH8=
+github.com/asaskevich/govalidator v0.0.0-20190424111038-f61b66f89f4a/go.mod
h1:lB+ZfQJz7igIIfQNfa7Ml4HSf2uFQQRzpGGRXenZAgY=
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod
h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
github.com/beorn7/perks v1.0.0/go.mod
h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8=
github.com/beorn7/perks v1.0.1/go.mod
h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
@@ -94,6 +105,9 @@ github.com/creack/pty v1.1.9/go.mod
h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ3
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/docopt/docopt-go v0.0.0-20180111231733-ee0de3bc6815/go.mod
h1:WwZ+bS3ebgob9U8Nd0kOddGdZWjyMGR8Wziv+TBNwSE=
+github.com/elazarl/goproxy v0.0.0-20180725130230-947c36da3153/go.mod
h1:/Zj4wYkgs4iZTTu3o/KG3Itv/qCCa8VVMlb3i9OVuzc=
+github.com/emicklei/go-restful v0.0.0-20170410110728-ff4f55a20633/go.mod
h1:otzb+WCGbkyDHkqmQmT5YD2WR4BBwUdeQoFo8l/7tVs=
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=
@@ -105,13 +119,19 @@ github.com/envoyproxy/go-control-plane
v0.9.10-0.20210907150352-cf90f659a021/go.
github.com/envoyproxy/go-control-plane v0.10.1/go.mod
h1:AY7fTTXNdv/aJ2O5jwpxAPOWUZ7hQAEvzN5Pf27BkQQ=
github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod
h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
github.com/envoyproxy/protoc-gen-validate v0.6.2/go.mod
h1:2t7qjJNvHPx8IjnBOzl9E9/baC+qXE/TeeyBRzgJDws=
+github.com/evanphx/json-patch v4.12.0+incompatible/go.mod
h1:50XU6AFN0ol/bzJsmQLiYLvXMP4fmwYFNcr97nuDLSk=
github.com/fatih/color v1.7.0/go.mod
h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4=
github.com/fatih/color v1.9.0/go.mod
h1:eQcE1qtQxscV5RaZvpXrrb8Drkc3/DdQ+uUYCNjL+zU=
github.com/fatih/color v1.13.0/go.mod
h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk=
+github.com/form3tech-oss/jwt-go v3.2.2+incompatible/go.mod
h1:pbq4aXjuKjdthFRnoDwaVPLA+WlJuPGy+QneDUgJi2k=
+github.com/form3tech-oss/jwt-go v3.2.3+incompatible/go.mod
h1:pbq4aXjuKjdthFRnoDwaVPLA+WlJuPGy+QneDUgJi2k=
github.com/frankban/quicktest v1.14.0
h1:+cqqvzZV87b4adx/5ayVOaYZ2CrvM4ejQvUdBzPPUss=
github.com/frankban/quicktest v1.14.0/go.mod
h1:NeW+ay9A/U67EYXNFA1nPE8e/tnQv/09mUdL/ijj8og=
+github.com/fsnotify/fsnotify v1.4.7/go.mod
h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
+github.com/fsnotify/fsnotify v1.4.9/go.mod
h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
github.com/fsnotify/fsnotify v1.5.1
h1:mZcQUHVQUQWoPXXtuf9yuEXKudkV2sx1E06UadKWpgI=
github.com/fsnotify/fsnotify v1.5.1/go.mod
h1:T3375wBYaZdLLcVNkcVbzGHY7f1l/uK5T5Ai1i3InKU=
+github.com/getkin/kin-openapi v0.76.0/go.mod
h1:660oXbgy5JFMKreazJaQTw7o+X00qeSyhcnluiMv+Xg=
github.com/ghodss/yaml v1.0.0/go.mod
h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
github.com/go-gl/glfw v0.0.0-20190409004039-e6da0acd62b1/go.mod
h1:vR7hzQXu2zJy9AVAgeJqvqgH9Q5CA+iKCZ2gyEVpxRU=
github.com/go-gl/glfw/v3.3/glfw v0.0.0-20191125211704-12ad95a8df72/go.mod
h1:tQ2UAYgL5IevRw8kRxooKSPJfGvJ9fJQFa0TUsXzTg8=
@@ -120,11 +140,20 @@ github.com/go-kit/kit v0.8.0/go.mod
h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2
github.com/go-kit/kit v0.9.0/go.mod
h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
github.com/go-logfmt/logfmt v0.3.0/go.mod
h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
github.com/go-logfmt/logfmt v0.4.0/go.mod
h1:3RMwSq7FuexP4Kalkev3ejPJsZTpXXBr9+V4qmtdjCk=
+github.com/go-logr/logr v0.1.0/go.mod
h1:ixOQHD9gLJUVQQ2ZOR7zLEifBX6tGkNJF4QyIY7sIas=
+github.com/go-logr/logr v0.2.0/go.mod
h1:z6/tIYblkpsD+a4lm/fGIIU9mZ+XfAiaFtq7xTgseGU=
+github.com/go-logr/logr v1.2.0 h1:QK40JKJyMdUDz+h+xvCsru/bJhvG0UxvePV0ufL/AcE=
+github.com/go-logr/logr v1.2.0/go.mod
h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
github.com/go-ole/go-ole v1.2.6 h1:/Fpf6oFPoeFik9ty7siob0G6Ke8QvQEuVcuChpwXzpY=
github.com/go-ole/go-ole v1.2.6/go.mod
h1:pprOEPIfldk/42T2oK7lQ4v4JSDwmV0As9GaiUsvbm0=
+github.com/go-openapi/jsonpointer v0.19.3/go.mod
h1:Pl9vOtqEWErmShwVjC8pYs9cog34VGT37dQOVbmoatg=
+github.com/go-openapi/jsonpointer v0.19.5/go.mod
h1:Pl9vOtqEWErmShwVjC8pYs9cog34VGT37dQOVbmoatg=
+github.com/go-openapi/jsonreference v0.19.3/go.mod
h1:rjx6GuL8TTa9VaixXglHmQmIL98+wF9xc8zWvFonSJ8=
+github.com/go-openapi/swag v0.19.5/go.mod
h1:POnQmlKehdgb5mhVOsnJFsivZCEZ/vjK9gh66Z9tfKk=
github.com/go-stack/stack v1.8.0/go.mod
h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
github.com/godbus/dbus/v5 v5.0.4/go.mod
h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
github.com/gogo/protobuf v1.1.1/go.mod
h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
+github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
github.com/gogo/protobuf v1.3.2/go.mod
h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod
h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
github.com/golang/groupcache v0.0.0-20190702054246-869f871628b6/go.mod
h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
@@ -161,6 +190,7 @@ github.com/golang/protobuf v1.5.2/go.mod
h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiu
github.com/golang/snappy v0.0.3/go.mod
h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod
h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
github.com/google/btree v1.0.0/go.mod
h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
+github.com/google/btree v1.0.1/go.mod
h1:xXMiIv4Fb/0kKde4SpL7qlzvu5cMJDRkFDxJfI9uaxA=
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=
@@ -175,6 +205,8 @@ github.com/google/go-cmp v0.5.5/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ=
github.com/google/go-cmp v0.5.6/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/gofuzz v1.0.0/go.mod
h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
+github.com/google/gofuzz v1.1.0 h1:Hsa8mG0dQ46ij8Sl2AYJDUv1oA9/d6Vk+3LG99Oe02g=
+github.com/google/gofuzz v1.1.0/go.mod
h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
github.com/google/martian v2.1.0+incompatible/go.mod
h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs=
github.com/google/martian/v3 v3.0.0/go.mod
h1:y5Zk1BBys9G+gd6Jrk0W3cC1+ELVxBWuIGO+w/tUAp0=
github.com/google/martian/v3 v3.1.0/go.mod
h1:y5Zk1BBys9G+gd6Jrk0W3cC1+ELVxBWuIGO+w/tUAp0=
@@ -201,6 +233,12 @@ github.com/googleapis/gax-go/v2 v2.0.4/go.mod
h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+
github.com/googleapis/gax-go/v2 v2.0.5/go.mod
h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk=
github.com/googleapis/gax-go/v2 v2.1.0/go.mod
h1:Q3nei7sK6ybPYH7twZdmQpAd1MKb7pfu6SK+H1/DsU0=
github.com/googleapis/gax-go/v2 v2.1.1/go.mod
h1:hddJymUZASv3XPyGkUpKj8pPO47Rmb0eJc8R6ouapiM=
+github.com/googleapis/gnostic v0.5.1/go.mod
h1:6U4PtQXGIEt/Z3h5MAT7FNofLnw9vXk2cUuW7uA/OeU=
+github.com/googleapis/gnostic v0.5.5
h1:9fHAtK0uDfpveeqqo1hkEZJcFvYXAiCN3UutL8F9xHw=
+github.com/googleapis/gnostic v0.5.5/go.mod
h1:7+EbHbldMins07ALC74bsA81Ovc97DwqyJO1AENw9kA=
+github.com/gorilla/mux v1.8.0/go.mod
h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So=
+github.com/gorilla/websocket v1.4.2/go.mod
h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
+github.com/gregjones/httpcache v0.0.0-20180305231024-9cad4c3443a7/go.mod
h1:FecbI9+v66THATjSRHfNgh1IVFe/9kFxbXtjV0ctIMA=
github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod
h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw=
github.com/hashicorp/consul/api v1.11.0/go.mod
h1:XjsvQN+RJGWI2TWy1/kqaE16HrR2J/FWgkYjdZQsX9M=
github.com/hashicorp/consul/api v1.12.0/go.mod
h1:6pVBMo0ebnYdt2S3H87XhekM/HHrUoTD2XXb/VrZVy0=
@@ -237,15 +275,18 @@ github.com/hashicorp/memberlist v0.2.2/go.mod
h1:MS2lj3INKhZjWNqd3N0m3J+Jxf3DAOn
github.com/hashicorp/memberlist v0.3.0/go.mod
h1:MS2lj3INKhZjWNqd3N0m3J+Jxf3DAOnAH9VT3Sh9MUE=
github.com/hashicorp/serf v0.9.5/go.mod
h1:UWDWwZeL5cuWDJdl0C6wrvrUwEqtQ4ZKBKKENpqIUyk=
github.com/hashicorp/serf v0.9.6/go.mod
h1:TXZNMjZQijwlDvp+r0b63xZ45H7JmCmgg4gpTwn9UV4=
+github.com/hpcloud/tail v1.0.0/go.mod
h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
github.com/iancoleman/strcase v0.2.0/go.mod
h1:iwCmte+B7n89clKwxIoIXy/HfoL7AsD47ZCWhYzw7ho=
github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6/go.mod
h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639
h1:mV02weKRL81bEnm8A0HT1/CAelMQDBuQIfLw8n+d6xI=
github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod
h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
+github.com/imdario/mergo v0.3.5/go.mod
h1:2EnlNZ0deacrJVfApfmtdGgDfMuh/nq6Ok1EcJh5FfA=
github.com/inconshreveable/mousetrap v1.0.0
h1:Z8tu5sraLXCXIcARxBp/8cbvlwVa7Z1NHg9XEKhtSvM=
github.com/inconshreveable/mousetrap v1.0.0/go.mod
h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
github.com/json-iterator/go v1.1.6/go.mod
h1:+SdeFBvtyEkXs7REEP0seUULqWtbJapLOCVDaaPEHmU=
github.com/json-iterator/go v1.1.9/go.mod
h1:KdQUCv79m/52Kvf8AW2vK1V8akMuk1QjK/uOdHXbAo4=
github.com/json-iterator/go v1.1.11/go.mod
h1:KdQUCv79m/52Kvf8AW2vK1V8akMuk1QjK/uOdHXbAo4=
+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/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod
h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
github.com/jstemmer/go-junit-report v0.9.1/go.mod
h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk=
@@ -266,6 +307,8 @@ github.com/kr/text v0.2.0/go.mod
h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
github.com/lyft/protoc-gen-star v0.5.3/go.mod
h1:V0xaHgaf5oCCqmcxYcWiDfTiKsZsRc87/1qhoTACD8w=
github.com/magiconair/properties v1.8.5
h1:b6kJs+EmPFMYGkow9GiUyCyOvIwYetYJ3fSaWak/Gls=
github.com/magiconair/properties v1.8.5/go.mod
h1:y3VJvCyxH9uVvJTWEGAELF3aiYNyPKd5NZ3oSwXrF60=
+github.com/mailru/easyjson v0.0.0-20190614124828-94de47d64c63/go.mod
h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc=
+github.com/mailru/easyjson v0.0.0-20190626092158-b2ccc519800e/go.mod
h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc=
github.com/mattn/go-colorable v0.0.9/go.mod
h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU=
github.com/mattn/go-colorable v0.1.4/go.mod
h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE=
github.com/mattn/go-colorable v0.1.6/go.mod
h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
@@ -288,18 +331,38 @@ github.com/mitchellh/mapstructure
v0.0.0-20160808181253-ca63d7c062ee/go.mod h1:F
github.com/mitchellh/mapstructure v1.1.2/go.mod
h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
github.com/mitchellh/mapstructure v1.4.3
h1:OVowDSCllw/YjdLkam3/sm7wEtOy59d8ndGgCcyj8cs=
github.com/mitchellh/mapstructure v1.4.3/go.mod
h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
+github.com/moby/spdystream v0.2.0/go.mod
h1:f7i0iNDQJ059oMTcWxx8MA/zKFIuD/lY+0GqbN2Wy8c=
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod
h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
+github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd
h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod
h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742/go.mod
h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
github.com/modern-go/reflect2 v1.0.1/go.mod
h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
+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/munnerz/goautoneg v0.0.0-20120707110453-a547fc61f48d/go.mod
h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod
h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
+github.com/mxk/go-flowrate v0.0.0-20140419014527-cca7078d478f/go.mod
h1:ZdcZmHo+o7JKHSa8/e818NopupXU1YMK5fe1lsApnBw=
+github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e
h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs=
+github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod
h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno=
+github.com/nxadm/tail v1.4.4 h1:DQuhQpB1tVlglWS2hLQ5OV6B5r8aGxSrPc5Qo6uTN78=
+github.com/nxadm/tail v1.4.4/go.mod
h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
+github.com/onsi/ginkgo v0.0.0-20170829012221-11459a886d9c/go.mod
h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
+github.com/onsi/ginkgo v1.6.0/go.mod
h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
+github.com/onsi/ginkgo v1.12.1/go.mod
h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk=
+github.com/onsi/ginkgo v1.14.0 h1:2mOpI4JVVPBN+WQRa0WKH2eXR+Ey+uK4n7Zj0aYpIQA=
+github.com/onsi/ginkgo v1.14.0/go.mod
h1:iSB4RoI2tjJc9BBv4NKIKWKya62Rps+oPG/Lv9klQyY=
+github.com/onsi/gomega v0.0.0-20170829124025-dcabb60a477c/go.mod
h1:C1qb7wdrVGGVU+Z6iS04AVkA3Q65CEZX59MT0QO5uiA=
+github.com/onsi/gomega v1.7.1/go.mod
h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY=
+github.com/onsi/gomega v1.10.1 h1:o0+MgICZLuZ7xjH7Vx6zS/zcu93/BEp1VwkIW1mEXCE=
+github.com/onsi/gomega v1.10.1/go.mod
h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo=
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod
h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
github.com/pascaldekloe/goe v0.1.0/go.mod
h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
github.com/pelletier/go-toml v1.9.4
h1:tjENF6MfZAg8e4ZmZTeWaWiT2vXtsoO6+iuOjFhECwM=
github.com/pelletier/go-toml v1.9.4/go.mod
h1:u1nR/EPcESfeI/szUZKdtJ0xRNbUoANCkoOuaOx1Y+c=
+github.com/peterbourgon/diskv v2.0.1+incompatible/go.mod
h1:uqqh8zWWbv1HBMNONnaR/tNboyR3/BZd58JJSHlUSCU=
github.com/pkg/errors v0.8.0/go.mod
h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
github.com/pkg/errors v0.8.1/go.mod
h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/pkg/errors v0.9.1/go.mod
h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
github.com/pkg/sftp v1.10.1/go.mod
h1:lYOWFsE0bwd1+KfKJaKeuokY15vzFx25BLbzYYoAxZI=
github.com/pmezard/go-difflib v1.0.0
h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod
h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
@@ -333,6 +396,7 @@ github.com/sirupsen/logrus v1.4.2/go.mod
h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6Mwd
github.com/sirupsen/logrus v1.8.1
h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE=
github.com/sirupsen/logrus v1.8.1/go.mod
h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0=
github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod
h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
+github.com/spf13/afero v1.2.2/go.mod
h1:9ZxEEn6pIJ8Rxe320qSDBk6AsU0r9pR7Q4OcevTdifk=
github.com/spf13/afero v1.3.3/go.mod
h1:5KUK8ByomD5Ti5Artl0RtHeI5pTF7MIDuXL3yY520V4=
github.com/spf13/afero v1.6.0 h1:xoax2sJ2DT8S8xA2paPFjDCScCNeWsg75VG0DLRreiY=
github.com/spf13/afero v1.6.0/go.mod
h1:Ai8FlHk4v/PARR026UzYexafAt9roJ7LcLMAmO6Z93I=
@@ -347,6 +411,7 @@ github.com/spf13/pflag v1.0.5/go.mod
h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An
github.com/spf13/viper v1.10.0/go.mod
h1:SoyBPwAtKDzypXNDFKN5kzH7ppppbGZtls1UpIy5AsM=
github.com/spf13/viper v1.10.1 h1:nuJZuYpG7gTj/XqiUwg8bA0cp1+M2mC3J4g5luUYBKk=
github.com/spf13/viper v1.10.1/go.mod
h1:IGlFPqhNAPKRxohIzWpI5QEy4kuI7tcl5WvR+8qy1rU=
+github.com/stoewer/go-strcase v1.2.0/go.mod
h1:IBiWB2sKIp3wVVQ3Y035++gc+knqhUQag1KpM8ahLw8=
github.com/stretchr/objx v0.1.0/go.mod
h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/objx v0.1.1/go.mod
h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/testify v1.2.2/go.mod
h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
@@ -393,6 +458,7 @@ golang.org/x/crypto
v0.0.0-20190820162420-60c769a6c586/go.mod h1:yigFU9vqHzYiE8U
golang.org/x/crypto v0.0.0-20190923035154-9ee001bba392/go.mod
h1:/lpIB1dKB+9EgE3H3cr1v9wB50oz8l4C4h62xy7jSTY=
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-20201002170205-7f63de1d35b0/go.mod
h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
golang.org/x/crypto v0.0.0-20210817164053-32db794688a5/go.mod
h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod
h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
golang.org/x/exp v0.0.0-20190306152737-a1d7652674e8/go.mod
h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
@@ -432,6 +498,7 @@ golang.org/x/mod v0.4.2/go.mod
h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
golang.org/x/mod v0.5.0/go.mod h1:5OXOZSfqPIIbmVBIIKWRFfZjPR0E5r58TLhUjH0a2Ro=
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-20180906233101-161cd47e91fd/go.mod
h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181023162649-9b4f9f5ad519/go.mod
h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod
h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod
h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
@@ -445,6 +512,7 @@ golang.org/x/net v0.0.0-20190613194153-d28f0bde5980/go.mod
h1:z5CRVTTTmAJ677TzLL
golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20190628185345-da137c7871d7/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20190724013045-ca1201d0de80/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20190827160401-ba9fcec4b297/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20190923162816-aa69164e4478/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20191209160850-c0dbc17a3553/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
@@ -456,6 +524,7 @@ golang.org/x/net v0.0.0-20200324143707-d3edc9973b7e/go.mod
h1:qpuaurCH72eLCgpAm/
golang.org/x/net v0.0.0-20200501053045-e0ff5e5a1de5/go.mod
h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
golang.org/x/net v0.0.0-20200506145744-7e3656a0809f/go.mod
h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
golang.org/x/net v0.0.0-20200513185701-a91f0712d120/go.mod
h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200520004742-59133d7f0dd7/go.mod
h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
golang.org/x/net v0.0.0-20200520182314-0ba52f642ac2/go.mod
h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
golang.org/x/net v0.0.0-20200625001655-4c5254603344/go.mod
h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
golang.org/x/net v0.0.0-20200707034311-ab3426394381/go.mod
h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
@@ -471,8 +540,9 @@ golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod
h1:p54w0d4576C0XHj96b
golang.org/x/net v0.0.0-20210410081132-afb366fc7cd1/go.mod
h1:9tjilg8BloeKEkVJvy7fQ90B1CfIiPueXVOjqfkSzI8=
golang.org/x/net v0.0.0-20210503060351-7fd8e65b6420/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20210813160813-60bc85c4be6d/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
-golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f
h1:OfiFi4JbukWwe3lzw+xunroH1mnC1e2Gy5cxNJApiSY=
golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
+golang.org/x/net v0.0.0-20211209124913-491a49abca63
h1:iocB37TsdFuN6IBRZ+ry36wrkoV51/tl5vOWqkcPGvY=
+golang.org/x/net v0.0.0-20211209124913-491a49abca63/go.mod
h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod
h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod
h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod
h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
@@ -489,6 +559,7 @@ golang.org/x/oauth2
v0.0.0-20210628180205-a41e5a781914/go.mod h1:KelEdhl1UZF7XfJ
golang.org/x/oauth2 v0.0.0-20210805134026-6f1e6394065a/go.mod
h1:KelEdhl1UZF7XfJ4dDtk6s++YSgaE7mD/BuKKDLBl4A=
golang.org/x/oauth2 v0.0.0-20210819190943-2bc19b11175f/go.mod
h1:KelEdhl1UZF7XfJ4dDtk6s++YSgaE7mD/BuKKDLBl4A=
golang.org/x/oauth2 v0.0.0-20211005180243-6b3c2da341f1/go.mod
h1:KelEdhl1UZF7XfJ4dDtk6s++YSgaE7mD/BuKKDLBl4A=
+golang.org/x/oauth2 v0.0.0-20211104180415-d3ed0bb246c8
h1:RerP+noqYHUQ8CMRcPlC2nvTa4dcBIjegkuWdcUDuqg=
golang.org/x/oauth2 v0.0.0-20211104180415-d3ed0bb246c8/go.mod
h1:KelEdhl1UZF7XfJ4dDtk6s++YSgaE7mD/BuKKDLBl4A=
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=
@@ -504,6 +575,7 @@ golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod
h1:RxMgew5VJxzue5/jJ
golang.org/x/sys v0.0.0-20180823144017-11551d06cbcc/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181026203630-95b1ffbd15a5/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
@@ -516,12 +588,15 @@ golang.org/x/sys
v0.0.0-20190507160741-ecd444e8653b/go.mod h1:h1NjWce9XRLGQEsW7w
golang.org/x/sys v0.0.0-20190606165138-5da285871e9c/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190624142023-c5567b49c5d0/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190726091711-fc99dfbffb4e/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190916202348-b4ddaad3f8a3/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190922100055-0a153f010e69/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190924154521-2837fb4f24fe/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191001151750-bb3f8db39f24/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191008105621-543471e840be/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191204072324-ce4227a45e2e/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20191228213918-04cbcbbfeed8/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200113162924-86b910548bc1/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -537,6 +612,7 @@ golang.org/x/sys v0.0.0-20200331124033-c3d80250170d/go.mod
h1:h1NjWce9XRLGQEsW7w
golang.org/x/sys v0.0.0-20200501052902-10377860bb8e/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200511232937-7e40ca221e25/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200515095857-1151b9dac4a9/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200519105757-fe76b779f299/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200523222454-059865788121/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200803210538-64077c9b5642/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20200905004654-be1d3432aa8f/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -563,6 +639,7 @@ golang.org/x/sys v0.0.0-20210806184541-e5e7981a1069/go.mod
h1:oPkhp1MJrh7nUepCBc
golang.org/x/sys v0.0.0-20210816074244-15123e1e1f71/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20210816183151-1e6c022a8912/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20210823070655-63515b42dcdf/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20210831042530-f4d43177bf5e/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20210906170528-6f6e22806c34/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20210908233432-aa78b53d3365/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20210927094055-39ccf1dd6fa6/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
@@ -573,6 +650,8 @@ golang.org/x/sys v0.0.0-20211205182925-97ca703d548d/go.mod
h1:oPkhp1MJrh7nUepCBc
golang.org/x/sys v0.0.0-20211210111614-af8b64212486
h1:5hpz5aRr+W1erYCL5JRhSUBJRph7l9XkNveoExlrKYk=
golang.org/x/sys v0.0.0-20211210111614-af8b64212486/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-20210615171337-6886f2dfbf5b
h1:9zKuko04nR4gjZ4+DNjHqRlAJqbJETHwiNKDqTfOjfE=
+golang.org/x/term v0.0.0-20210615171337-6886f2dfbf5b/go.mod
h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod
h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod
h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
@@ -586,6 +665,8 @@ golang.org/x/text v0.3.7/go.mod
h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
+golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac
h1:7zkz7BUtwNFFqcowJ+RIgu2MaV/MapERkDIy+mwPyjs=
+golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac/go.mod
h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
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=
@@ -621,6 +702,7 @@ golang.org/x/tools
v0.0.0-20200304193943-95d2e580d8eb/go.mod h1:o4KQGtdN14AW+yjs
golang.org/x/tools v0.0.0-20200312045724-11d5b4c81c7d/go.mod
h1:o4KQGtdN14AW+yjsvvwRTJJuXz8XRtIHtEnmAXLyFUw=
golang.org/x/tools v0.0.0-20200331025713-a30bf2db82d4/go.mod
h1:Sl4aGygMT6LrqrWclx+PTx3U+LnKx/seiNR+3G19Ar8=
golang.org/x/tools v0.0.0-20200501065659-ab2804fb9c9d/go.mod
h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20200505023115-26f46d2f7ef8/go.mod
h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
golang.org/x/tools v0.0.0-20200512131952-2bc93b1c0c88/go.mod
h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
golang.org/x/tools v0.0.0-20200515010526-7d3b6ebf133d/go.mod
h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
golang.org/x/tools v0.0.0-20200618134242-20370b0cb4b2/go.mod
h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
@@ -684,6 +766,7 @@ google.golang.org/appengine v1.5.0/go.mod
h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7
google.golang.org/appengine v1.6.1/go.mod
h1:i06prIuMbXzDqacNJfV5OdTW448YApPu5ww/cMBSeb0=
google.golang.org/appengine v1.6.5/go.mod
h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
google.golang.org/appengine v1.6.6/go.mod
h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
+google.golang.org/appengine v1.6.7
h1:FZR1q0exgwxzPzp/aF+VccGrSfxfPpkBqjIIEq3ru6c=
google.golang.org/appengine v1.6.7/go.mod
h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod
h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
google.golang.org/genproto v0.0.0-20190307195333-5fe7a883aa19/go.mod
h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
@@ -716,6 +799,7 @@ google.golang.org/genproto
v0.0.0-20200729003335-053ba62fc06f/go.mod h1:FWY/as6D
google.golang.org/genproto v0.0.0-20200804131852-c06518451d9c/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
google.golang.org/genproto v0.0.0-20200825200019-8632dd797987/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
google.golang.org/genproto v0.0.0-20200904004341-0bd0a958aa1d/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
+google.golang.org/genproto v0.0.0-20201019141844-1ed22bb0c154/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
google.golang.org/genproto v0.0.0-20201109203340-2640f1f9cdfb/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
google.golang.org/genproto v0.0.0-20201201144952-b05cb90ed32e/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
google.golang.org/genproto v0.0.0-20201210142538-e3217bee35cc/go.mod
h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
@@ -798,20 +882,28 @@ google.golang.org/protobuf v1.28.0/go.mod
h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqw
gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod
h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod
h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod
h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15
h1:YR8cESwS4TdDjEe65xsg0ogRM/Nc3DYOhEAlW+xobZo=
gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod
h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f
h1:BLraFXnmrev5lT+xlilqcH8XK9/i0At2xKjWk4p6zsU=
+gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f/go.mod
h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
+gopkg.in/fsnotify.v1 v1.4.7/go.mod
h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
+gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc=
+gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw=
gopkg.in/ini.v1 v1.66.2 h1:XfR1dOYubytKy4Shzc2LHrrGhU0lDCfDGG1yLPmpgsI=
gopkg.in/ini.v1 v1.66.2/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7
h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod
h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
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.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.2.5/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod
h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.0-20200615113413-eeeca48fe776/go.mod
h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b
h1:h8qDotaEPuJATrMmW04NCwg7v22aHH28wwpauUhK9Oo=
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod
h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod
h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
@@ -821,8 +913,31 @@ honnef.co/go/tools
v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWh
honnef.co/go/tools v0.0.1-2019.2.3/go.mod
h1:a3bituU0lyd329TUQxRnasdCoJDkEUEAqEt0JzvZhAg=
honnef.co/go/tools v0.0.1-2020.1.3/go.mod
h1:X/FiERA/W4tHapMX5mGpAtMSVEeEUOyHaw9vFzvIQ3k=
honnef.co/go/tools v0.0.1-2020.1.4/go.mod
h1:X/FiERA/W4tHapMX5mGpAtMSVEeEUOyHaw9vFzvIQ3k=
+k8s.io/api v0.23.5 h1:zno3LUiMubxD/V1Zw3ijyKO3wxrhbUF1Ck+VjBvfaoA=
+k8s.io/api v0.23.5/go.mod h1:Na4XuKng8PXJ2JsploYYrivXrINeTaycCGcYgF91Xm8=
+k8s.io/apimachinery v0.23.5 h1:Va7dwhp8wgkUPWsEXk6XglXWU4IKYLKNlv8VkX7SDM0=
+k8s.io/apimachinery v0.23.5/go.mod
h1:BEuFMMBaIbcOqVIJqNZJXGFTP4W6AycEpb5+m/97hrM=
+k8s.io/client-go v0.23.5 h1:zUXHmEuqx0RY4+CsnkOn5l0GU+skkRXKGJrhmE2SLd8=
+k8s.io/client-go v0.23.5/go.mod h1:flkeinTO1CirYgzMPRWxUCnV0G4Fbu2vLhYCObnt/r4=
+k8s.io/gengo v0.0.0-20210813121822-485abfe95c7c/go.mod
h1:FiNAH4ZV3gBg2Kwh89tzAEV2be7d5xI0vBa/VySYy3E=
+k8s.io/klog/v2 v2.0.0/go.mod h1:PBfzABfn139FHAV07az/IF9Wp1bkk3vpT2XSJ76fSDE=
+k8s.io/klog/v2 v2.2.0/go.mod h1:Od+F08eJP+W3HUb4pSrPpgp9DGU4GzlpG/TmITuYh/Y=
+k8s.io/klog/v2 v2.30.0 h1:bUO6drIvCIsvZ/XFgfxoGFQU/a4Qkh0iAlvUR7vlHJw=
+k8s.io/klog/v2 v2.30.0/go.mod h1:y1WjHnz7Dj687irZUWR/WLkLc5N1YHtjLdmgWjndZn0=
+k8s.io/kube-openapi v0.0.0-20211115234752-e816edb12b65
h1:E3J9oCLlaobFUqsjG9DfKbP2BmgwBL2p7pn0A3dG9W4=
+k8s.io/kube-openapi v0.0.0-20211115234752-e816edb12b65/go.mod
h1:sX9MT8g7NVZM5lVL/j8QyCCJe8YSMW30QvGZWaCIDIk=
+k8s.io/utils v0.0.0-20210802155522-efc7438f0176/go.mod
h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
+k8s.io/utils v0.0.0-20211116205334-6203023598ed
h1:ck1fRPWPJWsMd8ZRFsWc6mh/zHp5fZ/shhbrgPUxDAE=
+k8s.io/utils v0.0.0-20211116205334-6203023598ed/go.mod
h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
rsc.io/binaryregexp v0.2.0/go.mod
h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=
-skywalking.apache.org/repo/goapi v0.0.0-20220407130404-69485e13dbb3
h1:DHRqCV17xjLT/HIyNWzLmhrizkne8JgaQDYclHg1tLg=
-skywalking.apache.org/repo/goapi v0.0.0-20220407130404-69485e13dbb3/go.mod
h1:uWwwvhcwe2MD/nJCg0c1EE/eL6KzaBosLHDfMFoEJ30=
+sigs.k8s.io/json v0.0.0-20211020170558-c049b76a60c6
h1:fD1pz4yfdADVNfFmcP2aBEtudwUQ1AlLnRBALr33v3s=
+sigs.k8s.io/json v0.0.0-20211020170558-c049b76a60c6/go.mod
h1:p4QtZmO4uMYipTQNzagwnNoseA6OxSUutVw05NhYDRs=
+sigs.k8s.io/structured-merge-diff/v4 v4.0.2/go.mod
h1:bJZC9H9iH24zzfZ/41RGcq60oK1F7G282QMXDPYydCw=
+sigs.k8s.io/structured-merge-diff/v4 v4.2.1
h1:bKCqE9GvQ5tiVHn5rfn1r+yao3aLQEaLzkkmAkf+A6Y=
+sigs.k8s.io/structured-merge-diff/v4 v4.2.1/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-20220421134447-34b3d2780c61
h1:MCjReXfgVVV/ay303rO104fQJFMGpbwwjXSOl0h82SY=
+skywalking.apache.org/repo/goapi v0.0.0-20220421134447-34b3d2780c61/go.mod
h1:uWwwvhcwe2MD/nJCg0c1EE/eL6KzaBosLHDfMFoEJ30=
diff --git a/pkg/process/config.go b/pkg/process/config.go
index b201ced..ebc39fe 100644
--- a/pkg/process/config.go
+++ b/pkg/process/config.go
@@ -19,6 +19,7 @@ package process
import (
"github.com/apache/skywalking-rover/pkg/module"
+ "github.com/apache/skywalking-rover/pkg/process/finders/kubernetes"
"github.com/apache/skywalking-rover/pkg/process/finders/scanner"
)
@@ -28,8 +29,10 @@ type Config struct {
// heartbeat the process list period
HeartbeatPeriod string `mapstructure:"heartbeat_period"`
- // Scanner process from VM
+ // Scanner process from Linux
Scanner *scanner.Config `mapstructure:"scanner"`
+
+ Kubernetes *kubernetes.Config `mapstructure:"kubernetes"`
}
func (c *Config) IsActive() bool {
diff --git a/pkg/process/finders/base/config.go
b/pkg/process/finders/base/config.go
index 6ba8144..ccffffa 100644
--- a/pkg/process/finders/base/config.go
+++ b/pkg/process/finders/base/config.go
@@ -17,5 +17,56 @@
package base
+import (
+ "fmt"
+ "regexp"
+ "strings"
+ "time"
+)
+
type FinderBaseConfig interface {
+ // ActiveFinder to detect process
+ ActiveFinder() bool
+}
+
+func StringMustNotNull(err error, confKey, confValue string) error {
+ if err != nil {
+ return err
+ }
+ if confValue == "" {
+ return fmt.Errorf("the %s of Scanner process must be set",
confKey)
+ }
+ return nil
+}
+
+func TemplateMustNotNull(err error, confKey, confValue string)
(*TemplateBuilder, error) {
+ if err1 := StringMustNotNull(err, confKey, confValue); err1 != nil {
+ return nil, err1
+ }
+ return NewTemplateBuilder(confKey, confValue)
+}
+
+func RegexMustNotNull(err error, confKey, confValue string) (*regexp.Regexp,
error) {
+ if err1 := StringMustNotNull(err, confKey, confValue); err1 != nil {
+ return nil, err1
+ }
+ return regexp.Compile(confValue)
+}
+
+func DurationMustNotNull(err error, confKey, confValue string) (time.Duration,
error) {
+ if err1 := StringMustNotNull(err, confKey, confValue); err1 != nil {
+ return 0, err1
+ }
+ return time.ParseDuration(confValue)
+}
+
+func ParseLabels(labelStr string) []string {
+ tmp := strings.Split(labelStr, ",")
+ result := make([]string, 0)
+ for _, s := range tmp {
+ if s != "" {
+ result = append(result, s)
+ }
+ }
+ return result
}
diff --git a/pkg/process/finders/base/finder.go
b/pkg/process/finders/base/finder.go
index 1e3a288..29733f6 100644
--- a/pkg/process/finders/base/finder.go
+++ b/pkg/process/finders/base/finder.go
@@ -55,6 +55,4 @@ type ProcessManager interface {
GetModuleManager() *module.Manager
// SyncAllProcessInFinder is mean synchronized all processes data from
current ProcessFinder
SyncAllProcessInFinder(processes []DetectedProcess)
- // QueryProcess means get the process if already sync
- QueryProcess(pid int32) DetectedProcess
}
diff --git a/pkg/process/finders/base/template.go
b/pkg/process/finders/base/template.go
index 3b30c9b..aa4b7da 100644
--- a/pkg/process/finders/base/template.go
+++ b/pkg/process/finders/base/template.go
@@ -22,6 +22,8 @@ import (
"fmt"
"text/template"
+ "github.com/shirou/gopsutil/process"
+
"github.com/apache/skywalking-rover/pkg/core"
"github.com/apache/skywalking-rover/pkg/module"
"github.com/apache/skywalking-rover/pkg/tools"
@@ -57,8 +59,8 @@ func NewTemplateRover(manager *module.Manager) *TemplateRover
{
}
// NewTemplateProcess is generated the process context for render
-func NewTemplateProcess(manager *module.Manager, process DetectedProcess)
*TemplateProcess {
- return &TemplateProcess{process}
+func NewTemplateProcess(manager *module.Manager, p *process.Process)
*TemplateProcess {
+ return &TemplateProcess{p}
}
type TemplateRover struct {
@@ -94,30 +96,30 @@ func (t *TemplateRover) HostName() string {
}
type TemplateProcess struct {
- DetectedProcess
+ *process.Process
}
// ExeFilePath Execute file path
func (p *TemplateProcess) ExeFilePath() (string, error) {
- return p.OriginalProcess().Exe()
+ return p.Exe()
}
// ExeName Execute file name
func (p *TemplateProcess) ExeName() (string, error) {
- return p.OriginalProcess().Name()
+ return p.Name()
}
// CommandLine command line of process
func (p *TemplateProcess) CommandLine() (string, error) {
- return p.OriginalProcess().Cmdline()
+ return p.Cmdline()
}
// Pid of process
func (p *TemplateProcess) Pid() int32 {
- return p.OriginalProcess().Pid
+ return p.Process.Pid
}
// WorkDir means which directory to run the execute file
func (p *TemplateProcess) WorkDir() (string, error) {
- return p.OriginalProcess().Cwd()
+ return p.Cwd()
}
diff --git a/pkg/process/finders/base/tool.go b/pkg/process/finders/base/tool.go
new file mode 100644
index 0000000..2eba046
--- /dev/null
+++ b/pkg/process/finders/base/tool.go
@@ -0,0 +1,68 @@
+// 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 base
+
+import (
+ "fmt"
+ "os"
+
+ "github.com/apache/skywalking-rover/pkg/tools"
+ "github.com/apache/skywalking-rover/pkg/tools/host"
+ "github.com/apache/skywalking-rover/pkg/tools/profiling"
+
+ "github.com/shirou/gopsutil/process"
+)
+
+// BuildProfilingStat use to build the profiling info for profiling
+func BuildProfilingStat(ps *process.Process) (*profiling.Info, error) {
+ path := tryToFindFileExecutePath(ps)
+ if path == "" {
+ return nil, fmt.Errorf("could not found executable file")
+ }
+
+ // check support profiling
+ return tools.ExecutableFileProfilingStat(path)
+}
+
+func tryToFindFileExecutePath(ps *process.Process) string {
+ exe, err := ps.Exe()
+ if pathExists(exe, err) {
+ return exe
+ }
+ cwd, err := ps.Cwd()
+ if pathExists(cwd, err) && pathExists(cwd+"/"+exe, err) {
+ return cwd + "/" + exe
+ }
+ linuxProcessRoot := host.GetFileInHost(fmt.Sprintf("/proc/%d/root",
ps.Pid))
+ if pathExists(linuxProcessRoot, nil) {
+ if pathExists(linuxProcessRoot+"/"+exe, nil) {
+ return linuxProcessRoot + "/" + exe
+ } else if pathExists(linuxProcessRoot+"/"+cwd+"/"+exe, nil) {
+ return linuxProcessRoot + "/" + cwd + "/" + exe
+ }
+ }
+ return ""
+}
+
+func pathExists(exe string, err error) bool {
+ if err != nil {
+ return false
+ }
+ _, e := os.Stat(exe)
+ return !os.IsNotExist(e)
+}
diff --git a/pkg/process/finders/kubernetes/config.go
b/pkg/process/finders/kubernetes/config.go
new file mode 100644
index 0000000..3b7e127
--- /dev/null
+++ b/pkg/process/finders/kubernetes/config.go
@@ -0,0 +1,85 @@
+// 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 kubernetes
+
+import (
+ "fmt"
+
+ "github.com/apache/skywalking-rover/pkg/process/finders/base"
+)
+
+type Config struct {
+ base.FinderBaseConfig
+
+ Active bool `mapstrcture:"active"`
+
+ NodeName string `mapstructure:"node_name"`
+ Namespaces string `mapstructure:"namespaces"`
+ Analyzers []*ProcessBuilder `mapstructure:"analyzers"`
+}
+
+type ProcessBuilder struct {
+ Filters []string `mapstructure:"filters"`
+ Layer string `mapstructure:"layer"`
+ ServiceName string `mapstructure:"service_name"`
+ InstanceName string `mapstructure:"instance_name"`
+ ProcessName string `mapstructure:"process_name"`
+ LabelsStr string `mapstructure:"labels"`
+
+ // runtime
+ FiltersBuilder []*base.TemplateBuilder
+ ServiceNameBuilder *base.TemplateBuilder
+ InstanceNameBuilder *base.TemplateBuilder
+ ProcessNameBuilder *base.TemplateBuilder
+ Labels []string
+}
+
+// ProcessBuildersInit used to init process builders
+func ProcessBuildersInit(builders []*ProcessBuilder) error {
+ for _, b := range builders {
+ var err error
+ if len(b.Filters) > 0 {
+ b.FiltersBuilder = make([]*base.TemplateBuilder, 0)
+ for _, f := range b.Filters {
+ err = base.StringMustNotNull(err, "filter", f)
+ builder, err1 := base.TemplateMustNotNull(err,
"filter", fmt.Sprintf("{{%s}}", f))
+ if err1 != nil {
+ return fmt.Errorf("build filter error:
%s, error: %v", f, err1)
+ }
+ b.FiltersBuilder = append(b.FiltersBuilder,
builder)
+ }
+ }
+ b.ServiceNameBuilder, err = base.TemplateMustNotNull(err,
"service name", b.ServiceName)
+ b.InstanceNameBuilder, err = base.TemplateMustNotNull(err,
"instance name", b.InstanceName)
+ b.ProcessNameBuilder, err = base.TemplateMustNotNull(err,
"process name", b.ProcessName)
+ b.Labels = base.ParseLabels(b.LabelsStr)
+
+ if err != nil {
+ return fmt.Errorf("build process builder error: %v",
err)
+ }
+ }
+ return nil
+}
+
+func (c *Config) ActiveFinder() bool {
+ return c.Active
+}
+
+type MeshConfig struct {
+ ServiceName string `mapstructure:"service_name"`
+}
diff --git a/pkg/process/finders/kubernetes/container.go
b/pkg/process/finders/kubernetes/container.go
new file mode 100644
index 0000000..c2a3a62
--- /dev/null
+++ b/pkg/process/finders/kubernetes/container.go
@@ -0,0 +1,148 @@
+// 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 kubernetes
+
+import (
+ "context"
+ "strings"
+
+ "k8s.io/client-go/kubernetes/scheme"
+
+ "k8s.io/apimachinery/pkg/runtime/schema"
+ "k8s.io/client-go/rest"
+
+ "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+
+ v1 "k8s.io/api/core/v1"
+ metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+type PodContainer struct {
+ // pod references
+ Pod *v1.Pod
+ ContainerSpec v1.Container
+ ContainerStatus v1.ContainerStatus
+
+ // the kubernetes resource registry
+ registry *Registry
+}
+
+// AnalyzeContainers means query the containers by pod
+func AnalyzeContainers(pod *v1.Pod, registry *Registry) []*PodContainer {
+ containers := make([]*PodContainer, 0)
+ // nolint
+ for _, cs := range pod.Status.ContainerStatuses {
+ // nolint
+ for _, c := range pod.Spec.Containers {
+ if c.Name != cs.Name {
+ continue
+ }
+
+ containers = append(containers, &PodContainer{
+ Pod: pod,
+ ContainerSpec: c,
+ ContainerStatus: cs,
+ registry: registry,
+ })
+ }
+ }
+ return containers
+}
+
+func (c *PodContainer) CGroupID() string {
+ cgroupID := c.ContainerStatus.ContainerID
+ // delete the container runtime prefix is the cgroupid
+ cgroupID = strings.TrimPrefix(cgroupID, "containerd://")
+ cgroupID = strings.TrimPrefix(cgroupID, "dockerd://")
+ return cgroupID
+}
+
+func (c *PodContainer) ServiceName() string {
+ return c.registry.FindServiceName(c.Pod.Namespace, c.Pod.Name)
+}
+
+// FindOwner means query the owner in the container, it would loop up with
parent owner until empty
+func (c *PodContainer) FindOwner(ctx context.Context, kindName string,
k8sConfig *rest.Config) (*metav1.OwnerReference, error) {
+ // find in cache result
+ findedReferences := make([]metav1.OwnerReference, 0)
+ if owner := c.findOwner(c.Pod.OwnerReferences, kindName); owner != nil {
+ return owner, nil
+ }
+ findedReferences = append(findedReferences, c.Pod.OwnerReferences...)
+
+ // found from owner
+ for len(findedReferences) > 0 {
+ current := findedReferences[0]
+ findedReferences = findedReferences[1:]
+
+ // must be a controller
+ if c := current.Controller; c != nil && !*c {
+ continue
+ }
+
+ // query reference data
+ restClient, err := c.parseRestClientFromAPIVersion(k8sConfig,
current.APIVersion)
+ if err != nil {
+ return nil, err
+ }
+ do := restClient.Get().Resource(current.Kind + "s").
+ Name(current.Name).
+ Namespace(c.Pod.Namespace).
+ Do(ctx)
+ if do.Error() != nil {
+ return nil, do.Error()
+ }
+ data := &unstructured.Unstructured{}
+ if err := do.Into(data); err != nil {
+ return nil, err
+ }
+
+ // query parent references from current reference
+ references := data.GetOwnerReferences()
+ if owner := c.findOwner(references, kindName); owner != nil {
+ return owner, nil
+ }
+ findedReferences = append(findedReferences, references...)
+ }
+ return nil, nil
+}
+
+func (c *PodContainer) parseRestClientFromAPIVersion(conf *rest.Config,
apiVersion string) (rest.Interface, error) {
+ groupVersion, err := schema.ParseGroupVersion(apiVersion)
+ if err != nil {
+ return nil, err
+ }
+ queryConf := rest.CopyConfig(conf)
+ queryConf.GroupVersion = &groupVersion
+ queryConf.APIPath = "/apis"
+ queryConf.NegotiatedSerializer = scheme.Codecs.WithoutConversion()
+
+ if queryConf.UserAgent == "" {
+ queryConf.UserAgent = rest.DefaultKubernetesUserAgent()
+ }
+ return rest.RESTClientFor(queryConf)
+}
+
+func (c *PodContainer) findOwner(refs []metav1.OwnerReference, kindName
string) *metav1.OwnerReference {
+ for _, o := range refs {
+ if o.Kind == kindName {
+ return &o
+ }
+ }
+ return nil
+}
diff --git a/pkg/process/finders/kubernetes/finder.go
b/pkg/process/finders/kubernetes/finder.go
new file mode 100644
index 0000000..946f7cb
--- /dev/null
+++ b/pkg/process/finders/kubernetes/finder.go
@@ -0,0 +1,312 @@
+// 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 kubernetes
+
+import (
+ "bufio"
+ "context"
+ "fmt"
+ "os"
+ "strconv"
+ "strings"
+ "time"
+
+ commonv3 "skywalking.apache.org/repo/goapi/collect/common/v3"
+
+ "github.com/shirou/gopsutil/process"
+
+ v1 "k8s.io/api/core/v1"
+ metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+ "k8s.io/client-go/kubernetes"
+ "k8s.io/client-go/rest"
+
+ v3 "skywalking.apache.org/repo/goapi/collect/ebpf/profiling/process/v3"
+
+ "github.com/apache/skywalking-rover/pkg/logger"
+ "github.com/apache/skywalking-rover/pkg/process/api"
+ "github.com/apache/skywalking-rover/pkg/process/finders/base"
+ "github.com/apache/skywalking-rover/pkg/tools/host"
+)
+
+var log = logger.GetLogger("process", "finder", "kubernetes")
+
+type ProcessFinder struct {
+ conf *Config
+
+ // runtime
+ manager base.ProcessManager
+ ctx context.Context
+ cancelCtx context.CancelFunc
+ stopChan chan struct{}
+
+ // k8s clients
+ k8sConfig *rest.Config
+ cli *kubernetes.Clientset
+ registry *Registry
+
+ // runtime config
+ namespaces []string
+}
+
+func (f *ProcessFinder) Init(ctx context.Context, conf base.FinderBaseConfig,
manager base.ProcessManager) error {
+ k8sConf, cli, err := f.validateConfig(ctx, conf.(*Config))
+ if err != nil {
+ return err
+ }
+ f.conf = conf.(*Config)
+ f.k8sConfig = k8sConf
+ f.cli = cli
+
+ f.ctx, f.cancelCtx = context.WithCancel(ctx)
+ f.stopChan = make(chan struct{}, 1)
+ f.registry = NewRegistry(f.cli, f.namespaces, f.conf.NodeName)
+ f.manager = manager
+
+ return nil
+}
+
+func (f *ProcessFinder) validateConfig(ctx context.Context, conf *Config)
(*rest.Config, *kubernetes.Clientset, error) {
+ // init kubernetes client, must be inside kubernetes cluster
+ k8sConfig, err := rest.InClusterConfig()
+ if err != nil {
+ return nil, nil, fmt.Errorf("please make sure started inside
the kubernetes cluster: %v", err)
+ }
+ cli, err := kubernetes.NewForConfig(k8sConfig)
+ if err != nil {
+ return nil, nil, err
+ }
+
+ // check node exists
+ _, err = cli.CoreV1().Nodes().Get(ctx, conf.NodeName,
metav1.GetOptions{})
+ if err != nil {
+ return nil, nil, fmt.Errorf("could not found the node: %s, %v",
conf.NodeName, err)
+ }
+
+ // namespace update
+ if conf.Namespaces != "" {
+ f.namespaces = strings.Split(conf.Namespaces, ",")
+ } else {
+ f.namespaces = []string{v1.NamespaceAll}
+ }
+
+ // process builders
+ if err := ProcessBuildersInit(conf.Analyzers); err != nil {
+ return nil, nil, err
+ }
+
+ return k8sConfig, cli, nil
+}
+
+func (f *ProcessFinder) Start() {
+ // add service and pod informers
+ f.registry.Start(f.stopChan)
+ go func() {
+ timeTicker := time.NewTicker(time.Second * 5)
+ for {
+ select {
+ case <-timeTicker.C:
+ if err := f.analyzeProcesses(); err != nil {
+ log.Errorf("found process failure: %v",
err)
+ }
+ case <-f.ctx.Done():
+ timeTicker.Stop()
+ return
+ }
+ }
+ }()
+}
+
+func (f *ProcessFinder) analyzeProcesses() error {
+ // find out all containers
+ containers := f.registry.BuildPodContainers()
+ if len(containers) == 0 {
+ return nil
+ }
+
+ processes, err := process.Processes()
+ if err != nil {
+ return err
+ }
+
+ result := make([]base.DetectedProcess, 0)
+ for _, p := range processes {
+ cgroup, err := f.getProcessCGroup(p.Pid)
+ if err != nil {
+ continue
+ }
+
+ c := containers[cgroup]
+ if c == nil {
+ continue
+ }
+
+ // check support profiling
+ _, err = base.BuildProfilingStat(p)
+ if err != nil {
+ continue
+ }
+
+ // find process builder
+ ps, err := f.buildProcesses(p, c)
+ if err != nil {
+ log.Warnf("find process builder error for pid: %d, err:
%v", p.Pid, err)
+ continue
+ }
+
+ for _, pro := range ps {
+ result = append(result, pro)
+ }
+ }
+
+ if len(result) > 0 {
+ f.manager.SyncAllProcessInFinder(result)
+ }
+ return nil
+}
+
+func (f *ProcessFinder) buildProcesses(p *process.Process, pc *PodContainer)
([]*Process, error) {
+ // find builder
+ builders := make([]*ProcessBuilder, 0)
+ for _, b := range f.conf.Analyzers {
+ success, err := executeFilter(b.FiltersBuilder, p, pc, f)
+ if err != nil {
+ return nil, err
+ } else if success {
+ builders = append(builders, b)
+ }
+ }
+ if len(builders) == 0 {
+ return nil, nil
+ }
+
+ cmdline, err := p.Cmdline()
+ if err != nil {
+ return nil, err
+ }
+
+ // build process
+ processes := make([]*Process, 0)
+ for _, builder := range builders {
+ entity := &api.ProcessEntity{}
+ entity.Layer = builder.Layer
+ entity.ServiceName, err = f.buildEntity(err, p, pc,
builder.ServiceNameBuilder)
+ entity.InstanceName, err = f.buildEntity(err, p, pc,
builder.InstanceNameBuilder)
+ entity.ProcessName, err = f.buildEntity(err, p, pc,
builder.ProcessNameBuilder)
+ entity.Labels = builder.Labels
+ if err != nil {
+ return nil, err
+ }
+ processes = append(processes, NewProcess(p, cmdline, pc,
entity))
+ }
+
+ return processes, nil
+}
+
+func (f *ProcessFinder) buildEntity(err error, ps *process.Process, pc
*PodContainer, entity *base.TemplateBuilder) (string, error) {
+ if err != nil {
+ return "", err
+ }
+ return renderTemplate(entity, ps, pc, f)
+}
+
+func (f *ProcessFinder) getProcessCGroup(pid int32) (string, error) {
+ processCgroupFilePath :=
host.GetFileInHost(fmt.Sprintf("/proc/%d/cgroup", pid))
+ cgroupFile, err := os.Open(processCgroupFilePath)
+ if err != nil {
+ return "", err
+ }
+ defer cgroupFile.Close()
+
+ scanner := bufio.NewScanner(cgroupFile)
+ for scanner.Scan() {
+ infos := strings.Split(scanner.Text(), ":")
+ if len(infos) < 3 {
+ continue
+ }
+ // find by most common type of cgroup
+ if infos[1] == "memory" {
+ lastPath := strings.LastIndex(infos[2], "/")
+ if lastPath > 1 && lastPath != len(infos[2])-1 {
+ return infos[2][lastPath+1:], nil
+ }
+ return "", nil
+ }
+ }
+ return "", fmt.Errorf("no memory config")
+}
+
+func (f *ProcessFinder) Stop() error {
+ close(f.stopChan)
+ f.cancelCtx()
+ return nil
+}
+
+func (f *ProcessFinder) DetectType() api.ProcessDetectType {
+ return api.Kubernetes
+}
+
+func (f *ProcessFinder) ValidateProcessIsSame(p1, p2 base.DetectedProcess)
bool {
+ k1 := p1.(*Process)
+ k2 := p2.(*Process)
+ return p1.Pid() == p2.Pid() && k1.cmd == k2.cmd &&
p1.Entity().SameWith(p2.Entity())
+}
+
+func (f *ProcessFinder) BuildEBPFProcess(ctx *base.BuildEBPFProcessContext, ps
base.DetectedProcess) *v3.EBPFProcessProperties {
+ k8sProcess := &v3.EBPFKubernetesProcessMetadata{}
+ k8sProcess.Pid = ps.Pid()
+ k8sProcess.Entity = &v3.EBPFProcessEntityMetadata{
+ Layer: ps.Entity().Layer,
+ ServiceName: ps.Entity().ServiceName,
+ InstanceName: ps.Entity().InstanceName,
+ ProcessName: ps.Entity().ProcessName,
+ Labels: ps.Entity().Labels,
+ }
+ k8sProcess.Properties = []*commonv3.KeyStringValuePair{
+ {
+ Key: "host_ip",
+ Value: ctx.HostIP,
+ },
+ {
+ Key: "container_ip",
+ Value: ps.(*Process).podContainer.Pod.Status.PodIP,
+ },
+ {
+ Key: "pid",
+ Value: strconv.FormatInt(int64(ps.Pid()), 10),
+ },
+ {
+ Key: "command_line",
+ Value: ps.(*Process).cmd,
+ },
+ }
+ properties := &v3.EBPFProcessProperties{Metadata:
&v3.EBPFProcessProperties_K8SProcess{
+ K8SProcess: k8sProcess,
+ }}
+ return properties
+}
+
+func (f *ProcessFinder) ParseProcessID(ps base.DetectedProcess, downstream
*v3.EBPFProcessDownstream) string {
+ if downstream.GetK8SProcess() == nil {
+ return ""
+ }
+ if ps.Pid() == downstream.GetK8SProcess().GetPid() {
+ return downstream.GetProcessId()
+ }
+ return ""
+}
diff --git a/pkg/process/finders/kubernetes/process.go
b/pkg/process/finders/kubernetes/process.go
new file mode 100644
index 0000000..6c35b10
--- /dev/null
+++ b/pkg/process/finders/kubernetes/process.go
@@ -0,0 +1,68 @@
+// 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 kubernetes
+
+import (
+ "github.com/shirou/gopsutil/process"
+
+ "github.com/apache/skywalking-rover/pkg/process/api"
+ "github.com/apache/skywalking-rover/pkg/tools/profiling"
+)
+
+type Process struct {
+ original *process.Process
+
+ // process data
+ pid int32
+ cmd string
+ profiling *profiling.Info
+ podContainer *PodContainer
+
+ // entity for the backend
+ entity *api.ProcessEntity
+}
+
+func NewProcess(p *process.Process, cmdline string, pc *PodContainer, entity
*api.ProcessEntity) *Process {
+ return &Process{
+ original: p,
+ pid: p.Pid,
+ cmd: cmdline,
+ podContainer: pc,
+ entity: entity,
+ }
+}
+
+func (p *Process) Pid() int32 {
+ return p.pid
+}
+
+func (p *Process) OriginalProcess() *process.Process {
+ return p.original
+}
+
+func (p *Process) Entity() *api.ProcessEntity {
+ return p.entity
+}
+
+func (p *Process) DetectType() api.ProcessDetectType {
+ return api.Kubernetes
+}
+
+func (p *Process) ProfilingStat() *profiling.Info {
+ return p.profiling
+}
diff --git a/pkg/process/finders/kubernetes/registry.go
b/pkg/process/finders/kubernetes/registry.go
new file mode 100644
index 0000000..ccef80b
--- /dev/null
+++ b/pkg/process/finders/kubernetes/registry.go
@@ -0,0 +1,118 @@
+// 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 kubernetes
+
+import (
+ "time"
+
+ "k8s.io/apimachinery/pkg/labels"
+
+ v1 "k8s.io/api/core/v1"
+ "k8s.io/apimachinery/pkg/fields"
+ "k8s.io/client-go/kubernetes"
+ "k8s.io/client-go/tools/cache"
+)
+
+const rsyncPeriod = 5 * time.Minute
+
+type Registry struct {
+ podInformers []cache.SharedInformer
+ serviceInformers []cache.SharedInformer
+
+ podServiceNameCache map[string]string
+}
+
+func NewRegistry(cli *kubernetes.Clientset, namespaces []string, nodeName
string) *Registry {
+ r := &Registry{
+ podInformers: make([]cache.SharedInformer, 0),
+ serviceInformers: make([]cache.SharedInformer, 0),
+ podServiceNameCache: make(map[string]string),
+ }
+ for _, ns := range namespaces {
+ podListWatch :=
cache.NewListWatchFromClient(cli.CoreV1().RESTClient(), "pods", ns,
fields.OneTermEqualSelector("spec.nodeName", nodeName))
+ podInformer := cache.NewSharedInformer(podListWatch, &v1.Pod{},
rsyncPeriod)
+ podInformer.AddEventHandler(r)
+ r.podInformers = append(r.podInformers, podInformer)
+
+ serviceListWatch :=
cache.NewListWatchFromClient(cli.CoreV1().RESTClient(), "services", ns,
fields.Everything())
+ serviceInformer := cache.NewSharedInformer(serviceListWatch,
&v1.Service{}, rsyncPeriod)
+ serviceInformer.AddEventHandler(r)
+ r.serviceInformers = append(r.serviceInformers, serviceInformer)
+ }
+
+ return r
+}
+
+func (r *Registry) Start(stopChan chan struct{}) {
+ for i := range r.podInformers {
+ go r.podInformers[i].Run(stopChan)
+ go r.serviceInformers[i].Run(stopChan)
+ }
+}
+
+func (r *Registry) BuildPodContainers() map[string]*PodContainer {
+ // cgroupid -> container
+ containers := make(map[string]*PodContainer)
+ for _, in := range r.podInformers {
+ list := in.GetStore().List()
+ for _, p := range list {
+ analyzeContainers := AnalyzeContainers(p.(*v1.Pod), r)
+ for _, c := range analyzeContainers {
+ containers[c.CGroupID()] = c
+ }
+ }
+ }
+ return containers
+}
+
+func (r *Registry) FindServiceName(namespace, podName string) string {
+ return r.podServiceNameCache[namespace+"_"+podName]
+}
+
+func (r *Registry) recomposePodServiceName() {
+ result := make(map[string]string)
+ for i := range r.podInformers {
+ for _, podT := range r.podInformers[i].GetStore().List() {
+ for _, serviceT := range
r.serviceInformers[i].GetStore().List() {
+ pod := podT.(*v1.Pod)
+ service := serviceT.(*v1.Service)
+
+ if pod.Namespace != service.Namespace {
+ continue
+ }
+
+ if
labels.Set(service.Spec.Selector).AsSelector().Matches(labels.Set(pod.ObjectMeta.Labels))
{
+ result[pod.Namespace+"_"+pod.Name] =
service.Name
+ }
+ }
+ }
+ }
+ r.podServiceNameCache = result
+}
+
+func (r *Registry) OnAdd(_ interface{}) {
+ r.recomposePodServiceName()
+}
+
+func (r *Registry) OnUpdate(_, _ interface{}) {
+ r.recomposePodServiceName()
+}
+
+func (r *Registry) OnDelete(_ interface{}) {
+ r.recomposePodServiceName()
+}
diff --git a/pkg/process/finders/kubernetes/template.go
b/pkg/process/finders/kubernetes/template.go
new file mode 100644
index 0000000..dc82baa
--- /dev/null
+++ b/pkg/process/finders/kubernetes/template.go
@@ -0,0 +1,175 @@
+// 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 kubernetes
+
+import (
+ "fmt"
+ "strconv"
+ "strings"
+
+ "github.com/apache/skywalking-rover/pkg/process/finders/base"
+
+ "github.com/shirou/gopsutil/process"
+
+ "k8s.io/apimachinery/pkg/labels"
+)
+
+func executeFilter(builders []*base.TemplateBuilder, p *process.Process, pc
*PodContainer, finder *ProcessFinder) (bool, error) {
+ if len(builders) == 0 {
+ return true, nil
+ }
+
+ moduleManager := finder.manager.GetModuleManager()
+ for _, b := range builders {
+ result, err := b.Execute(&FilterContext{
+ Process: base.NewTemplateProcess(moduleManager, p),
+ Pod: &TemplatePodJudgment{&TemplatePod{pc,
finder}},
+ Container: &TemplateContainer{pc},
+ })
+ if err != nil {
+ return false, err
+ }
+
+ success, err := strconv.ParseBool(result)
+ if err != nil {
+ return false, err
+ }
+
+ // must all filtering success
+ // if have any false, just short circuit
+ if !success {
+ return false, nil
+ }
+ }
+ return true, nil
+}
+
+func renderTemplate(builder *base.TemplateBuilder, p *process.Process, pc
*PodContainer, finder *ProcessFinder) (string, error) {
+ moduleManager := finder.manager.GetModuleManager()
+ return builder.Execute(&EntityRenderContext{
+ Rover: base.NewTemplateRover(moduleManager),
+ Process: base.NewTemplateProcess(moduleManager, p),
+ Pod: &TemplatePod{pc, finder},
+ Container: &TemplateContainer{pc},
+ })
+}
+
+type FilterContext struct {
+ Process *base.TemplateProcess
+ Pod *TemplatePodJudgment
+ Container *TemplateContainer
+}
+
+type EntityRenderContext struct {
+ Rover *base.TemplateRover
+ Process *base.TemplateProcess
+ Pod *TemplatePod
+ Container *TemplateContainer
+}
+
+type TemplatePod struct {
+ pc *PodContainer
+ finder *ProcessFinder
+}
+
+func (p *TemplatePod) Name() string {
+ return p.pc.Pod.Name
+}
+
+func (p *TemplatePod) Namespace() string {
+ return p.pc.Pod.Namespace
+}
+
+func (p *TemplatePod) Node() string {
+ return p.pc.Pod.Spec.NodeName
+}
+
+func (p *TemplatePod) LabelValue(names string) (string, error) {
+ namesArray := strings.Split(names, ",")
+ for _, name := range namesArray {
+ val := p.pc.Pod.Labels[name]
+ if val != "" {
+ return val, nil
+ }
+ }
+ actualNames := make([]string, 0)
+ for k := range p.pc.Pod.Labels {
+ actualNames = append(actualNames, k)
+ }
+ return "", fmt.Errorf("could not found matches label, want names: %v,
actual names: %v", namesArray, actualNames)
+}
+
+func (p *TemplatePod) ServiceName() string {
+ return p.pc.ServiceName()
+}
+
+func (p *TemplatePod) OwnerName(kindNames string) (string, error) {
+ kindNameArray := strings.Split(kindNames, ",")
+ for _, name := range kindNameArray {
+ if strings.EqualFold(name, "service") {
+ if s := p.ServiceName(); s != "" {
+ return s, nil
+ }
+ continue
+ }
+ if owner, err := p.pc.FindOwner(p.finder.ctx, name,
p.finder.k8sConfig); err != nil {
+ return "", err
+ } else if owner != nil {
+ return owner.Name, nil
+ }
+ }
+ return "", fmt.Errorf("could not found owner in %v", kindNameArray)
+}
+
+type TemplatePodJudgment struct {
+ *TemplatePod
+}
+
+func (t *TemplatePodJudgment) HasContainer(name string) bool {
+ // nolint
+ for _, c := range t.pc.Pod.Spec.Containers {
+ if c.Name == name {
+ return true
+ }
+ }
+ return false
+}
+
+func (t *TemplatePodJudgment) LabelSelector(selector string) (bool, error) {
+ labelsMap, err := labels.ConvertSelectorToLabelsMap(selector)
+ if err != nil {
+ return false, err
+ }
+ return labelsMap.AsSelector().Matches(labels.Set(t.pc.Pod.Labels)), nil
+}
+
+func (t *TemplatePodJudgment) HasServiceName() bool {
+ return t.ServiceName() != ""
+}
+
+type TemplateContainer struct {
+ pc *PodContainer
+}
+
+func (c *TemplateContainer) Name() string {
+ return c.pc.ContainerSpec.Name
+}
+
+func (c *TemplateContainer) ID() string {
+ return c.pc.ContainerStatus.ContainerID
+}
diff --git a/pkg/process/finders/manager.go b/pkg/process/finders/manager.go
index e6d8977..1787cf5 100644
--- a/pkg/process/finders/manager.go
+++ b/pkg/process/finders/manager.go
@@ -53,7 +53,7 @@ func NewProcessManager(ctx context.Context, moduleManager
*module.Manager,
confinedFinders := make(map[base.FinderBaseConfig]base.ProcessFinder)
fsList := make([]base.ProcessFinder, 0)
for _, conf := range configs {
- if conf == nil {
+ if conf == nil || !conf.ActiveFinder() {
continue
}
finder := getFinder(conf)
@@ -118,10 +118,6 @@ func (p *ProcessManagerWithFinder)
SyncAllProcessInFinder(processes []base.Detec
p.storage.SyncAllProcessInFinder(p.finderType, processes)
}
-func (p *ProcessManagerWithFinder) QueryProcess(pid int32)
base.DetectedProcess {
- return p.storage.QueryProcess(pid)
-}
-
func (m *ProcessManager) FindProcessByID(processID string)
api.ProcessInterface {
return m.storage.FindProcessByID(processID)
}
diff --git a/pkg/process/finders/register.go b/pkg/process/finders/register.go
index babf52f..a764c27 100644
--- a/pkg/process/finders/register.go
+++ b/pkg/process/finders/register.go
@@ -20,6 +20,8 @@ package finders
import (
"reflect"
+ "github.com/apache/skywalking-rover/pkg/process/finders/kubernetes"
+
"github.com/apache/skywalking-rover/pkg/process/finders/base"
"github.com/apache/skywalking-rover/pkg/process/finders/scanner"
)
@@ -28,6 +30,7 @@ var finders = make(map[reflect.Type]base.ProcessFinder)
func init() {
registerFinder(reflect.TypeOf(&scanner.Config{}),
&scanner.ProcessFinder{})
+ registerFinder(reflect.TypeOf(&kubernetes.Config{}),
&kubernetes.ProcessFinder{})
}
func registerFinder(t reflect.Type, finder base.ProcessFinder) {
diff --git a/pkg/process/finders/scanner/config.go
b/pkg/process/finders/scanner/config.go
index 01a2c2d..29e65ad 100644
--- a/pkg/process/finders/scanner/config.go
+++ b/pkg/process/finders/scanner/config.go
@@ -70,3 +70,7 @@ type AgentFinder struct {
ProcessStatusRefreshPeriodDuration time.Duration
}
+
+func (c *Config) ActiveFinder() bool {
+ return true
+}
diff --git a/pkg/process/finders/scanner/finder.go
b/pkg/process/finders/scanner/finder.go
index cdc01ba..0705785 100644
--- a/pkg/process/finders/scanner/finder.go
+++ b/pkg/process/finders/scanner/finder.go
@@ -24,13 +24,13 @@ import (
"fmt"
"os"
"path"
- "regexp"
"strconv"
"strings"
"time"
"github.com/spf13/viper"
+ commonv3 "skywalking.apache.org/repo/goapi/collect/common/v3"
v3 "skywalking.apache.org/repo/goapi/collect/ebpf/profiling/process/v3"
"github.com/shirou/gopsutil/process"
@@ -38,7 +38,6 @@ import (
"github.com/apache/skywalking-rover/pkg/logger"
"github.com/apache/skywalking-rover/pkg/process/api"
"github.com/apache/skywalking-rover/pkg/process/finders/base"
- "github.com/apache/skywalking-rover/pkg/tools"
"github.com/apache/skywalking-rover/pkg/tools/host"
)
@@ -92,9 +91,7 @@ func (p *ProcessFinder) ValidateProcessIsSame(p1, p2
base.DetectedProcess) bool
func (p *ProcessFinder) BuildEBPFProcess(ctx *base.BuildEBPFProcessContext, ps
base.DetectedProcess) *v3.EBPFProcessProperties {
hostProcess := &v3.EBPFHostProcessMetadata{}
- hostProcess.HostIP = ctx.HostIP
hostProcess.Pid = ps.Pid()
- hostProcess.Cmd = ps.(*Process).cmd
hostProcess.Entity = &v3.EBPFProcessEntityMetadata{
Layer: ps.Entity().Layer,
ServiceName: ps.Entity().ServiceName,
@@ -102,6 +99,20 @@ func (p *ProcessFinder) BuildEBPFProcess(ctx
*base.BuildEBPFProcessContext, ps b
ProcessName: ps.Entity().ProcessName,
Labels: ps.Entity().Labels,
}
+ hostProcess.Properties = []*commonv3.KeyStringValuePair{
+ {
+ Key: "host_ip",
+ Value: ctx.HostIP,
+ },
+ {
+ Key: "pid",
+ Value: strconv.FormatInt(int64(ps.Pid()), 10),
+ },
+ {
+ Key: "command_line",
+ Value: ps.(*Process).cmd,
+ },
+ }
properties := &v3.EBPFProcessProperties{Metadata:
&v3.EBPFProcessProperties_HostProcess{
HostProcess: hostProcess,
}}
@@ -200,10 +211,6 @@ func (p *ProcessFinder) agentFindProcesses()
([]base.DetectedProcess, error) {
for _, pro := range processes {
// already contains the processes
pid := pro.Pid
- if detectProcess := p.manager.QueryProcess(pid); detectProcess
!= nil {
- findedProcesses = append(findedProcesses, detectProcess)
- continue
- }
// if we cannot get temp directory, just ignore it
// May have some system process
@@ -214,7 +221,6 @@ func (p *ProcessFinder) agentFindProcesses()
([]base.DetectedProcess, error) {
metadataFilePath, metadataFile, err :=
p.tryingToGetAgentMetadataFile(pro, tmpDir)
if err != nil {
- log.Infof("found metadata file error, pid: %d, error:
%v", pid, err)
continue
}
@@ -319,7 +325,7 @@ func (p *ProcessFinder)
validateTheProcessesCouldProfiling(processes []*Process)
result := make([]*Process, 0)
for _, ps := range processes {
if err := p.validateProcessCouldProfiling(ps); err != nil {
- log.Warnf("could not read process exe file path, pid:
%d", ps.pid)
+ log.Warnf("could not read process exe file path, pid:
%d, err: %v", ps.pid, err)
continue
}
result = append(result, ps)
@@ -328,15 +334,9 @@ func (p *ProcessFinder)
validateTheProcessesCouldProfiling(processes []*Process)
}
func (p *ProcessFinder) validateProcessCouldProfiling(ps *Process) error {
- exe := p.tryToFindFileExecutePath(ps.original)
- if exe == "" {
- return fmt.Errorf("could not read process exe file path, pid:
%d", ps.pid)
- }
-
- // check support profiling
- pf, err := tools.ExecutableFileProfilingStat(exe)
+ pf, err := base.BuildProfilingStat(ps.original)
if err != nil {
- return fmt.Errorf("the process could not be profiling, so
ignored. pid: %d, reason: %v", ps.pid, err)
+ return err
}
ps.profiling = pf
return nil
@@ -450,7 +450,7 @@ func (p *ProcessFinder) findMatchesFinder(ps
*process.Process) (*RegexFinder, st
func validateConfig(conf *Config) error {
if conf.ScanMode == Agent {
var err error
- conf.Agent.ProcessStatusRefreshPeriodDuration, err =
durationMustNotNull(err, "process_status_refresh_period",
+ conf.Agent.ProcessStatusRefreshPeriodDuration, err =
base.DurationMustNotNull(err, "process_status_refresh_period",
conf.Agent.ProcessStatusRefreshPeriod)
return err
} else if conf.ScanMode != Regex {
@@ -463,11 +463,11 @@ func validateConfig(conf *Config) error {
// validate config
for _, f := range conf.RegexFinders {
var err error
- err = stringMustNotNull(err, "layer", f.Layer)
- f.commandlineRegex, err = regexMustNotNull(err,
"match_cmd_regex", f.MatchCommandRegex)
- f.serviceNameBuilder, err = templateMustNotNull(err,
"service_name", f.ServiceName)
- f.instanceNameBuilder, err = templateMustNotNull(err,
"instance_name", f.InstanceName)
- f.processNameBuilder, err = templateMustNotNull(err,
"process_name", f.ProcessName)
+ err = base.StringMustNotNull(err, "layer", f.Layer)
+ f.commandlineRegex, err = base.RegexMustNotNull(err,
"match_cmd_regex", f.MatchCommandRegex)
+ f.serviceNameBuilder, err = base.TemplateMustNotNull(err,
"service_name", f.ServiceName)
+ f.instanceNameBuilder, err = base.TemplateMustNotNull(err,
"instance_name", f.InstanceName)
+ f.processNameBuilder, err = base.TemplateMustNotNull(err,
"process_name", f.ProcessName)
f.ParsedLabels = parseLabels(f.LabelsStr)
if err != nil {
@@ -489,57 +489,6 @@ func parseLabels(labelStr string) []string {
return result
}
-func stringMustNotNull(err error, confKey, confValue string) error {
- if err != nil {
- return err
- }
- if confValue == "" {
- return fmt.Errorf("the %s of Scanner process must be set",
confKey)
- }
- return nil
-}
-
-func templateMustNotNull(err error, confKey, confValue string)
(*base.TemplateBuilder, error) {
- if err1 := stringMustNotNull(err, confKey, confValue); err1 != nil {
- return nil, err1
- }
- return base.NewTemplateBuilder(confKey, confValue)
-}
-
-func regexMustNotNull(err error, confKey, confValue string) (*regexp.Regexp,
error) {
- if err1 := stringMustNotNull(err, confKey, confValue); err1 != nil {
- return nil, err1
- }
- return regexp.Compile(confValue)
-}
-
-func durationMustNotNull(err error, confKey, confValue string) (time.Duration,
error) {
- if err1 := stringMustNotNull(err, confKey, confValue); err1 != nil {
- return 0, err1
- }
- return time.ParseDuration(confValue)
-}
-
-func (p *ProcessFinder) tryToFindFileExecutePath(ps *process.Process) string {
- exe, err := ps.Exe()
- if pathExists(exe, err) {
- return exe
- }
- cwd, err := ps.Cwd()
- if pathExists(cwd, err) && pathExists(cwd+"/"+exe, err) {
- return cwd + "/" + exe
- }
- linuxProcessRoot := host.GetFileInHost(fmt.Sprintf("/proc/%d/root",
ps.Pid))
- if pathExists(linuxProcessRoot, nil) {
- if pathExists(linuxProcessRoot+"/"+exe, nil) {
- return linuxProcessRoot + "/" + exe
- } else if pathExists(linuxProcessRoot+"/"+cwd+"/"+exe, nil) {
- return linuxProcessRoot + "/" + cwd + "/" + exe
- }
- }
- return ""
-}
-
func pathExists(exe string, err error) bool {
if err != nil {
return false
diff --git a/pkg/process/finders/scanner/template.go
b/pkg/process/finders/scanner/template.go
index 04fcdc3..f629744 100644
--- a/pkg/process/finders/scanner/template.go
+++ b/pkg/process/finders/scanner/template.go
@@ -27,7 +27,7 @@ func renderTemplate(builder *base.TemplateBuilder, process
*Process, finder *Pro
moduleManager := finder.manager.GetModuleManager()
return builder.Execute(&TemplateContext{
Rover: base.NewTemplateRover(moduleManager),
- Process: base.NewTemplateProcess(moduleManager, process),
+ Process: base.NewTemplateProcess(moduleManager,
process.OriginalProcess()),
Finder: &TemplateFinder{finder: finder, process: process},
})
}
diff --git a/pkg/process/finders/storage.go b/pkg/process/finders/storage.go
index 70f742a..8b5f03b 100644
--- a/pkg/process/finders/storage.go
+++ b/pkg/process/finders/storage.go
@@ -34,7 +34,7 @@ import (
)
type ProcessStorage struct {
- processes map[int32]*ProcessContext
+ processes map[int32]*processesWrapper
mutex sync.Mutex
// working with backend
@@ -50,7 +50,7 @@ type ProcessStorage struct {
func NewProcessStorage(ctx context.Context, moduleManager *module.Manager,
reportInterval time.Duration, finderList []base.ProcessFinder)
(*ProcessStorage, error) {
- data := make(map[int32]*ProcessContext)
+ data := make(map[int32]*processesWrapper)
// working with core module
coreOperator :=
moduleManager.FindModule(core.ModuleName).(core.Operator)
roverID := coreOperator.InstanceID()
@@ -104,11 +104,13 @@ func (s *ProcessStorage) reportAllProcesses() error {
// build process list(wait report or keep alive)
waitReportProcesses := make([]*ProcessContext, 0)
keepAliveProcesses := make([]*ProcessContext, 0)
- for _, p := range s.processes {
- if p.syncStatus == NotReport {
- waitReportProcesses = append(waitReportProcesses, p)
- } else if p.syncStatus == ReportSuccess {
- keepAliveProcesses = append(keepAliveProcesses, p)
+ for _, wrapper := range s.processes {
+ for _, p := range wrapper.processes {
+ if p.syncStatus == NotReport {
+ waitReportProcesses =
append(waitReportProcesses, p)
+ } else if p.syncStatus == ReportSuccess {
+ keepAliveProcesses = append(keepAliveProcesses,
p)
+ }
}
}
@@ -182,59 +184,78 @@ func (s *ProcessStorage)
processesReport(waitReportProcesses []*ProcessContext)
return nil
}
-func (s *ProcessStorage) QueryProcess(pid int32) base.DetectedProcess {
- processContext := s.processes[pid]
- if processContext != nil {
- return processContext.detectProcess
- }
- return nil
-}
-
func (s *ProcessStorage) SyncAllProcessInFinder(finder api.ProcessDetectType,
processes []base.DetectedProcess) {
s.mutex.Lock()
defer s.mutex.Unlock()
- pidToProcess := make(map[int32]base.DetectedProcess)
+ pidToProcess := make(map[int32]map[base.DetectedProcess]bool)
for _, ps := range processes {
- pidToProcess[ps.Pid()] = ps
+ samePidProcesses := pidToProcess[ps.Pid()]
+ if samePidProcesses == nil {
+ samePidProcesses = make(map[base.DetectedProcess]bool)
+ pidToProcess[ps.Pid()] = samePidProcesses
+ }
+ samePidProcesses[ps] = false
}
// for each all process in the manager
- for pid, managedProcess := range s.processes {
- needToSyncProcess := pidToProcess[pid]
+ for pid, managedProcesses := range s.processes {
+ needToSyncProcesses := pidToProcess[pid]
// remove it from the list of need to sync
- pidToProcess[pid] = nil
+ delete(pidToProcess, pid)
// The process to be synchronized is not found in all process
list
// And this process is same with finder type
// So we need to remove this process
- if needToSyncProcess == nil {
- if managedProcess.DetectType() == finder {
+ if needToSyncProcesses == nil {
+ if managedProcesses.deleteWithSameFinder(finder) {
delete(s.processes, pid)
}
continue
}
- // they are the not same detect type
- // TODO we just implement the Scanner mode process for now, so
continue
- if needToSyncProcess.DetectType() !=
managedProcess.DetectType() {
- continue
+ // build result for the pid
+ result := make([]*ProcessContext, 0)
+
+ // find out all need to be update process
+ for _, p := range managedProcesses.processes {
+ // if in difference detect type, keep the process data
+ if p.DetectType() != finder {
+ result = append(result, p)
+ continue
+ }
+
+ for update := range needToSyncProcesses {
+ // should only have one process if they have
the same layer and detect type
+ if update.Entity().Layer != p.Entity().Layer {
+ continue
+ }
+ tmp := p
+ if
!s.finders[finder].ValidateProcessIsSame(p.detectProcess, update) {
+ tmp =
s.constructNewProcessContext(finder, update)
+ }
+ result = append(result, tmp)
+ needToSyncProcesses[update] = true
+ break
+ }
}
- // check the entity is the same
- if
s.finders[needToSyncProcess.DetectType()].ValidateProcessIsSame(needToSyncProcess,
managedProcess.detectProcess) {
- continue
+ for p, hasSync := range needToSyncProcesses {
+ if !hasSync {
+ result = append(result,
s.constructNewProcessContext(finder, p))
+ }
}
- // different entity, so we need to remove oldest and add the
new process
- s.processes[pid] = s.constructNewProcessContext(finder,
needToSyncProcess)
+ s.processes[pid] = &processesWrapper{result}
}
// other processes are need to be added
for pid, ps := range pidToProcess {
- if ps != nil {
- s.processes[pid] = s.constructNewProcessContext(finder,
ps)
+ result := make([]*ProcessContext, 0)
+ for p := range ps {
+ result = append(result,
s.constructNewProcessContext(finder, p))
}
+ s.processes[pid] = &processesWrapper{result}
}
}
@@ -249,7 +270,7 @@ func (s *ProcessStorage) constructNewProcessContext(finder
api.ProcessDetectType
func (s *ProcessStorage) updateProcessToUploadSuccess(pc *ProcessContext, id
string) {
pc.id = id
pc.syncStatus = ReportSuccess
- log.Infof("uploaded process name: %s, id: %s",
pc.detectProcess.Entity().ProcessName, id)
+ log.Infof("uploaded process pid: %d, name: %s, id: %s",
pc.detectProcess.Pid(), pc.detectProcess.Entity().ProcessName, id)
}
func (s *ProcessStorage) updateProcessToUploadIgnored(pc *ProcessContext) {
@@ -257,10 +278,29 @@ func (s *ProcessStorage) updateProcessToUploadIgnored(pc
*ProcessContext) {
}
func (s *ProcessStorage) FindProcessByID(processID string)
api.ProcessInterface {
- for _, ps := range s.processes {
- if ps.id == processID {
- return ps
+ for _, wrapper := range s.processes {
+ for _, p := range wrapper.processes {
+ if p.id == processID {
+ return p
+ }
}
}
return nil
}
+
+// processesWrapper used to wrap multiple process context which has the same
pid
+// Usually they have difference entity
+type processesWrapper struct {
+ processes []*ProcessContext
+}
+
+func (w *processesWrapper) deleteWithSameFinder(finder api.ProcessDetectType)
bool {
+ existingProcesses := make([]*ProcessContext, 0)
+ for _, p := range w.processes {
+ if p.DetectType() != finder {
+ existingProcesses = append(existingProcesses, p)
+ }
+ }
+ w.processes = existingProcesses
+ return len(w.processes) == 0
+}
diff --git a/pkg/process/module.go b/pkg/process/module.go
index 74a9c41..f3f728e 100644
--- a/pkg/process/module.go
+++ b/pkg/process/module.go
@@ -56,7 +56,7 @@ func (m *Module) Start(ctx context.Context, mgr
*module.Manager) error {
if err != nil {
return err
}
- processManager, err := finders.NewProcessManager(ctx, mgr, period,
m.config.Scanner)
+ processManager, err := finders.NewProcessManager(ctx, mgr, period,
m.config.Scanner, m.config.Kubernetes)
if err != nil {
return err
}
diff --git a/pkg/tools/profiling/objdump.go b/pkg/tools/profiling/objdump.go
index a04bfd7..6d906f8 100644
--- a/pkg/tools/profiling/objdump.go
+++ b/pkg/tools/profiling/objdump.go
@@ -20,6 +20,7 @@ package profiling
import (
"bufio"
"bytes"
+ "fmt"
"os/exec"
"regexp"
"strconv"
@@ -52,7 +53,11 @@ func (o *ObjDump) Analyze(filepath string) (*Info, error) {
symbols := make([]*Symbol, 0)
scanner := bufio.NewScanner(bytes.NewReader(resBytes))
for scanner.Scan() {
- submatch := o.outputRegex.FindStringSubmatch(scanner.Text())
+ text := scanner.Text()
+ if text == "no symbols" {
+ return nil, fmt.Errorf("no symbols")
+ }
+ submatch := o.outputRegex.FindStringSubmatch(text)
if len(submatch) == 0 {
continue
}
diff --git a/scripts/build/docker.mk b/scripts/build/docker.mk
index ace697a..04136bb 100644
--- a/scripts/build/docker.mk
+++ b/scripts/build/docker.mk
@@ -16,8 +16,6 @@
# under the License.
#
-HUB ?= apache
-
.PHONY: docker
docker: build-base-container
docker build --build-arg VERSION=$(VERSION) --build-arg
BASE_IMAGE=${CONTAINER_COMMAND_IMAGE}:${CONTAINER_COMMAND_TAG} \
