multiclusterservice

package
v1.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 13, 2024 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source
const ControllerName = "multiclusterservice-controller"

ControllerName is the controller name that will be used when reporting events.

View Source
const EndpointSliceCollectControllerName = "endpointslice-collect-controller"

EndpointSliceCollectControllerName is the controller name that will be used when reporting events.

View Source
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

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

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

Reconcile performs a full reconciliation for the object referred to by the Request.

func (*EndpointsliceDispatchController) SetupWithManager

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL