Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for Marshall (0.19 sec)

  1. cni/pkg/install/kubeconfig.go

    	}
    
    	lcfg, err := latest.Scheme.ConvertToVersion(kcfg, latest.ExternalVersion)
    	if err != nil {
    		return kubeconfig{}, err
    	}
    	// Convert to v1 schema which has proper encoding
    	fullYaml, err := yaml.Marshal(lcfg)
    	if err != nil {
    		return kubeconfig{}, err
    	}
    
    	// Log with redaction
    	if err := api.RedactSecrets(kcfg); err != nil {
    		return kubeconfig{}, err
    	}
    	for _, c := range kcfg.Clusters {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Aug 11 01:19:03 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  2. 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)
  3. cni/pkg/plugin/cnieventclient.go

    	}
    	// Currently we only use the netns from the original CNI event
    	addEvent := nodeagent.CNIPluginAddEvent{Netns: event.Netns, PodName: podName, PodNamespace: podNamespace, IPs: ncconfigs}
    	eventData, err := json.Marshal(addEvent)
    	if err != nil {
    		return err
    	}
    	var response *http.Response
    	response, err = cniClient.client.Post(cniClient.url, "application/json", bytes.NewBuffer(eventData))
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  4. cni/pkg/util/pluginutil.go

    	plugin, ok := rawPlugin.(map[string]any)
    	if !ok {
    		err = fmt.Errorf("error reading plugin from CNI config plugin list")
    		return
    	}
    	return
    }
    
    // Marshal the CNI config map and append a new line
    func MarshalCNIConfig(cniConfigMap map[string]any) ([]byte, error) {
    	cniConfig, err := json.MarshalIndent(cniConfigMap, "", "  ")
    	if err != nil {
    		return nil, err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  5. istioctl/pkg/wait/wait_test.go

    	cannedResponseObj := []xds.SyncedVersions{
    		{
    			ProxyID:         "foo",
    			ClusterVersion:  "1",
    			ListenerVersion: "1",
    			RouteVersion:    "1",
    			EndpointVersion: "1",
    		},
    	}
    	cannedResponse, _ := json.Marshal(cannedResponseObj)
    	cannedResponseMap := map[string][]byte{"onlyonepilot": cannedResponse}
    
    	distributionTrackingDisabledResponse := xds.DistributionTrackingDisabledMessage
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 08:28:50 GMT 2024
    - 6.8K bytes
    - Viewed (1)
  6. 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