Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 474 for loads (0.05 sec)

  1. cmd/bucket-metadata-sys.go

    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	sys.objAPI = objAPI
    
    	// Load bucket metadata sys.
    	sys.init(ctx, buckets)
    	return nil
    }
    
    // concurrently load bucket metadata to speed up loading bucket metadata.
    func (sys *BucketMetadataSys) concurrentLoad(ctx context.Context, buckets []string) {
    	g := errgroup.WithNErrs(len(buckets))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. cmd/tier.go

    			return
    		case <-t.C:
    			err := config.Reload(ctx, objAPI)
    			if err != nil {
    				tierLogIf(ctx, err)
    			}
    		}
    		t.Reset(tierCfgRefresh + randInterval())
    	}
    }
    
    // loadTierConfig loads remote tier configuration from objAPI.
    func loadTierConfig(ctx context.Context, objAPI ObjectLayer) (*TierConfigMgr, error) {
    	if objAPI == nil {
    		return nil, errServerNotInitialized
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. docs/sts/web-identity.md

    MINIO_IDENTITY_OPENID_REDIRECT_URI="http://127.0.0.1:10000/oauth_callback"
    MINIO_IDENTITY_OPENID_CLAIM_NAME="groups"
    ```
    </details>
    
    ### Redirection from OpenID Provider
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  4. cmd/config-current.go

    	return readServerConfig(GlobalContext, objAPI, nil)
    }
    
    // loadConfig - loads a new config from disk, overrides params
    // from env if found and valid
    // data is optional. If nil it will be loaded from backend.
    func loadConfig(objAPI ObjectLayer, data []byte) error {
    	bootstrapTraceMsg("load the configuration")
    	srvCfg, err := readServerConfig(GlobalContext, objAPI, data)
    	if err != nil {
    		return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  5. cmd/iam.go

    func (sys *IAMSys) Initialized() bool {
    	if sys == nil {
    		return false
    	}
    	sys.Lock()
    	defer sys.Unlock()
    	return sys.store != nil
    }
    
    // Load - loads all credentials, policies and policy mappings.
    func (sys *IAMSys) Load(ctx context.Context, firstTime bool) error {
    	loadStartTime := time.Now()
    	err := sys.store.LoadIAMCache(ctx, firstTime)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/Response.kt

       * will be truncated to [byteCount] bytes.
       *
       * It is an error to call this method after the body has been consumed.
       *
       * **Warning:** this method loads the requested bytes into memory. Most applications should set
       * a modest limit on `byteCount`, such as 1 MiB.
       */
      @Throws(IOException::class)
      fun peekBody(byteCount: Long): ResponseBody {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 06 09:38:30 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/reflect/ClassPath.java

         * named with the '$' character. If this is a concern, you could use {@link #load} and then
         * check on the loaded {@link Class} object instead.
         *
         * @since 30.1
         */
        public boolean isTopLevel() {
          return className.indexOf('$') == -1;
        }
    
        /**
         * Loads (but doesn't link or initialize) the class.
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jan 05 17:43:40 UTC 2022
    - 24.9K bytes
    - Viewed (0)
  8. cmd/format-erasure.go

    }
    
    // loadFormatErasureAll - load all format config from all input disks in parallel.
    func loadFormatErasureAll(storageDisks []StorageAPI, heal bool) ([]*formatErasureV3, []error) {
    	// Initialize list of errors.
    	g := errgroup.WithNErrs(len(storageDisks))
    
    	// Initialize format configs.
    	formats := make([]*formatErasureV3, len(storageDisks))
    
    	// Load format from each disk in parallel
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

              @Override
              public String load(String key) throws Exception {
                return cache.get(
                    key,
                    identityLoader()); // recursive load (same as the initial one), this should fail
              }
            };
        CacheLoader<String, String> proxyLoader =
            new CacheLoader<String, String>() {
              @Override
              public String load(String key) throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/LocalCacheTest.java

              @Override
              public String load(String key) throws Exception {
                return cache.get(
                    key,
                    identityLoader()); // recursive load (same as the initial one), this should fail
              }
            };
        CacheLoader<String, String> proxyLoader =
            new CacheLoader<String, String>() {
              @Override
              public String load(String key) throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
Back to top