- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for read_source (0.17 sec)
-
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) -
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) -
operator/pkg/helmreconciler/reconciler.go
objYAML, err := object.NewK8sObject(&obj, nil, nil).YAML() if err != nil { return err } whReaderSource := local.ReaderSource{ Name: fmt.Sprintf("in-cluster-webhook-%d", i), Reader: strings.NewReader(string(objYAML)), } err = sa.AddReaderKubeSource([]local.ReaderSource{whReaderSource}) if err != nil { return err } } err = sa.AddReaderKubeSource(localWebhookYAMLReaders)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 22 08:32:23 UTC 2024 - 22K bytes - Viewed (0) -
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) -
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)