- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 144 for monitors (0.25 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)