Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. staging/src/k8s.io/apimachinery/pkg/util/yaml/decoder.go

    type YAMLToJSONDecoder struct {
    	reader Reader
    }
    
    // NewYAMLToJSONDecoder decodes YAML documents from the provided
    // stream in chunks by converting each document (as defined by
    // the YAML spec) into its own chunk, converting it to JSON via
    // yaml.YAMLToJSON, and then passing it to json.Decoder.
    func NewYAMLToJSONDecoder(r io.Reader) *YAMLToJSONDecoder {
    	reader := bufio.NewReader(r)
    	return &YAMLToJSONDecoder{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 19 21:24:36 UTC 2021
    - 10.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/yaml/decoder_test.go

    	if s.Scan() {
    		t.Fatalf("scan should have been done")
    	}
    	if s.Err() != nil {
    		t.Fatalf("err should have been nil: %v", s.Err())
    	}
    }
    
    func TestDecodeYAML(t *testing.T) {
    	s := NewYAMLToJSONDecoder(bytes.NewReader([]byte(`---
    stuff: 1
    
    ---   
      `)))
    	obj := generic{}
    	if err := s.Decode(&obj); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 10 07:29:34 UTC 2023
    - 12.4K bytes
    - Viewed (0)
  3. operator/pkg/object/objects.go

    // is found if failOnError is set to false.
    func ParseK8sObjectsFromYAMLManifestFailOption(manifest string, failOnError bool) (K8sObjects, error) {
    	jsonDecoder := k8syaml.NewYAMLToJSONDecoder(bytes.NewReader([]byte(manifest)))
    	var objects K8sObjects
    
    	wrapErr := func(err error) error {
    		return fmt.Errorf("failed to parse YAML to a k8s object: %v", err)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 21 07:16:46 UTC 2023
    - 15.5K bytes
    - Viewed (0)
Back to top