- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewMapOf (0.07 sec)
-
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) -
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) -
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) -
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) -
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)