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(_ context.Context, event event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (a *APIServiceHandler) Delete(_ context.Context, event event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (a *APIServiceHandler) Generic(_ context.Context, event event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (a *APIServiceHandler) Update(_ context.Context, event event.UpdateEvent, q workqueue.RateLimitingInterface)
• type AddonHealthHandler
  • func (a AddonHealthHandler) Create(_ context.Context, createEvent event.CreateEvent, ...)
  • func (a AddonHealthHandler) Delete(_ context.Context, deleteEvent event.DeleteEvent, ...)
  • func (a AddonHealthHandler) Generic(_ context.Context, genericEvent event.GenericEvent, ...)
  • func (a AddonHealthHandler) Update(_ context.Context, updateEvent event.UpdateEvent, ...)
• type ClusterGatewayConfigurationHandler
  • func (c *ClusterGatewayConfigurationHandler) Create(ctx context.Context, event event.CreateEvent, ...)
  • func (c *ClusterGatewayConfigurationHandler) Delete(ctx context.Context, event event.DeleteEvent, ...)
  • func (c *ClusterGatewayConfigurationHandler) Generic(ctx context.Context, event event.GenericEvent, ...)
  • func (c *ClusterGatewayConfigurationHandler) Update(ctx context.Context, event event.UpdateEvent, ...)
• type GeneratorFunc
• type SecretHandler
  • func (s *SecretHandler) Create(_ context.Context, event event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (s *SecretHandler) Delete(_ context.Context, event event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (s *SecretHandler) Generic(_ context.Context, event event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (s *SecretHandler) Update(_ context.Context, 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(_ context.Context, event event.CreateEvent, q workqueue.RateLimitingInterface)

func (*APIServiceHandler) Delete

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

func (*APIServiceHandler) Generic

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

func (*APIServiceHandler) Update

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

type AddonHealthHandler

type AddonHealthHandler struct {
}

func (AddonHealthHandler) Create

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

func (AddonHealthHandler) Delete

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

func (AddonHealthHandler) Generic

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

func (AddonHealthHandler) Update

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

type ClusterGatewayConfigurationHandler

type ClusterGatewayConfigurationHandler struct {
	client.Client
}

func (*ClusterGatewayConfigurationHandler) Create

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

func (*ClusterGatewayConfigurationHandler) Delete

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

func (*ClusterGatewayConfigurationHandler) Generic

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

func (*ClusterGatewayConfigurationHandler) Update

func (c *ClusterGatewayConfigurationHandler) Update(ctx context.Context, 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(_ context.Context, event event.CreateEvent, q workqueue.RateLimitingInterface)

func (*SecretHandler) Delete

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

func (*SecretHandler) Generic

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

func (*SecretHandler) Update

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