- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 73 for Kmenta (0.82 sec)
-
docs/debugging/xl-meta/main.go
func decodeVersions(buf []byte, versions int, fn func(idx int, hdr, meta []byte) error) (err error) { var tHdr, tMeta []byte // Zero copy bytes for i := 0; i < versions; i++ { tHdr, buf, err = msgp.ReadBytesZC(buf) if err != nil { return err } tMeta, buf, err = msgp.ReadBytesZC(buf) if err != nil { return err } if err = fn(i, tHdr, tMeta); err != nil { return err } } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/xl-storage-meta-inline.go
Anis Eleuch <******@****.***> 1712232280 +0100
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/object-api-common.go
// TLDR.. // Not used anymore xl.meta captures the right blockSize // so blockSizeV2 should be used for all future purposes. // this value is kept here to calculate the max API // requests based on RAM size for existing content. blockSizeV1 = 10 * humanize.MiByte // Block size used in erasure coding version 2. blockSizeV2 = 1 * humanize.MiByte // Buckets meta prefix. bucketMetaPrefix = "buckets"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2.1K bytes - Viewed (0) -
cmd/erasure-object.go
// is ready to be read. // // This is possible to be lock free because // - xl.meta for inlined objects has already read the data // into memory, any mutation on xl.meta subsequently is // inconsequential to the overall read operation. // - xl.meta metadata is still verified for quorum under lock() // however writing the response doesn't need to serialize // concurrent writers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/bucket-targets.go
t madmin.BucketTargets meta map[string]string ) if len(cdata) == 0 { return nil, nil } data = cdata json := jsoniter.ConfigCompatibleWithStandardLibrary if len(cmetadata) != 0 { if err := json.Unmarshal(cmetadata, &meta); err != nil { return nil, err } if crypto.S3.IsEncrypted(meta) { if data, err = decryptBucketMetadata(cdata, bucket, meta, kms.Context{ bucket: bucket,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/data-scanner_test.go
obj := "obj-1" now := time.Now() meta := BucketMetadata{ Name: bucket, Created: now, LifecycleConfigXML: lcXML, VersioningConfigXML: vcfgXML, VersioningConfigUpdatedAt: now, LifecycleConfigUpdatedAt: now, lifecycleConfig: &lc, versioningConfig: &vcfg, } globalBucketMetadataSys.Set(bucket, meta) item := scannerItem{ Path: obj,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/erasure-object_test.go
case VersionNotFound: default: t.Fatalf("Object %s is not removed", test.bucket+SlashSeparator+test.object) } } if _, err = os.ReadFile(pathJoin(fsDirs[0], bucketName, "dir/obj1", "xl.meta")); err == nil { t.Fatalf("xl.meta still present after removal") } } func TestErasureDeleteObjectsErasureSet(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// If it doesn't exist we get a new, so ignore errors meta := newBucketMetadata(bucket) meta.SetCreatedAt(opts.CreatedAt) if opts.LockEnabled { meta.VersioningConfigXML = enabledBucketVersioningConfig meta.ObjectLockConfigXML = enabledBucketObjectLockConfig } if opts.VersioningEnabled { meta.VersioningConfigXML = enabledBucketVersioningConfig } if err := meta.Save(context.Background(), z); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/crypto/metadata_test.go
}, Expected: map[string]string{}, }, { // 1 Metadata: map[string]string{ MetaMultipart: "", MetaIV: "", "X-Amz-Meta-A": "X", "X-Minio-Internal-B": "Y", }, Expected: map[string]string{ "X-Amz-Meta-A": "X", "X-Minio-Internal-B": "Y", }, }, } func TestRemoveInternalEntries(t *testing.T) { isEqual := func(x, y map[string]string) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 00:13:57 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/signature-v4-utils.go
func checkMetaHeaders(signedHeadersMap http.Header, r *http.Request) APIErrorCode { // check values from http header for k, val := range r.Header { if stringsHasPrefixFold(k, "X-Amz-Meta-") { if signedHeadersMap.Get(k) == val[0] { continue } return ErrUnsignedHeaders } } return ErrNone
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0)