Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for CreateStringSet (0.18 sec)

  1. cmd/iam-store.go

    	gi, ok := cache.iamGroupsMap[group]
    	if !ok {
    		return updatedAt, errNoSuchGroup
    	}
    
    	s := set.CreateStringSet(gi.Members...)
    	d := set.CreateStringSet(members...)
    	gi.Members = s.Difference(d).ToSlice()
    
    	if !updateCacheOnly {
    		err := store.saveGroupInfo(ctx, group, gi)
    		if err != nil {
    			return updatedAt, err
    		}
    	}
    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)
  2. cmd/endpoint_contrib_test.go

    	}{
    		{set.NewStringSet(), set.NewStringSet()},
    		{set.CreateStringSet("localhost"), set.NewStringSet()},
    		{set.CreateStringSet("localhost", "10.0.0.1"), set.CreateStringSet("10.0.0.1:9000")},
    		{set.CreateStringSet("localhost:9001", "10.0.0.1"), set.CreateStringSet("10.0.0.1:9000")},
    		{set.CreateStringSet("localhost", "10.0.0.1:9001"), set.CreateStringSet("10.0.0.1:9001")},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 30 15:50:39 GMT 2021
    - 2.2K bytes
    - Viewed (0)
  3. cmd/sts-handlers_test.go

    		gotBuckets.Add(b.Name)
    		if !(b.Access.Read && b.Access.Write) {
    			c.Fatalf("root user should have read and write access to bucket: %v", b.Name)
    		}
    	}
    	shouldHaveBuckets := set.CreateStringSet(bucket2, bucket)
    	if !gotBuckets.Equals(shouldHaveBuckets) {
    		c.Fatalf("root user should have access to all buckets")
    	}
    
    	// This must fail.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  4. cmd/server_test.go

    		c.Fatal(err)
    	}
    
    	for k := range expectedMap {
    		if v, ok := res.Header[k]; !ok {
    			c.Errorf("Expected key %s missing from %v", k, res.Header)
    		} else {
    			expectedSet := set.CreateStringSet(expectedMap[k]...)
    			gotSet := set.CreateStringSet(strings.Split(v[0], ", ")...)
    			if !expectedSet.Equals(gotSet) {
    				c.Errorf("Expected value %v, got %v", strings.Join(expectedMap[k], ", "), v)
    			}
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  5. cmd/site-replication_test.go

    			set.CreateStringSet("dep1", "dep2", "dep3"),
    			set.CreateStringSet("dep1", "dep2", "dep3", "dep4"),
    			[]string{},
    		},
    		// Test3: not currently under site replication.
    		{
    			[]madmin.PeerInfo{},
    			set.CreateStringSet(),
    			set.CreateStringSet("dep1", "dep2", "dep3", "dep4"),
    			[]string{},
    		},
    	}
    
    	for i, tc := range testCases {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 20 00:53:08 GMT 2023
    - 2.2K bytes
    - Viewed (0)
  6. cmd/iam.go

    	for _, parentUser := range parentUsers {
    		currGroupsSet := updatedGroups[parentUser]
    		currGroups := currGroupsSet.ToSlice()
    		for _, cred := range parentUserToCredsMap[parentUser] {
    			gSet := set.CreateStringSet(cred.Groups...)
    			if gSet.Equals(currGroupsSet) {
    				// No change to groups memberships for this
    				// credential.
    				continue
    			}
    
    			// Expired credentials don't need group membership updates.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  7. cmd/policy_test.go

    			Principal: miniogopolicy.User{AWS: set.CreateStringSet("*")},
    			Resources: set.CreateStringSet(policy.NewResource(bucketName).String()),
    			Actions:   set.CreateStringSet("s3:GetBucketLocation", "s3:ListBucket"),
    		},
    		{
    			Effect:    string(policy.Allow),
    			Principal: miniogopolicy.User{AWS: set.CreateStringSet("*")},
    			Resources: set.CreateStringSet(policy.NewResource(bucketName + "/" + prefix).String()),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 8.9K bytes
    - Viewed (0)
  8. internal/http/listener_test.go

    	}{
    		{[]string{"localhost:" + casePorts[0]}, set.CreateStringSet("127.0.0.1:" + casePorts[0])},
    		{[]string{nonLoopBackIP + ":" + casePorts[1]}, set.CreateStringSet(nonLoopBackIP + ":" + casePorts[1])},
    		{[]string{"127.0.0.1:" + casePorts[2], nonLoopBackIP + ":" + casePorts[2]}, set.CreateStringSet("127.0.0.1:"+casePorts[2], nonLoopBackIP+":"+casePorts[2])},
    		{[]string{"localhost:" + casePorts[3]}, set.CreateStringSet("127.0.0.1:" + casePorts[3])},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  9. internal/config/config.go

    var NotifySubSystems = set.CreateStringSet(
    	NotifyKafkaSubSys,
    	NotifyMQTTSubSys,
    	NotifyMySQLSubSys,
    	NotifyNATSSubSys,
    	NotifyNSQSubSys,
    	NotifyESSubSys,
    	NotifyAMQPSubSys,
    	NotifyPostgresSubSys,
    	NotifyRedisSubSys,
    	NotifyWebhookSubSys,
    )
    
    // LambdaSubSystems - all lambda sub-systems
    var LambdaSubSystems = set.CreateStringSet(
    	LambdaWebhookSubSys,
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  10. cmd/net_test.go

    		}
    	}
    }
    
    func TestMustGetLocalIP4(t *testing.T) {
    	testCases := []struct {
    		expectedIPList set.StringSet
    	}{
    		{set.CreateStringSet("127.0.0.1")},
    	}
    
    	for _, testCase := range testCases {
    		ipList := mustGetLocalIP4()
    		if testCase.expectedIPList != nil && testCase.expectedIPList.Intersection(ipList).IsEmpty() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 08:43:09 GMT 2024
    - 9.3K bytes
    - Viewed (0)
Back to top