mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-03-28 18:38:40 +00:00
Code Activity

rename file, move append events

Browse source
This commit is contained in:
shivdudhani 2019-05-06 10:30:44 -07:00
parent bd1a84190b
commit 8af86ab002
1 changed files with 14 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
pkg/violation/violation.go → pkg/violation/builder.go
View file

@ -63,8 +63,16 @@ func (b *builder) ProcessViolation(info utils.ViolationInfo) error {
modifiedPolicy := policy.DeepCopy()
modifiedViolations := []types.Violation{}
// Create new violation
newViolation := types.Violation{
Kind: info.Kind,
Resource: info.Resource,
Rule: info.Rule,
Reason: info.Reason,
Message: info.Message,
}
for _, violation := range modifiedPolicy.PolicyViolation.Violations {
ok, err := b.IsActive(info.Kind, info.Resource)
ok, err := b.IsActive(info.Kind, violation.Resource)
if err != nil {
utilruntime.HandleError(err)
continue
@ -74,7 +82,7 @@ func (b *builder) ProcessViolation(info utils.ViolationInfo) error {
// Create a removal event
b.eventBuilder.AddEvent(eventutils.EventInfo{
Kind: "Policy",
Resource: info.Resource,
Resource: info.Policy,
Rule: info.Rule,
Reason: info.Reason,
Message: info.Message,
@ -82,14 +90,10 @@ func (b *builder) ProcessViolation(info utils.ViolationInfo) error {
continue
}
// If violation already exists for this rule, we update the violation
if violation.Kind == info.Kind &&
violation.Resource == info.Resource &&
violation.Rule == info.Rule {
violation.Reason = info.Reason
violation.Message = info.Message
}
modifiedViolations = append(modifiedViolations, violation)
//TODO: update violation, instead of re-creating one every time
}
modifiedViolations = append(modifiedViolations, newViolation)
modifiedPolicy.PolicyViolation.Violations = modifiedViolations
return b.Patch(policy, modifiedPolicy)
@ -122,6 +126,7 @@ func (b *builder) Patch(policy *types.Policy, updatedPolicy *types.Policy) error
}
_, err = b.controller.PatchPolicy(policy.Name, mergetypes.MergePatchType, patchBytes)
if err != nil {
// Unable to patch
return err
}