event

Documentation

Index

• func AddOnHealthResyncHandler(c client.Client, interval time.Duration) (*source.Channel, handler.EventHandler)
• func StartBackgroundExternalTimerResync(g GeneratorFunc, interval time.Duration) *source.Channel
• type APIServiceHandler
  • func (a *APIServiceHandler) Create(event event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (a *APIServiceHandler) Delete(event event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (a *APIServiceHandler) Generic(event event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (a *APIServiceHandler) Update(event event.UpdateEvent, q workqueue.RateLimitingInterface)
• type AddonHealthHandler
  • func (a AddonHealthHandler) Create(createEvent event.CreateEvent, ...)
  • func (a AddonHealthHandler) Delete(deleteEvent event.DeleteEvent, ...)
  • func (a AddonHealthHandler) Generic(genericEvent event.GenericEvent, ...)
  • func (a AddonHealthHandler) Update(updateEvent event.UpdateEvent, ...)
• type ClusterGatewayConfigurationHandler
  • func (c *ClusterGatewayConfigurationHandler) Create(event event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (c *ClusterGatewayConfigurationHandler) Delete(event event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (c *ClusterGatewayConfigurationHandler) Generic(event event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (c *ClusterGatewayConfigurationHandler) Update(event event.UpdateEvent, q workqueue.RateLimitingInterface)
• type GeneratorFunc
• type SecretHandler
  • func (s *SecretHandler) Create(event event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (s *SecretHandler) Delete(event event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (s *SecretHandler) Generic(event event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (s *SecretHandler) Update(event event.UpdateEvent, q workqueue.RateLimitingInterface)

Functions

func AddOnHealthResyncHandler

func AddOnHealthResyncHandler(c client.Client, interval time.Duration) (*source.Channel, handler.EventHandler)

func StartBackgroundExternalTimerResync

func StartBackgroundExternalTimerResync(g GeneratorFunc, interval time.Duration) *source.Channel

Types

type APIServiceHandler

type APIServiceHandler struct {
	WatchingName string
}

func (*APIServiceHandler) Create

func (a *APIServiceHandler) Create(event event.CreateEvent, q workqueue.RateLimitingInterface)

func (*APIServiceHandler) Delete

func (a *APIServiceHandler) Delete(event event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*APIServiceHandler) Generic

func (a *APIServiceHandler) Generic(event event.GenericEvent, q workqueue.RateLimitingInterface)

func (*APIServiceHandler) Update

func (a *APIServiceHandler) Update(event event.UpdateEvent, q workqueue.RateLimitingInterface)

type AddonHealthHandler

type AddonHealthHandler struct {
}

func (AddonHealthHandler) Create

func (a AddonHealthHandler) Create(createEvent event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)

func (AddonHealthHandler) Delete

func (a AddonHealthHandler) Delete(deleteEvent event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)

func (AddonHealthHandler) Generic

func (a AddonHealthHandler) Generic(genericEvent event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)

func (AddonHealthHandler) Update

func (a AddonHealthHandler) Update(updateEvent event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)

type ClusterGatewayConfigurationHandler

type ClusterGatewayConfigurationHandler struct {
	client.Client
}

func (*ClusterGatewayConfigurationHandler) Create

func (c *ClusterGatewayConfigurationHandler) Create(event event.CreateEvent, q workqueue.RateLimitingInterface)

func (*ClusterGatewayConfigurationHandler) Delete

func (c *ClusterGatewayConfigurationHandler) Delete(event event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*ClusterGatewayConfigurationHandler) Generic

func (c *ClusterGatewayConfigurationHandler) Generic(event event.GenericEvent, q workqueue.RateLimitingInterface)

func (*ClusterGatewayConfigurationHandler) Update

func (c *ClusterGatewayConfigurationHandler) Update(event event.UpdateEvent, q workqueue.RateLimitingInterface)

type GeneratorFunc

type GeneratorFunc func() ([]event.GenericEvent, error)

type SecretHandler

type SecretHandler struct {
}

func (*SecretHandler) Create

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

func (*SecretHandler) Delete

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

func (*SecretHandler) Generic

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

func (*SecretHandler) Update

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