- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 205 for marshaled (0.12 sec)
-
cmd/metacache_gen.go
if err != nil { return } err = en.WriteUint8(z.dataVersion) if err != nil { err = msgp.WrapError(err, "dataVersion") return } return } // MarshalMsg implements msgp.Marshaler func (z *metacache) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 13 // string "end" o = append(o, 0x8d, 0xa3, 0x65, 0x6e, 0x64)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Nov 08 18:26:08 UTC 2021 - 10K bytes - Viewed (0) -
cmd/kubeadm/app/util/staticpod/utils.go
func PatchStaticPod(pod *v1.Pod, patchesDir string, output io.Writer) (*v1.Pod, error) { // Marshal the Pod manifest into YAML. podYAML, err := kubeadmutil.MarshalToYaml(pod, v1.SchemeGroupVersion) if err != nil { return pod, errors.Wrapf(err, "failed to marshal Pod manifest to YAML") } patchManager, err := patches.GetPatchManagerForPath(patchesDir, patches.KnownTargets(), output)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 14.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/initconfiguration.go
// Exception: If the specified groupversion is targeting the internal type, don't print embedded ClusterConfiguration contents // This is mostly used for unit testing. In a real scenario the internal version of the API is never marshalled as-is. if gv.Version != runtime.APIVersionInternal { clusterbytes, err := kubeadmutil.MarshalToYamlForCodecs(&cfg.ClusterConfiguration, gv, kubeadmscheme.Codecs) if err != nil { return []byte{}, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 12:41:16 UTC 2024 - 17.3K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
QuoteCharacter: defaultQuoteCharacter, QuoteEscapeCharacter: defaultQuoteEscapeCharacter, CommentCharacter: defaultCommentCharacter, AllowQuotedRecordDelimiter: false, unmarshaled: true, }) for { record, err = r.Read(record) if err != nil { break } opts := sql.WriteCSVOpts{ FieldDelimiter: []rune(c.fieldDelimiter)[0],
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 38.5K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
} // Validate the received bucket replication config if err = replicationConfig.Validate(bucket, sameTarget); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } configData, err := xml.Marshal(replicationConfig) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketReplicationConfig, configData); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/wasm/convert.go
status = marshalFailure return nil, fmt.Errorf("failed to marshal new wasm HTTP filter %+v to protobuf Any: %w", wasmHTTPFilterConfig, err) } ec.TypedConfig = wasmTypedConfig wasmLog.Debugf("new extension config resource %+v", ec) nec, err := anypb.New(ec) if err != nil { status = marshalFailure return nil, fmt.Errorf("failed to marshal new extension config resource: %w", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/api/scheduling/v1alpha1/generated.pb.go
} func (m *PriorityClass) 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 *PriorityClass) 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 - 18.9K bytes - Viewed (0) -
staging/src/k8s.io/api/scheduling/v1beta1/generated.pb.go
0x00, } func (m *PriorityClass) 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 *PriorityClass) 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 - 18.9K bytes - Viewed (0) -
cmd/last-minute_gen.go
err = en.Append(0xa1, 0x4e) if err != nil { return } err = en.WriteInt64(z.N) if err != nil { err = msgp.WrapError(err, "N") return } return } // MarshalMsg implements msgp.Marshaler func (z AccElem) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 3 // string "Total" o = append(o, 0x83, 0xa5, 0x54, 0x6f, 0x74, 0x61, 0x6c)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jul 05 21:45:49 UTC 2022 - 17.2K bytes - Viewed (0) -
pkg/apis/autoscaling/v1/conversion.go
return err } } if len(otherMetrics) > 0 { otherMetricsEnc, err := json.Marshal(otherMetrics) if err != nil { return err } // copy before mutating if !copiedAnnotations { copiedAnnotations = true out.Annotations = autoscaling.DeepCopyStringMap(out.Annotations) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 16 03:29:22 UTC 2021 - 21.2K bytes - Viewed (0)