Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for follower (0.17 sec)

  1. cmd/object-multipart-handlers.go

    	if s3Err == ErrNone && retentionMode.Valid() {
    		metadata[strings.ToLower(xhttp.AmzObjectLockMode)] = string(retentionMode)
    		metadata[strings.ToLower(xhttp.AmzObjectLockRetainUntilDate)] = amztime.ISO8601Format(retentionDate.UTC())
    	}
    	if s3Err == ErrNone && legalHold.Status.Valid() {
    		metadata[strings.ToLower(xhttp.AmzObjectLockLegalHold)] = string(legalHold.Status)
    	}
    	if s3Err != ErrNone {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  2. internal/event/target/kafka.go

    	config.Producer.Return.Successes = true
    	config.Producer.Return.Errors = true
    	config.Producer.RequiredAcks = 1
    	config.Producer.Timeout = (5 * time.Second)
    	// Set Producer Compression
    	cc, ok := codecs[strings.ToLower(args.Producer.Compression)]
    	if ok {
    		config.Producer.Compression = cc
    		config.Producer.CompressionLevel = args.Producer.CompressionLevel
    	}
    
    	config.Net.ReadTimeout = (5 * time.Second)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  3. internal/s3select/select.go

    			return err
    		}
    
    		return errMalformedXML(err)
    	}
    	if err := parsedS3Select.ScanRange.Validate(); err != nil {
    		return errInvalidScanRangeParameter(err)
    	}
    	parsedS3Select.ExpressionType = strings.ToLower(parsedS3Select.ExpressionType)
    	if parsedS3Select.ExpressionType != "sql" {
    		return errInvalidExpressionType(fmt.Errorf("invalid expression type '%v'", parsedS3Select.ExpressionType))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (1)
  4. cmd/handler-utils.go

    		if err != nil {
    			return nil, err
    		}
    	}
    
    	// Set content-type to default value if it is not set.
    	if _, ok := metadata[strings.ToLower(xhttp.ContentType)]; !ok {
    		metadata[strings.ToLower(xhttp.ContentType)] = "binary/octet-stream"
    	}
    
    	// https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
    	for k := range metadata {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  5. internal/event/target/postgresql.go

    			return '0'
    		case r == '_', r == '$':
    			return r
    		default:
    			valid = false
    			return -1
    		}
    	}, name)
    
    	if valid {
    		// check for simple name or quoted name
    		// - letter/underscore followed by one or more letter/digit/underscore
    		// - any text between quotes (text cannot contain a quote itself)
    		if match, err := regexp.MatchString("^[a_][a0_$]*$", cleaned); err != nil {
    			return err
    		} else if match {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  6. cmd/signature-v2.go

    }
    
    // Return canonical headers.
    func canonicalizedAmzHeadersV2(headers http.Header) string {
    	var keys []string
    	keyval := make(map[string]string, len(headers))
    	for key := range headers {
    		lkey := strings.ToLower(key)
    		if !strings.HasPrefix(lkey, "x-amz-") {
    			continue
    		}
    		keys = append(keys, lkey)
    		keyval[lkey] = strings.Join(headers[key], ",")
    	}
    	sort.Strings(keys)
    	var canonicalHeaders []string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 12.2K bytes
    - Viewed (0)
  7. cmd/streaming-signature-v4.go

    		}
    		return errSignatureMismatch
    	}
    
    	// Parse trailers.
    	wantTrailers := make(map[string]struct{}, len(cr.trailers))
    	for k := range cr.trailers {
    		wantTrailers[strings.ToLower(k)] = struct{}{}
    	}
    	input := bufio.NewScanner(bytes.NewReader(valueBuffer.Bytes()))
    	for input.Scan() {
    		line := strings.TrimSpace(input.Text())
    		if line == "" {
    			continue
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  8. cmd/encryption-v1.go

    // with the given object encryption key.
    //
    // However, DecryptETag does not try to decrypt the ETag if
    // it consists of a 128 bit hex value (32 hex chars) and exactly
    // one '-' followed by a 32-bit number.
    // This special case addresses randomly-generated ETags generated
    // by the MinIO server when running in non-compat mode. These
    // random ETags are not encrypt.
    //
    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)
  9. cmd/api-response.go

    			toRemove = append(toRemove, k)
    			continue
    		}
    	}
    
    	for _, k := range toRemove {
    		delete(m, k)
    		delete(m, strings.ToLower(k))
    	}
    
    	return m
    }
    
    // generates an ListBucketVersions response for the said bucket with other enumerated options.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  10. cmd/bucket-lifecycle.go

    	meta := make(map[string]string)
    	sc := rreq.OutputLocation.S3.StorageClass
    	if sc == "" {
    		sc = objInfo.StorageClass
    	}
    	meta[strings.ToLower(xhttp.AmzStorageClass)] = sc
    
    	if rreq.Type == SelectRestoreRequest {
    		for _, v := range rreq.OutputLocation.S3.UserMetadata {
    			if !stringsHasPrefixFold(v.Name, "x-amz-meta") {
    				meta["x-amz-meta-"+v.Name] = v.Value
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
Back to top