- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 125 for Marshal (2.64 sec)
-
internal/bucket/lifecycle/lifecycle_test.go
t.Fatal(err) } ruleSet := make(map[string]struct{}) for _, rule := range lc.Rules { ruleBytes, err := xml.Marshal(rule) if err != nil { t.Fatal(err) } ruleSet[string(ruleBytes)] = struct{}{} } for _, rule := range lc1.Rules { ruleBytes, err := xml.Marshal(rule) if err != nil { t.Fatal(err) } if _, ok := ruleSet[string(ruleBytes)]; !ok {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 55.5K bytes - Viewed (0) -
cmd/xl-storage-format_test.go
} // Constructs xlMetaV1Object{} for given number of parts and converts it into bytes. func getXLMetaBytes(totalParts int) []byte { xlSampleMeta := getSampleXLMeta(totalParts) xlMetaBytes, err := json.Marshal(xlSampleMeta) if err != nil { panic(err) } return xlMetaBytes } // Returns sample xlMetaV1Object{} for number of parts. func getSampleXLMeta(totalParts int) xlMetaV1Object {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 17.5K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
t.Fatal(err) } vers = append(vers, xl.versions) } for _, v2 := range vers { for _, ver := range v2 { b, _ := json.Marshal(ver.header) t.Log(string(b)) var x xlMetaV2Version _, _ = x.unmarshalV(0, ver.meta) b, _ = json.Marshal(x) t.Log(string(b), x.getSignature()) } } for i := range vers { t.Run(fmt.Sprintf("non-strict-q%d", i), func(t *testing.T) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37.8K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
} return fi, nil } // Signature will return a signature that is expected to be the same across all disks. func (j *xlMetaV2DeleteMarker) Signature() [4]byte { // Shallow copy c := *j // Marshal metadata crc := hashDeterministicBytes(c.MetaSys) c.MetaSys = nil if bts, err := c.MarshalMsg(metaDataPoolGet()); err == nil { crc ^= xxhash.Sum64(bts) metaDataPoolPut(bts) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 65.6K bytes - Viewed (1) -
cmd/batch-expire.go
// immediately one last time before we exit this method. xioutil.SafeClose(saverQuitCh) // Notify expire jobs final status to the configured endpoint buf, _ := json.Marshal(ri) if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil { batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err)) } return nil }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
api/go1.21.txt
pkg context, func WithoutCancel(Context) Context #40221 pkg context, func WithTimeoutCause(Context, time.Duration, error) (Context, CancelFunc) #56661 pkg crypto/elliptic, func GenerateKey //deprecated #52221 pkg crypto/elliptic, func Marshal //deprecated #52221 pkg crypto/elliptic, func Unmarshal //deprecated #52221 pkg crypto/elliptic, method (*CurveParams) Add //deprecated #34648 pkg crypto/elliptic, method (*CurveParams) Double //deprecated #34648
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Mon Aug 07 09:39:17 UTC 2023 - 25.6K bytes - Viewed (0) -
cmd/iam-object-store.go
return iamOS.usersSysType } func (iamOS *IAMObjectStore) saveIAMConfig(ctx context.Context, item any, objPath string, opts ...options) error { json := jsoniter.ConfigCompatibleWithStandardLibrary data, err := json.Marshal(item) if err != nil { return err } if GlobalKMS != nil { data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{ minioMetaBucket: path.Join(minioMetaBucket, objPath), }) if err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26.6K bytes - Viewed (0) -
cmd/peer-rest-client.go
func (client *peerRESTClient) doTrace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) { gridConn := client.gridConn() if gridConn == nil { return } payload, err := json.Marshal(traceOpts) if err != nil { bugLogIf(ctx, err) return } st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload) if err != nil { return } st.Results(func(b []byte) error {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 26.1K bytes - Viewed (0) -
cmd/test-utils_test.go
return &pem.Block{Type: "RSA PRIVATE KEY", Bytes: x509.MarshalPKCS1PrivateKey(k)} case *ecdsa.PrivateKey: b, err := x509.MarshalECPrivateKey(k) if err != nil { fmt.Fprintf(os.Stderr, "Unable to marshal ECDSA private key: %v", err) os.Exit(2) } return &pem.Block{Type: "EC PRIVATE KEY", Bytes: b} default: return nil } } var priv any var err error
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
cmd/api-response.go
} // ObjectVersion container for object version metadata type ObjectVersion struct { Object IsLatest bool VersionID string `xml:"VersionId"` isDeleteMarker bool } // MarshalXML - marshal ObjectVersion func (o ObjectVersion) MarshalXML(e *xxml.Encoder, start xxml.StartElement) error { if o.isDeleteMarker { start.Name.Local = "DeleteMarker" } else { start.Name.Local = "Version" }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:19 UTC 2025 - 35K bytes - Viewed (0)