- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 115 for newCounter (1.37 sec)
-
pkg/volume/flexvolume/plugin.go
return []api.PersistentVolumeAccessMode{ api.ReadWriteOnce, api.ReadOnlyMany, } } // NewMounter is part of the volume.VolumePlugin interface. func (plugin *flexVolumePlugin) NewMounter(spec *volume.Spec, pod *api.Pod, _ volume.VolumeOptions) (volume.Mounter, error) { return plugin.newMounterInternal(spec, pod, plugin.host.GetMounter(plugin.GetPluginName()), plugin.runner)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/crossdomain-xml-handler_test.go
import ( "net/http" "net/http/httptest" "testing" "github.com/minio/mux" ) // Test cross domain xml handler. func TestCrossXMLHandler(t *testing.T) { // Server initialization. router := mux.NewRouter().SkipClean(true).UseEncodedPath() handler := setCrossDomainPolicyMiddleware(router) srv := httptest.NewServer(handler) resp, err := http.Get(srv.URL + crossDomainXMLEntity) if err != nil { t.Fatal(err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jul 08 14:31:42 UTC 2023 - 1.3K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
pv := makeTestPV(tc.specVolumeName, 10, testDriver, testVol) spec := volume.NewSpecFromPersistentVolume(pv, pv.Spec.PersistentVolumeSource.CSI.ReadOnly) mounter, err := plug.NewMounter( spec, &corev1.Pod{ObjectMeta: meta.ObjectMeta{UID: testPodUID, Namespace: testns}}, volume.VolumeOptions{}, ) if err != nil { t.Fatalf("Failed to make a new Mounter: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/types/typeutil/ui.go
for i, n := 0, mset.Len(); i < n; i++ { result = append(result, mset.At(i)) } } else { // T is some other concrete type. // Report methods of T and *T, preferring those of T. pmset := msets.MethodSet(types.NewPointer(T)) for i, n := 0, pmset.Len(); i < n; i++ { meth := pmset.At(i) if m := mset.Lookup(meth.Obj().Pkg(), meth.Obj().Name()); m != nil { meth = m } result = append(result, meth) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/volume/plugins_test.go
func (plugin *testPlugins) SupportsMountOption() bool { return false } func (plugin *testPlugins) SupportsSELinuxContextMount(spec *Spec) (bool, error) { return false, nil } func (plugin *testPlugins) NewMounter(spec *Spec, podRef *v1.Pod, opts VolumeOptions) (Mounter, error) { return nil, nil } func (plugin *testPlugins) NewUnmounter(name string, podUID types.UID) (Unmounter, error) { return nil, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 4.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/types/typeutil/methodsetcache.go
// instance whose underlying type is a named type. msets, ok := cache.named[named] if !ok { msets.value = types.NewMethodSet(named) msets.pointer = types.NewMethodSet(types.NewPointer(named)) cache.named[named] = msets } return msets
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 23 18:08:27 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
volume.podName, pod.UID, newMapperErr) } } else { var err error volumeMounter, err = plugin.NewMounter( volumeSpec, pod, volumepkg.VolumeOptions{}) if err != nil { return nil, fmt.Errorf( "reconstructVolume.NewMounter failed for volume %q (spec.Name: %q) pod %q (UID: %q) with: %v", uniqueVolumeName, volumeSpec.Name(), volume.podName, pod.UID,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/volume/hostpath/host_path_test.go
Name: "vol1", VolumeSource: v1.VolumeSource{HostPath: &v1.HostPathVolumeSource{Path: "/no/backsteps/allowed/.."}}, } pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}} mounter, err := plug.NewMounter(volume.NewSpecFromVolume(spec), pod, volume.VolumeOptions{}) if err != nil { t.Fatal(err) } err = mounter.SetUp(volume.MounterArgs{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 20.5K bytes - Viewed (0) -
pkg/volume/projected/projected_test.go
if err != nil { t.Fatal("Can't find the plugin by name") } pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{Namespace: testNamespace, UID: testPodUID}} mounter, err := plugin.NewMounter(volume.NewSpecFromVolume(volumeSpec), pod, volume.VolumeOptions{}) if err != nil { t.Errorf("Failed to make a new Mounter: %v", err) } if mounter == nil { t.Errorf("Got a nil Mounter") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 40.5K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
t.Run(tc.name, func(t *testing.T) { featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.SELinuxMountReadWriteOncePod, tc.seLinuxMountEnabled) mounter, err := plug.NewMounter( tc.originSpec, &api.Pod{ObjectMeta: meta.ObjectMeta{UID: tc.podUID, Namespace: testns}}, volume.VolumeOptions{}, ) if err != nil { t.Fatal(err) } if mounter == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0)