Documentation
¶
Index ¶
Constants ¶
View Source
const ( FederateControllerName = "federate-controller" EventReasonCreateFederatedObject = "CreateFederatedObject" EventReasonUpdateFederatedObject = "UpdateFederatedObject" // If this finalizer is present on a k8s resource, the federate // controller will have the opportunity to perform pre-deletion operations // (like deleting federtated resources). FinalizerFederateController = common.DefaultPrefix + "federate-controller" // If this annotation is present on the source object, skip federating it. NoFederatedResource = common.DefaultPrefix + "no-federated-resource" )
Variables ¶
This section is empty.
Functions ¶
func CreateMergePatch ¶
CreateMergePatch will return a merge patch document capable of converting the source object to the target object.
func TemplateForSourceObject ¶
func TemplateForSourceObject( sourceObj *unstructured.Unstructured, annotations, labels map[string]string, ) *unstructured.Unstructured
Types ¶
type FederateController ¶
type FederateController struct {
// contains filtered or unexported fields
}
FederateController federates objects of source type to FederatedObjects or ClusterFederatedObjects.
func NewFederateController ¶
func NewFederateController( kubeClient kubernetes.Interface, dynamicClient dynamic.Interface, fedClient fedclient.Interface, fedObjectInformer fedcorev1a1informers.FederatedObjectInformer, clusterFedObjectInformer fedcorev1a1informers.ClusterFederatedObjectInformer, informerManager informermanager.InformerManager, metrics stats.Metrics, logger klog.Logger, workerCount int, fedSystemNamespace string, ) (*FederateController, error)
func (*FederateController) HasSynced ¶
func (c *FederateController) HasSynced() bool
func (*FederateController) IsControllerReady ¶
func (c *FederateController) IsControllerReady() bool
func (*FederateController) Run ¶
func (c *FederateController) Run(ctx context.Context)
Source Files
Click to show internal directories.
Click to hide internal directories.