Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for read_source (0.22 sec)

  1. istioctl/pkg/analyze/analyze.go

    		}
    	}
    	return readers, nil
    }
    
    func gatherFile(f string) (local.ReaderSource, error) {
    	r, err := os.Open(f)
    	if err != nil {
    		return local.ReaderSource{}, err
    	}
    	runtime.SetFinalizer(r, func(x *os.File) {
    		err = x.Close()
    		if err != nil {
    			log.Infof("file : %s is not closed: %v", f, err)
    		}
    	})
    	return local.ReaderSource{Name: f, Reader: r}, nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 08:32:06 UTC 2024
    - 17K bytes
    - Viewed (0)
  2. pkg/config/analysis/local/istiod_analyze.go

    func (sa *IstiodAnalyzer) AddTestReaderKubeSource(readers []ReaderSource) error {
    	return sa.addReaderKubeSourceInternal(readers, true)
    }
    
    // AddReaderKubeSource adds a source based on the specified k8s yaml files to the current IstiodAnalyzer
    func (sa *IstiodAnalyzer) AddReaderKubeSource(readers []ReaderSource) error {
    	return sa.addReaderKubeSourceInternal(readers, false)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 21:06:13 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  3. pkg/config/analysis/analyzers/analyzers_test.go

    		}
    	}
    
    	// Gather test files
    	var files []local.ReaderSource
    	for _, f := range tc.inputFiles {
    		of, err := os.Open(f)
    		if err != nil {
    			return nil, fmt.Errorf("error opening test file: %q", f)
    		}
    		files = append(files, local.ReaderSource{Name: f, Reader: of})
    	}
    
    	// Include resources from test files
    	err := sa.AddTestReaderKubeSource(files)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 07:22:31 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  4. istioctl/pkg/tag/tag.go

    	sa := local.NewSourceAnalyzer(analysis.Combine("webhook", &webhook.Analyzer{}), "", resource.Namespace(istioNamespace), nil)
    	if err := sa.AddReaderKubeSource([]local.ReaderSource{{Name: "", Reader: strings.NewReader(wh)}}); err != nil {
    		return err
    	}
    	k, err := kube.NewClient(kube.NewClientConfigForRestConfig(config), "")
    	if err != nil {
    		return err
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 08:32:06 UTC 2024
    - 16.3K bytes
    - Viewed (0)
Back to top