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.
Source Files