basecontroller

Documentation

Index

• Constants
• func GetGVRForLocationInLogicalClusterIndexKey(location string, clusterName logicalcluster.Name, ...) string
• func GetLocationInLogicalClusterIndexKey(location string, clusterName logicalcluster.Name) string
• func NewClusterReconciler(name string, reconciler ClusterReconcileImpl, ...) (*ClusterReconciler, ClusterQueue, error)
• type ClusterQueue
• type ClusterReconcileImpl
• type ClusterReconciler
  • func (c *ClusterReconciler) ShutDown()
  • func (c *ClusterReconciler) Start(ctx context.Context)

Constants

const GVRForLocationInLogicalClusterIndexName = "GVRForLocationInLogicalCluster"

const LocationInLogicalClusterIndexName = "LocationInLogicalCluster"

Functions

func GetGVRForLocationInLogicalClusterIndexKey

func GetGVRForLocationInLogicalClusterIndexKey(location string, clusterName logicalcluster.Name, gvr metav1.GroupVersionResource) string

func GetLocationInLogicalClusterIndexKey

func GetLocationInLogicalClusterIndexKey(location string, clusterName logicalcluster.Name) string

func NewClusterReconciler

func NewClusterReconciler(
	name string,
	reconciler ClusterReconcileImpl,
	kcpClusterClient kcpclient.Interface,
	clusterInformer workloadinformer.SyncTargetInformer,
	apiResourceImportInformer apiresourceinformer.APIResourceImportInformer,
) (*ClusterReconciler, ClusterQueue, error)

NewClusterReconciler returns a new controller which reconciles Cluster resources in the API server it reaches using the REST client.

Types

type ClusterQueue

type ClusterQueue interface {
	EnqueueAfter(*workloadv1alpha1.SyncTarget, time.Duration)
}

type ClusterReconcileImpl

type ClusterReconcileImpl interface {
	Reconcile(ctx context.Context, cluster *workloadv1alpha1.SyncTarget) error
	Cleanup(ctx context.Context, deletedCluster *workloadv1alpha1.SyncTarget)
}

ClusterReconcileImpl defines the methods that ClusterReconciler will call in response to changes to Cluster resources.

type ClusterReconciler

type ClusterReconciler struct {
	// contains filtered or unexported fields
}

func (*ClusterReconciler) ShutDown

func (c *ClusterReconciler) ShutDown()

func (*ClusterReconciler) Start

func (c *ClusterReconciler) Start(ctx context.Context)