- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 460 for if (0.27 sec)
-
internal/crypto/metadata_test.go
keyID, dataKey, sealedKey, err := S3.ParseMetadata(test.Metadata) if err != nil && test.ExpectedErr == nil { t.Errorf("Test %d: got error '%v' - want error '%v'", i, err, test.ExpectedErr) } if err == nil && test.ExpectedErr != nil { t.Errorf("Test %d: got error '%v' - want error '%v'", i, err, test.ExpectedErr) } if err != nil && test.ExpectedErr != nil { if err.Error() != test.ExpectedErr.Error() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 00:13:57 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/mrf.go
return case u, ok := <-m.opCh: if !ok { return } // We might land at .metacache, .trash, .multipart // no need to heal them skip, only when bucket // is '.minio.sys' if u.bucket == minioMetaBucket { // No MRF needed for temporary objects if wildcard.Match("buckets/*/.metacache/*", u.object) { continue } if wildcard.Match("tmp/*", u.object) { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/erasure-common.go
Prefix: req.Prefix, File: wantFile, } for i := range resps { if disks[i] == nil { continue } select { case <-ctx.Done(): case gotFile, ok := <-resps[i]: if !ok { continue } if gotFile.Error != "" || !gotFile.Exists { continue } if gotFile.File != wantFile || gotFile.Bucket != req.Bucket || gotFile.Prefix != req.Prefix { continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/logger/console.go
// Strip escape control characters from json message msg = ansiRE.ReplaceAllLiteralString(msg, "") console.json(msg, args...) case quietFlag: if len(msg) != 0 && len(args) == 0 { args = append(args, msg) msg = "%s" } console.quiet(msg+"\n", args...) default: if len(msg) != 0 && len(args) == 0 { args = append(args, msg) msg = "%s" } console.pretty(msg+"\n", args...) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
docs/sts/assume-role.go
} else { defer f.Close() bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } stsOpts.Policy = policy } if expiryDuration != 0 { stsOpts.DurationSeconds = int(expiryDuration.Seconds()) } li, err := cr.NewSTSAssumeRole(stsEndpoint, stsOpts) if err != nil { log.Fatalf("Error initializing STS Identity: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 16:09:55 GMT 2024 - 4K bytes - Viewed (1) -
cmd/signals.go
// If global profiler is set stop before we exit. globalProfilerMu.Lock() defer globalProfilerMu.Unlock() for _, p := range globalProfiler { p.Stop() } if success { os.Exit(0) } os.Exit(1) } stopProcess := func() bool { // send signal to various go-routines that they need to quit. cancelGlobalContext() if httpServer := newHTTPServerFn(); httpServer != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/license-update.go
resp, err := globalSubnetConfig.Post(url, nil) if err != nil { subnetLogIf(ctx, fmt.Errorf("error from %s: %w", url, err)) return } r := gjson.Parse(resp).Get("license_v2") if r.Index == 0 { internalLogIf(ctx, fmt.Errorf("license not found in response from %s", url)) return } lic := r.String() if lic == globalSubnetConfig.License { // license hasn't changed. return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/httprange_test.go
rs, err := parseRequestRangeSpec(testCase.spec) if err != nil { if !testCase.errExpected || err == nil && testCase.errExpected { t.Errorf("unexpected err: %v", err) } continue } h, err := rs.ToHeader() if err != nil && !testCase.errExpected || err == nil && testCase.errExpected { t.Errorf("expected error with invalid range: %v", err) } if h != testCase.spec {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 3.7K bytes - Viewed (0) -
internal/http/server.go
) var interfaceFound bool for i := range listenErrs { if listenErrs[i] != nil { listenErrCallback(srv.Addrs[i], listenErrs[i]) } else { interfaceFound = true } } if !interfaceFound { return nil, errors.New("no available interface found") } // Wrap given handler to do additional // * return 503 (service unavailable) if the server in shutdown.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
docs/debugging/xattr/main.go
table.SetNoWhiteSpace(true) if set { if err := setxattr(path, name, value); err != nil { log.Fatalln(fmt.Errorf("setting attribute %s failed with: %v", name, err)) } } else { if name == "" { log.Fatalln("you must specify an attribute name for reading") } var names []string if name == "." { attrs, err := listxattr(path) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 29 23:52:41 GMT 2023 - 3.2K bytes - Viewed (0)