- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 183 for background (0.15 sec)
-
cmd/erasure-object.go
if err != nil { if errors.Is(err, errErasureReadQuorum) && !strings.HasPrefix(srcBucket, minioMetaBucket) { _, derr := er.deleteIfDangling(context.Background(), srcBucket, srcObject, metaArr, errs, nil, srcOpts) if derr != nil { err = derr } } return ObjectInfo{}, toObjectErr(err, srcBucket, srcObject) } // List all online disks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/grid/grid_test.go
})) // local to remote remoteConn := local.Connection(remoteHost) remoteConn.WaitForConnect(context.Background()) defer testlogger.T.SetErrorTB(t)() t.Run("localToRemote", func(t *testing.T) { const testPayload = "Hello Grid World!" start := time.Now() resp, err := remoteConn.Request(context.Background(), handlerTest, []byte(testPayload)) errFatal(err) if string(resp) != testPayload {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/event/target/webhook.go
func (target *WebhookTarget) initWebhook() error { args := target.args transport := target.transport if args.ClientCert != "" && args.ClientKey != "" { manager, err := certs.NewManager(context.Background(), args.ClientCert, args.ClientKey, tls.LoadX509KeyPair) if err != nil { return err } manager.ReloadOnSignal(syscall.SIGHUP) // allow reloads upon SIGHUP
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
cmd/erasure_test.go
buffer := make([]byte, len(data), 2*len(data)) copy(buffer, data) erasure, err := NewErasure(context.Background(), test.dataBlocks, test.parityBlocks, blockSizeV2) if err != nil { t.Fatalf("Test %d: failed to create erasure: %v", i, err) } encoded, err := erasure.EncodeData(context.Background(), buffer) if err != nil { t.Fatalf("Test %d: failed to encode data: %v", i, err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 4.8K bytes - Viewed (0) -
cmd/jwt_test.go
return token.SignedString([]byte(secretKey)) } // Tests web request authenticator. func TestWebRequestAuthenticate(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:14 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
func TestListOnlineDisks(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, disks, err := prepareErasure16(ctx) if err != nil { t.Fatalf("Prepare Erasure backend failed - %v", err) } setObjectLayer(obj) defer obj.Shutdown(context.Background()) defer removeRoots(disks) type tamperKind int const ( noTamper tamperKind = iota
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 23K bytes - Viewed (1) -
cmd/object-api-multipart_test.go
err = obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{}) if err != nil { // failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } res, err := obj.NewMultipartUpload(context.Background(), bucket, "\\", opts) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) } err = obj.AbortMultipartUpload(context.Background(), bucket, "\\", res.UploadID, opts)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
cmd/admin-heal-ops.go
clientToken = fmt.Sprintf("%s:%d", h.clientToken, GetProxyEndpointLocalIndex(globalProxyEndpoints)) } if h.clientToken == bgHealingUUID { // For background heal do nothing, do not spawn an unnecessary goroutine. } else { // Launch top-level background heal go-routine go h.healSequenceStart(objAPI) } b, err := json.Marshal(madmin.HealStartSuccess{ ClientToken: clientToken,
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) -
internal/config/cache/cache.go
return nil, err } // We do not want Gets to take so much time, anything // beyond 250ms we should cut it, remote cache is too // busy already. ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, c.Endpoint+mcacheV1Check, bytes.NewReader(buf)) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/hash/checksum.go
b = append(b, crc...) if c.Type.Is(ChecksumMultipart) { var checksums int // Ensure we don't divide by 0: if c.Type.RawByteLen() == 0 || len(parts)%c.Type.RawByteLen() != 0 { hashLogIf(context.Background(), fmt.Errorf("internal error: Unexpected checksum length: %d, each checksum %d", len(parts), c.Type.RawByteLen())) checksums = 0 parts = nil } else { checksums = len(parts) / c.Type.RawByteLen() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0)