Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for newObjectLayerFn (0.27 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to Top