Documentation
¶
Index ¶
- type BucketingWorkQueue
- type ClusterQuotaReconcilationController
- func (c *ClusterQuotaReconcilationController) AddMapping(quotaName, namespaceName string)
- func (c *ClusterQuotaReconcilationController) RemoveMapping(quotaName, namespaceName string)
- func (c *ClusterQuotaReconcilationController) Run(workers int, stopCh <-chan struct{})
- func (c *ClusterQuotaReconcilationController) Sync(discoveryFunc resourcequota.NamespacedResourcesFunc, period time.Duration, ...)
- type ClusterQuotaReconcilationControllerOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BucketingWorkQueue ¶
type BucketingWorkQueue interface { AddWithData(key interface{}, data ...interface{}) AddWithDataRateLimited(key interface{}, data ...interface{}) GetWithData() (key interface{}, data []interface{}, quit bool) Done(key interface{}) Forget(key interface{}) ShutDown() }
BucketingWorkQueue gives a way to add items related to a single entry in a work queue this allows you work on a set of related work in a single UOW-style way
func NewBucketingWorkQueue ¶
func NewBucketingWorkQueue(name string) BucketingWorkQueue
type ClusterQuotaReconcilationController ¶
type ClusterQuotaReconcilationController struct {
// contains filtered or unexported fields
}
func NewClusterQuotaReconcilationController ¶
func NewClusterQuotaReconcilationController(options ClusterQuotaReconcilationControllerOptions) (*ClusterQuotaReconcilationController, error)
func (*ClusterQuotaReconcilationController) AddMapping ¶
func (c *ClusterQuotaReconcilationController) AddMapping(quotaName, namespaceName string)
func (*ClusterQuotaReconcilationController) RemoveMapping ¶
func (c *ClusterQuotaReconcilationController) RemoveMapping(quotaName, namespaceName string)
func (*ClusterQuotaReconcilationController) Run ¶
func (c *ClusterQuotaReconcilationController) Run(workers int, stopCh <-chan struct{})
Run begins quota controller using the specified number of workers
func (*ClusterQuotaReconcilationController) Sync ¶ added in v3.10.0
func (c *ClusterQuotaReconcilationController) Sync(discoveryFunc resourcequota.NamespacedResourcesFunc, period time.Duration, stopCh <-chan struct{})
Sync periodically resyncs the controller when new resources are observed from discovery.
type ClusterQuotaReconcilationControllerOptions ¶
type ClusterQuotaReconcilationControllerOptions struct { ClusterQuotaInformer quotainformer.ClusterResourceQuotaInformer ClusterQuotaMapper clusterquotamapping.ClusterQuotaMapper ClusterQuotaClient quotatypedclient.ClusterResourceQuotaInterface // Knows how to calculate usage Registry utilquota.Registry // Controls full recalculation of quota usage ResyncPeriod time.Duration // Discover list of supported resources on the server. DiscoveryFunc resourcequota.NamespacedResourcesFunc // A function that returns the list of resources to ignore IgnoredResourcesFunc func() map[schema.GroupResource]struct{} // InformersStarted knows if informers were started. InformersStarted <-chan struct{} // InformerFactory interfaces with informers. InformerFactory resourcequota.InformerFactory // Controls full resync of objects monitored for replenihsment. ReplenishmentResyncPeriod controller.ResyncPeriodFunc }
Click to show internal directories.
Click to hide internal directories.