mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-04-30 12:56:03 +00:00
73 lines
2.3 KiB
Go
73 lines
2.3 KiB
Go
package kubernetes
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/kubeshark/kubeshark/config"
|
|
"github.com/rs/zerolog/log"
|
|
v1 "k8s.io/api/core/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
)
|
|
|
|
const (
|
|
SUFFIX_SECRET = "secret"
|
|
SUFFIX_CONFIG_MAP = "config-map"
|
|
SECRET_LICENSE = "LICENSE"
|
|
CONFIG_POD_REGEX = "POD_REGEX"
|
|
CONFIG_NAMESPACES = "NAMESPACES"
|
|
CONFIG_EXCLUDED_NAMESPACES = "EXCLUDED_NAMESPACES"
|
|
CONFIG_SCRIPTING_ENV = "SCRIPTING_ENV"
|
|
CONFIG_INGRESS_ENABLED = "INGRESS_ENABLED"
|
|
CONFIG_INGRESS_HOST = "INGRESS_HOST"
|
|
CONFIG_PROXY_FRONT_PORT = "PROXY_FRONT_PORT"
|
|
CONFIG_AUTH_ENABLED = "AUTH_ENABLED"
|
|
CONFIG_AUTH_TYPE = "AUTH_TYPE"
|
|
CONFIG_AUTH_SAML_IDP_METADATA_URL = "AUTH_SAML_IDP_METADATA_URL"
|
|
)
|
|
|
|
func SetSecret(provider *Provider, key string, value string) (updated bool, err error) {
|
|
var secret *v1.Secret
|
|
secret, err = provider.clientSet.CoreV1().Secrets(config.Config.Tap.Release.Namespace).Get(context.TODO(), SELF_RESOURCES_PREFIX+SUFFIX_SECRET, metav1.GetOptions{})
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
if secret.StringData[key] != value {
|
|
updated = true
|
|
}
|
|
secret.Data[key] = []byte(value)
|
|
|
|
_, err = provider.clientSet.CoreV1().Secrets(config.Config.Tap.Release.Namespace).Update(context.TODO(), secret, metav1.UpdateOptions{})
|
|
if err == nil {
|
|
if updated {
|
|
log.Info().Str("secret", key).Str("value", value).Msg("Updated:")
|
|
}
|
|
} else {
|
|
log.Error().Str("secret", key).Err(err).Send()
|
|
}
|
|
return
|
|
}
|
|
|
|
func SetConfig(provider *Provider, key string, value string) (updated bool, err error) {
|
|
var configMap *v1.ConfigMap
|
|
configMap, err = provider.clientSet.CoreV1().ConfigMaps(config.Config.Tap.Release.Namespace).Get(context.TODO(), SELF_RESOURCES_PREFIX+SUFFIX_CONFIG_MAP, metav1.GetOptions{})
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
if configMap.Data[key] != value {
|
|
updated = true
|
|
}
|
|
configMap.Data[key] = value
|
|
|
|
_, err = provider.clientSet.CoreV1().ConfigMaps(config.Config.Tap.Release.Namespace).Update(context.TODO(), configMap, metav1.UpdateOptions{})
|
|
if err == nil {
|
|
if updated {
|
|
log.Info().Str("config", key).Str("value", value).Msg("Updated:")
|
|
}
|
|
} else {
|
|
log.Error().Str("config", key).Err(err).Send()
|
|
}
|
|
return
|
|
}
|