foreign_cluster_operator

Documentation

Index

• Constants
• func StartOperator(mgr *manager.Manager, namespace string, requeueAfter time.Duration, ...)
• type ForeignClusterReconciler
  • func GetFCReconciler(scheme *runtime.Scheme, namespace string, crdClient *crdClient.CRDClient, ...) *ForeignClusterReconciler
  • func (r *ForeignClusterReconciler) Peer(fc *discoveryv1alpha1.ForeignCluster, ...) (*discoveryv1alpha1.ForeignCluster, error)
  • func (r *ForeignClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *ForeignClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *ForeignClusterReconciler) Unpeer(fc *discoveryv1alpha1.ForeignCluster, ...) (*discoveryv1alpha1.ForeignCluster, error)
  • func (r *ForeignClusterReconciler) Update(fc *discoveryv1alpha1.ForeignCluster) (*discoveryv1alpha1.ForeignCluster, error)

Constants

const FinalizerString = "foreigncluster.discovery.liqo.io/peered"

Functions

func StartOperator

func StartOperator(mgr *manager.Manager, namespace string, requeueAfter time.Duration, discoveryCtrl *discovery.DiscoveryCtrl, kubeconfigPath string)

Types

type ForeignClusterReconciler

type ForeignClusterReconciler struct {
	Scheme *runtime.Scheme

	Namespace string

	RequeueAfter time.Duration

	ConfigProvider discovery.ConfigProvider

	// testing
	ForeignConfig *rest.Config
	// contains filtered or unexported fields
}

ForeignClusterReconciler reconciles a ForeignCluster object

func GetFCReconciler

func GetFCReconciler(scheme *runtime.Scheme, namespace string, crdClient *crdClient.CRDClient, advertisementClient *crdClient.CRDClient, networkClient *crdClient.CRDClient, clusterId clusterID.ClusterID, requeueAfter time.Duration, configProvider discovery.ConfigProvider) *ForeignClusterReconciler

func (*ForeignClusterReconciler) Peer

func (r *ForeignClusterReconciler) Peer(fc *discoveryv1alpha1.ForeignCluster, foreignDiscoveryClient *crdClient.CRDClient) (*discoveryv1alpha1.ForeignCluster, error)

func (*ForeignClusterReconciler) Reconcile

func (r *ForeignClusterReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*ForeignClusterReconciler) SetupWithManager

func (r *ForeignClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

func (*ForeignClusterReconciler) Unpeer

func (r *ForeignClusterReconciler) Unpeer(fc *discoveryv1alpha1.ForeignCluster, foreignDiscoveryClient *crdClient.CRDClient) (*discoveryv1alpha1.ForeignCluster, error)

func (*ForeignClusterReconciler) Update

func (r *ForeignClusterReconciler) Update(fc *discoveryv1alpha1.ForeignCluster) (*discoveryv1alpha1.ForeignCluster, error)