resourcequota contains a controller that makes resource quota usage observations



    This section is empty.


    This section is empty.


    func GetQuotableResources

    func GetQuotableResources(discoveryFunc NamespacedResourcesFunc) (map[schema.GroupVersionResource]struct{}, error)

      GetQuotableResources returns all resources that the quota system should recognize. It requires a resource supports the following verbs: 'create','list','delete' This function may return both results and an error. If that happens, it means that the discovery calls were only partially successful. A decision about whether to proceed or not is left to the caller.


      type InformerFactory

      type InformerFactory interface {
      	ForResource(resource schema.GroupVersionResource) (informers.GenericInformer, error)
      	Start(stopCh <-chan struct{})

        InformerFactory is all the quota system needs to interface with informers.

        type NamespacedResourcesFunc

        type NamespacedResourcesFunc func() ([]*metav1.APIResourceList, error)

          NamespacedResourcesFunc knows how to discover namespaced resources.

          type QuotaMonitor

          type QuotaMonitor struct {
          	// contains filtered or unexported fields

          func NewQuotaMonitor

          func NewQuotaMonitor(informersStarted <-chan struct{}, informerFactory InformerFactory, ignoredResources map[schema.GroupResource]struct{}, resyncPeriod controller.ResyncPeriodFunc, replenishmentFunc ReplenishmentFunc, registry quota.Registry) *QuotaMonitor

          func (*QuotaMonitor) IsSynced

          func (qm *QuotaMonitor) IsSynced() bool

            IsSynced returns true if any monitors exist AND all those monitors' controllers HasSynced functions return true. This means IsSynced could return true at one time, and then later return false if all monitors were reconstructed.

            func (*QuotaMonitor) Run

            func (qm *QuotaMonitor) Run(stopCh <-chan struct{})

              Run sets the stop channel and starts monitor execution until stopCh is closed. Any running monitors will be stopped before Run returns.

              func (*QuotaMonitor) StartMonitors

              func (qm *QuotaMonitor) StartMonitors()

                StartMonitors ensures the current set of monitors are running. Any newly started monitors will also cause shared informers to be started.

                If called before Run, StartMonitors does nothing (as there is no stop channel to support monitor/informer execution).

                func (*QuotaMonitor) SyncMonitors

                func (qm *QuotaMonitor) SyncMonitors(resources map[schema.GroupVersionResource]struct{}) error

                  SyncMonitors rebuilds the monitor set according to the supplied resources, creating or deleting monitors as necessary. It will return any error encountered, but will make an attempt to create a monitor for each resource instead of immediately exiting on an error. It may be called before or after Run. Monitors are NOT started as part of the sync. To ensure all existing monitors are started, call StartMonitors.

                  type ReplenishmentFunc

                  type ReplenishmentFunc func(groupResource schema.GroupResource, namespace string)

                    ReplenishmentFunc is a signal that a resource changed in specified namespace that may require quota to be recalculated.

                    type ResourceQuotaController

                    type ResourceQuotaController struct {
                    	// contains filtered or unexported fields

                      ResourceQuotaController is responsible for tracking quota usage status in the system

                      func NewResourceQuotaController

                      func NewResourceQuotaController(options *ResourceQuotaControllerOptions) (*ResourceQuotaController, error)

                        NewResourceQuotaController creates a quota controller with specified options

                        func (*ResourceQuotaController) Run

                        func (rq *ResourceQuotaController) Run(workers int, stopCh <-chan struct{})

                          Run begins quota controller using the specified number of workers

                          func (*ResourceQuotaController) Sync

                          func (rq *ResourceQuotaController) Sync(discoveryFunc NamespacedResourcesFunc, period time.Duration, stopCh <-chan struct{})

                            Sync periodically resyncs the controller when new resources are observed from discovery.

                            type ResourceQuotaControllerOptions

                            type ResourceQuotaControllerOptions struct {
                            	// Must have authority to list all quotas, and update quota status
                            	QuotaClient corev1client.ResourceQuotasGetter
                            	// Shared informer for resource quotas
                            	ResourceQuotaInformer coreinformers.ResourceQuotaInformer
                            	// Controls full recalculation of quota usage
                            	ResyncPeriod controller.ResyncPeriodFunc
                            	// Maintains evaluators that know how to calculate usage for group resource
                            	Registry quota.Registry
                            	// Discover list of supported resources on the server.
                            	DiscoveryFunc 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 InformerFactory
                            	// Controls full resync of objects monitored for replenishment.
                            	ReplenishmentResyncPeriod controller.ResyncPeriodFunc

                              ResourceQuotaControllerOptions holds options for creating a quota controller