Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 375 for jstream (0.1 sec)

  1. docs/bucket/replication/DESIGN.md

          "x-minio-internal-tier-free-versionID": "OWZlZjk5N2QtMjMzZi00N2U3LTlkZmMtNWYxNzc3NzdlZTM2"
        },
        "MetaUsr": {
          "X-Amz-Replication-Status": "COMPLETED",
          "content-type": "application/octet-stream",
          "etag": "8315e643ed6a5d7c9962fc0a8ef9c11f"
        },
    ...
    ```
    
    ### Metadata for object replication - on target
    
    ```
    ...
      "MetaSys": {
          "x-minio-internal-inline-data": "dHJ1ZQ==",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    		var ack message
    		ack.Op = OpAckMux
    		ack.Flags = m.BaseFlags
    		ack.MuxID = m.ID
    		m.send(ack)
    		if debugPrint {
    			fmt.Println("connected stream mux:", ack.MuxID)
    		}
    	}()
    
    	// Data inbound to the handler
    	var handlerIn chan []byte
    	if inboundCap > 0 {
    		m.inbound = make(chan []byte, inboundCap)
    		handlerIn = make(chan []byte, 1)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  3. docs/sts/dex.yaml

      skipApprovalScreen: false
      # If only one authentication method is enabled, the default behavior is to
      # go directly to it. For connected IdPs, this redirects the browser away
      # from application to upstream provider such as the Google login page
      alwaysShowLoginScreen: false
      # Uncommend the passwordConnector to use a specific connector for password grants
      passwordConnector: local
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 15 11:55:55 UTC 2020
    - 2.7K bytes
    - Viewed (0)
  4. docs/distributed/README.md

    Install MinIO either on Kubernetes or Distributed Linux.
    
    Install MinIO on Kubernetes:
    
    - [MinIO Quickstart Guide for Kubernetes](https://min.io/docs/minio/kubernetes/upstream/index.html#quickstart-for-kubernetes).
    - [Deploy a Tenant from the MinIO Operator](https://min.io/docs/minio/kubernetes/upstream/operations/install-deploy-manage/deploy-minio-tenant.html)
    
    Install Distributed MinIO on Linux:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top