Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for loadGroup (0.05 sec)

  1. cmd/iam-etcd-store.go

    	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
    		}
    		return err
    	}
    	m[group] = gi
    	return nil
    }
    
    func (ies *IAMEtcdStore) loadGroups(ctx context.Context, m map[string]GroupInfo) error {
    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

    }
    
    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
    		}
    		return err
    	}
    	m[group] = g
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadGroups(ctx context.Context, m map[string]GroupInfo) error {
    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

    	loadSecretKey(ctx context.Context, user string, userType IAMUserType) (string, error)
    	loadUsers(ctx context.Context, userType IAMUserType, m map[string]UserIdentity) error
    	loadGroup(ctx context.Context, group string, m map[string]GroupInfo) error
    	loadGroups(ctx context.Context, m map[string]GroupInfo) error
    	loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error
    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)
  8. cmd/admin-handlers-users.go

    				writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL)
    				return
    			}
    		case allGroupsFile:
    			groups := make(map[string]GroupInfo)
    			err := globalIAMSys.store.loadGroups(ctx, groups)
    			if err != nil {
    				writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL)
    				return
    			}
    			groupData, err := json.Marshal(groups)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  9. cmd/site-replication.go

    			}
    		}
    	}
    
    	// Next should be Groups for some of these users, LDAP might have some Group
    	// DNs here
    	{
    		groups := make(map[string]GroupInfo)
    		err := globalIAMSys.store.loadGroups(ctx, groups)
    		if err != nil {
    			return errSRBackendIssue(err)
    		}
    
    		for gname, group := range groups {
    			if err := c.IAMChangeHook(ctx, madmin.SRIAMItem{
    				Type: madmin.SRIAMItemGroupInfo,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top