Documentation ¶
Index ¶
Constants ¶
const ControllerName = "multiclusterservice-controller"
ControllerName is the controller name that will be used when reporting events.
const EndpointSliceCollectControllerName = "endpointslice-collect-controller"
EndpointSliceCollectControllerName is the controller name that will be used when reporting events.
const EndpointsliceDispatchControllerName = "endpointslice-dispatch-controller"
EndpointsliceDispatchControllerName is the controller name that will be used when reporting events.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EndpointSliceCollectController ¶
type EndpointSliceCollectController struct { client.Client RESTMapper meta.RESTMapper StopChan <-chan struct{} InformerManager genericmanager.MultiClusterInformerManager WorkerNumber int // WorkerNumber is the number of worker goroutines PredicateFunc predicate.Predicate // PredicateFunc is the function that filters events before enqueuing the keys. ClusterDynamicClientSetFunc func(clusterName string, client client.Client) (*util.DynamicClusterClient, error) ClusterCacheSyncTimeout metav1.Duration // contains filtered or unexported fields }
EndpointSliceCollectController collects EndpointSlice from member clusters and reports them to control-plane.
func (*EndpointSliceCollectController) Reconcile ¶
func (c *EndpointSliceCollectController) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
Reconcile performs a full reconciliation for the object referred to by the Request.
func (*EndpointSliceCollectController) RunWorkQueue ¶
func (c *EndpointSliceCollectController) RunWorkQueue()
RunWorkQueue initializes worker and run it, worker will process resource asynchronously.
func (*EndpointSliceCollectController) SetupWithManager ¶
func (c *EndpointSliceCollectController) SetupWithManager(mgr controllerruntime.Manager) error
SetupWithManager creates a controller and register to controller manager.
type EndpointsliceDispatchController ¶
type EndpointsliceDispatchController struct { client.Client EventRecorder record.EventRecorder RESTMapper meta.RESTMapper InformerManager genericmanager.MultiClusterInformerManager }
EndpointsliceDispatchController will reconcile a MultiClusterService object
func (*EndpointsliceDispatchController) Reconcile ¶
func (c *EndpointsliceDispatchController) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
Reconcile performs a full reconciliation for the object referred to by the Request.
func (*EndpointsliceDispatchController) SetupWithManager ¶
func (c *EndpointsliceDispatchController) SetupWithManager(mgr controllerruntime.Manager) error
SetupWithManager creates a controller and register to controller manager.
type MCSController ¶
type MCSController struct { client.Client EventRecorder record.EventRecorder RateLimiterOptions ratelimiterflag.Options }
MCSController is to sync MultiClusterService.
func (*MCSController) IsClusterReady ¶ added in v1.9.0
func (c *MCSController) IsClusterReady(clusterName string) bool
IsClusterReady checks whether the cluster is ready.
func (*MCSController) Reconcile ¶
func (c *MCSController) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
Reconcile performs a full reconciliation for the object referred to by the Request. The Controller will requeue the Request to be processed again if an error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
func (*MCSController) SetupWithManager ¶
func (c *MCSController) SetupWithManager(mgr controllerruntime.Manager) error
SetupWithManager creates a controller and register to controller manager.