Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for mapOf (5.87 sec)

  1. cmd/iam-etcd-store.go

    	return ies.loadMappedPolicy(ctx, name, userType, isGroup, m)
    }
    
    func (ies *IAMEtcdStore) loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error {
    	var p MappedPolicy
    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)
  2. cmd/iam-store.go

    	loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error
    	loadMappedPolicyWithRetry(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy], retries int) error
    	loadMappedPolicies(ctx context.Context, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error
    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. internal/grid/connection.go

    	remoteID    *uuid.UUID
    	reconnectMu sync.Mutex
    
    	// Context for the server.
    	ctx context.Context
    
    	// Active mux connections.
    	outgoing *xsync.MapOf[uint64, *muxClient]
    
    	// Incoming streams
    	inStream *xsync.MapOf[uint64, *muxServer]
    
    	// outQueue is the output queue
    	outQueue chan []byte
    
    	// Client or serverside.
    	side ws.State
    
    	// Transport for outgoing connections.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  4. cmd/iam-object-store.go

    			return err
    		}
    	}
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadMappedPolicyWithRetry(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy], retries int) error {
    	for {
    	retry:
    		var p MappedPolicy
    		err := iamOS.loadIAMConfig(ctx, &p, getMappedPolicyPath(name, userType, isGroup))
    		if err != nil {
    			if err == errConfigNotFound {
    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)
  5. cmd/site-replication.go

    			if svcErr != nil {
    				return info, errSRBackendIssue(svcErr)
    			}
    		}
    		info.UserPolicies = make(map[string]madmin.SRPolicyMapping, userPolicyMap.Size())
    		addPolicy := func(t IAMUserType, mp *xsync.MapOf[string, MappedPolicy]) {
    			mp.Range(func(k string, mp MappedPolicy) bool {
    				info.UserPolicies[k] = madmin.SRPolicyMapping{
    					IsGroup:     false,
    					UserOrGroup: k,
    					UserType:    int(t),
    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)
Back to top