diff options
author | 2020-08-31 22:46:10 +0000 | |
---|---|---|
committer | 2020-09-25 18:43:36 +0000 | |
commit | 425795c7d4e6ce81932918aca2a1462384d4507f (patch) | |
tree | 68f9793b29b3d282e62426ab52669319b4dfd4eb /src/monitor/pkg/controller/resourcebundlestate/csr_predicate.go | |
parent | 8b5c4236639a46f39cbfe852590f34e64f58a85a (diff) |
Introduce Monitor support for CSR resource
These changes allow the Monitor to also track CSR
(CertificateSigningResource) resources which will make
it possible to know when a certificate has been issued by
the K8s cluster signer. In turn, DCM will be able to read,
store and use that certificate to generate kubeconfigs.
Out-of-tree actions required:
- publish monitor's docker image built from this source
onto emcov2/monitor:latest
Issue-ID: MULTICLOUD-1143
Change-Id: I7facd27bbfe08891151bb3b6a9a19948435e24e4
Signed-off-by: Igor D.C <igor.duarte.cardoso@intel.com>
Diffstat (limited to 'src/monitor/pkg/controller/resourcebundlestate/csr_predicate.go')
-rw-r--r-- | src/monitor/pkg/controller/resourcebundlestate/csr_predicate.go | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/src/monitor/pkg/controller/resourcebundlestate/csr_predicate.go b/src/monitor/pkg/controller/resourcebundlestate/csr_predicate.go new file mode 100644 index 00000000..cb83eec1 --- /dev/null +++ b/src/monitor/pkg/controller/resourcebundlestate/csr_predicate.go @@ -0,0 +1,44 @@ +package resourcebundlestate + +import ( + "sigs.k8s.io/controller-runtime/pkg/event" +) + +type csrPredicate struct { +} + +func (p *csrPredicate) Create(evt event.CreateEvent) bool { + + if evt.Meta == nil { + return false + } + + labels := evt.Meta.GetLabels() + return checkLabel(labels) +} + +func (p *csrPredicate) Delete(evt event.DeleteEvent) bool { + + if evt.Meta == nil { + return false + } + + labels := evt.Meta.GetLabels() + return checkLabel(labels) +} + +func (p *csrPredicate) Update(evt event.UpdateEvent) bool { + + if evt.MetaNew == nil { + return false + } + + labels := evt.MetaNew.GetLabels() + return checkLabel(labels) +} + +func (p *csrPredicate) Generic(evt event.GenericEvent) bool { + + labels := evt.Meta.GetLabels() + return checkLabel(labels) +} |