subscription

Documentation

Index

• Variables
• func Add(mgr manager.Manager, hubconfig *rest.Config, syncid *types.NamespacedName, ...) error
• type LeaseReconciler
  • func (r *LeaseReconciler) Reconcile(ctx context.Context)
• type ReconcileSubscription
  • func (r *ReconcileSubscription) DeleteReferredObjects(rq types.NamespacedName, gvk schema.GroupVersionKind) error
  • func (r *ReconcileSubscription) ListAndDeployReferredObject(instance *appv1alpha1.Subscription, gvk schema.GroupVersionKind, ...) error
  • func (r *ReconcileSubscription) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Variables

var ConfigMapKindStr = "ConfigMap"

var SecretKindStr = "Secret"

var SercertReferredMarker = "IsReferredBySub-"

SercertReferredMarker is used as a label key to filter out the secert coming from reference

var SubscriptionGVK = schema.GroupVersionKind{
	Group:   appv1alpha1.SchemeGroupVersion.Group,
	Kind:    "Subscription",
	Version: appv1alpha1.SchemeGroupVersion.Version}

Functions

func Add

func Add(mgr manager.Manager, hubconfig *rest.Config, syncid *types.NamespacedName, standalone bool) error

Add creates a new Subscription Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started. If standalone = true, it will only reconcile standalone subscriptions without hosting subscription from ACM hub. If standalone = false, it will only reconcile subscriptions that are propagated from ACM hub.

Types

type LeaseReconciler

type LeaseReconciler struct {
	HubKubeClient        kubernetes.Interface
	KubeClient           kubernetes.Interface
	ClusterName          string
	LeaseName            string
	LeaseDurationSeconds int32
	// contains filtered or unexported fields
}

LeaseReconciler reconciles a Secret object

func (*LeaseReconciler) Reconcile

func (r *LeaseReconciler) Reconcile(ctx context.Context)

type ReconcileSubscription

type ReconcileSubscription struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	client.Client
	// contains filtered or unexported fields
}

ReconcileSubscription reconciles a Subscription object

func (*ReconcileSubscription) DeleteReferredObjects

func (r *ReconcileSubscription) DeleteReferredObjects(rq types.NamespacedName, gvk schema.GroupVersionKind) error

func (*ReconcileSubscription) ListAndDeployReferredObject

func (r *ReconcileSubscription) ListAndDeployReferredObject(instance *appv1alpha1.Subscription, gvk schema.GroupVersionKind, refObj referredObject) error

func (*ReconcileSubscription) Reconcile

func (r *ReconcileSubscription) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Subscription object and makes changes based on the state read and what is in the Subscription.Spec