Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 44 for Watcher (0.21 sec)

  1. cmd/encryption-v1.go

    // is more efficient than decrypting ETags sequentually.
    func DecryptETags(ctx context.Context, k kms.KMS, objects []ObjectInfo) error {
    	const BatchSize = 250 // We process the objects in batches - 250 is a reasonable default.
    	var (
    		metadata = make([]map[string]string, 0, BatchSize)
    		buckets  = make([]string, 0, BatchSize)
    		names    = make([]string, 0, BatchSize)
    	)
    	for len(objects) > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  2. cmd/api-router.go

    				// is available and honored at this domain.
    				//
    				// All other `<bucket>.<namespace>.svc.<cluster_domain>`
    				// makes sure that buckets are routed through this matcher
    				// to match for `<bucket>`
    				return host != minioReservedBucket+"."+domainName
    			}).Host("{bucket:.+}."+domainName).Subrouter())
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    	if err != nil {
    		return err
    	}
    	*ef = BatchJobExpireFilter(tmp)
    	ef.line, ef.col = value.Line, value.Column
    	return err
    }
    
    // Matches returns true if obj matches the filter conditions specified in ef.
    func (ef BatchJobExpireFilter) Matches(obj ObjectInfo, now time.Time) bool {
    	switch ef.Type {
    	case BatchJobExpireObject:
    		if obj.DeleteMarker {
    			return false
    		}
    	case BatchJobExpireDeleted:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  4. internal/bucket/replication/replication_test.go

    		{ObjectOpts{Name: "abc/c4test", DeleteMarker: true, OpType: DeleteReplicationType}, cfgs[3], true},                                      // 36. matches rule 2 - DeleteMarker replication allowed by rule
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  5. docs/metrics/prometheus/grafana/bucket/minio-bucket.json

                    "color": "red",
                    "value": 80
                  }
                ]
              },
              "unit": "none"
            },
            "overrides": [
              {
                "matcher": {
                  "id": "byName",
                  "options": "S3 Errors"
                },
                "properties": [
                  {
                    "id": "color",
                    "value": {
    Json
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 10:03:01 GMT 2024
    - 102K bytes
    - Viewed (1)
  6. internal/s3select/sql/stringfuncs_test.go

    		{"abcd", "bc", false, "", false},
    		{"abcd", "bc", true, "d", true},
    	}
    
    	for i, tc := range matcherCases {
    		res, ok := matcher(tc.iText, tc.iPat, tc.iHasLeadingPercent)
    		if res != tc.resultExpected || ok != tc.matchExpected {
    			t.Errorf("Matcher Case %d failed", i)
    		}
    	}
    
    	evalCases := []struct {
    		iText, iPat   string
    		iEsc          rune
    		matchExpected bool
    		errExpected   error
    	}{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.1K bytes
    - Viewed (0)
  7. cmd/signature-v4.go

    }
    
    // doesPolicySignatureMatch - Verify query headers with post policy
    //   - http://docs.aws.amazon.com/AmazonS3/latest/API/sigv4-HTTPPOSTConstructPolicy.html
    //
    // returns ErrNone if the signature matches.
    func doesPolicySignatureV4Match(formValues http.Header) (auth.Credentials, APIErrorCode) {
    	// Server region.
    	region := globalSite.Region
    
    	// Parse credential tag.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  8. cmd/object-handlers-common.go

    	ifNoneMatchETagHeader := r.Header.Get(xhttp.AmzCopySourceIfNoneMatch)
    	if ifNoneMatchETagHeader != "" {
    		if isETagEqual(objInfo.ETag, ifNoneMatchETagHeader) {
    			// If the object ETag matches with the specified ETag.
    			writeHeaders()
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPreconditionFailed), r.URL)
    			return true
    		}
    	}
    	// Object content should be written to http.ResponseWriter
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 08:17:49 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  9. internal/etag/reader.go

    	return wrapReader{
    		Reader: wrapped,
    	}
    }
    
    // A Reader wraps an io.Reader and computes the
    // MD5 checksum of the read content as ETag.
    //
    // Optionally, a Reader can also verify that
    // the computed ETag matches an expected value.
    // Therefore, it compares both ETags once the
    // underlying io.Reader returns io.EOF.
    // If the computed ETag does not match the
    // expected ETag then Read returns a VerifyError.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  10. cmd/metacache-set.go

    				topEntries[i] = entry
    				current = entry
    				agree++
    				continue
    			}
    			// If exact match, we agree.
    			if _, ok := current.matches(&entry, true); ok {
    				topEntries[i] = entry
    				agree++
    				continue
    			}
    			// If only the name matches we didn't agree, but add it for resolution.
    			if entry.name == current.name {
    				topEntries[i] = entry
    				continue
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
Back to top