Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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")},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 30 15:50:39 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  2. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  3. 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()),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. 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])},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. 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() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 19 08:43:09 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  6. 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,
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  7. 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
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  8. cmd/admin-handlers-idp-config.go

    	if cfgTarget != madmin.Default {
    		// This cannot give an error at this point.
    		subSysTargets, _ := s.GetAvailableTargets(subSys)
    		subSysTargetsSet := set.CreateStringSet(subSysTargets...)
    		if isUpdate && !subSysTargetsSet.Contains(cfgTarget) {
    			return ErrAdminConfigIDPCfgNameDoesNotExist
    		}
    		if !isUpdate && subSysTargetsSet.Contains(cfgTarget) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. cmd/admin-handlers-users_test.go

    	}
    	groupInfo, err := s.adm.GetGroupDescription(ctx, group)
    	if err != nil {
    		c.Fatalf("group desc err: %v", err)
    	}
    	c.Assert(groupInfo.Name, group)
    	c.Assert(set.CreateStringSet(groupInfo.Members...), set.CreateStringSet(accessKey))
    	c.Assert(groupInfo.Policy, policy)
    	c.Assert(groupInfo.Status, string(madmin.GroupEnabled))
    
    	// 5. Disable/enable the group and verify that user access is revoked/restored.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  10. cmd/iam.go

    func (sys *IAMSys) createCleanEntitiesQuery(q madmin.PolicyEntitiesQuery, ldap bool) cleanEntitiesQuery {
    	cleanQ := cleanEntitiesQuery{
    		Users:    make(map[string]set.StringSet),
    		Groups:   set.CreateStringSet(q.Groups...),
    		Policies: set.CreateStringSet(q.Policy...),
    	}
    
    	if ldap {
    		// Validate and normalize users, then fetch and normalize their groups
    		// Also include unvalidated users for backward compatibility.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
Back to top