multiclusterservice

Documentation

Index

• Constants
• type EndpointSliceCollectController
  • func (c *EndpointSliceCollectController) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
  • func (c *EndpointSliceCollectController) RunWorkQueue()
  • func (c *EndpointSliceCollectController) SetupWithManager(mgr controllerruntime.Manager) error
• type EndpointsliceDispatchController
  • func (c *EndpointsliceDispatchController) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
  • func (c *EndpointsliceDispatchController) SetupWithManager(mgr controllerruntime.Manager) error
• type MCSController
  • func (c *MCSController) IsClusterReady(clusterName string) bool
  • func (c *MCSController) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
  • func (c *MCSController) SetupWithManager(mgr controllerruntime.Manager) error

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.

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

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.