Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for loadUser (0.16 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  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 May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  5. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  6. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  8. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  9. 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 {
    				return err
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:05:22 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  10. cmd/data-usage-cache.go

    }
    
    // load the cache content with name from minioMetaBackgroundOpsBucket.
    // Only backend errors are returned as errors.
    // The loader is optimistic and has no locking, but tries 5 times before giving up.
    // If the object is not found, a nil error with empty data usage cache is returned.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
Back to top