- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 205 for marshaled (0.25 sec)
-
staging/src/k8s.io/apimachinery/pkg/test/apis_meta_v1_unstructed_unstructure_test.go
{accessor: "UID", val: types.UID("uid")}, {accessor: "ResourceVersion", val: "1"}, {accessor: "Generation", val: int64(5)}, {accessor: "SelfLink", val: "/foo"}, // TODO: Handle timestamps, which are being marshalled as UTC and // unmarshalled as Local. // https://github.com/kubernetes/kubernetes/issues/21402 // {accessor: "CreationTimestamp", val: someTime}, // {accessor: "DeletionTimestamp", val: someTimeP},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 20:12:50 UTC 2022 - 17.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
if devices.allocResp == nil { klog.ErrorS(nil, "Can't marshal allocResp, allocation response is missing", "podUID", podUID, "containerName", conName, "resourceName", resource) continue } allocResp, err := devices.allocResp.Marshal() if err != nil { klog.ErrorS(err, "Can't marshal allocResp", "podUID", podUID, "containerName", conName, "resourceName", resource) continue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/config/http_test.go
TypeMeta: metav1.TypeMeta{APIVersion: "v1"}, Spec: v1.PodSpec{ Containers: []v1.Container{{Name: "_INVALID_"}}, }, }, }, } for _, testCase := range testCases { data, err := json.Marshal(testCase.pod) if err != nil { t.Fatalf("%s: Some weird json problem: %v", testCase.desc, err) } fakeHandler := utiltesting.FakeHandler{ StatusCode: http.StatusOK, ResponseBody: string(data),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 11.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1beta1/generated.pb.go
} func (m *PartialObjectMetadataList) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PartialObjectMetadataList) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size])
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 11K bytes - Viewed (0) -
cmd/metacache-set_gen.go
if err != nil { return } err = en.WriteInt(z.set) if err != nil { err = msgp.WrapError(err, "set") return } return } // MarshalMsg implements msgp.Marshaler func (z *listPathOptions) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 19 // string "ID" o = append(o, 0xde, 0x0, 0x13, 0xa2, 0x49, 0x44)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 19 20:23:12 UTC 2024 - 13.8K bytes - Viewed (0) -
internal/config/storageclass/storage-class.go
scStr := string(b) if scStr == "" { return nil } s, err := parseStorageClass(scStr) if err != nil { return err } sc.Parity = s.Parity return nil } // MarshalText - marshals storage class string. func (sc *StorageClass) MarshalText() ([]byte, error) { if sc.Parity != 0 { return []byte(fmt.Sprintf("%s:%d", schemePrefix, sc.Parity)), nil } return []byte{}, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/controller/serviceaccount/legacy_serviceaccount_token_cleaner.go
patchContent, err := json.Marshal(applyv1.Secret(secret.Name, secret.Namespace).WithUID(secret.UID).WithLabels(map[string]string{serviceaccount.InvalidSinceLabelKey: invalidSince})) if err != nil { logger.Error(err, "Failed to marshal invalid since label") } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 10K bytes - Viewed (0) -
src/math/big/ratconv.go
} return } // String returns a string representation of x in the form "a/b" (even if b == 1). func (x *Rat) String() string { return string(x.marshal()) } // marshal implements String returning a slice of bytes func (x *Rat) marshal() []byte { var buf []byte buf = x.a.Append(buf, 10) buf = append(buf, '/') if len(x.b.abs) != 0 { buf = x.b.Append(buf, 10) } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 15 22:16:34 UTC 2023 - 12.3K bytes - Viewed (0) -
cmd/admin-heal-ops.go
for !he.hasEnded() { time.Sleep(1 * time.Second) } ahs.Lock() defer ahs.Unlock() // Heal sequence explicitly stopped, remove it. delete(ahs.healSeqMap, path) } b, err := json.Marshal(&hsp) return b, toAdminAPIErr(GlobalContext, err) } // LaunchNewHealSequence - launches a background routine that performs // healing according to the healSequence argument. For each heal
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/dispatcher.go
key := "validation.policy.admission.k8s.io/validation_failure" // Marshal to a list of failures since, in the future, we may need to support multiple failures valueJSON, err := utiljson.Marshal([]ValidationFailureValue{{ ExpressionIndex: expressionIndex, Message: decision.Message, ValidationActions: binding.Spec.ValidationActions,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.4K bytes - Viewed (0)