- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 391 for ctx_ (0.04 sec)
-
docs/bucket/lifecycle/DESIGN.md
Tiering and lifecycle transition are applicable only to erasure/distributed MinIO. ## Explore Further - [MinIO | Golang Client API Reference](https://min.io/docs/minio/linux/developers/go/API.html#setbucketlifecycle-ctx-context-context-bucketname-config-lifecycle-configuration-error)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 4.3K bytes - Viewed (0) -
cmd/xl-storage_test.go
// create xlStorage test setup xl, _, err := newXLStorageTestSetup(t) if err != nil { t.Fatalf("Unable to create xlStorage test setup, %s", err) } ctx := context.Background() volume := "myvol-vol" object := "my-object" if err := xl.MakeVol(ctx, volume); err != nil { t.Fatalf("Unable to create volume, %s", err) } var versions [50]string for i := range versions {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 66.7K bytes - Viewed (0) -
tests/test_filter_pydantic_sub_model_pv2.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Apr 18 19:40:57 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/signature-v4_test.go
} } } func TestDoesPresignedSignatureMatch(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) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 10.5K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
server.enqueue(MockResponse(body = "abc")) val ctxt = InstrumentationRegistry.getInstrumentation().targetContext.applicationContext val cacheSize = 1L * 1024 * 1024 // 1MB val cache = Cache(ctxt.cacheDir.resolve("testCache"), cacheSize) try { client = client.newBuilder() .cache(cache)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 27K bytes - Viewed (0) -
internal/crypto/sse-s3.go
// from the metadata using the KMS and returns the decrypted object // keys. // // The metadata, buckets and objects slices must have the same length. func (s3 sses3) UnsealObjectKeys(ctx context.Context, k *kms.KMS, metadata []map[string]string, buckets, objects []string) ([]ObjectKey, error) { if k == nil { return nil, Errorf("KMS not configured") }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/etag/reader.go
// MD5 checksum of the content read from r as ETag. // // If the provided etag is not nil the returned // Reader compares the etag with the computed // MD5 sum once the r returns io.EOF. func NewReader(ctx context.Context, r io.Reader, etag ETag, forceMD5 []byte) *Reader { if er, ok := r.(*Reader); ok { if er.readN == 0 && Equal(etag, er.checksum) { return er } } if len(forceMD5) != 0 { return &Reader{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 4.8K bytes - Viewed (0) -
internal/bucket/object/lock/lock.go
xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/env" ) const ( logSubsys = "locking" ) func lockLogIf(ctx context.Context, err error) { logger.LogIf(ctx, logSubsys, err) } // Enabled indicates object locking is enabled const Enabled = "Enabled" // RetMode - object retention mode. type RetMode string const (
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 29 01:20:27 UTC 2024 - 17.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
ipc.send(new Trans2GetDfsReferral(ctx.getConfig(), path), resp); dfsResp = resp.getDfsResponse(); } if ( dfsResp.getNumReferrals() == 0 ) { return null; } else if ( rn == 0 || dfsResp.getNumReferrals() < rn ) { rn = dfsResp.getNumReferrals();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 18 23:47:00 UTC 2023 - 67K bytes - Viewed (0) -
cmd/object-handlers_test.go
uploadID: uploadIDs[0], parts: inputParts[0].parts, accessKey: credentials.AccessKey, secretKey: credentials.SecretKey, expectedContent: encodeResponse(getAPIErrorResponse(ctx, toAPIError(ctx, InvalidPart{}), getGetObjectURL("", bucketName, objectName), "", "")), expectedRespStatus: http.StatusBadRequest, }, // Test case - 2. // No parts specified in CompletePart{}.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:10:44 UTC 2024 - 163.2K bytes - Viewed (0)