- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for decodeInt8 (0.15 sec)
-
cmd/kubeadm/app/phases/uploadconfig/uploadconfig_test.go
if configData == "" { t2.Fatal("Fail to find ClusterConfigurationConfigMapKey key") } decodedCfg := &kubeadmapi.ClusterConfiguration{} if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), []byte(configData), decodedCfg); err != nil { t2.Fatalf("unable to decode config from bytes: %v", err) } if len(decodedCfg.ComponentConfigs) != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 08:46:51 UTC 2023 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/log/backend_test.go
backend.ProcessEvents(event) // decode events back and compare with the original one. result := &auditinternal.Event{} decoder := audit.Codecs.UniversalDecoder(version) if err := runtime.DecodeInto(decoder, buf.Bytes(), result); err != nil { t.Errorf("failed decoding buf: %s, apiVersion: %s", buf.String(), version) continue } if !reflect.DeepEqual(event, result) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 08 06:37:26 UTC 2022 - 5K bytes - Viewed (0) -
cluster/gce/gci/configure_helper_test.go
json, err := os.ReadFile(c.manifestDestination) if err != nil { c.t.Fatalf("Failed to read manifest: %s, %v", c.manifestDestination, err) } if err := runtime.DecodeInto(legacyscheme.Codecs.UniversalDecoder(), json, &c.pod); err != nil { c.t.Fatalf("Failed to decode manifest:\n%s\nerror: %v", json, err) } } func (c *ManifestTestCase) tearDown() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 30 06:23:50 UTC 2021 - 4.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/joinconfiguration.go
} if len(joinBytes) == 0 { return nil, errors.Errorf("no %s found in the supplied config", constants.JoinConfigurationKind) } internalcfg := &kubeadmapi.JoinConfiguration{} if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), joinBytes, internalcfg); err != nil { return nil, err } // Applies dynamic defaults to settings not provided with flags
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 12:41:16 UTC 2024 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/tracing.go
} internalConfig := &apiserver.TracingConfiguration{} // this handles json/yaml/whatever, and decodes all registered version to the internal version if err := runtime.DecodeInto(codecs.UniversalDecoder(), data, internalConfig); err != nil { return nil, fmt.Errorf("unable to decode tracing configuration data: %v", err) } return &internalConfig.TracingConfiguration, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 21:39:39 UTC 2023 - 4.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/resetconfiguration.go
} if len(resetBytes) == 0 { return nil, errors.Errorf("no %s found in the supplied config", constants.JoinConfigurationKind) } internalcfg := &kubeadmapi.ResetConfiguration{} if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), resetBytes, internalcfg); err != nil { return nil, err } // Applies dynamic defaults to settings not provided with flags
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 12:41:16 UTC 2024 - 6.6K bytes - Viewed (0) -
tests/fuzz/crd_roundtrip_fuzzer.go
} // decode the encoded data into a new object (instead of letting the codec // create a new object) obj3 := reflect.New(reflect.TypeOf(object).Elem()).Interface().(runtime.Object) if err := runtime.DecodeInto(codec, data, obj3); err != nil { panic(fmt.Sprintf("%v: %v\n", name, err)) } // ensure that the object produced from decoding the encoded data is equal // to the original object
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 01 01:34:15 UTC 2023 - 5.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/upgradeconfiguration.go
// Decode the bytes into the internal struct. Under the hood, the bytes will be unmarshalled into the // right external version, defaulted, and converted into the internal version. if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), bytes, internalcfg); err != nil { return nil, err } continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/helper.go
} return obj, nil } // could not decode, so leave the object as Unknown, but give the decoders the // chance to set Unknown.TypeMeta if it is available. for _, decoder := range decoders { if err := DecodeInto(decoder, obj.Raw, obj); err == nil { return obj, nil } } return obj, nil } // DecodeList alters the list in place, attempting to decode any objects found in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 13 22:54:34 UTC 2023 - 8.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/proxy/proxy_test.go
for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { daemonSetBytes, _ := kubeadmutil.ParseTemplate(testCase.manifest, testCase.data) daemonSet := &apps.DaemonSet{} if err := runtime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), daemonSetBytes, daemonSet); err != nil { t.Errorf("unexpected error: %v", err) } if daemonSet.Spec.Template.Spec.PriorityClassName != "system-node-critical" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 8.7K bytes - Viewed (0)