- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 456 for ctx (0.01 seconds)
-
tests/tracer_test.go
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Tue Oct 18 09:28:06 GMT 2022 - 830 bytes - Click Count (0) -
cmd/config-common.go
} return buf, r.ObjInfo, nil } func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) { buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{}) return buf, err } type objectDeleter interface { DeleteObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) } func deleteConfig(ctx context.Context, objAPI objectDeleter, configFile string) error {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 3.1K bytes - Click Count (0) -
cmd/erasure-object.go
} return false } func readAllXL(ctx context.Context, disks []StorageAPI, bucket, object string, readData, inclFreeVers bool) ([]FileInfo, []error) { rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData) return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
cmd/background-newdisks-heal-ops.go
return err } globalBackgroundHealState.updateHealStatus(h) return h.disk.WriteAll(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, healingTrackerFilename), htrackerBytes) } // delete the tracker on disk. func (h *healingTracker) delete(ctx context.Context) error { return h.disk.Delete(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, healingTrackerFilename), DeleteOptions{ Recursive: false,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 16.5K bytes - Click Count (0) -
cmd/admin-handlers-site-replication.go
return } var state madmin.SRStateEditReq if err := parseJSONBody(ctx, r.Body, &state, ""); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } if err := globalSiteReplicationSys.PeerStateEditReq(ctx, state); err != nil { adminLogIf(ctx, err) writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.4K bytes - Click Count (0) -
cmd/dummy-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Validate if bucket exists, before proceeding further... _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 13 15:25:16 GMT 2024 - 8.8K bytes - Click Count (0) -
cmd/bucket-quota.go
bucketStorageCache.InitOnce(10*time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (DataUsageInfo, error) { if objAPI == nil { return DataUsageInfo{}, errServerNotInitialized } ctx, done := context.WithTimeout(ctx, 2*time.Second) defer done() return loadDataUsageFromBackend(ctx, objAPI) }, ) } // GetBucketUsageInfo return bucket usage info for a given bucket
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
cmd/kms-handlers.go
ctx := newContext(r, w, "KMSMetrics") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) objectAPI, _ := validateAdminReq(ctx, w, r, policy.KMSMetricsAction) if objectAPI == nil { return } if GlobalKMS == nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrKMSNotConfigured), r.URL) return } metrics, err := GlobalKMS.Metrics(ctx) if err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Aug 18 06:43:03 GMT 2024 - 10.1K bytes - Click Count (0) -
cmd/admin-handlers-idp-config.go
} cfg, err := readServerConfig(ctx, objectAPI, nil) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } dynamic, err := cfg.ReadConfig(strings.NewReader(cfgData)) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // IDP config is not dynamic. Sanity check.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 12.7K bytes - Click Count (0) -
cmd/admin-handlers-config-kv.go
if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } for _, chEntry := range chEntries { if err = delServerConfigHistory(ctx, objectAPI, chEntry.RestoreID); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.8K bytes - Click Count (1)