- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for monitorGetter (0.46 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go
mutex sync.Mutex monitorGetter func() ([]Monitor, error) } func (m *monitorCollector) setGetter(monitorGetter func() ([]Monitor, error)) { m.mutex.Lock() defer m.mutex.Unlock() m.monitorGetter = monitorGetter } func (m *monitorCollector) getGetter() func() ([]Monitor, error) { m.mutex.Lock() defer m.mutex.Unlock() return m.monitorGetter }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 21:15:32 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
// setup encryption if err := s.maybeApplyResourceTransformers(c); err != nil { return err } metrics.SetStorageMonitorGetter(monitorGetter(factory)) c.RESTOptionsGetter = s.CreateRESTOptionsGetter(factory, c.ResourceTransformers) return nil } func monitorGetter(factory serverstorage.StorageFactory) func() (monitors []metrics.Monitor, err error) { return func() (monitors []metrics.Monitor, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics_test.go
want: ``, }, } for _, test := range testCases { t.Run(test.desc, func(t *testing.T) { defer registry.Reset() if test.getterOverride != nil { oldGetter := storageMonitor.monitorGetter defer SetStorageMonitorGetter(oldGetter) SetStorageMonitorGetter(test.getterOverride) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 21:15:32 UTC 2024 - 10.2K bytes - Viewed (0)