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.Cluster,
	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)