- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 216 for Walser (0.15 sec)
-
internal/event/target/nats.go
target.natsConn, connErr = target.args.connectNats() } else if !target.natsConn.IsConnected() { return false, store.ErrNotConnected } } if connErr != nil { if connErr.Error() == nats.ErrNoServers.Error() { return false, store.ErrNotConnected } return false, connErr } if target.natsConn != nil && target.args.JetStream.Enable {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
} } else { removeKey = func(s []byte) bool { for _, key := range keys { if key == string(s) { return true } } return false } } // Version plus header... plSize := 1 + msgp.MapHeaderSize found := false for i := uint32(0); i < sz; i++ { var foundKey, foundVal []byte var err error foundKey, buf, err = msgp.ReadMapKeyZC(buf) if err != nil { break
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/hash/reader_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.3K bytes - Viewed (0) -
cmd/is-dir-empty_linux.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 15:17:08 GMT 2024 - 1.4K bytes - Viewed (0) -
cmd/bucket-targets.go
if h, ok := sys.hc[ep.Host]; ok { return !h.Online } go sys.initHC(ep) return false } // markOffline sets endpoint to offline if network i/o timeout seen. func (sys *BucketTargetSys) markOffline(ep *url.URL) { sys.hMutex.Lock() defer sys.hMutex.Unlock() if h, ok := sys.hc[ep.Host]; ok { h.Online = false sys.hc[ep.Host] = h } } func (sys *BucketTargetSys) initHC(ep *url.URL) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/object_api_suite_test.go
globalCompressConfig.Enabled = false globalCompressConfigMu.Unlock() globalAutoEncryption = true var err error GlobalKMS, err = kms.Parse("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=") if err != nil { t.Fatal(err) } } func resetCompressEncryption() { // Reset... globalCompressConfigMu.Lock() globalCompressConfig.Enabled = false globalCompressConfig.AllowEncrypted = false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/api-utils.go
"net/http" "reflect" "runtime" "strings" ) func shouldEscape(c byte) bool { if 'A' <= c && c <= 'Z' || 'a' <= c && c <= 'z' || '0' <= c && c <= '9' { return false } switch c { case '-', '_', '.', '/', '*': return false } return true } // s3URLEncode is based on Golang's url.QueryEscape() code, // while considering some S3 exceptions: // - Avoid encoding '/' and '*'
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/object-handlers.go
if srcBucket == dstBucket { return false } return isRemoteCallRequired(ctx, dstBucket, objAPI) } // Check if the bucket is on a remote site, this code only gets executed when federation is enabled. func isRemoteCallRequired(ctx context.Context, bucket string, objAPI ObjectLayer) bool { if globalDNSConfig == nil { return false } if globalBucketFederation {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/data-usage_test.go
s, err = os.Stat(item.Path) if err != nil { return } sizeS.totalSize = s.Size() sizeS.versions++ return sizeS, nil } return } weSleep := func() bool { return false } got, err := scanDataFolder(context.Background(), nil, base, dataUsageCache{Info: dataUsageCacheInfo{Name: bucket}}, getSize, 0, weSleep) if err != nil { t.Fatal(err) } // Test dirs want := []struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
if err != nil || len(b) != len(toWrite) { continue } err = p.storage.Delete(context.Background(), minioMetaTmpBucket, fn, DeleteOptions{ Recursive: false, Immediate: false, }) if err == nil { logger.Event(context.Background(), "healthcheck", "node(%s): Read/Write/Delete successful, bringing drive %s online", globalLocalNodeName, p.storage.String())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)