Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for loadUsers (0.06 sec)

  1. 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
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  2. cmd/iam-store.go

    	loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error
    	loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error
    	loadSecretKey(ctx context.Context, user string, userType IAMUserType) (string, error)
    	loadUsers(ctx context.Context, userType IAMUserType, m map[string]UserIdentity) error
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 87.1K bytes
    - Viewed (0)
  3. cmd/iam-object-store.go

    	return userIdentities, err
    }
    
    func (iamOS *IAMObjectStore) loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error {
    	u, err := iamOS.loadUserIdentity(ctx, user, userType)
    	if err != nil {
    		return err
    	}
    	m[user] = u
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadUsers(ctx context.Context, userType IAMUserType, m map[string]UserIdentity) error {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  4. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 184.8K bytes
    - Viewed (1)
  5. 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)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/base/FinalizableReferenceQueue.java

          }
        }
      }
    
      /**
       * Iterates through the given loaders until it finds one that can load Finalizer.
       *
       * @return Finalizer.class
       */
      private static Class<?> loadFinalizer(FinalizerLoader... loaders) {
        for (FinalizerLoader loader : loaders) {
          Class<?> finalizer = loader.loadFinalizer();
          if (finalizer != null) {
            return finalizer;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  7. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Oct 15 17:00:45 UTC 2025
    - 76.5K bytes
    - Viewed (0)
  8. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  9. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  10. 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 np, nerr
    }
    
    // LoadGroupHandler - reloads group along with members list.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
Back to top