Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 391 for ctx_ (0.05 sec)

  1. 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)
  2. 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)
  3. tests/test_filter_pydantic_sub_model_pv2.py

            IsDict(
                {
                    "type": "value_error",
                    "loc": ("response", "name"),
                    "msg": "Value error, name must end in A",
                    "input": "modelX",
                    "ctx": {"error": HasRepr("ValueError('name must end in A')")},
                }
            )
            | IsDict(
                # TODO remove when deprecating Pydantic v1
                {
                    "loc": ("response", "name"),
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top