policies/opa/gatekeeper/node-selector/validate/constraint-templates/4-affinity-constraint-template-pod.yaml (107 lines of code) (raw):
apiVersion: templates.gatekeeper.sh/v1beta1
kind: ConstraintTemplate
metadata:
name: k8srequirednodeaffinitypod
spec:
crd:
spec:
names:
kind: K8sRequiredNodeAffinityPod
validation:
# Schema for the `parameters` field
openAPIV3Schema:
properties:
ops:
type: array
items:
type: string
nodeAffinity:
type: object
properties:
requiredDuringSchedulingIgnoredDuringExecution:
type: object
properties:
nodeSelectorTerms:
type: array
items:
type: object
properties:
matchExpressions:
type: array
items:
type: object
properties:
key:
type: string
operator:
type: string
values:
type: array
items:
type: string
errMsg:
type: string
targets:
- target: admission.k8s.gatekeeper.sh
libs:
- |
package lib.k8s.helpers
allowed_operations = value {
value := {"CREATE", "UPDATE"}
}
review_operation = value {
value := input.review.operation
}
review_metadata_labels = value {
value := input.review.object.metadata.labels
}
review_spec_template_metadata_labels = value {
value := input.review.object.spec.template.metadata.labels
}
deployment_error = value {
value := "DEPLOYMENT_INVALID"
}
deployment_containers = value {
value := input.review.object.spec.template.spec.containers
}
deployment_role = value {
value := input.review.object.spec.template.metadata.annotations["iam.amazonaws.com/role"]
}
review_id = value {
value := sprintf("%v/%v/%v", [
review_namespace,
review_name,
review_kind
])
}
review_name = value {
value := input.review.object.metadata.name
}
else = value {
value := "NOT_FOUND"
}
review_namespace = value {
value := input.review.object.metadata.namespace
}
else = value {
value := "NOT_FOUND"
}
review_kind = value {
value := input.review.kind.kind
}
else = value {
value := "NOT_FOUND"
}
review_tolerations = value {
value := input.review.object.spec.template.spec.tolerations
}
rego: |
package k8srequirednodeaffinity
import data.lib.k8s.helpers as helpers
violation[{"msg": msg, "details": {"missing":missing}}] {
input.review.operation == input.parameters.ops[_]
provided := {x | x := input.review.object.spec.affinity.nodeAffinity}
required := {x | x := input.parameters.nodeAffinity}
missing := required - provided
count(missing) > 0
msg := sprintf("%v: Resource missing correct node affinity. Provided node affinity: %v, Required node affinity: %v. Resource ID (ns/name/kind): %v", [input.parameters.errMsg,provided,required,helpers.review_id])
}