- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for CreateStringSet (0.07 sec)
-
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Jun 20 00:53:08 UTC 2023 - 2.2K bytes - Viewed (0) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.9K bytes - Viewed (0) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.2K bytes - Viewed (0) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 86.7K bytes - Viewed (0) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 12.7K bytes - Viewed (0) -
cmd/admin-handlers-idp-openid.go
cfgToUsersMap[config.Name] = newResp } if len(roleArnMap) == 0 { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminNoSuchConfigTarget), r.URL) return } userSet := set.CreateStringSet(userList...) accessKeys, err := globalIAMSys.ListAllAccessKeys(ctx) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } for _, accessKey := range accessKeys {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Sep 06 17:38:46 UTC 2025 - 7.6K bytes - Viewed (0) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 47.4K bytes - Viewed (0) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 75.3K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
break } // Handle if we have some buckets in-memory those are stale. // first delete them and then replace the newer state() // from disk. diskBuckets := set.CreateStringSet() for _, bucket := range buckets { diskBuckets.Add(bucket.Name) } sys.RemoveStaleBuckets(diskBuckets) for i := range buckets { wait := sleeper.Timer(ctx)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.4K bytes - Viewed (0) -
cmd/bucket-handlers.go
bucketsSet.Add(bucket) r, ok := dnsBuckets[bucket] if !ok { bucketsToBeUpdated.Add(bucket) continue } if !globalDomainIPs.Intersection(set.CreateStringSet(getHostsSlice(r)...)).IsEmpty() { if globalDomainIPs.Difference(set.CreateStringSet(getHostsSlice(r)...)).IsEmpty() && !domainMissing { // No difference in terms of domainIPs and nothing // has changed so we don't change anything on the etcd. //
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.9K bytes - Viewed (0)