Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for obj (0.13 sec)

  1. operator/cmd/mesh/manifest_shared_test.go

    	}
    	if err := clnt.Get(ctx, client.ObjectKeyFromObject(obj), check); kerrors.IsNotFound(err) {
    		if err := clnt.Create(ctx, check); err != nil {
    			return fmt.Errorf("could not inject object creation for fake: %w", err)
    		}
    	} else if err != nil {
    		return err
    	}
    	obj.SetResourceVersion(check.GetResourceVersion())
    	return clnt.Update(ctx, obj)
    }}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Feb 20 22:39:28 GMT 2024
    - 11.7K bytes
    - Viewed (1)
  2. istioctl/pkg/validate/validate.go

    		if obj.Namespace == "" {
    			// If the user didn't specify --namespace, and is validating a CR with no namespace, use "default"
    			if defaultNamespace == "" {
    				defaultNamespace = metav1.NamespaceDefault
    			}
    			obj.Namespace = defaultNamespace
    		}
    
    		warnings, err := schema.ValidateConfig(*obj)
    		return warnings, err
    	}
    
    	var errs error
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Jan 22 17:58:52 GMT 2024
    - 15K bytes
    - Viewed (0)
  3. istioctl/pkg/kubeinject/kubeinject.go

    	if err != nil {
    		return nil, err
    	}
    	defer resp.Body.Close()
    	body, err := io.ReadAll(resp.Body)
    	if err != nil {
    		return nil, err
    	}
    	var obj runtime.Object
    	var ar *kube.AdmissionReview
    	out, _, err := deserializer.Decode(body, nil, obj)
    	if err != nil {
    		return nil, fmt.Errorf("could not decode body: %v", err)
    	}
    	ar, err = kube.AdmissionReviewKubeToAdapter(out)
    	if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
  4. operator/cmd/mesh/test-util_test.go

    	obj := objs.kind(name2.RoleStr).nameEquals(name)
    	g.Expect(obj).Should(Not(BeNil()))
    	return obj
    }
    
    // mustGetContainer returns the container tree with the given name in the deployment with the given name.
    func mustGetContainer(g *WithT, objs *ObjectSet, deploymentName, containerName string) map[string]any {
    	obj := mustGetDeployment(g, objs, deploymentName)
    	container := obj.Container(containerName)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Oct 31 14:48:28 GMT 2023
    - 15.3K bytes
    - Viewed (0)
  5. istioctl/pkg/multicluster/remote_secret_test.go

    }
    
    func mustFindObject(t test.Failer, objs object.K8sObjects, name, kind string) {
    	t.Helper()
    	var obj *object.K8sObject
    	for _, o := range objs {
    		if o.Kind == kind && o.Name == name {
    			obj = o
    			break
    		}
    	}
    	if obj == nil {
    		t.Fatalf("expected %v/%v", name, kind)
    	}
    }
    
    func TestCreateRemoteKubeconfig(t *testing.T) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Oct 31 14:48:28 GMT 2023
    - 20.6K bytes
    - Viewed (0)
  6. operator/cmd/mesh/manifest-generate_test.go

    	return runManifestCommand("generate", filenames, flags, chartSource, fileSelect)
    }
    
    func mustGetWebhook(t test.Failer, obj object.K8sObject) []v1.MutatingWebhook {
    	t.Helper()
    	path := mustGetPath(t, obj, "webhooks")
    	by, err := json.Marshal(path)
    	if err != nil {
    		t.Fatal(err)
    	}
    	var mwh []v1.MutatingWebhook
    	if err := json.Unmarshal(by, &mwh); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 18 18:16:49 GMT 2024
    - 43.5K bytes
    - Viewed (0)
Back to top