mirror of
https://github.com/vmware-tanzu/velero.git
synced 2026-01-06 13:26:26 +00:00
770ff142d7
Some checks failed
Run the E2E test on kind / build (push) Failing after 8m21s
Run the E2E test on kind / setup-test-matrix (push) Successful in 4s
Run the E2E test on kind / run-e2e-test (push) Has been skipped
Main CI / Build (push) Failing after 42s
Close stale issues and PRs / stale (push) Successful in 21s
Trivy Nightly Scan / Trivy nightly scan (velero, main) (push) Failing after 1m49s
Trivy Nightly Scan / Trivy nightly scan (velero-plugin-for-aws, main) (push) Failing after 1m17s
Trivy Nightly Scan / Trivy nightly scan (velero-plugin-for-gcp, main) (push) Failing after 3m30s
Trivy Nightly Scan / Trivy nightly scan (velero-plugin-for-microsoft-azure, main) (push) Failing after 3m12s
Signed-off-by: Xun Jiang <xun.jiang@broadcom.com>
84 lines
2.5 KiB
Go
84 lines
2.5 KiB
Go
/*
|
|
Copyright The Velero Contributors.
|
|
|
|
Licensed 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 exposer
|
|
|
|
import (
|
|
"context"
|
|
"strings"
|
|
|
|
"github.com/pkg/errors"
|
|
corev1api "k8s.io/api/core/v1"
|
|
"k8s.io/client-go/kubernetes"
|
|
|
|
"github.com/vmware-tanzu/velero/pkg/nodeagent"
|
|
)
|
|
|
|
type inheritedPodInfo struct {
|
|
image string
|
|
serviceAccount string
|
|
env []corev1api.EnvVar
|
|
envFrom []corev1api.EnvFromSource
|
|
volumeMounts []corev1api.VolumeMount
|
|
volumes []corev1api.Volume
|
|
logLevelArgs []string
|
|
logFormatArgs []string
|
|
dnsPolicy corev1api.DNSPolicy
|
|
dnsConfig *corev1api.PodDNSConfig
|
|
imagePullSecrets []corev1api.LocalObjectReference
|
|
}
|
|
|
|
func getInheritedPodInfo(ctx context.Context, client kubernetes.Interface, veleroNamespace string, osType string) (inheritedPodInfo, error) {
|
|
podInfo := inheritedPodInfo{}
|
|
|
|
podSpec, err := nodeagent.GetPodSpec(ctx, client, veleroNamespace, osType)
|
|
if err != nil {
|
|
return podInfo, errors.Wrap(err, "error to get node-agent pod template")
|
|
}
|
|
|
|
if len(podSpec.Containers) != 1 {
|
|
return podInfo, errors.New("unexpected pod template from node-agent")
|
|
}
|
|
|
|
podInfo.image = podSpec.Containers[0].Image
|
|
podInfo.serviceAccount = podSpec.ServiceAccountName
|
|
|
|
podInfo.env = podSpec.Containers[0].Env
|
|
podInfo.envFrom = podSpec.Containers[0].EnvFrom
|
|
podInfo.volumeMounts = podSpec.Containers[0].VolumeMounts
|
|
podInfo.volumes = podSpec.Volumes
|
|
|
|
podInfo.dnsPolicy = podSpec.DNSPolicy
|
|
podInfo.dnsConfig = podSpec.DNSConfig
|
|
|
|
args := podSpec.Containers[0].Args
|
|
for i, arg := range args {
|
|
if arg == "--log-format" {
|
|
podInfo.logFormatArgs = append(podInfo.logFormatArgs, args[i:i+2]...)
|
|
} else if strings.HasPrefix(arg, "--log-format") {
|
|
podInfo.logFormatArgs = append(podInfo.logFormatArgs, arg)
|
|
} else if arg == "--log-level" {
|
|
podInfo.logLevelArgs = append(podInfo.logLevelArgs, args[i:i+2]...)
|
|
} else if strings.HasPrefix(arg, "--log-level") {
|
|
podInfo.logLevelArgs = append(podInfo.logLevelArgs, arg)
|
|
}
|
|
}
|
|
|
|
podInfo.imagePullSecrets = podSpec.ImagePullSecrets
|
|
|
|
return podInfo, nil
|
|
}
|