Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 118 for Producers (0.07 seconds)

  1. doc/godebug.md

    [`httpmuxgo121` setting](/pkg/net/http/#ServeMux).
    
    Go 1.22 added the [Alias type](/pkg/go/types#Alias) to [go/types](/pkg/go/types)
    for the explicit representation of [type aliases](/ref/spec#Type_declarations).
    Whether the type checker produces `Alias` types or not is controlled by the
    [`gotypesalias` setting](/pkg/go/types#Alias).
    For Go 1.22 it defaults to `gotypesalias=0`.
    For Go 1.23, `gotypesalias=1` will become the default.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 15:49:10 GMT 2026
    - 26K bytes
    - Click Count (0)
  2. fastapi/routing.py

                        ObjectReceiveStream[bytes]
                    ]:
                        # Use a memory stream to decouple generator iteration
                        # from the keepalive timer. A producer task pulls items
                        # from the generator independently, so
                        # `anyio.fail_after` never wraps the generator's
                        # `__anext__` directly - avoiding CancelledError that
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 193K bytes
    - Click Count (0)
  3. docs/bucket/notifications/README.md

    MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_CODEC  (none|snappy|gzip|lz4|zstd) compression codec for producer messages
    MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_LEVEL  (number)                    compression level for producer messages, defaults to '0'
    ```
    
    To update the configuration, use `mc admin config get` command to get the current configuration.
    
    ```sh
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  4. CHANGELOG/CHANGELOG-1.2.md

      * “kubectl run” now produces Deployments (instead of ReplicationControllers) and
    Jobs (instead of Pods) by default.
      * Pods can now consume Secret data in environment variables and inject those
    environment variables into a container’s command-line args.
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Fri Dec 04 06:36:19 GMT 2020
    - 41.4K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/Multimaps.java

       *     keyFunction} on each value in the input collection to that value
       * @throws NullPointerException if any element of {@code values} is {@code null}, or if {@code
       *     keyFunction} produces {@code null} for any key
       */
      public static <K, V> ImmutableListMultimap<K, V> index(
          Iterable<V> values, Function<? super V, K> keyFunction) {
        return index(values.iterator(), keyFunction);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 86K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/Multimaps.java

       *     keyFunction} on each value in the input collection to that value
       * @throws NullPointerException if any element of {@code values} is {@code null}, or if {@code
       *     keyFunction} produces {@code null} for any key
       */
      public static <K, V> ImmutableListMultimap<K, V> index(
          Iterable<V> values, Function<? super V, K> keyFunction) {
        return index(values.iterator(), keyFunction);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 86.3K bytes
    - Click Count (0)
  7. tensorflow/c/c_api.cc

    }
    
    // TF_Graph functions ---------------------------------------------------------
    
    TF_Graph::TF_Graph()
        : graph(tensorflow::OpRegistry::Global()),
          refiner(graph.versions().producer(), graph.op_registry()),
          delete_requested(false),
          parent(nullptr),
          parent_inputs(nullptr) {
      // Tell the shape refiner to also run shape inference on functions.
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Oct 04 05:55:32 GMT 2025
    - 102.4K bytes
    - Click Count (0)
  8. cmd/object-api-utils.go

    		gotIdx = <-indexCh
    		return gotIdx
    	}
    }
    
    // compressSelfTest performs a self-test to ensure that compression
    // algorithms completes a roundtrip. If any algorithm
    // produces an incorrect checksum it fails with a hard error.
    //
    // compressSelfTest tries to catch any issue in the compression implementation
    // early instead of silently corrupting data.
    func compressSelfTest() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  9. guava/src/com/google/common/base/CharMatcher.java

       * for matchers that only match a few characters, and so on. In the worst-case scenario, it
       * constructs an eight-kilobyte bit array and queries that. In many situations this produces a
       * matcher which is faster to query than the original.
       */
      @GwtIncompatible // SmallCharMatcher
      CharMatcher precomputedInternal() {
        BitSet table = new BitSet();
        setBits(table);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 54.4K bytes
    - Click Count (0)
  10. src/bytes/bytes.go

    				if o < 0 {
    					return -1
    				}
    				i += o + 1
    			}
    			if s[i+1] == c1 && Equal(s[i:i+n], sep) {
    				return i
    			}
    			fails++
    			i++
    			// Switch to bytealg.Index when IndexByte produces too many false positives.
    			if fails > bytealg.Cutover(i) {
    				r := bytealg.Index(s[i:], sep)
    				if r >= 0 {
    					return r + i
    				}
    				return -1
    			}
    		}
    		return -1
    	}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Mar 12 17:56:55 GMT 2026
    - 36.3K bytes
    - Click Count (0)
Back to Top