- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 177 for Case (0.17 sec)
-
cmd/config-current.go
} case config.DriveSubSys: if _, err := drive.LookupConfig(s[config.DriveSubSys][config.Default]); err != nil { return err } case config.CacheSubSys: if _, err := cache.LookupConfig(s[config.CacheSubSys][config.Default], globalRemoteTargetTransport); err != nil { return err } case config.PolicyOPASubSys: // In case legacy OPA config is being set, we treat it as if the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/warm-backend.go
switch tier.Type { case madmin.S3: d, err = newWarmBackendS3(*tier.S3, tier.Name) case madmin.Azure: d, err = newWarmBackendAzure(*tier.Azure, tier.Name) case madmin.GCS: d, err = newWarmBackendGCS(*tier.GCS, tier.Name) case madmin.MinIO: d, err = newWarmBackendMinIO(*tier.MinIO, tier.Name) default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// unconsumedTimer fires. select { // Check after a second case <-time.After(time.Second): h.mutex.Unlock() continue case <-h.ctx.Done(): h.mutex.Unlock() // discard result and return. return errHealStopSignalled // Timeout if no results consumed for too long. case <-unconsumedTimer.C: h.mutex.Unlock() return errHealIdleTimeout } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/metrics-v2.go
switch madmin.BatchJobType(mj.JobType) { case madmin.BatchJobReplicate: objects = float64(mj.Replicate.Objects) objectsFailed = float64(mj.Replicate.ObjectsFailed) bucket = mj.Replicate.Bucket case madmin.BatchJobKeyRotate: objects = float64(mj.KeyRotate.Objects) objectsFailed = float64(mj.KeyRotate.ObjectsFailed) bucket = mj.KeyRotate.Bucket case madmin.BatchJobExpire:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/net.go
// ":9000" // "localhost:9000" // "localhost" <- in this case, we check for scheme host, port, err := net.SplitHostPort(addr) if err != nil { if !strings.Contains(err.Error(), "missing port in address") { return "", "", err } host = addr switch scheme { case "https": port = "443" case "http": port = "80" default:
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/bucket/bandwidth/monitor_gen.go
if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "LimitInBytesPerSecond": z.LimitInBytesPerSecond, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "LimitInBytesPerSecond") return } case "CurrentBandwidthInBytesPerSecond": z.CurrentBandwidthInBytesPerSecond, err = dc.ReadFloat64() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/bucket-policy.go
var signatureVersion string switch authType { case authTypeSignedV2, authTypePresignedV2: signatureVersion = signV2Algorithm case authTypeSigned, authTypePresigned, authTypeStreamingSigned, authTypePostPolicy: signatureVersion = signV4Algorithm } var authtype string switch authType { case authTypePresignedV2, authTypePresigned: authtype = "REST-QUERY-STRING"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8K bytes - Viewed (0) -
cmd/object-api-utils.go
r, w := 0, 0 if rooted { r, w = 1, 1 } for r < n { switch { case path[r] > 127: // Non ascii. return true case path[r] == '/': // multiple / elements return true case path[r] == '.' && (r+1 == n || path[r+1] == '/'): // . element - assume it has to be cleaned. return true case path[r] == '.' && path[r+1] == '.' && (r+2 == n || path[r+2] == '/'):
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
internal/grid/muxclient.go
for { select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) } err := context.Cause(m.ctx) if !errors.Is(err, errStreamEOF) { m.addErrorNonBlockingClose(respHandler, err) } return case resp, ok := <-respServer: if !ok { return } select { case respHandler <- resp: m.respMu.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0)