- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for loadUsers (0.2 sec)
-
cmd/iam-etcd-store.go
return errNoSuchUser } return err } return ies.addUser(ctx, user, userType, u, m) } func (ies *IAMEtcdStore) loadUsers(ctx context.Context, userType IAMUserType, m map[string]UserIdentity) error { var basePrefix string switch userType { case svcUser: basePrefix = iamConfigServiceAccountsPrefix case stsUser: basePrefix = iamConfigSTSPrefix default: basePrefix = iamConfigUsersPrefix }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/iam-store.go
} // LoadUser - attempts to load user info from storage and updates cache. func (store *IAMStoreSys) LoadUser(ctx context.Context, accessKey string) { cache := store.lock() defer store.unlock() cache.updatedAt = time.Now() _, found := cache.iamUsersMap[accessKey] // Check for regular user access key if !found { store.loadUser(ctx, accessKey, regUser, cache.iamUsersMap)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/iam-object-store.go
stsAccPoliciesFromStore := xsync.NewMapOf[string, MappedPolicy]() for _, item := range iamListing[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(GlobalContext,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/site-replication.go
uerr := globalIAMSys.store.loadUsers(ctx, regUser, userAccounts) if uerr != nil { return info, errSRBackendIssue(uerr) } serr := globalIAMSys.store.loadUsers(ctx, svcUser, userAccounts) if serr != nil { return info, errSRBackendIssue(serr) } terr := globalIAMSys.store.loadUsers(ctx, stsUser, userAccounts) if terr != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 184.1K bytes - Viewed (1) -
cmd/admin-handlers-users.go
writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL) return } case allUsersFile: userIdentities := make(map[string]UserIdentity) err := globalIAMSys.store.loadUsers(ctx, regUser, userIdentities) if err != nil { writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL) return } userAccounts := make(map[string]madmin.AddOrUpdateUserReq)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 77.3K bytes - Viewed (0) -
cmd/metrics-v3-types.go
// JoinLoaders - joins multiple loaders into a single loader. The returned // loader will call each of the given loaders in order. If any of the loaders // return an error, the returned loader will return that error. func JoinLoaders(loaders ...MetricsLoaderFn) MetricsLoaderFn { return func(ctx context.Context, m MetricValues, c *metricsCache) error { for _, loader := range loaders { if err := loader(ctx, m, c); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 14.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
* </ul> * * To force selection of our fallback strategies we load {@link AbstractFuture} (and all of {@code * com.google.common.util.concurrent}) in degenerate class loaders which make certain platform * classes unavailable. Then we construct a test suite so we can run the normal AbstractFutureTest * test methods in these degenerate classloaders. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 6.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
* </ul> * * To force selection of our fallback strategies we load {@link AggregateFutureState} (and all of * {@code com.google.common.util.concurrent}) in degenerate class loaders which make certain * platform classes unavailable. Then we construct a test suite so we can run the normal FuturesTest * test methods in these degenerate classloaders. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 5.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
* </ul> * * To force selection of our fallback strategies we load {@link AggregateFutureState} (and all of * {@code com.google.common.util.concurrent}) in degenerate class loaders which make certain * platform classes unavailable. Then we construct a test suite so we can run the normal FuturesTest * test methods in these degenerate classloaders. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 5.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
* </ul> * * To force selection of our fallback strategies we load {@link AbstractFuture} (and all of {@code * com.google.common.util.concurrent}) in degenerate class loaders which make certain platform * classes unavailable. Then we construct a test suite so we can run the normal AbstractFutureTest * test methods in these degenerate classloaders. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 6.2K bytes - Viewed (0)