Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewYAMLReader (0.34 sec)

  1. cmd/kubeadm/app/util/marshal.go

    func SplitYAMLDocuments(yamlBytes []byte) (kubeadmapi.DocumentMap, error) {
    	gvkmap := kubeadmapi.DocumentMap{}
    	knownKinds := map[string]bool{}
    	errs := []error{}
    	buf := bytes.NewBuffer(yamlBytes)
    	reader := utilyaml.NewYAMLReader(bufio.NewReader(buf))
    	for {
    		// Read one YAML document at a time, until io.EOF is returned
    		b, err := reader.Read()
    		if err == io.EOF {
    			break
    		} else if err != nil {
    			return nil, err
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 05:14:21 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/patches/patches.go

    	var patches []string
    
    	// Split the patches and convert them to JSON.
    	// Data that is already JSON will not cause an error.
    	buf := bytes.NewBuffer([]byte(data))
    	reader := utilyaml.NewYAMLReader(bufio.NewReader(buf))
    	for {
    		patch, err := reader.Read()
    		if err == io.EOF {
    			break
    		} else if err != nil {
    			return nil, errors.Wrapf(err, "could not split patches for data:\n%s\n", data)
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. pkg/kube/inject/inject.go

    	valuesConfig ValuesConfig, revision string, meshconfig *meshconfig.MeshConfig, in io.Reader, out io.Writer, warningHandler func(string),
    ) error {
    	reader := yamlDecoder.NewYAMLReader(bufio.NewReaderSize(in, 4096))
    	for {
    		raw, err := reader.Read()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    			return err
    		}
    
    		obj, err := FromRawToObject(raw)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (1)
Back to top