- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 406 for producer (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)