Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for MapOf (0.02 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  2. cmd/iam-object-store.go

    	p, err := iamOS.loadMappedPolicyInternal(ctx, name, userType, isGroup)
    	if err != nil {
    		return err
    	}
    	m.Store(name, p)
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadMappedPolicies(ctx context.Context, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error {
    	var basePath string
    	if isGroup {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  3. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
  4. .teamcity/src/main/kotlin/common/CommonExtensions.kt

    fun functionalTestExtraParameters(
        buildScanTags: List<String>,
        os: Os,
        arch: Arch,
        testJvmVersion: String,
        testJvmVendor: String,
    ): String {
        val buildScanValues =
            mapOf(
                "coverageOs" to os.name.lowercase(),
                "coverageArch" to arch.name.lowercase(),
                "coverageJvmVendor" to testJvmVendor,
                "coverageJvmVersion" to "java$testJvmVersion",
            )
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Sep 10 01:37:13 UTC 2025
    - 15K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      @SuppressWarnings("JUnitIncompatibleType")
      public void testWhere() {
        assertEquals(new TypeToken<Map<String, Integer>>() {}, mapOf(String.class, Integer.class));
        // Type inference is doomed here: int.class is the same as Integer.class, so this is comparing
        // TypeToken<int[]> and TypeToken<Integer[]>.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Sep 02 17:23:59 UTC 2025
    - 89K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    	return nil
    }
    
    // listAllBuckets lists all buckets from all disks. It also
    // returns the occurrence of each buckets in all disks
    func listAllBuckets(ctx context.Context, storageDisks []StorageAPI, healBuckets *xsync.MapOf[string, VolInfo], readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    	for index := range storageDisks {
    		g.Go(func() error {
    			if storageDisks[index] == nil {
    				// we ignore disk not found errors
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      @SuppressWarnings("JUnitIncompatibleType")
      public void testWhere() {
        assertEquals(new TypeToken<Map<String, Integer>>() {}, mapOf(String.class, Integer.class));
        // Type inference is doomed here: int.class is the same as Integer.class, so this is comparing
        // TypeToken<int[]> and TypeToken<Integer[]>.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Sep 02 17:23:59 UTC 2025
    - 89K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    	return s.sets[s.getHashedSetIndex(input)]
    }
    
    // listDeletedBuckets lists deleted buckets from all disks.
    func listDeletedBuckets(ctx context.Context, storageDisks []StorageAPI, delBuckets *xsync.MapOf[string, VolInfo], readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    	for index := range storageDisks {
    		g.Go(func() error {
    			if storageDisks[index] == nil {
    				// we ignore disk not found errors
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  9. cmd/erasure-server-pool.go

    	deploymentID     [16]byte
    	distributionAlgo string
    
    	serverPools []*erasureSets
    
    	// Active decommission canceler
    	decommissionCancelers []context.CancelFunc
    
    	s3Peer *S3PeerSys
    
    	mpCache *xsync.MapOf[string, MultipartInfo]
    }
    
    func (z *erasureServerPools) SinglePool() bool {
    	return len(z.serverPools) == 1
    }
    
    // Initialize new pool of erasure sets.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  10. 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),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (1)
Back to top