github/capsule
1
0
Fork 0
mirror of https://github.com/projectcapsule/capsule.git synced 2026-08-19 04:26:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: providing event for Tenant cordoning

Browse Source
This commit is contained in:
Dario Tranchitella
2021-06-24 13:47:43 +02:00
parent 9a940096c9
commit b3c6082a1e
1 changed files with 20 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/webhook/tenant/validating.go
+20 -1
View File
@@ -8,6 +8,7 @@ import (
"fmt"
"regexp"
v1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/fields"
"k8s.io/client-go/tools/record"
"sigs.k8s.io/controller-runtime/pkg/client"
@@ -169,11 +170,29 @@ func (h *validatingHandler) OnDelete(client.Client, *admission.Decoder, record.E
}
}
func (h *validatingHandler) OnUpdate(client client.Client, decoder *admission.Decoder, _ record.EventRecorder) capsulewebhook.Func {
func (h *validatingHandler) OnUpdate(client client.Client, decoder *admission.Decoder, recorder record.EventRecorder) capsulewebhook.Func {
return func(ctx context.Context, req admission.Request) admission.Response {
if err := h.validateTenant(ctx, req, client, decoder); err != nil {
return admission.Denied(err.Error())
}
oldTnt := &v1alpha1.Tenant{}
if err := decoder.DecodeRaw(req.OldObject, oldTnt); err != nil {
return admission.Denied(err.Error())
}
newTnt := &v1alpha1.Tenant{}
if err := decoder.Decode(req, newTnt); err != nil {
return admission.Denied(err.Error())
}
switch {
case !oldTnt.IsCordoned() && newTnt.IsCordoned():
recorder.Eventf(newTnt, v1.EventTypeNormal, "TenantCordoned", "Tenant has been cordoned")
case oldTnt.IsCordoned() && !newTnt.IsCordoned():
recorder.Eventf(newTnt, v1.EventTypeNormal, "TenantUncordoned", "Tenant has been uncordoned")
}
return admission.Allowed("")
}
}