Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewYAMLOrJSONDecoder (0.23 sec)

  1. pilot/pkg/config/kube/crd/conversion.go

    	var others []IstioKind
    	reader := bytes.NewReader([]byte(inputs))
    	empty := IstioKind{}
    
    	// We store configs as a YaML stream; there may be more than one decoder.
    	yamlDecoder := kubeyaml.NewYAMLOrJSONDecoder(reader, 512*1024)
    	for {
    		obj := IstioKind{}
    		err := yamlDecoder.Decode(&obj)
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 18:26:16 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. pkg/config/crd/validator.go

    		data, err := os.Open(file)
    		if err != nil {
    			return nil, fmt.Errorf("failed to read input yaml file: %v", err)
    		}
    		closers = append(closers, data)
    
    		yamlDecoder := kubeyaml.NewYAMLOrJSONDecoder(data, 512*1024)
    		for {
    			un := &unstructured.Unstructured{}
    			err = yamlDecoder.Decode(&un)
    			if err == io.EOF {
    				break
    			}
    			if err != nil {
    				return nil, err
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 17 15:38:40 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  3. plugin/pkg/admission/podnodeselector/admission.go

    //	namespace2: <node-selectors-labels>
    func readConfig(config io.Reader) *pluginConfig {
    	defaultConfig := &pluginConfig{}
    	if config == nil || reflect.ValueOf(config).IsNil() {
    		return defaultConfig
    	}
    	d := yaml.NewYAMLOrJSONDecoder(config, 4096)
    	for {
    		if err := d.Decode(defaultConfig); err != nil {
    			if err != io.EOF {
    				continue
    			}
    		}
    		break
    	}
    	return defaultConfig
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 8.3K bytes
    - Viewed (0)
Back to top