- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewYAMLOrJSONDecoder (0.23 sec)
-
pilot/pkg/config/kube/crd/conversion.go
var others []IstioKind reader := bytes.NewReader([]byte(inputs)) empty := IstioKind{} // We store configs as a YaML stream; there may be more than one decoder. yamlDecoder := kubeyaml.NewYAMLOrJSONDecoder(reader, 512*1024) for { obj := IstioKind{} err := yamlDecoder.Decode(&obj) if err == io.EOF { break } if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 18:26:16 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/config/crd/validator.go
data, err := os.Open(file) if err != nil { return nil, fmt.Errorf("failed to read input yaml file: %v", err) } closers = append(closers, data) yamlDecoder := kubeyaml.NewYAMLOrJSONDecoder(data, 512*1024) for { un := &unstructured.Unstructured{} err = yamlDecoder.Decode(&un) if err == io.EOF { break } if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 17 15:38:40 UTC 2023 - 8.3K bytes - Viewed (0) -
plugin/pkg/admission/podnodeselector/admission.go
// namespace2: <node-selectors-labels> func readConfig(config io.Reader) *pluginConfig { defaultConfig := &pluginConfig{} if config == nil || reflect.ValueOf(config).IsNil() { return defaultConfig } d := yaml.NewYAMLOrJSONDecoder(config, 4096) for { if err := d.Decode(defaultConfig); err != nil { if err != io.EOF { continue } } break } return defaultConfig }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.3K bytes - Viewed (0)