Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Marshall (0.16 sec)

  1. istioctl/pkg/waypoint/waypoint.go

    		RunE: func(cmd *cobra.Command, args []string) error {
    			gw, err := makeGateway(false)
    			if err != nil {
    				return fmt.Errorf("failed to create gateway: %v", err)
    			}
    			b, err := yaml.Marshal(gw)
    			if err != nil {
    				return err
    			}
    			// strip junk
    			res := strings.ReplaceAll(string(b), `  creationTimestamp: null
    `, "")
    			res = strings.ReplaceAll(res, `status: {}
    `, "")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  2. istioctl/pkg/validate/validate.go

    		},
    		Spec: data,
    	}, nil
    }
    
    // TODO(nmittler): Remove this once Pilot migrates to galley schema.
    func fromSchemaAndJSONMap(schema resource.Schema, data any) (config.Spec, error) {
    	// Marshal to json bytes
    	str, err := json.Marshal(data)
    	if err != nil {
    		return nil, err
    	}
    	out, err := schema.NewInstance()
    	if err != nil {
    		return nil, err
    	}
    	if err = config.ApplyJSONStrict(out, string(str)); err != nil {
    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

    	} else if isMCPAddr(address) {
    		var err error
    		client.Transport, err = mcpTransport(context.TODO(), client.Transport)
    		if err != nil {
    			return nil, err
    		}
    	}
    	podBytes, err := json.Marshal(pod)
    	if pod.Namespace != "" {
    		deploymentNS = pod.Namespace
    	}
    	if err != nil {
    		return nil, err
    	}
    	rev := &admission.AdmissionReview{
    		TypeMeta: metav1.TypeMeta{
    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. istioctl/pkg/workload/workload_test.go

    	}
    }
    
    func TestWorkloadEntryToPodPortsMeta(t *testing.T) {
    	cases := []struct {
    		description string
    		ports       map[string]uint32
    		want        string
    	}{
    		{
    			description: "test json marshal",
    			ports: map[string]uint32{
    				"HTTP":  80,
    				"HTTPS": 443,
    			},
    			want: `[{"name":"HTTP","containerPort":80,"protocol":""},{"name":"HTTPS","containerPort":443,"protocol":""}]`,
    		},
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Mar 27 16:59:05 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/listener.go

    		if filter.Verify(listener) {
    			filteredListeners = append(filteredListeners, listener)
    		}
    	}
    	out, err := json.MarshalIndent(filteredListeners, "", "    ")
    	if err != nil {
    		return fmt.Errorf("failed to marshal listeners: %v", err)
    	}
    	if outputFormat == "yaml" {
    		if out, err = yaml.JSONToYAML(out); err != nil {
    			return err
    		}
    	}
    	fmt.Fprintln(c.Stdout, string(out))
    	return nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/ztunnelserver.go

    	r := &zdsapi.WorkloadRequest{
    		Payload: &zdsapi.WorkloadRequest_Del{
    			Del: &zdsapi.DelWorkload{
    				Uid: uid,
    			},
    		},
    	}
    	data, err := proto.Marshal(r)
    	if err != nil {
    		return err
    	}
    
    	log.Debugf("sending delete pod to ztunnel: %s %v", uid, r)
    
    	var delErr []error
    
    	z.conns.mu.Lock()
    	defer z.conns.mu.Unlock()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  7. cni/pkg/plugin/plugin.go

    	}
    
    	log.Debugf("istio-cni: Config is: %+v", conf)
    	// Parse previous result. Remove this if your plugin is not chained.
    	if conf.RawPrevResult != nil {
    		resultBytes, err := json.Marshal(conf.RawPrevResult)
    		if err != nil {
    			return nil, fmt.Errorf("could not serialize prevResult: %v", err)
    		}
    		res, err := version.NewResult(conf.CNIVersion, resultBytes)
    		if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  8. istioctl/pkg/workload/workload.go

    	iSpec, err := unstructureIstioType(spec)
    	if err != nil {
    		return nil, err
    	}
    	u.Object["spec"] = iSpec
    
    	wgYAML, err := yaml.Marshal(u.Object)
    	if err != nil {
    		return nil, err
    	}
    	return wgYAML, nil
    }
    
    func configureCommand(ctx cli.Context) *cobra.Command {
    	var opts clioptions.ControlPlaneOptions
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  9. operator/cmd/mesh/manifest-generate_test.go

    }
    
    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 {
    		t.Fatal(err)
    	}
    	return mwh
    }
    
    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