scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-03 19:58:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #106399 from justinsb/populate_event_typemetad

Browse Source 
leaderelection: populate the apiVersion/kind when reporting events
This commit is contained in:
Kubernetes Prow Robot
2021-11-15 09:05:00 -08:00
committed by GitHub
parent da73a24f6a 3bf06ff3a1
commit ed3d9f7b48
3 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
staging/src/k8s.io/client-go/tools/leaderelection/resourcelock/configmaplock.go
View File

@@ -107,7 +107,11 @@ func (cml *ConfigMapLock) RecordEvent(s string) {
return return
} }
events := fmt.Sprintf("%v %v", cml.LockConfig.Identity, s) events := fmt.Sprintf("%v %v", cml.LockConfig.Identity, s)
cml.LockConfig.EventRecorder.Eventf(&v1.ConfigMap{ObjectMeta: cml.cm.ObjectMeta}, v1.EventTypeNormal, "LeaderElection", events) subject := &v1.ConfigMap{ObjectMeta: cml.cm.ObjectMeta}
// Populate the type meta, so we don't have to get it from the schema
subject.Kind = "ConfigMap"
subject.APIVersion = v1.SchemeGroupVersion.String()
cml.LockConfig.EventRecorder.Eventf(subject, v1.EventTypeNormal, "LeaderElection", events)
} }
// Describe is used to convert details on current resource lock // Describe is used to convert details on current resource lock

6
staging/src/k8s.io/client-go/tools/leaderelection/resourcelock/endpointslock.go
View File

@@ -102,7 +102,11 @@ func (el *EndpointsLock) RecordEvent(s string) {
return return
} }
events := fmt.Sprintf("%v %v", el.LockConfig.Identity, s) events := fmt.Sprintf("%v %v", el.LockConfig.Identity, s)
el.LockConfig.EventRecorder.Eventf(&v1.Endpoints{ObjectMeta: el.e.ObjectMeta}, v1.EventTypeNormal, "LeaderElection", events) subject := &v1.Endpoints{ObjectMeta: el.e.ObjectMeta}
// Populate the type meta, so we don't have to get it from the schema
subject.Kind = "Endpoints"
subject.APIVersion = v1.SchemeGroupVersion.String()
el.LockConfig.EventRecorder.Eventf(subject, v1.EventTypeNormal, "LeaderElection", events)
} }
// Describe is used to convert details on current resource lock // Describe is used to convert details on current resource lock

6
staging/src/k8s.io/client-go/tools/leaderelection/resourcelock/leaselock.go
View File

@@ -87,7 +87,11 @@ func (ll *LeaseLock) RecordEvent(s string) {
return return
} }
events := fmt.Sprintf("%v %v", ll.LockConfig.Identity, s) events := fmt.Sprintf("%v %v", ll.LockConfig.Identity, s)
ll.LockConfig.EventRecorder.Eventf(&coordinationv1.Lease{ObjectMeta: ll.lease.ObjectMeta}, corev1.EventTypeNormal, "LeaderElection", events) subject := &coordinationv1.Lease{ObjectMeta: ll.lease.ObjectMeta}
// Populate the type meta, so we don't have to get it from the schema
subject.Kind = "Lease"
subject.APIVersion = coordinationv1.SchemeGroupVersion.String()
ll.LockConfig.EventRecorder.Eventf(subject, corev1.EventTypeNormal, "LeaderElection", events)
} }
// Describe is used to convert details on current resource lock // Describe is used to convert details on current resource lock