Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 406 for producer (0.08 sec)

  1. internal/config/notify/parse.go

    		compressionCodecEnv := target.EnvKafkaProducerCompressionCodec
    		if k != config.Default {
    			compressionCodecEnv = compressionCodecEnv + config.Default + k
    		}
    		kafkaArgs.Producer.Compression = env.Get(compressionCodecEnv, kv.Get(target.KafkaCompressionCodec))
    
    		compressionLevelEnv := target.EnvKafkaProducerCompressionLevel
    		if k != config.Default {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/storage/v1beta1/generated.proto

    // a certain combination:
    // - no object exists with suitable topology and storage class name
    // - such an object exists, but the capacity is unset
    // - such an object exists, but the capacity is zero
    //
    // The producer of these objects can decide which approach is more suitable.
    //
    // They are consumed by the kube-scheduler when a CSI driver opts into
    // capacity-aware scheduling with CSIDriverSpec.StorageCapacity. The scheduler
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  3. common-protos/k8s.io/api/storage/v1/generated.proto

    // a certain combination:
    // - no object exists with suitable topology and storage class name
    // - such an object exists, but the capacity is unset
    // - such an object exists, but the capacity is zero
    //
    // The producer of these objects can decide which approach is more suitable.
    //
    // They are consumed by the kube-scheduler when a CSI driver opts into
    // capacity-aware scheduling with CSIDriverSpec.StorageCapacity. The scheduler
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  5. 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.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  6. tests/hooks_test.go

    	DB.Model(&product).Updates(Product3{Code: "L1214"})
    	if product.Price != 270 || product.Code != "L1214" {
    		t.Errorf("invalid data after update, got %+v", product)
    	}
    
    	// Code changed, price should changed
    	DB.Model(&product).Select("Name", "Code", "Price").Updates(Product3{Name: "Product New4", Code: ""})
    	if product.Name != "Product New4" || product.Price != 320 || product.Code != "" {
    		t.Errorf("invalid data after update, got %+v", product)
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 17 03:59:06 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/Packaging.java

    import org.apache.maven.api.model.PluginContainer;
    
    /**
     * Represents the packaging of a Maven project.
     *
     * <p>The {@code Packaging} class defines the type of artifact that a Maven project produces during the build process.
     * The packaging type determines the structure of the project's output and how Maven will treat the resulting artifact.</p>
     *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Aug 27 21:13:34 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/hash/HashFunction.java

     *       (given by {@link #bits}). For example, {@link Hashing#sha1} produces a 160-bit number,
     *       while {@link Hashing#murmur3_32()} yields only 32 bits. Because a {@code long} value is
     *       clearly insufficient to hold all hash code values, this API represents a hash code as an
     *       instance of {@link HashCode}.
     *   <li><b>pure function:</b> the value produced must depend only on the input bytes, in the order
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 25 18:22:59 UTC 2021
    - 10.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/hash/HashFunction.java

     *       (given by {@link #bits}). For example, {@link Hashing#sha1} produces a 160-bit number,
     *       while {@link Hashing#murmur3_32()} yields only 32 bits. Because a {@code long} value is
     *       clearly insufficient to hold all hash code values, this API represents a hash code as an
     *       instance of {@link HashCode}.
     *   <li><b>pure function:</b> the value produced must depend only on the input bytes, in the order
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 25 18:22:59 UTC 2021
    - 10.9K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/envoy/configdump/configdump_test.go

    				util.CompareContent(t, gotOut.Bytes(), tt.wantOutputFile)
    			}
    			if err == nil && tt.wantErr {
    				t.Errorf("PrintBootstrapDump (%v) did not produce expected err", tt.name)
    			} else if err != nil && !tt.wantErr {
    				t.Errorf("PrintBootstrapDump (%v) produced unexpected err: %v", tt.name, err)
    			}
    		})
    	}
    }
    
    func TestConfigWriter_PrintVersionSummary(t *testing.T) {
    	tests := []struct {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 03 23:08:06 UTC 2024
    - 3.5K bytes
    - Viewed (0)
Back to top