Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for monitorGetter (0.46 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top