- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 41 for decodeUint (0.54 sec)
-
staging/src/k8s.io/apimachinery/pkg/runtime/scheme_test.go
externalToInternalCalls: 0, } // Register functions to verify that scope.Meta() gets set correctly. utilruntime.Must(conversions.registerConversions(scheme)) t.Run("Encode, Decode, DecodeInto, and DecodeToVersion", func(t *testing.T) { simple := &runtimetesting.InternalSimple{ TestString: "foo", } codecs := serializer.NewCodecFactory(scheme) codec := codecs.LegacyCodec(externalGV)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 38.2K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/configset.go
klog.Warning(err.Error()) } // As long as we support only component configs with a single kind, this is allowed return runtime.DecodeInto(Codecs.UniversalDecoder(), yaml, into) } return nil } // ensureInitializedComponentConfigs is an utility func to initialize the ComponentConfigMap in ClusterConfiguration prior to possible writes to it
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 04 15:36:00 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go
objToUpdate := p.restPatcher.New() if err := runtime.DecodeInto(p.codec, patchedObjJS, objToUpdate); err != nil { strictError, isStrictError := runtime.AsStrictDecodingError(err) switch { case !isStrictError: // disregard any appliedStrictErrs, because it's an incomplete // list of strict errors given that we don't know what fields were // unknown because DecodeInto failed. Non-strict errors trump in this case.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 28.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
var decoded *apidiscoveryv2beta1.APIGroupDiscoveryList if len(bytes) > 0 { decoded = &apidiscoveryv2beta1.APIGroupDiscoveryList{} err := runtime.DecodeInto(codecs.UniversalDecoder(), bytes, decoded) if err != nil { panic(fmt.Sprintf("failed to decode response: %v", err)) } } return r, bytes, decoded }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
var inj injectedResult if err := DecodeInto(injArgs, &inj); err != nil { return nil, err } return &TestScoreWithNormalizePlugin{scoreWithNormalizePlugin1, inj}, nil } func newScoreWithNormalizePlugin2(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) { var inj injectedResult if err := DecodeInto(injArgs, &inj); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/visitor.go
if !meta.IsListType(currObj) { items = append(items, currObj) continue } currItems, err := meta.ExtractList(currObj) if err != nil { return err } if errs := runtime.DecodeList(currItems, v.mapper.decoder); len(errs) > 0 { return utilerrors.NewAggregate(errs) } itemsToProcess = append(itemsToProcess, currItems...) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 10:17:56 UTC 2023 - 21.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/dns/dns_test.go
for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { deploymentBytes, _ := kubeadmutil.ParseTemplate(testCase.manifest, testCase.data) deployment := &apps.Deployment{} if err := runtime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), deploymentBytes, deployment); err != nil { t.Errorf("unexpected error: %v", err) } if deployment.Spec.Template.Spec.PriorityClassName != "system-cluster-critical" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 41.7K bytes - Viewed (0) -
pkg/volume/util/util.go
} if len(podDef) == 0 { return nil, fmt.Errorf("file was empty: %s", filePath) } pod := &v1.Pod{} codec := legacyscheme.Codecs.UniversalDecoder() if err := apiruntime.DecodeInto(codec, podDef, pod); err != nil { return nil, fmt.Errorf("failed decoding file: %v", err) } return pod, nil } // CalculateTimeoutForVolume calculates time for a Recycler pod to complete a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
} return nil } func newFakeNodeSelector(_ context.Context, args runtime.Object, _ framework.Handle) (framework.Plugin, error) { pl := &fakeNodeSelector{} if err := frameworkruntime.DecodeInto(args, &pl.fakeNodeSelectorArgs); err != nil { return nil, err } return pl, nil } const ( fakeSpecifiedNodeNameAnnotation = "fake-specified-node-name" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
src/internal/trace/traceviewer/static/trace_viewer_full.html
decodeUInt32();const oldThreadId=decoder.decodeUInt32();const newThreadPriority=decoder.decodeInt8();const oldThreadPriority=decoder.decodeInt8();const previousCState=decoder.decodeUInt8();const spareByte=decoder.decodeInt8();const oldThreadWaitReason=decoder.decodeInt8();const oldThreadWaitMode=decoder.decodeInt8();const oldThreadState=decoder.decodeInt8();const oldThreadWaitIdealProcessor=decoder.decodeInt8();const newThreadWaitTime=decoder.decodeUInt32();const reserved=decoder.decodeUInt32();...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2.5M bytes - Viewed (0)