- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for CreateStringSet (0.7 sec)
-
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) -
cmd/signature-v4.go
query.Set(xhttp.AmzSignedHeaders, strings.Join(pSignValues.SignedHeaders, ";")) query.Set(xhttp.AmzCredential, cred.AccessKey+SlashSeparator+pSignValues.Credential.getScope()) defaultSigParams := set.CreateStringSet( xhttp.AmzContentSha256, xhttp.AmzSecurityToken, xhttp.AmzAlgorithm, xhttp.AmzDate, xhttp.AmzExpires, xhttp.AmzSignedHeaders, xhttp.AmzCredential, xhttp.AmzSignature, )
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Dec 13 22:19:12 UTC 2024 - 12.4K bytes - Viewed (0) -
cmd/generic-handlers.go
} else { writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return } if globalDomainIPs.Intersection(set.CreateStringSet(getHostsSlice(sr)...)).IsEmpty() { r.URL.Scheme = "http" if globalIsTLS { r.URL.Scheme = "https" } r.URL.Host = getHostFromSrv(sr) // Make sure we remove any existing headers before
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.7K bytes - Viewed (1) -
cmd/background-newdisks-heal-ops.go
// Order is preserved. func (h *healingTracker) setQueuedBuckets(buckets []BucketInfo) { h.mu.Lock() defer h.mu.Unlock() s := set.CreateStringSet(h.HealedBuckets...) h.QueuedBuckets = make([]string, 0, len(buckets)) for _, b := range buckets { if !s.Contains(b.Name) { h.QueuedBuckets = append(h.QueuedBuckets, b.Name) } } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.5K bytes - Viewed (0) -
cmd/endpoint.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 34.4K bytes - Viewed (0) -
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) } } } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118.1K bytes - Viewed (0) -
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.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 100.2K bytes - Viewed (1)