Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for loadUsers (0.03 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-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)
  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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Feb 28 19:33:08 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  4. 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)
  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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  6. 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)
Back to top