Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Machen (0.17 sec)

  1. cmd/iam-store.go

    	// cached.updatedAt is more recent than the refresh cycle began.
    	if cache.updatedAt.Before(loadedAt) {
    		// No one has updated anything since the config was loaded,
    		// so we just replace whatever is on the disk into memory.
    		cache.iamGroupPolicyMap = newCache.iamGroupPolicyMap
    		cache.iamGroupsMap = newCache.iamGroupsMap
    		cache.iamPolicyDocsMap = newCache.iamPolicyDocsMap
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  2. cmd/xl-storage.go

    			if err == nil {
    				cache.Info.replication = replicationConfig{
    					Config:  rcfg,
    					remotes: tgts,
    				}
    			}
    		}
    	}
    
    	vcfg, _ := globalBucketVersioningSys.Get(cache.Info.Name)
    
    	// return initialized object layer
    	objAPI := newObjectLayerFn()
    	// object layer not initialized, return.
    	if objAPI == nil {
    		return cache, errServerNotInitialized
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  3. cmd/iam.go

    			entityKeysInStorage.Add(stsUserName)
    		}
    	} else {
    		// For non-iam object store, we copy the mapping keys from the cache.
    		cache := sys.store.rlock()
    		defer sys.store.runlock()
    		cachedPolicyMap := cache.iamSTSPolicyMap
    		if isGroup {
    			cachedPolicyMap = cache.iamGroupPolicyMap
    		}
    		cachedPolicyMap.Range(func(k string, v MappedPolicy) bool {
    			entityKeysInStorage.Add(k)
    			return true
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  4. cmd/erasure-server-pool.go

    // that all buckets are present on all serverPools.
    func (z *erasureServerPools) ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error) {
    	if opts.Cached {
    		listBucketsCache.InitOnce(time.Second,
    			cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    			func() ([]BucketInfo, error) {
    				ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    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)
  5. cmd/sts-handlers_test.go

    	})
    	if err != nil {
    		c.Fatalf("Err creating user admin client: %v", err)
    	}
    	userAdmClient.SetCustomTransport(s.TestSuiteCommon.client.Transport)
    
    	time.Sleep(2 * time.Second) // wait for listbuckets cache to be invalidated
    
    	accInfo, err := userAdmClient.AccountInfo(ctx, madmin.AccountOpts{})
    	if err != nil {
    		c.Fatalf("root user STS should be able to get account info: %v", err)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users.go

    			})
    		}
    		sort.Slice(buckets, func(i, j int) bool {
    			return buckets[i].Name < buckets[j].Name
    		})
    	} else {
    		buckets, err = objectAPI.ListBuckets(ctx, BucketOptions{Cached: true})
    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    
    	accountName := cred.AccessKey
    	if cred.IsTemp() || cred.IsServiceAccount() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
Back to top