Skip to content

Commit

Permalink
Fix: handling unexpected global-anchor-variable for the apply command
Browse files Browse the repository at this point in the history
Signed-off-by: ansalamdaniel <ansalam.daniel@infracloud.io>
  • Loading branch information
ansalamdaniel committed Nov 28, 2022
1 parent 92e5b3a commit 5e9352c
Show file tree
Hide file tree
Showing 6 changed files with 159 additions and 1 deletion.
20 changes: 19 additions & 1 deletion pkg/engine/mutate/patch/strategicPreprocessing.go
Original file line number Diff line number Diff line change
Expand Up @@ -137,9 +137,9 @@ func processListOfMaps(logger logr.Logger, pattern, resource *yaml.RNode) error
if hasAnyAnchor {
anyGlobalConditionPassed := false
var lastGlobalAnchorError error = nil
patternElementCopy := patternElement.Copy()

for _, resourceElement := range resourceElements {
patternElementCopy := patternElement.Copy()
if err := preProcessRecursive(logger, patternElementCopy, resourceElement); err != nil {
logger.V(3).Info("anchor mismatch", "reason", err.Error())
if isConditionError(err) {
Expand All @@ -163,7 +163,25 @@ func processListOfMaps(logger logr.Logger, pattern, resource *yaml.RNode) error
}
}
}
if resource == nil {
if err := preProcessRecursive(logger, patternElementCopy, resource); err != nil {
logger.V(3).Info("anchor mismatch", "reason", err.Error())
if isConditionError(err) {
continue
}

if isGlobalConditionError(err) {
lastGlobalAnchorError = err
}

return err
}

if hasGlobalConditions {
// global anchor has passed, there is no need to return an error
anyGlobalConditionPassed = true
}
}
if !anyGlobalConditionPassed && lastGlobalAnchorError != nil {
return lastGlobalAnchorError
}
Expand Down
28 changes: 28 additions & 0 deletions test/cli/test-mutate/global-anchor/kyverno-test.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,28 @@
name: validate-service-loadbalancer
policies:
- policy.yaml
resources:
- resources.yaml
results:
- policy: add-safe-to-evict
rule: annotate-empty-dir
resource: pod-without-emptydir-hostpath
kind: Pod
result: skip
- policy: add-safe-to-evict
rule: annotate-empty-dir
resource: pod-with-emptydir-hostpath
patchedResource: patchedResource.yaml
kind: Pod
result: pass
- policy: add-safe-to-evict
rule: annotate-empty-dir
resource: pod-with-emptydir-hostpath-1
patchedResource: patchedResource1.yaml
kind: Pod
result: pass
- policy: add-safe-to-evict
rule: annotate-empty-dir
resource: pod-without-emptydir-hostpath-1
kind: Pod
result: skip
14 changes: 14 additions & 0 deletions test/cli/test-mutate/global-anchor/patchedResource.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
apiVersion: v1
kind: Pod
metadata:
annotations:
cluster-autoscaler.kubernetes.io/safe-to-evict: "true"
name: pod-with-emptydir-hostpath
namespace: default
spec:
containers:
- image: nginx
name: nginx
volumes:
- name: demo-volume
emptyDir: {}
18 changes: 18 additions & 0 deletions test/cli/test-mutate/global-anchor/patchedResource1.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
apiVersion: v1
kind: Pod
metadata:
annotations:
cluster-autoscaler.kubernetes.io/safe-to-evict: "true"
name: pod-with-emptydir-hostpath-1
namespace: default
spec:
containers:
- image: nginx
name: nginx
volumeMounts:
- mountPath: /cache
name: cache-volume
volumes:
- name: cache-volume
emptyDir:
sizeLimit: 500Mi
25 changes: 25 additions & 0 deletions test/cli/test-mutate/global-anchor/policy.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
apiVersion: kyverno.io/v1
kind: ClusterPolicy
metadata:
name: add-safe-to-evict
annotations:
policies.kyverno.io/category: Workload Management
policies.kyverno.io/description: The Kubernetes cluster autoscaler does not evict pods that
use hostPath or emptyDir volumes. To allow eviction of these pods, the annotation
cluster-autoscaler.kubernetes.io/safe-to-evict=true must be added to the pods.
spec:
rules:
- name: annotate-empty-dir
match:
any:
- resources:
kinds:
- Pod
mutate:
patchStrategicMerge:
metadata:
annotations:
+(cluster-autoscaler.kubernetes.io/safe-to-evict): "true"
spec:
volumes:
- <(emptyDir): {}
55 changes: 55 additions & 0 deletions test/cli/test-mutate/global-anchor/resources.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,55 @@
apiVersion: v1
kind: Pod
metadata:
name: pod-without-emptydir-hostpath
spec:
containers:
- name: nginx
image: nginx
---
apiVersion: v1
kind: Pod
metadata:
name: pod-with-emptydir-hostpath
spec:
containers:
- name: nginx
image: nginx
volumes:
- name: demo-volume
emptyDir: {}
---
apiVersion: v1
kind: Pod
metadata:
name: pod-with-emptydir-hostpath-1
spec:
containers:
- name: nginx
image: nginx
volumeMounts:
- mountPath: /cache
name: cache-volume
volumes:
- name: cache-volume
emptyDir:
sizeLimit: 500Mi
---
apiVersion: v1
kind: Pod
metadata:
name: pod-without-emptydir-hostpath-1
spec:
containers:
- name: nginx
image: nginx
volumeMounts:
- name: config-vol
mountPath: /etc/config
volumes:
- name: config-vol
configMap:
name: log-config
items:
- key: log_level
path: log_level

0 comments on commit 5e9352c

Please sign in to comment.