func()

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
}