Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewStreamVisitor (0.19 sec)

  1. staging/src/k8s.io/cli-runtime/pkg/resource/kustomizevisitor.go

    	k := krusty.MakeKustomizer(kOpts)
    	m, err := k.Run(v.fSys, v.dirPath)
    	if err != nil {
    		return err
    	}
    	v.yml, err = m.AsYaml()
    	if err != nil {
    		return err
    	}
    	sv := NewStreamVisitor(
    		bytes.NewReader(v.yml), v.mapper, v.dirPath, v.schema)
    	return sv.Visit(fn)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 16:40:28 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/cli-runtime/pkg/resource/visitor.go

    type StreamVisitor struct {
    	io.Reader
    	*mapper
    
    	Source string
    	Schema ContentValidator
    }
    
    // NewStreamVisitor is a helper function that is useful when we want to change the fields of the struct but keep calls the same.
    func NewStreamVisitor(r io.Reader, mapper *mapper, source string, schema ContentValidator) *StreamVisitor {
    	return &StreamVisitor{
    		Reader: r,
    		mapper: mapper,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 10:17:56 UTC 2023
    - 21.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/cli-runtime/pkg/resource/builder.go

    func (b *Builder) URL(httpAttemptCount int, urls ...*url.URL) *Builder {
    	for _, u := range urls {
    		b.paths = append(b.paths, &URLVisitor{
    			URL:              u,
    			StreamVisitor:    NewStreamVisitor(nil, b.mapper, u.String(), b.schema),
    			HttpAttemptCount: httpAttemptCount,
    		})
    	}
    	return b
    }
    
    // Stdin will read objects from the standard input. If ContinueOnError() is set
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 10:17:56 UTC 2023
    - 37.2K bytes
    - Viewed (0)
Back to top