github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-06-20 13:33:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

⚡ Add GODEBUG=netdns=go environment variable to worker

Browse Source
This commit is contained in:
M. Mert Yildiran 2023-02-04 03:27:12 +03:00
parent 17e038e703
commit 22e8490b93
No known key found for this signature in database
GPG Key ID: DA5D6DCBB758A461
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
kubernetes/provider.go
View File

@ -26,6 +26,7 @@ import (
"k8s.io/apimachinery/pkg/watch" "k8s.io/apimachinery/pkg/watch"
applyconfapp "k8s.io/client-go/applyconfigurations/apps/v1" applyconfapp "k8s.io/client-go/applyconfigurations/apps/v1"
applyconfcore "k8s.io/client-go/applyconfigurations/core/v1" applyconfcore "k8s.io/client-go/applyconfigurations/core/v1"
v1 "k8s.io/client-go/applyconfigurations/core/v1"
applyconfmeta "k8s.io/client-go/applyconfigurations/meta/v1" applyconfmeta "k8s.io/client-go/applyconfigurations/meta/v1"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
_ "k8s.io/client-go/plugin/pkg/client/auth" _ "k8s.io/client-go/plugin/pkg/client/auth"
@ -711,14 +712,17 @@ func (provider *Provider) ApplyWorkerDaemonSet(
workerContainer.WithCommand(command...) workerContainer.WithCommand(command...)
var envvars []*v1.EnvVarApplyConfiguration
envvars = append(envvars, applyconfcore.EnvVar().WithName("GODEBUG").WithValue("netdns=go"))
if debug { if debug {
workerContainer.WithEnv( envvars = append(envvars, applyconfcore.EnvVar().WithName("MEMORY_PROFILING_ENABLED").WithValue("true"))
applyconfcore.EnvVar().WithName("MEMORY_PROFILING_ENABLED").WithValue("true"), envvars = append(envvars, applyconfcore.EnvVar().WithName("MEMORY_PROFILING_INTERVAL_SECONDS").WithValue("10"))
applyconfcore.EnvVar().WithName("MEMORY_PROFILING_INTERVAL_SECONDS").WithValue("10"), envvars = append(envvars, applyconfcore.EnvVar().WithName("MEMORY_USAGE_INTERVAL_MILLISECONDS").WithValue("500"))
applyconfcore.EnvVar().WithName("MEMORY_USAGE_INTERVAL_MILLISECONDS").WithValue("500"),
)
} }
workerContainer.WithEnv(envvars...)
cpuLimit, err := resource.ParseQuantity(resources.CpuLimit) cpuLimit, err := resource.ParseQuantity(resources.CpuLimit)
if err != nil { if err != nil {
return fmt.Errorf("invalid cpu limit for %s container", workerPodName) return fmt.Errorf("invalid cpu limit for %s container", workerPodName)