Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 144 for monitors (0.25 sec)

  1. pkg/controller/resourcequota/resource_quota_monitor.go

    	// Stop any running monitors.
    	qm.monitorLock.Lock()
    	defer qm.monitorLock.Unlock()
    	monitors := qm.monitors
    	stopped := 0
    	for _, monitor := range monitors {
    		if monitor.stopCh != nil {
    			stopped++
    			close(monitor.stopCh)
    		}
    	}
    	logger.Info("QuotaMonitor stopped monitors", "stopped", stopped, "total", len(monitors))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. pkg/controller/garbagecollector/graph_builder.go

    	<-gb.informersStarted
    
    	monitors := gb.monitors
    	started := 0
    	for _, monitor := range monitors {
    		if monitor.stopCh == nil {
    			monitor.stopCh = make(chan struct{})
    			gb.sharedInformers.Start(gb.stopCh)
    			go monitor.Run()
    			started++
    		}
    	}
    	logger.V(4).Info("started new monitors", "new", started, "current", len(monitors))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/etcd.go

    	return nil
    }
    
    func monitorGetter(factory serverstorage.StorageFactory) func() (monitors []metrics.Monitor, err error) {
    	return func() (monitors []metrics.Monitor, err error) {
    		defer func() {
    			if err != nil {
    				for _, m := range monitors {
    					m.Close()
    				}
    			}
    		}()
    
    		var m metrics.Monitor
    		for _, cfg := range factory.Configs() {
    			m, err = storagefactory.CreateMonitor(cfg)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 15:02:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  4. pkg/controller/resourcequota/resource_quota_controller.go

    	// knows how to calculate usage
    	registry quota.Registry
    	// knows how to monitor all the resources tracked by quota and trigger replenishment
    	quotaMonitor *QuotaMonitor
    	// controls the workers that process quotas
    	// this lock is acquired to control write access to the monitors and ensures that all
    	// monitors are synced before the controller can process quotas.
    	workerLock sync.RWMutex
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go

    	monitors, err := c.getGetter()()
    	if err != nil {
    		return
    	}
    
    	for i, m := range monitors {
    		storageClusterID := fmt.Sprintf("etcd-%d", i)
    
    		klog.V(4).InfoS("Start collecting storage metrics", "storage_cluster_id", storageClusterID)
    		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    		metrics, err := m.Monitor(ctx)
    		cancel()
    		m.Close()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 21:15:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  6. pkg/controller/garbagecollector/garbagecollector.go

    			// attempt.
    			if err := gc.resyncMonitors(logger, newResources); err != nil {
    				utilruntime.HandleError(fmt.Errorf("failed to sync resource monitors (attempt %d): %v", attempt, err))
    				metrics.GarbageCollectorResourcesSyncError.Inc()
    				return false, nil
    			}
    			logger.V(4).Info("resynced monitors")
    
    			// wait for caches to fill for a while (our sync period) before attempting to rediscover resources and retry syncing.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/testdata/v1.29.0/apps.v1beta2.ReplicaSet.yaml

              kind: kindValue
              readOnly: true
            azureFile:
              readOnly: true
              secretName: secretNameValue
              shareName: shareNameValue
            cephfs:
              monitors:
              - monitorsValue
              path: pathValue
              readOnly: true
              secretFile: secretFileValue
              secretRef:
                name: nameValue
              user: userValue
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 34.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/testdata/v1.29.0/core.v1.PodTemplate.yaml

            kind: kindValue
            readOnly: true
          azureFile:
            readOnly: true
            secretName: secretNameValue
            shareName: shareNameValue
          cephfs:
            monitors:
            - monitorsValue
            path: pathValue
            readOnly: true
            secretFile: secretFileValue
            secretRef:
              name: nameValue
            user: userValue
          cinder:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 31.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/testdata/v1.29.0/extensions.v1beta1.ReplicaSet.yaml

              kind: kindValue
              readOnly: true
            azureFile:
              readOnly: true
              secretName: secretNameValue
              shareName: shareNameValue
            cephfs:
              monitors:
              - monitorsValue
              path: pathValue
              readOnly: true
              secretFile: secretFileValue
              secretRef:
                name: nameValue
              user: userValue
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 34.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/testdata/HEAD/apps.v1.ReplicaSet.yaml

              kind: kindValue
              readOnly: true
            azureFile:
              readOnly: true
              secretName: secretNameValue
              shareName: shareNameValue
            cephfs:
              monitors:
              - monitorsValue
              path: pathValue
              readOnly: true
              secretFile: secretFileValue
              secretRef:
                name: nameValue
              user: userValue
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 34.8K bytes
    - Viewed (0)
Back to top