Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Unmarshal (0.2 sec)

  1. istioctl/pkg/multixds/gather.go

    			Component: "MISSING",
    			ID:        "MISSING",
    			Info: istioversion.BuildInfo{
    				Version: "MISSING CP ID",
    			},
    		}
    	}
    
    	cpID := pilotxds.IstioControlPlaneInstance{}
    	err := json.Unmarshal([]byte(xdsResponse.ControlPlane.Identifier), &cpID)
    	if err != nil {
    		return pilotxds.IstioControlPlaneInstance{
    			Component: "INVALID",
    			ID:        "INVALID",
    			Info: istioversion.BuildInfo{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  2. istioctl/pkg/kubeinject/kubeinject.go

    			valuesConfigMapKey, injectConfigMapName)
    	}
    
    	return valuesData, nil
    }
    
    func readInjectConfigFile(f []byte) (inject.RawTemplates, error) {
    	var injectConfig inject.Config
    	err := yaml.Unmarshal(f, &injectConfig)
    	if err != nil || len(injectConfig.RawTemplates) == 0 {
    		// This must be a direct template, instead of an inject.Config. We support both formats
    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)
  3. cni/pkg/nodeagent/ztunnelserver.go

    		return nil, 0, fmt.Errorf("truncated message")
    	}
    	if flags&unix.MSG_CTRUNC != 0 {
    		return nil, 0, fmt.Errorf("truncated control message")
    	}
    	var resp T
    	var respPtr PT = &resp
    	err = proto.Unmarshal(buf[:n], respPtr)
    	if err != nil {
    		return nil, 0, err
    	}
    	return respPtr, oobn, nil
    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)
  4. cni/pkg/plugin/plugin.go

    	conf := Config{}
    
    	if err := json.Unmarshal(stdin, &conf); err != nil {
    		return nil, fmt.Errorf("failed to parse network configuration: %v", err)
    	}
    
    	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 {
    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)
  5. istioctl/pkg/proxyconfig/proxyconfig.go

    			Global struct {
    				Proxy struct {
    					LogLevel string `json:"logLevel"`
    				} `json:"proxy"`
    			} `json:"global"`
    		} `json:"sidecarInjectorWebhook"`
    	}
    	if err := yaml.Unmarshal([]byte(valuesConfig), &values); err != nil {
    		return "", fmt.Errorf("failed to parse values config: %v [%v]", err, valuesConfig)
    	}
    	return values.SidecarInjectorWebhook.Global.Proxy.LogLevel, nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 16 03:28:36 GMT 2024
    - 48K bytes
    - Viewed (0)
  6. istioctl/pkg/workload/workload.go

    // fake go-client used for mocking cannot.)
    func unstructureIstioType(spec any) (map[string]any, error) {
    	b, err := yaml.Marshal(spec)
    	if err != nil {
    		return nil, err
    	}
    	iSpec := map[string]any{}
    	err = yaml.Unmarshal(b, &iSpec)
    	if err != nil {
    		return nil, err
    	}
    	return iSpec, nil
    }
    
    func convertToUnsignedInt32Map(s []string) map[string]uint32 {
    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)
  7. 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)
  8. 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)
  9. istioctl/pkg/precheck/precheck.go

    		if err != nil {
    			fmt.Printf("Error getting configmap %s: %v\n", configMapName, err)
    		}
    		meshData := make(map[string]interface{})
    		if data, exists := configMap.Data["mesh"]; exists {
    			if err := yaml.Unmarshal([]byte(data), &meshData); err != nil {
    				fmt.Printf("Error parsing meshConfig: %v\n", err)
    				return err
    			}
    		}
    		if scopingImpacted = meshData["discoverySelectors"] != nil; !scopingImpacted {
    			continue
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 02:57:30 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  10. 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
    }
    
    func getWebhooks(t *testing.T, setFlags string, webhookName string) []v1.MutatingWebhook {
    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