Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewMapOf (0.07 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top