- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 48 for loadUser (0.18 sec)
-
cmd/iam-object-store.go
stsAccPoliciesFromStore := xsync.NewMapOf[string, MappedPolicy]() for _, item := range listedConfigItems[stsListKey] { userName := path.Dir(item) // loadUser() will delete expired user during the load. err := iamOS.loadUser(ctx, userName, stsUser, stsAccountsFromStore) if err != nil && !errors.Is(err, errNoSuchUser) { iamLogIf(ctx, err) } // No need to return errors for failed expiration of STS users
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26.6K bytes - Viewed (0) -
cmd/iam.go
if !sys.Initialized() { return errServerNotInitialized } return sys.store.PolicyMappingNotificationHandler(ctx, userOrGroup, isGroup, userType) } // LoadUser - reloads a specific user from backend disks or etcd. func (sys *IAMSys) LoadUser(ctx context.Context, objAPI ObjectLayer, accessKey string, userType IAMUserType) error { if !sys.Initialized() { return errServerNotInitialized }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 75.3K bytes - Viewed (0) -
cmd/iam-store.go
return err } return cache.updateUserWithClaims(cred.AccessKey, ui) } // LoadUser - attempts to load user info from storage and updates cache. func (store *IAMStoreSys) LoadUser(ctx context.Context, accessKey string) error { groupLoad := env.Get("_MINIO_IAM_GROUP_REFRESH", config.EnableOff) == config.EnableOn
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 86.7K bytes - Viewed (0) -
cmd/peer-rest-client.go
_, err = deleteSvcActRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTUser: accessKey, })) return err } // LoadUser - reload a specific user. func (client *peerRESTClient) LoadUser(ctx context.Context, accessKey string, temp bool) (err error) { _, err = loadUserRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTUser: accessKey,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/notification.go
if client == nil { return errPeerNotReachable } return client.DeleteUser(ctx, accessKey) }, idx, *client.host) } return ng.Wait() } // LoadUser - reloads a specific user across all peers func (sys *NotificationSys) LoadUser(ctx context.Context, accessKey string, temp bool) []NotificationPeerErr { ng := WithNPeers(len(sys.peerClients)).WithRetries(1) for idx, client := range sys.peerClients {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K bytes - Viewed (0) -
cmd/iam-etcd-store.go
if err != nil { if errors.Is(err, errConfigNotFound) { return "", errNoSuchUser } return "", err } return u.Credentials.SecretKey, nil } func (ies *IAMEtcdStore) loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error { var u UserIdentity err := ies.loadIAMConfig(ctx, &u, getUserIdentityPath(user, userType)) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
cmd/peer-rest-server.go
temp, err := strconv.ParseBool(mss.Get(peerRESTUserTemp)) if err != nil { return np, grid.NewRemoteErr(err) } userType := regUser if temp { userType = stsUser } if err = globalIAMSys.LoadUser(context.Background(), objAPI, accessKey, userType); err != nil { return np, grid.NewRemoteErr(err) } return } // LoadGroupHandler - reloads group along with members list.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 53.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/lang/ClassLoaderUtil.java
} /** * Returns the class loader. * <p> * The class loader is searched in the following order: * </p> * <ol> * <li>If the context class loader is set for the calling thread, that context class loader</li> * <li>If the class loader that loaded the target class can be obtained, that class loader</li> * <li>If the class loader that loaded this class can be obtained, that class loader</li>
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 7.6K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java
private final CacheLoader<? super K, V> loader; private final RemovalListener<? super K, ? super V> removalListener; private final StatsCounter statsCounter; private final Ticker ticker; private final long expireAfterWrite; private final long expireAfterAccess; LocalCache(CacheBuilder<? super K, ? super V> builder, CacheLoader<? super K, V> loader) { this.loader = loader; this.removalListener = builder.removalListener;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheRefreshTest.java
assertEquals(expectedLoads, loader.getLoadCount()); assertEquals(expectedReloads, loader.getReloadCount()); ticker.advance(1, MILLISECONDS); } assertEquals(Integer.valueOf(0), cache.getUnchecked(0)); assertEquals(Integer.valueOf(1), cache.getUnchecked(1)); assertEquals(Integer.valueOf(2), cache.getUnchecked(2)); assertEquals(expectedLoads, loader.getLoadCount());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 4K bytes - Viewed (0)