Documentation
¶
Index ¶
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
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
type ClusterQuotaReconcilationControllerOptions ¶
type ClusterQuotaReconcilationControllerOptions struct {
ClusterQuotaInformer shared.ClusterResourceQuotaInformer
ClusterQuotaMapper clusterquotamapping.ClusterQuotaMapper
ClusterQuotaClient client.ClusterResourceQuotasInterface
// Knows how to calculate usage
Registry utilquota.Registry
// Controls full recalculation of quota usage
ResyncPeriod time.Duration
// Knows how to build controllers that notify replenishment events
ControllerFactory resourcequota.ReplenishmentControllerFactory
// Controls full resync of objects monitored for replenihsment.
ReplenishmentResyncPeriod controller.ResyncPeriodFunc
// List of GroupKind objects that should be monitored for replenishment at
// a faster frequency than the quota controller recalculation interval
GroupKindsToReplenish []unversioned.GroupKind
}
Source Files
¶
- reconcilation_controller.go
- workqueuebucket.go
Click to show internal directories.
Click to hide internal directories.