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 ¶
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
}
Source Files
¶
- reconciliation_controller.go
- workqueuebucket.go
Click to show internal directories.
Click to hide internal directories.