src/monitor/pkg/controller/resourcebundlestate/service_predicate.go

   1 package resourcebundlestate
   2
   3 import (
   4         "sigs.k8s.io/controller-runtime/pkg/event"
   5 )
   6
   7 type servicePredicate struct {
   8 }
   9
  10 func (s *servicePredicate) Create(evt event.CreateEvent) bool {
  11
  12         if evt.Meta == nil {
  13                 return false
  14         }
  15
  16         labels := evt.Meta.GetLabels()
  17         return checkLabel(labels)
  18 }
  19
  20 func (s *servicePredicate) Delete(evt event.DeleteEvent) bool {
  21
  22         if evt.Meta == nil {
  23                 return false
  24         }
  25
  26         labels := evt.Meta.GetLabels()
  27         return checkLabel(labels)
  28 }
  29
  30 func (s *servicePredicate) Update(evt event.UpdateEvent) bool {
  31
  32         if evt.MetaNew == nil {
  33                 return false
  34         }
  35
  36         labels := evt.MetaNew.GetLabels()
  37         return checkLabel(labels)
  38 }
  39
  40 func (s *servicePredicate) Generic(evt event.GenericEvent) bool {
  41
  42         labels := evt.Meta.GetLabels()
  43         return checkLabel(labels)
  44 }