Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for LoadGroup (0.1 sec)

  1. cmd/iam-etcd-store.go

    	for _, userKv := range r.Kvs {
    		if err = ies.getUserKV(ctx, userKv, userType, m, basePrefix); err != nil && err != errNoSuchUser {
    			return err
    		}
    	}
    	return nil
    }
    
    func (ies *IAMEtcdStore) loadGroup(ctx context.Context, group string, m map[string]GroupInfo) error {
    	var gi GroupInfo
    	err := ies.loadIAMConfig(ctx, &gi, getGroupInfoPath(group))
    	if err != nil {
    		if err == errConfigNotFound {
    			return errNoSuchGroup
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  2. cmd/iam-object-store.go

    		userName := path.Dir(item.Item)
    		if err := iamOS.loadUser(ctx, userName, userType, m); err != nil && err != errNoSuchUser {
    			return err
    		}
    	}
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadGroup(ctx context.Context, group string, m map[string]GroupInfo) error {
    	var g GroupInfo
    	err := iamOS.loadIAMConfig(ctx, &g, getGroupInfoPath(group))
    	if err != nil {
    		if err == errConfigNotFound {
    			return errNoSuchGroup
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    	_, err = loadSvcActRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTUser: accessKey,
    	}))
    	return err
    }
    
    // LoadGroup - send load group command to peers.
    func (client *peerRESTClient) LoadGroup(ctx context.Context, group string) error {
    	_, err := loadGroupRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTGroup: group,
    	}))
    	return err
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/notification.go

    			if client == nil {
    				return errPeerNotReachable
    			}
    			return client.LoadUser(ctx, accessKey, temp)
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    // LoadGroup - loads a specific group on all peers.
    func (sys *NotificationSys) LoadGroup(ctx context.Context, group string) []NotificationPeerErr {
    	ng := WithNPeers(len(sys.peerClients)).WithRetries(1)
    	for idx, client := range sys.peerClients {
    		client := client
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  5. cmd/iam-store.go

    	if isGroup {
    		if store.getUsersSysType() == MinIOUsersSysType {
    			g, ok := c.iamGroupsMap[name]
    			if !ok {
    				if err := store.loadGroup(context.Background(), name, c.iamGroupsMap); err != nil {
    					return nil, time.Time{}, err
    				}
    				g, ok = c.iamGroupsMap[name]
    				if !ok {
    					return nil, time.Time{}, errNoSuchGroup
    				}
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  6. cmd/iam.go

    	regUser
    	stsUser
    	svcUser
    )
    
    // LoadGroup - loads a specific group from storage, and updates the
    // memberships cache. If the specified group does not exist in
    // storage, it is removed from in-memory maps as well - this
    // simplifies the implementation for group removal. This is called
    // only via IAM notifications.
    func (sys *IAMSys) LoadGroup(ctx context.Context, objAPI ObjectLayer, group string) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    		return np, grid.NewRemoteErr(errServerNotInitialized)
    	}
    
    	group := mss.Get(peerRESTGroup)
    	if group == "" {
    		return np, grid.NewRemoteErr(errors.New("group is missing"))
    	}
    
    	err := globalIAMSys.LoadGroup(context.Background(), objAPI, group)
    	if err != nil {
    		return np, grid.NewRemoteErr(err)
    	}
    
    	return
    }
    
    // StartProfilingHandler - Issues the start profiling command.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top