Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for LoadUser (0.25 sec)

  1. 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)
  2. 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)
  3. 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
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  4. cmd/notification.go

    			if client == nil {
    				return errPeerNotReachable
    			}
    			return client.DeleteUser(accessKey)
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    // LoadUser - reloads a specific user across all peers
    func (sys *NotificationSys) LoadUser(accessKey string, temp bool) []NotificationPeerErr {
    	ng := WithNPeers(len(sys.peerClients)).WithRetries(1)
    	for idx, client := range sys.peerClients {
    		client := client
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  5. cmd/peer-rest-client.go

    	_, err = deleteSvcActRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTUser: accessKey,
    	}))
    	return err
    }
    
    // LoadUser - reload a specific user.
    func (client *peerRESTClient) LoadUser(accessKey string, temp bool) (err error) {
    	_, err = loadUserRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTUser:     accessKey,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  6. cmd/iam-etcd-store.go

    		u.Credentials.Claims = jwtClaims.Map()
    	}
    	if u.Credentials.Description == "" {
    		u.Credentials.Description = u.Credentials.Comment
    	}
    
    	m[user] = u
    	return 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 {
    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)
  7. 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.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  8. cmd/site-replication.go

    	s.RLock()
    	if s.Creds.IsValid() {
    		s.RUnlock()
    		return s.Creds, nil
    	}
    	s.RUnlock()
    	m := make(map[string]UserIdentity)
    	if err := globalIAMSys.store.loadUser(ctx, siteReplicatorSvcAcc, svcUser, m); err != nil {
    		return auth.Credentials{}, err
    	}
    	s.Set(m[siteReplicatorSvcAcc].Credentials)
    	return m[siteReplicatorSvcAcc].Credentials, 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)
Back to top