- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for CreateStringSet (0.12 sec)
-
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.8K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 10 18:57:03 UTC 2025 - 9.2K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 37.7K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 87.1K 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 Dec 28 19:28:13 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 Dec 28 19:28:13 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Oct 15 17:00:45 UTC 2025 - 50.6K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Oct 15 17:00:45 UTC 2025 - 76.5K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 63.9K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.4K bytes - Viewed (0)