- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for NewStringSet (0.24 sec)
-
cmd/bootstrap-peer-server.go
incorrectConfigs = nil } } return nil } func newBootstrapRESTClients(endpointServerPools EndpointServerPools, gm *grid.Manager) []*bootstrapRESTClient { seenClient := set.NewStringSet() var clnts []*bootstrapRESTClient for _, ep := range endpointServerPools { for _, endpoint := range ep.Endpoints { if endpoint.IsLocal { continue } if seenClient.Contains(endpoint.Host) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/net.go
func mustGetLocalIP4() (ipList set.StringSet) { ipList = set.NewStringSet() for _, ip := range mustGetLocalIPs() { if ip.To4() != nil { ipList.Add(ip.String()) } } return } // mustGetLocalIP6 returns IPv6 addresses of localhost. It panics on error. func mustGetLocalIP6() (ipList set.StringSet) { ipList = set.NewStringSet() for _, ip := range mustGetLocalIPs() { if ip.To4() == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/event/config.go
type filterRuleList FilterRuleList rules := filterRuleList{} if err := d.DecodeElement(&rules, &start); err != nil { return err } // FilterRuleList must have only one prefix and/or suffix. nameSet := set.NewStringSet() for _, rule := range rules.Rules { if nameSet.Contains(rule.Name) { if rule.Name == "prefix" { return &ErrFilterNamePrefix{} } return &ErrFilterNameSuffix{} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 8.4K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
pkMap: map[string]interface{}{}, }, roleArnPolicyMap: map[arn.ARN]string{}, transport: openIDClientTransport, closeRespFn: closeRespFn, } seenClientIDs := set.NewStringSet() deprecatedKeys := []string{JwksURL} // remove this since we have removed support for this already. for k := range s[config.IdentityOpenIDSubSys] { for _, dk := range deprecatedKeys {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0) -
cmd/site-replication.go
numSites := len(sris) allBuckets := set.NewStringSet() // across sites allUsers := set.NewStringSet() allUserWPolicies := set.NewStringSet() allGroups := set.NewStringSet() allGroupWPolicies := set.NewStringSet() allILMExpiryRules := set.NewStringSet() allPolicies := set.NewStringSet() for _, sri := range sris { for b := range sri.Buckets { allBuckets.Add(b)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/iam-etcd-store.go
"go.etcd.io/etcd/api/v3/mvccpb" etcd "go.etcd.io/etcd/client/v3" ) var defaultContextTimeout = 30 * time.Second func etcdKvsToSet(prefix string, kvs []*mvccpb.KeyValue) set.StringSet { users := set.NewStringSet() for _, kv := range kvs { user := extractPathPrefixAndSuffix(string(kv.Key), prefix, path.Base(string(kv.Key))) users.Add(user) } return users }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/endpoint_contrib_test.go
defer func() { globalDomainIPs = tempGlobalDomainIPs }() ipv4TestCases := []struct { endPoints set.StringSet expectedResult set.StringSet }{ {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")},
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) -
cmd/endpoint-ellipses.go
} setArgs = s.Get() } else { s, err := parseEndpointSet(setDriveCount, args...) if err != nil { return nil, err } setArgs = s.Get() } uniqueArgs := set.NewStringSet() for _, sargs := range setArgs { for _, arg := range sargs { if uniqueArgs.Contains(arg) { return nil, config.ErrInvalidErasureEndpoints(nil).Msg(fmt.Sprintf("Input args (%s) has duplicate ellipses", args))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/endpoint.go
} for i, endpoints := range poolEndpoints { // Here all endpoints are URL style. endpointPathSet := set.NewStringSet() localEndpointCount := 0 localServerHostSet := set.NewStringSet() localPortSet := set.NewStringSet() for _, endpoint := range endpoints { endpointPathSet.Add(endpoint.Path) if endpoint.IsLocal && endpoint.Host != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cmd/iam.go
accessKeyMap[k] = v } return nil } func (sys *IAMSys) getStoredLDAPPolicyMappingKeys(ctx context.Context, isGroup bool) set.StringSet { entityKeysInStorage := set.NewStringSet() if iamOS, ok := sys.store.IAMStorageAPI.(*IAMObjectStore); ok { // Load existing mapping keys from the cached listing for // `IAMObjectStore`.
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)