resourcerequestoperator

Documentation

Overview

Package resourcerequestoperator contains the ResourceRequest controller which reconciles the resource and creates new ResourceOffer and related tests. utils.go contains all utility function.

Index

• func GetResourceRequest(ctx context.Context, k8sClient client.Client, clusterID string) (*discoveryv1alpha1.ResourceRequest, error)
• func GetTenantName(cluster discoveryv1alpha1.ClusterIdentity) string
• type OfferQueue
  • func NewOfferQueue(offerUpdater *OfferUpdater) OfferQueue
  • func (u *OfferQueue) Push(cluster discoveryv1alpha1.ClusterIdentity)
  • func (u *OfferQueue) Start(ctx context.Context) error
• type OfferUpdater
  • func NewOfferUpdater(ctx context.Context, k8sClient client.Client, ...) *OfferUpdater
  • func (u *OfferUpdater) CreateOrUpdateOffer(cluster discoveryv1alpha1.ClusterIdentity) (requeue bool, err error)
  • func (u *OfferUpdater) NotifyChange(clusterID string)
  • func (u *OfferUpdater) SetThreshold(updateThresholdPercentage uint)
  • func (u *OfferUpdater) Start(ctx context.Context) error
• type ResourceRequestReconciler
  • func (r *ResourceRequestReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)
  • func (r *ResourceRequestReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func GetResourceRequest

func GetResourceRequest(ctx context.Context, k8sClient client.Client, clusterID string) (
	*discoveryv1alpha1.ResourceRequest, error)

GetResourceRequest returns ResourceRequest for the given cluster.

func GetTenantName

func GetTenantName(cluster discoveryv1alpha1.ClusterIdentity) string

GetTenantName returns the name of the Tenant for the given cluster.

Types

type OfferQueue

type OfferQueue struct {
	// contains filtered or unexported fields
}

OfferQueue is a component that periodically commands a broadcaster/broker to update its ResourceOffers. It also provides rate-limited retries for transient errors in the offering process.

func NewOfferQueue

func NewOfferQueue(offerUpdater *OfferUpdater) OfferQueue

NewOfferQueue constructs an OfferQueue.

func (*OfferQueue) Push

func (u *OfferQueue) Push(cluster discoveryv1alpha1.ClusterIdentity)

Push pushes a cluster ID into the queue.

func (*OfferQueue) Start

func (u *OfferQueue) Start(ctx context.Context) error

Start starts the update loop and blocks.

type OfferUpdater

type OfferUpdater struct {
	resourcemonitors.ResourceReader
	OfferQueue
	// contains filtered or unexported fields
}

OfferUpdater is a component that responds to ResourceRequests with the cluster's resources read from ResourceReader.

func NewOfferUpdater

func NewOfferUpdater(ctx context.Context, k8sClient client.Client, homeCluster discoveryv1alpha1.ClusterIdentity,
	clusterLabels map[string]string, reader resourcemonitors.ResourceReader, updateThresholdPercentage uint,
	localRealStorageClassName string, enableStorage bool,
	ingressClasses, loadBalancerClasses argutils.ClassNameList) *OfferUpdater

NewOfferUpdater constructs a new OfferUpdater.

func (*OfferUpdater) CreateOrUpdateOffer

func (u *OfferUpdater) CreateOrUpdateOffer(cluster discoveryv1alpha1.ClusterIdentity) (requeue bool, err error)

CreateOrUpdateOffer creates one or more offers for the given cluster, reading resources from the ResourceReader.

func (*OfferUpdater) NotifyChange

func (u *OfferUpdater) NotifyChange(clusterID string)

NotifyChange is used by the ResourceReader to notify that resources were changed for a single cluster identified by clusterID or for all clusters by passing resourcemonitors.AllClusterIDs.

func (*OfferUpdater) SetThreshold

func (u *OfferUpdater) SetThreshold(updateThresholdPercentage uint)

SetThreshold sets the threshold for resource updates to trigger an update of the ResourceOffers.

func (*OfferUpdater) Start

func (u *OfferUpdater) Start(ctx context.Context) error

Start starts the OfferUpdater and blocks.

type ResourceRequestReconciler

type ResourceRequestReconciler struct {
	client.Client
	Scheme      *runtime.Scheme
	HomeCluster discoveryv1alpha1.ClusterIdentity
	*OfferUpdater
	EnableIncomingPeering bool
}

ResourceRequestReconciler reconciles a ResourceRequest object.

func (*ResourceRequestReconciler) Reconcile

func (r *ResourceRequestReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

Reconcile is the main function of the controller which reconciles ResourceRequest resources.

func (*ResourceRequestReconciler) SetupWithManager

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

SetupWithManager is the setup function of the controller.