Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for loadUsers (0.04 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  3. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Feb 28 19:33:08 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
Back to top