Documentation
¶
Index ¶
Constants ¶
const ControllerName = "multiclusterservice-controller"
ControllerName is the controller name that will be used when reporting events and metrics.
const EndpointSliceCollectControllerName = "endpointslice-collect-controller"
EndpointSliceCollectControllerName is the controller name that will be used when reporting events and metrics.
const EndpointsliceDispatchControllerName = "endpointslice-dispatch-controller"
EndpointsliceDispatchControllerName is the controller name that will be used when reporting events and metrics.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EndpointSliceCollectController ¶
type EndpointSliceCollectController struct {
client.Client
RESTMapper meta.RESTMapper
Context context.Context
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 util.NewClusterDynamicClientSetFunc
ClusterClientOption *util.ClientOption
ClusterCacheSyncTimeout metav1.Duration
RateLimiterOptions ratelimiterflag.Options
// 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
RateLimiterOptions ratelimiterflag.Options
}
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) 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