Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for UnmarshalJSON (0.41 sec)

  1. istioctl/pkg/util/configdump/wrapper.go

    // Wrapper is a wrapper around the Envoy ConfigDump
    // It has extra helper functions for handling any/struct/marshal protobuf pain
    type Wrapper struct {
    	*admin.ConfigDump
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.ConfigDump{}
    	err := protomarshal.UnmarshalAllowUnknownWithAnyResolver(nonStrictResolver, b, cd)
    	*w = Wrapper{cd}
    	return err
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  2. istioctl/pkg/util/clusters/wrapper.go

    }
    
    // MarshalJSON is a custom marshaller to handle protobuf pain
    func (w *Wrapper) MarshalJSON() ([]byte, error) {
    	return protomarshal.Marshal(w)
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.Clusters{}
    	err := protomarshal.UnmarshalAllowUnknown(b, cd)
    	*w = Wrapper{cd}
    	return err
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 1.2K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/configdump.go

    	includeConfigType = p
    }
    
    // Prime loads the config dump into the writer ready for printing
    func (c *ConfigWriter) Prime(b []byte) error {
    	w := &configdump.Wrapper{}
    	err := w.UnmarshalJSON(b)
    	if err != nil {
    		return fmt.Errorf("error unmarshalling config dump response from Envoy: %v", err)
    	}
    	c.configDump = w
    	return nil
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Feb 29 20:46:41 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  4. istioctl/pkg/authz/authz.go

    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	data, err := io.ReadAll(file)
    	if err != nil {
    		return nil, err
    	}
    
    	envoyConfig := &configdump.Wrapper{}
    	if err := envoyConfig.UnmarshalJSON(data); err != nil {
    		return nil, fmt.Errorf("failed to unmarshal proxy config: %s", err)
    	}
    	return envoyConfig, nil
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 5K bytes
    - Viewed (0)
  5. istioctl/pkg/describe/describe_test.go

    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			ic := util.ReadFile(t, test.inputConfig)
    			cd := configdump.Wrapper{}
    			err := cd.UnmarshalJSON(ic)
    			if err != nil {
    				t.Fatal(err)
    			}
    			out, err := getIstioVirtualServicePathForSvcFromRoute(&cd, test.inputService, test.inputPort)
    			if err != nil {
    				t.Fatal(err)
    			}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Mar 28 09:54:01 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  6. istioctl/pkg/describe/describe.go

    		if err != nil {
    			return fmt.Errorf("failed to execute command on ingress gateway sidecar: %v", err)
    		}
    		cd := configdump.Wrapper{}
    		err = cd.UnmarshalJSON(byConfigDump)
    		if err != nil {
    			return fmt.Errorf("can't parse ingress gateway sidecar config_dump: %v", err)
    		}
    
    		for _, svc := range matchingServices {
    			for _, port := range svc.Spec.Ports {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
Back to top