mirror of
https://github.com/optim-enterprises-bv/kubernetes.git
synced 2025-12-09 17:45:35 +00:00
@@ -161,6 +161,11 @@ func (d *dispatcher) dispatchInvocations(
|
|||||||
}
|
}
|
||||||
|
|
||||||
invocationKey, invocationKeyErr := keyFor(invocation)
|
invocationKey, invocationKeyErr := keyFor(invocation)
|
||||||
|
if invocationKeyErr != nil {
|
||||||
|
// This should never happen. It occurs if there is a programming
|
||||||
|
// error causing the Param not to be a valid object.
|
||||||
|
return nil, k8serrors.NewInternalError(invocationKeyErr)
|
||||||
|
}
|
||||||
if reinvokeCtx.IsReinvoke() && !policyReinvokeCtx.ShouldReinvoke(invocationKey) {
|
if reinvokeCtx.IsReinvoke() && !policyReinvokeCtx.ShouldReinvoke(invocationKey) {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
@@ -169,12 +174,6 @@ func (d *dispatcher) dispatchInvocations(
|
|||||||
// Mutations for a single invocation of a MutatingAdmissionPolicy are evaluated
|
// Mutations for a single invocation of a MutatingAdmissionPolicy are evaluated
|
||||||
// in order.
|
// in order.
|
||||||
for mutationIndex := range invocation.Policy.Spec.Mutations {
|
for mutationIndex := range invocation.Policy.Spec.Mutations {
|
||||||
if invocationKeyErr != nil {
|
|
||||||
// This should never happen. It occurs if there is a programming
|
|
||||||
// error causing the Param not to be a valid object.
|
|
||||||
return nil, k8serrors.NewInternalError(invocationKeyErr)
|
|
||||||
}
|
|
||||||
|
|
||||||
lastVersionedAttr = versionedAttr
|
lastVersionedAttr = versionedAttr
|
||||||
if versionedAttr.VersionedObject == nil { // Do not call patchers if there is no object to patch.
|
if versionedAttr.VersionedObject == nil { // Do not call patchers if there is no object to patch.
|
||||||
continue
|
continue
|
||||||
|
|||||||
Reference in New Issue
Block a user