multiClusterWatch

Documentation

Index

• Constants
• type ClusterWatcher
  • 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
• type ResourceHandler
• type ResourceHandlerFactory
  • func NewTrafficHandlerFactory(dnsService *dns.Service, tlsService *tls.Service) ResourceHandlerFactory
• type WatchController
  • func (w *WatchController) WatchCluster(config *rest.Config) (Watcher, error)
• type Watcher
  • func NewClusterWatcher(mgr manager.Manager, config *rest.Config, ...) (Watcher, error)

Constants

const (
	RESYNC_PERIOD = 30 * time.Minute
)

Types

type ClusterWatcher

type ClusterWatcher struct {
	ClusterName string

	Handler ResourceHandler
	Queue   workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

func (*ClusterWatcher) Enqueue

func (w *ClusterWatcher) Enqueue(obj interface{})

func (*ClusterWatcher) EnqueueAfter

func (w *ClusterWatcher) EnqueueAfter(obj interface{}, dur time.Duration)

func (*ClusterWatcher) Start

func (w *ClusterWatcher) Start(ctx context.Context) error

func (*ClusterWatcher) WatchIngress

func (w *ClusterWatcher) WatchIngress(sharedInformer informers.SharedInformerFactory) error

type Interface

type Interface interface {
	WatchCluster(config *rest.Config) (Watcher, error)
}

type ResourceHandler

type ResourceHandler interface {
	Handle(context.Context, runtime.Object) (ctrl.Result, error)
}

type ResourceHandlerFactory

type ResourceHandlerFactory func(c *rest.Config, controlClient client.Client) (ResourceHandler, error)

func NewTrafficHandlerFactory

func NewTrafficHandlerFactory(dnsService *dns.Service, tlsService *tls.Service) ResourceHandlerFactory

type WatchController

type WatchController struct {
	InformerContext context.Context
	Manager         manager.Manager
	HandlerFactory  ResourceHandlerFactory
	// contains filtered or unexported fields
}

func (*WatchController) WatchCluster

func (w *WatchController) WatchCluster(config *rest.Config) (Watcher, error)

type Watcher

type Watcher interface {
	Start(context.Context) error
}

func NewClusterWatcher

func NewClusterWatcher(mgr manager.Manager, config *rest.Config, handlerFactory ResourceHandlerFactory) (Watcher, error)