Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewMapOf (0.05 sec)

  1. cmd/peer-s3-server.go

    	buckets = make([]BucketInfo, 0, 32)
    	healBuckets := xsync.NewMapOf[string, VolInfo]()
    
    	// lists all unique buckets across drives.
    	if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil {
    		return nil, err
    	}
    
    	// include deleted buckets in listBuckets output
    	deletedBuckets := xsync.NewMapOf[string, VolInfo]()
    
    	if opts.Deleted {
    		// lists all deleted buckets across drives.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  2. cmd/iam-store.go

    		iamUserPolicyMap:        xsync.NewMapOf[string, MappedPolicy](),
    		iamSTSAccountsMap:       map[string]UserIdentity{},
    		iamSTSPolicyMap:         xsync.NewMapOf[string, MappedPolicy](),
    		iamGroupsMap:            map[string]GroupInfo{},
    		iamUserGroupMemberships: map[string]set.StringSet{},
    		iamGroupPolicyMap:       xsync.NewMapOf[string, MappedPolicy](),
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    		}
    	}
    
    	if opts.Users || opts.Entity == madmin.SRUserEntity {
    		// Replicate policy mappings on local to all peers.
    		userPolicyMap := xsync.NewMapOf[string, MappedPolicy]()
    		stsPolicyMap := xsync.NewMapOf[string, MappedPolicy]()
    		svcPolicyMap := xsync.NewMapOf[string, MappedPolicy]()
    		if opts.Entity == madmin.SRUserEntity {
    			if mp, ok := globalIAMSys.store.GetMappedPolicy(opts.EntityValue, false); ok {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users.go

    				writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL)
    				return
    			}
    		case userPolicyMappingsFile:
    			userPolicyMap := xsync.NewMapOf[string, MappedPolicy]()
    			err := globalIAMSys.store.loadMappedPolicies(ctx, regUser, false, userPolicyMap)
    			if err != nil {
    				writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL)
    				return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  5. cmd/iam-object-store.go

    	purgeStart := time.Now()
    
    	// Purge expired STS credentials.
    
    	// Scan STS users on disk and purge expired ones.
    	stsAccountsFromStore := map[string]UserIdentity{}
    	stsAccPoliciesFromStore := xsync.NewMapOf[string, MappedPolicy]()
    	for _, item := range listedConfigItems[stsListKey] {
    		userName := path.Dir(item)
    		// loadUser() will delete expired user during the load.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    			time.Sleep(retry)
    			attempt++
    			continue
    		}
    		break
    	}
    
    	// initialize the incomplete uploads cache
    	z.mpCache = xsync.NewMapOf[string, MultipartInfo]()
    
    	go z.cleanupStaleMPCache(ctx)
    
    	return z, nil
    }
    
    func (z *erasureServerPools) cleanupStaleMPCache(ctx context.Context) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top