Versions in this module Expand all Collapse all v1 v1.0.0 Feb 10, 2023 Changes in this version + const RESYNC_PERIOD + type ClusterWatcher struct + ClusterName string + Handler ResourceHandler + Queue workqueue.RateLimitingInterface + func (w *ClusterWatcher) Enqueue(obj interface{}) + func (w *ClusterWatcher) EnqueueAfter(obj interface{}, dur time.Duration) + func (w *ClusterWatcher) Start(ctx context.Context) error + func (w *ClusterWatcher) WatchIngress(sharedInformer informers.SharedInformerFactory) error + type Interface interface + WatchCluster func(config *rest.Config) (Watcher, error) + type ResourceHandler interface + Handle func(context.Context, runtime.Object) (ctrl.Result, error) + type ResourceHandlerFactory func(c *rest.Config, controlClient client.Client) (ResourceHandler, error) + func NewTrafficHandlerFactory(dnsService *dns.Service, tlsService *tls.Service) ResourceHandlerFactory + type WatchController struct + HandlerFactory ResourceHandlerFactory + InformerContext context.Context + Manager manager.Manager + func (w *WatchController) WatchCluster(config *rest.Config) (Watcher, error) + type Watcher interface + Start func(context.Context) error + func NewClusterWatcher(mgr manager.Manager, config *rest.Config, ...) (Watcher, error)
Go to main page