in pkg/condition/conditions.go [178:206]
func (c *condition) IsPodSGPEnabled() bool {
daemonSet, err := c.K8sAPI.GetDaemonSet(config.VpcCNIDaemonSetName,
config.KubeSystemNamespace)
if err != nil {
if errors.IsNotFound(err) {
c.log.Info("aws-node ds is not present")
return false
}
c.log.Error(err, "failed to get aws-node")
return false
}
var isSGPEnabled bool
for _, container := range daemonSet.Spec.Template.Spec.Containers {
if container.Name == "aws-node" {
for _, env := range container.Env {
if env.Name == "ENABLE_POD_ENI" {
isSGPEnabled, err = strconv.ParseBool(env.Value)
if err != nil {
c.log.Error(err, "failed to parse ENABLE_POD_ENI", "value", env.Value)
return false
}
break
}
}
}
}
return isSGPEnabled
}