Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewCachedMetrics (0.18 sec)

  1. pkg/volume/metrics_cached.go

    type cachedMetrics struct {
    	wrapped       MetricsProvider
    	resultError   error
    	resultMetrics *Metrics
    	once          cacheOnce
    }
    
    // NewCachedMetrics creates a new cachedMetrics wrapping another
    // MetricsProvider and caching the results.
    func NewCachedMetrics(provider MetricsProvider) MetricsProvider {
    	return &cachedMetrics{wrapped: provider}
    }
    
    // GetMetrics runs the wrapped metrics provider's GetMetrics method once and
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 16 11:12:06 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  2. pkg/volume/secret/secret.go

    	return &secretVolumeMounter{
    		secretVolume: &secretVolume{
    			spec.Name(),
    			pod.UID,
    			plugin,
    			plugin.host.GetMounter(plugin.GetPluginName()),
    			volume.NewCachedMetrics(volume.NewMetricsDu(getPath(pod.UID, spec.Name(), plugin.host))),
    		},
    		source:    *spec.Volume.Secret,
    		pod:       *pod,
    		opts:      &opts,
    		getSecret: plugin.getSecret,
    	}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. pkg/volume/configmap/configmap.go

    	return &configMapVolumeMounter{
    		configMapVolume: &configMapVolume{
    			spec.Name(),
    			pod.UID,
    			plugin,
    			plugin.host.GetMounter(plugin.GetPluginName()),
    			volume.NewCachedMetrics(volume.NewMetricsDu(getPath(pod.UID, spec.Name(), plugin.host))),
    		},
    		source:       *spec.Volume.ConfigMap,
    		pod:          *pod,
    		opts:         &opts,
    		getConfigMap: plugin.getConfigMap,
    	}, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. pkg/volume/downwardapi/downwardapi.go

    	v := &downwardAPIVolume{
    		volName:         spec.Name(),
    		items:           spec.Volume.DownwardAPI.Items,
    		pod:             pod,
    		podUID:          pod.UID,
    		plugin:          plugin,
    		MetricsProvider: volume.NewCachedMetrics(volume.NewMetricsDu(getPath(pod.UID, spec.Name(), plugin.host))),
    	}
    	return &downwardAPIVolumeMounter{
    		downwardAPIVolume: v,
    		source:            *spec.Volume.DownwardAPI,
    		opts:              &opts,
    	}, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. pkg/volume/projected/projected.go

    		projectedVolume: &projectedVolume{
    			volName:         spec.Name(),
    			sources:         spec.Volume.Projected.Sources,
    			podUID:          pod.UID,
    			plugin:          plugin,
    			MetricsProvider: volume.NewCachedMetrics(volume.NewMetricsDu(getPath(pod.UID, spec.Name(), plugin.host))),
    		},
    		source: *spec.Volume.Projected,
    		pod:    pod,
    		opts:   &opts,
    	}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 12.8K bytes
    - Viewed (0)
Back to top