handlers

Documentation

Index

• type ConfigMapHandler
  • func NewConfigMapHandler(log logr.Logger, as *reftracker.AppRefTracker, aus *reftracker.AppUpdateStatus) *ConfigMapHandler
  • func (sch *ConfigMapHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (sch *ConfigMapHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (sch *ConfigMapHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (sch *ConfigMapHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type PackageInstallVersionHandler
  • func NewPackageInstallVersionHandler(c kcclient.Interface, globalNS string, log logr.Logger) *PackageInstallVersionHandler
  • func (ipvh *PackageInstallVersionHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (ipvh *PackageInstallVersionHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (ipvh *PackageInstallVersionHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (ipvh *PackageInstallVersionHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type SecretHandler
  • func NewSecretHandler(log logr.Logger, as *reftracker.AppRefTracker, aus *reftracker.AppUpdateStatus) *SecretHandler
  • func (sch *SecretHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (sch *SecretHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (sch *SecretHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (sch *SecretHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Types

type ConfigMapHandler

type ConfigMapHandler struct {
	// contains filtered or unexported fields
}

func NewConfigMapHandler

func NewConfigMapHandler(log logr.Logger, as *reftracker.AppRefTracker, aus *reftracker.AppUpdateStatus) *ConfigMapHandler

func (*ConfigMapHandler) Create

func (sch *ConfigMapHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*ConfigMapHandler) Delete

func (sch *ConfigMapHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*ConfigMapHandler) Generic

func (sch *ConfigMapHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*ConfigMapHandler) Update

func (sch *ConfigMapHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type PackageInstallVersionHandler

type PackageInstallVersionHandler struct {
	// contains filtered or unexported fields
}

TODO For this PoC, we are simply going to add all packages to the workqueue, but in the future, we will only enqueue the packages that are eligible for upgrade based on the new packages

func NewPackageInstallVersionHandler

func NewPackageInstallVersionHandler(c kcclient.Interface, globalNS string, log logr.Logger) *PackageInstallVersionHandler

func (*PackageInstallVersionHandler) Create

func (ipvh *PackageInstallVersionHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*PackageInstallVersionHandler) Delete

func (ipvh *PackageInstallVersionHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*PackageInstallVersionHandler) Generic

func (ipvh *PackageInstallVersionHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*PackageInstallVersionHandler) Update

func (ipvh *PackageInstallVersionHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type SecretHandler

type SecretHandler struct {
	// contains filtered or unexported fields
}

func NewSecretHandler

func NewSecretHandler(log logr.Logger, as *reftracker.AppRefTracker, aus *reftracker.AppUpdateStatus) *SecretHandler

func (*SecretHandler) Create

func (sch *SecretHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*SecretHandler) Delete

func (sch *SecretHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*SecretHandler) Generic

func (sch *SecretHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*SecretHandler) Update

func (sch *SecretHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)