- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for newObjectLayerFn (0.27 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bucket-metadata-sys.go
sys.Unlock() } } func (sys *BucketMetadataSys) updateAndParse(ctx context.Context, bucket string, configFile string, configData []byte, parse bool) (updatedAt time.Time, err error) { objAPI := newObjectLayerFn() if objAPI == nil { return updatedAt, errServerNotInitialized } if isMinioMetaBucketName(bucket) { return updatedAt, errInvalidArgument }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.4K bytes - Click Count (0) -
cmd/metrics.go
) } // Populates prometheus with bucket usage metrics, this metrics // is only enabled if scanner is enabled. func bucketUsageMetricsPrometheus(ch chan<- prometheus.Metric) { objLayer := newObjectLayerFn() // Service not initialized yet if objLayer == nil { return } dataUsageInfo, err := loadDataUsageFromBackend(GlobalContext, objLayer) if err != nil { return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:06:31 GMT 2025 - 16.7K bytes - Click Count (0) -
cmd/global-heal.go
scanMode := madmin.HealNormalScan // Make sure to copy since `buckets slice` // is modified in place by tracker. healBuckets := make([]string, len(buckets)) copy(healBuckets, buckets) objAPI := newObjectLayerFn() if objAPI == nil { return errServerNotInitialized } started := tracker.Started if started.IsZero() || started.Equal(timeSentinel) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 04 13:49:12 GMT 2025 - 16.2K bytes - Click Count (0) -
cmd/api-router.go
defer globalObjLayerMutex.RUnlock() return globalConsoleSrv } func setConsoleSrv(srv *consoleapi.Server) { globalObjLayerMutex.Lock() globalConsoleSrv = srv globalObjLayerMutex.Unlock() } func newObjectLayerFn() ObjectLayer { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalObjectAPI } func setObjectLayer(o ObjectLayer) { globalObjLayerMutex.Lock() globalObjectAPI = o
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:19 GMT 2025 - 23.3K bytes - Click Count (0) -
cmd/admin-handlers-idp-ldap.go
func (a adminAPIHandlers) ListAccessKeysLDAP(w http.ResponseWriter, r *http.Request) { ctx := r.Context() // Get current object layer instance. objectAPI := newObjectLayerFn() if objectAPI == nil || globalNotificationSys == nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:46:04 GMT 2025 - 19.2K bytes - Click Count (0) -
cmd/perf-tests.go
t := time.Now() f.t = &t } return n, err } // Runs the speedtest on local MinIO process. func selfSpeedTest(ctx context.Context, opts speedTestOpts) (res SpeedTestResult, err error) { objAPI := newObjectLayerFn() if objAPI == nil { return SpeedTestResult{}, errServerNotInitialized } var wg sync.WaitGroup var errOnce sync.Once var retError string var totalBytesWritten uint64 var totalBytesRead uint64
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 11.8K bytes - Click Count (0) -
cmd/config-current.go
return err } } return nil } func validateConfig(ctx context.Context, s config.Config, subSys string) error { objAPI := newObjectLayerFn() // We must have a global lock for this so nobody else modifies env while we do. defer env.LockSetEnv()() // Disable merging env values with config for validation. env.SetEnvOff()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 28.5K bytes - Click Count (0)