kubequota

Documentation

Index

• type Controller
  • func NewController(clusterWorkspacesInformer tenancyinformers.ClusterWorkspaceInformer, ...) (*Controller, error)
  • func (c *Controller) Start(ctx context.Context, numThreads int)
• type ScopingResourceQuotaInformer
  • func NewScopingResourceQuotaInformer(delegate coreinformers.ResourceQuotaInformer) *ScopingResourceQuotaInformer
  • func (s *ScopingResourceQuotaInformer) ForCluster(clusterName logicalcluster.Name) *SingleClusterResourceQuotaInformer
• type SingleClusterResourceQuotaInformer
  • func (s *SingleClusterResourceQuotaInformer) Informer() cache.SharedIndexInformer
  • func (s *SingleClusterResourceQuotaInformer) Lister() corelisters.ResourceQuotaLister
• type SingleClusterResourceQuotaLister
  • func (s SingleClusterResourceQuotaLister) List(selector labels.Selector) (ret []*corev1.ResourceQuota, err error)
  • func (s SingleClusterResourceQuotaLister) ResourceQuotas(namespace string) corelisters.ResourceQuotaNamespaceLister

Types

type Controller

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

Controller manages per-workspace resource quota controllers.

func NewController

func NewController(
	clusterWorkspacesInformer tenancyinformers.ClusterWorkspaceInformer,
	kubeClusterClient kubernetesclient.ClusterInterface,
	kubeInformerFactory kubernetesinformers.SharedInformerFactory,
	dynamicDiscoverySharedInformerFactory *informer.DynamicDiscoverySharedInformerFactory,
	crdInformer apiextensionsinformers.CustomResourceDefinitionInformer,
	quotaRecalculationPeriod time.Duration,
	fullResyncPeriod time.Duration,
	workersPerLogicalCluster int,
	informersStarted <-chan struct{},
) (*Controller, error)

NewController creates a new Controller.

func (*Controller) Start

func (c *Controller) Start(ctx context.Context, numThreads int)

Start starts the controller.

type ScopingResourceQuotaInformer

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

func NewScopingResourceQuotaInformer

func NewScopingResourceQuotaInformer(delegate coreinformers.ResourceQuotaInformer) *ScopingResourceQuotaInformer

func (*ScopingResourceQuotaInformer) ForCluster

func (s *ScopingResourceQuotaInformer) ForCluster(clusterName logicalcluster.Name) *SingleClusterResourceQuotaInformer

type SingleClusterResourceQuotaInformer

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

SingleClusterResourceQuotaInformer implements ResourceQuotaInformer, scoped to a single logical cluster. Calls to Informer().AddEventHandler() and Informer().AddEventHandlerWithResyncPeriod() are forwarded to registerHandler.

func (*SingleClusterResourceQuotaInformer) Informer

func (s *SingleClusterResourceQuotaInformer) Informer() cache.SharedIndexInformer

Informer returns a cache.SharedIndexInformer that delegates adding event handlers to registerEventHandlerForCluster.

func (*SingleClusterResourceQuotaInformer) Lister

func (s *SingleClusterResourceQuotaInformer) Lister() corelisters.ResourceQuotaLister

Lister returns a ResourceQuotaLister scoped to a single logical cluster.

type SingleClusterResourceQuotaLister

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

SingleClusterResourceQuotaLister is a ResourceQuotaLister scoped to a single logical cluster.

func (SingleClusterResourceQuotaLister) List

func (s SingleClusterResourceQuotaLister) List(selector labels.Selector) (ret []*corev1.ResourceQuota, err error)

List lists all ResourceQuota objects in a single logical cluster.

func (SingleClusterResourceQuotaLister) ResourceQuotas

func (s SingleClusterResourceQuotaLister) ResourceQuotas(namespace string) corelisters.ResourceQuotaNamespaceLister

ResourceQuotas returns a ResourceQuotaNamespaceLister scoped to a single logical cluster.