basecontroller

Documentation

Index

• Constants
• func GetLocationInLogicalClusterIndexKey(location string, clusterName logicalcluster.Path) 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 LocationInLogicalClusterIndexName = "LocationInLogicalCluster"

Functions

func GetLocationInLogicalClusterIndexKey

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

func NewClusterReconciler

func NewClusterReconciler(
	name string,
	reconciler ClusterReconcileImpl,
	kcpClusterClient kcpclientset.ClusterInterface,
	clusterInformer workloadv1alpha1informers.SyncTargetClusterInformer,
	apiResourceImportInformer apiresourcev1alpha1informers.APIResourceImportClusterInformer,
) (*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)