Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 392 for jstream (0.25 sec)

  1. ci/official/containers/linux_arm64/devel.usertools/wheel_verification.bats

        python3 -m auditwheel show "$TF_WHEEL" > audit.txt
        grep --quiet -zoP 'is consistent with the following platform tag:\n"manylinux_2_17_(aarch|x86_)64"\.' audit.txt
    }
    
    @test "Wheel conforms to upstream size limitations" {
        WHEEL_MEGABYTES=$(stat --format %s "$TF_WHEEL" | awk '{print int($1/(1024*1024))}')
        # Googlers: search for "test_tf_whl_size"
        case "$TF_WHEEL" in
            # CPU:
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Tue Jan 23 02:14:00 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. cmd/api-headers.go

    	return fmt.Sprintf("%X", t.UnixNano())
    }
    
    // setEventStreamHeaders to allow proxies to avoid buffering proxy responses
    func setEventStreamHeaders(w http.ResponseWriter) {
    	w.Header().Set(xhttp.ContentType, "text/event-stream")
    	w.Header().Set(xhttp.CacheControl, "no-cache") // nginx to turn off buffering
    	w.Header().Set("X-Accel-Buffering", "no")      // nginx to turn off buffering
    }
    
    // Write http common headers
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/filter.go

    }
    
    // UnmarshalXML - decodes XML data.
    func (f *Filter) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	f.set = true
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			switch se.Name.Local {
    			case "Prefix":
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 04 17:01:26 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  4. cmd/admin-handlers-idp-config.go

    		return
    	}
    
    	// Ensure body content type is opaque to ensure that request body has not
    	// been interpreted as form data.
    	contentType := r.Header.Get("Content-Type")
    	if contentType != "application/octet-stream" {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBadRequest), r.URL)
    		return
    	}
    
    	password := cred.SecretKey
    	reqBytes, err := madmin.DecryptData(password, io.LimitReader(r.Body, r.ContentLength))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. internal/http/response-recorder.go

    	lrw.headerBytesWritten += n
    	for k, v := range headers {
    		n, _ := fmt.Fprintf(w, "%s: %s\n", k, v[0])
    		lrw.headerBytesWritten += n
    	}
    }
    
    // blobBody returns a dummy body placeholder for blob (binary stream)
    var blobBody = []byte("<BLOB>")
    
    // gzippedBody returns a dummy body placeholder for gzipped content
    var gzippedBody = []byte("<GZIP>")
    
    // Body - Return response body.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java

            if (StringUtil.isNotEmpty(contentType)) {
                curlRequest.header("Content-Type", contentType);
            }
    
            request.getParameterMap().entrySet().stream().forEach(entry -> {
                if (entry.getValue().length > 1) {
                    curlRequest.param(entry.getKey(), String.join(",", entry.getValue()));
                } else if (entry.getValue().length == 1) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Aug 15 08:29:24 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  7. cmd/sts-errors.go

    		Description:    "STS IAM not initialized, please try again.",
    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrSTSUpstreamError: {
    		Code:           "InternalError",
    		Description:    "An upstream service required for this operation failed - please try again or contact an administrator.",
    		HTTPStatusCode: http.StatusInternalServerError,
    	},
    	ErrSTSInternalError: {
    		Code:           "InternalError",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    			return srcSet.CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts)
    		}
    		// Destination is not versioned and source version ID is empty
    		// perform an in-place update.
    		if !dstOpts.Versioned && srcOpts.VersionID == "" {
    			srcInfo.Reader.Close() // We are not interested in the reader stream at this point close it.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  9. docs/orchestration/docker-compose/README.md

      * Replicate a service definition and change the name of the new service appropriately.
      * Update the command section in each service.
      * Add a new MinIO server instance to the upstream directive in the Nginx configuration file.
    
      Read more about distributed MinIO [here](https://min.io/docs/minio/container/operations/install-deploy-manage/deploy-minio-single-node-multi-drive.html).
    
    ### Explore Further
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Mar 31 19:20:56 UTC 2023
    - 3K bytes
    - Viewed (0)
  10. internal/config/dns/operator_dns.go

    			TLSClientConfig: &tls.Config{
    				RootCAs: args.rootCAs,
    			},
    			// Go net/http automatically unzip if content-type is
    			// gzip disable this feature, as we are always interested
    			// in raw stream.
    			DisableCompression: true,
    		},
    	}
    	return args, nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
Back to top