- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 109 for Langen (0.38 sec)
-
internal/grid/benchmark_test.go
const requests = 10 // Create n managers. for _, remote := range grid.Managers { // Register a single handler which echos the payload. errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{ // Send 10x requests. Handle: func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr { got := 0 for b := range in { PutByteBuffer(b) got++ }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/xl-storage.go
if err != nil { return err } // Clear and repopulate for k := range foundDirs { delete(foundDirs, k) } // Populate into map for _, k := range dirs { foundDirs[k] = struct{}{} } // Delete all directories we expect to be there. for _, dir := range wantDirs { delete(foundDirs, dir) } // Nothing to delete if len(foundDirs) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/common-main.go
domainIPs := set.NewStringSet() for _, endpoint := range minioEndpoints { if net.ParseIP(endpoint) == nil { // Checking if the IP is a DNS entry. addrs, err := globalDNSCache.LookupHost(GlobalContext, endpoint) if err != nil { logger.FatalIf(err, "Unable to initialize MinIO server with [%s] invalid entry found in MINIO_PUBLIC_IPS", endpoint) } for _, addr := range addrs { domainIPs.Add(addr) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/admin-bucket-handlers.go
bucketSSEConfig, bucketTaggingConfig, bucketQuotaConfigFile, objectLockConfig, bucketVersioningConfig, bucketReplicationConfig, bucketTargetsFile, } for _, bi := range buckets { for _, cfgFile := range cfgFiles { cfgPath := pathJoin(bi.Name, cfgFile) bucket := bi.Name switch cfgFile { case bucketNotificationConfig: config, err := globalBucketMetadataSys.GetNotificationConfig(bucket)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/tier.go
default: return err } // Reset drivercache built using current config for k := range config.drivercache { delete(config.drivercache, k) } // Remove existing tier configs for k := range config.Tiers { delete(config.Tiers, k) } // Copy over the new tier configs for tier, cfg := range newConfig.Tiers { config.Tiers[tier] = cfg } config.lastRefreshedAt = UTCNow() return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
errs := make([]error, len(fanOutEntries)) objInfos := make([]ObjectInfo, len(fanOutEntries)) var wg sync.WaitGroup for i, req := range fanOutEntries { wg.Add(1) go func(idx int, req minio.PutObjectFanOutEntry) { defer wg.Done() objInfos[idx] = ObjectInfo{Name: req.Key} hopts := hash.Options{ Size: int64(len(fanOutBuf)),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0) -
internal/handlers/proxy_test.go
{forwarded, `for=172.32.10.15; proto=https;by=127.0.0.1;`, "https"}, // Space before proto {forwarded, `for=192.0.2.60;proto=http;by=203.0.113.43`, "http"}, // Multiple params } for _, v := range headers { req := &http.Request{ Header: http.Header{ v.key: []string{v.val}, }, } res := GetSourceScheme(req) if res != v.expected { t.Errorf("wrong header for %s: got %s want %s", v.key, res,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 3.2K bytes - Viewed (0) -
internal/bucket/replication/filter.go
// it returns true if there is no tags in the underlying Filter. func (f *Filter) TestTags(userTags string) bool { if f.cachedTags == nil { cached := make(map[string]string) for _, t := range append(f.And.Tags, f.Tag) { if !t.IsEmpty() { cached[t.Key] = t.Value } } f.cachedTags = cached } // This filter does not have any tags, always return true if len(f.cachedTags) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 28 18:25:46 GMT 2022 - 3.5K bytes - Viewed (2) -
docs/debugging/hash-set/main.go
set := sipHashMod(prefix+object, setCount, id) distrib[set] = append(distrib[set], prefix+object) } for set, files := range distrib { fmt.Println("Set:", set+1, "Objects:", len(files)) if !verbose { continue } for _, s := range files { fmt.Printf("\t%s\n", s) } } os.Exit(0) } if object == "" { log.Fatalln("object name is mandatory") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.7K bytes - Viewed (0) -
docs/ftp/README.md
Default port '8021' can be changed via ``` --ftp="address=:3021" ``` ### Change FTP passive port range By default FTP requests OS to give a free port automatically, however you may want to restrict this to specific ports in certain restricted environments via ``` --ftp="passive-port-range=30000-40000" ``` ### Change default SFTP port Default port '8022' can be changed via ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:15:45 GMT 2024 - 7.1K bytes - Viewed (0)