Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for toSlice (0.07 sec)

  1. cmd/iam-store.go

    func (mp MappedPolicy) toSlice() []string {
    	var policies []string
    	for policy := range strings.SplitSeq(mp.Policies, ",") {
    		if strings.TrimSpace(policy) == "" {
    			continue
    		}
    		policies = append(policies, policy)
    	}
    	return policies
    }
    
    func (mp MappedPolicy) policySet() set.StringSet {
    	return set.CreateStringSet(mp.toSlice()...)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
  2. cmd/net_test.go

    		case testCase.expectedErr.Error() != err.Error():
    			t.Fatalf("error: expected = %v, got = %v", testCase.expectedErr, err)
    		}
    
    		if testCase.expectedIPList != nil {
    			var found bool
    			for _, ip := range ipList.ToSlice() {
    				if testCase.expectedIPList.Contains(ip) {
    					found = true
    				}
    			}
    			if !found {
    				t.Fatalf("host: expected = %v, got = %v", testCase.expectedIPList, ipList)
    			}
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  3. cmd/iam.go

    		// associated with any of the provider configurations.
    		//
    		// If there is no roleARN mapped to the user, the user may be
    		// coming from a policy claim based openid provider.
    		roleArns := puInfo.roleArns.ToSlice()
    		var roleArn string
    		if len(roleArns) == 0 {
    			iamLogIf(GlobalContext,
    				fmt.Errorf("parentUser: %s had no roleArns mapped!", parentUser))
    			continue
    		}
    		roleArn = roleArns[0]
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  4. cmd/iam-etcd-store.go

    	if err != nil {
    		return err
    	}
    
    	groups := etcdKvsToSet(iamConfigGroupsPrefix, r.Kvs)
    
    	// Reload config for all groups.
    	for _, group := range groups.ToSlice() {
    		if err = ies.loadGroup(ctx, group, m); err != nil && err != errNoSuchGroup {
    			return err
    		}
    	}
    	return nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  5. cmd/config-current.go

    	defer env.SetEnvOn()
    	if subSys != "" {
    		return validateSubSysConfig(ctx, s, subSys, objAPI)
    	}
    
    	// No sub-system passed. Validate all of them.
    	for _, ss := range config.SubSystems.ToSlice() {
    		if err := validateSubSysConfig(ctx, s, ss, objAPI); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    func lookupConfigs(s config.Config, objAPI ObjectLayer) {
    	ctx := GlobalContext
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
  6. cmd/bucket-handlers.go

    		}
    	}
    
    	for _, bucket := range bucketsInConflict.ToSlice() {
    		dnsLogIf(ctx, fmt.Errorf("Unable to add bucket DNS entry for bucket %s, an entry exists for the same bucket by a different tenant. This local bucket will be ignored. Bucket names are globally unique in federated deployments. Use path style requests on following addresses '%v' to access this bucket", bucket, globalDomainIPs.ToSlice()))
    	}
    
    	var wg sync.WaitGroup
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users.go

    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    		policySlice := newMappedPolicy(policy).toSlice()
    		effectivePolicy = globalIAMSys.GetCombinedPolicy(policySlice...)
    
    	case hasPolicyClaim:
    		effectivePolicy = globalIAMSys.GetCombinedPolicy(policySetFromClaims.ToSlice()...)
    
    	default:
    		policies, err := globalIAMSys.PolicyDBGet(accountName, cred.Groups...)
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  8. cmd/endpoint_test.go

    		return !net.ParseIP(ip).IsLoopback()
    	}, "")
    	if len(nonLoopBackIPs) == 0 {
    		t.Fatalf("No non-loop back IP address found for this host")
    	}
    	nonLoopBackIP := nonLoopBackIPs.ToSlice()[0]
    
    	mustAbs := func(s string) string {
    		s, err := filepath.Abs(s)
    		if err != nil {
    			t.Fatal(err)
    		}
    		return s
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  9. cmd/sts-handlers.go

    		// should be set and configured on your identity provider as
    		// part of JWT custom claims.
    		policySet, ok := policy.GetPoliciesFromClaims(claims, iamPolicyClaimNameOpenID())
    		policies := strings.Join(policySet.ToSlice(), ",")
    		if ok {
    			policyName = globalIAMSys.CurrentPolicies(policies)
    		}
    
    		if newGlobalAuthZPluginFn() == nil {
    			if !ok {
    				writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.6K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    		derrs[i] = checkDelObjArgs(ctx, bucket, objects[i].ObjectName)
    		objSets.Add(objects[i].ObjectName)
    	}
    
    	// Acquire a bulk write lock across 'objects'
    	multiDeleteLock := z.NewNSLock(bucket, objSets.ToSlice()...)
    	lkctx, err := multiDeleteLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		for i := range derrs {
    			derrs[i] = err
    		}
    		return dobjects, derrs
    	}
    	ctx = lkctx.Context()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top