Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 39 for GetCounter (0.15 sec)

  1. testing/architecture-test/src/changes/archunit-store/public-api-mutable-properties.txt

    Method <org.gradle.testing.jacoco.plugins.JacocoTaskExtension.isJmx()> does not have raw return type assignable to org.gradle.api.provider.Property in (JacocoTaskExtension.java:0)
    Method <org.gradle.testing.jacoco.tasks.rules.JacocoLimit.getCounter()> does not have raw return type assignable to org.gradle.api.provider.Property in (JacocoLimit.java:0)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 22:42:49 UTC 2024
    - 160.5K bytes
    - Viewed (0)
  2. pkg/volume/emptydir/empty_dir.go

    }
    
    func (plugin *emptyDirPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) {
    	return plugin.newMounterInternal(spec, pod, plugin.host.GetMounter(plugin.GetPluginName()), &realMountDetector{plugin.host.GetMounter(plugin.GetPluginName())}, opts)
    }
    
    func calculateEmptyDirMemorySize(nodeAllocatableMemory *resource.Quantity, spec *volume.Spec, pod *v1.Pod) *resource.Quantity {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 19K bytes
    - Viewed (0)
  3. pkg/volume/nfs/nfs.go

    		v1.ReadWriteMany,
    	}
    }
    
    func (plugin *nfsPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, _ volume.VolumeOptions) (volume.Mounter, error) {
    	return plugin.newMounterInternal(spec, pod, plugin.host.GetMounter(plugin.GetPluginName()))
    }
    
    func (plugin *nfsPlugin) newMounterInternal(spec *volume.Spec, pod *v1.Pod, mounter mount.Interface) (volume.Mounter, error) {
    	source, readOnly, err := getVolumeSource(spec)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. 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,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. 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,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. pkg/volume/portworx/portworx.go

    	}
    }
    
    func (plugin *portworxVolumePlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, _ volume.VolumeOptions) (volume.Mounter, error) {
    	return plugin.newMounterInternal(spec, pod.UID, plugin.util, plugin.host.GetMounter(plugin.GetPluginName()))
    }
    
    func (plugin *portworxVolumePlugin) newMounterInternal(spec *volume.Spec, podUID types.UID, manager portworxManager, mounter mount.Interface) (volume.Mounter, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  7. pkg/controller/volume/persistentvolume/volume_host.go

    	return nil, fmt.Errorf("PersistentVolumeController.NewWrapperMounter is not implemented")
    }
    
    func (ctrl *PersistentVolumeController) GetMounter(pluginName string) mount.Interface {
    	return nil
    }
    
    func (ctrl *PersistentVolumeController) GetHostName() string {
    	return ""
    }
    
    func (ctrl *PersistentVolumeController) GetHostIP() (net.IP, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. pkg/kubelet/volume_host.go

    	}
    
    	plugin, err := kvh.kubelet.volumePluginMgr.FindPluginBySpec(&spec)
    	if err != nil {
    		return nil, err
    	}
    
    	return plugin.NewUnmounter(spec.Name(), podUID)
    }
    
    func (kvh *kubeletVolumeHost) GetMounter(pluginName string) mount.Interface {
    	return kvh.kubelet.mounter
    }
    
    func (kvh *kubeletVolumeHost) GetHostName() string {
    	return kvh.kubelet.hostname
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 10K bytes
    - Viewed (0)
  9. pkg/controller/volume/expand/expand_controller.go

    	return nil, fmt.Errorf("NewWrapperUnmounter not supported by expand controller's VolumeHost implementation")
    }
    
    func (expc *expandController) GetMounter(pluginName string) mount.Interface {
    	return nil
    }
    
    func (expc *expandController) GetExec(pluginName string) utilexec.Interface {
    	return utilexec.New()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. pkg/volume/testing/volume_host.go

    	return filepath.Join(f.rootDir, "pods", string(podUID), "plugins", pluginName)
    }
    
    func (f *fakeVolumeHost) GetKubeClient() clientset.Interface {
    	return f.kubeClient
    }
    
    func (f *fakeVolumeHost) GetMounter(pluginName string) mount.Interface {
    	return f.mounter
    }
    
    func (f *fakeVolumeHost) GetSubpather() subpath.Interface {
    	return f.subpather
    }
    
    func (f *fakeVolumeHost) GetPluginMgr() *VolumePluginMgr {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 16.5K bytes
    - Viewed (0)
Back to top