Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 115 for newCounter (0.25 sec)

  1. pkg/volume/downwardapi/downwardapi.go

    	return false
    }
    
    func (plugin *downwardAPIPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) {
    	return false, nil
    }
    
    func (plugin *downwardAPIPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) {
    	v := &downwardAPIVolume{
    		volName:         spec.Name(),
    		items:           spec.Volume.DownwardAPI.Items,
    		pod:             pod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. pkg/volume/nfs/nfs_test.go

    	spec := volume.NewSpecFromPersistentVolume(pv, true)
    	pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}}
    	mounter, _ := plug.NewMounter(spec, pod, volume.VolumeOptions{})
    	if mounter == nil {
    		t.Fatalf("Got a nil Mounter")
    	}
    
    	if !mounter.GetAttributes().ReadOnly {
    		t.Errorf("Expected true for mounter.IsReadOnly")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 9K bytes
    - Viewed (0)
  3. src/go/types/instantiate_test.go

    		{"func (r T[P]) m(T[P], T[string], T[int])", "func (T[int]).m(T[int], T[string], T[int])"},
    	}
    
    	for _, test := range tests {
    		src := prefix + test.decl
    		pkg := mustTypecheck(src, nil, nil)
    		typ := NewPointer(pkg.Scope().Lookup("X").Type())
    		obj, _, _ := LookupFieldOrMethod(typ, false, pkg, "m")
    		m, _ := obj.(*Func)
    		if m == nil {
    			t.Fatalf(`LookupFieldOrMethod(%s, "m") = %v, want func m`, typ, obj)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 03 18:48:38 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. pkg/volume/configmap/configmap.go

    	return false
    }
    
    func (plugin *configMapPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) {
    	return false, nil
    }
    
    func (plugin *configMapPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) {
    	return &configMapVolumeMounter{
    		configMapVolume: &configMapVolume{
    			spec.Name(),
    			pod.UID,
    			plugin,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. pkg/volume/testing/testing.go

    }
    
    func (f *FakeBasicVolumePlugin) Init(ost volume.VolumeHost) error {
    	return f.Plugin.Init(ost)
    }
    
    func (f *FakeBasicVolumePlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) {
    	return f.Plugin.NewMounter(spec, pod, opts)
    }
    
    func (f *FakeBasicVolumePlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  6. src/go/types/methodset_test.go

    		t.Fatalf("missing or unexpected error: %v", err)
    	}
    
    	// look up T.m and (*T).m
    	T := pkg.Scope().Lookup("T").Type()
    	name := "m"
    	for _, recv := range []Type{T, NewPointer(T)} {
    		// LookupFieldOrMethod and NewMethodSet must match:
    		// either both find m or neither finds it.
    		obj1, _, _ := LookupFieldOrMethod(recv, false, pkg, name)
    		mset := NewMethodSet(recv)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 08 15:27:57 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  7. pkg/webhooks/validation/controller/controller_test.go

    		CABundleWatcher:  watcher,
    		Revision:         revision,
    		ServiceName:      "istiod",
    	}, c)
    	return control
    }
    
    func setupGatewayError(c kube.Client) *atomic.Pointer[error] {
    	gatewayError := atomic.NewPointer[error](nil)
    	c.Istio().(*istiofake.Clientset).PrependReactor("*", "gateways", func(action ktesting.Action) (bool, runtime.Object, error) {
    		e := gatewayError.Load()
    		if e == nil {
    			return true, &v1alpha3.Gateway{}, nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 05 03:21:04 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. pkg/volume/emptydir/empty_dir_test.go

    	plug := makePluginUnderTest(t, "kubernetes.io/empty-dir", basePath)
    
    	spec := &v1.Volume{
    		Name: "vol1",
    	}
    	pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}}
    	mounter, err := plug.NewMounter(volume.NewSpecFromVolume(spec), pod, volume.VolumeOptions{})
    	if err != nil {
    		t.Errorf("Failed to make a new Mounter: %v", err)
    	}
    	if mounter == nil {
    		t.Fatalf("Got a nil Mounter")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  9. pkg/volume/downwardapi/downwardapi_test.go

    			DownwardAPI: &v1.DownwardAPIVolumeSource{
    				DefaultMode: &defaultMode,
    				Items:       files,
    			},
    		},
    	}
    	podMeta.UID = testPodUID
    	pod := &v1.Pod{ObjectMeta: podMeta}
    	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.Fatalf("Got a nil Mounter")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 04:48:49 UTC 2023
    - 11.2K bytes
    - Viewed (0)
  10. pkg/volume/git_repo/git_repo_test.go

    	if err != nil {
    		allErrs = append(allErrs,
    			fmt.Errorf("can't find the plugin by name"))
    		return allErrs
    	}
    	pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}}
    	mounter, err := plug.NewMounter(volume.NewSpecFromVolume(scenario.vol), pod, volume.VolumeOptions{})
    
    	if err != nil {
    		allErrs = append(allErrs,
    			fmt.Errorf("failed to make a new Mounter: %w", err))
    		return allErrs
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 08:26:26 UTC 2024
    - 12K bytes
    - Viewed (0)
Back to top