- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for QueueSize (0.12 sec)
-
internal/logger/config.go
queueSizeCfgVal := getCfgVal(EnvKafkaQueueSize, k, kv.Get(KafkaQueueSize)) queueSize, err := strconv.Atoi(queueSizeCfgVal) if err != nil { return cfg, err } if queueSize <= 0 { return cfg, errInvalidQueueSize } kafkaArgs.QueueSize = queueSize cfg.AuditKafka[k] = kafkaArgs } return cfg, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.8K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
*/ public SimplexTransferListener( TransferListener delegate, int queueSize, int batchMaxSize, boolean blockOnLastEvent) { this.delegate = requireNonNull(delegate); if (queueSize < 1 || batchMaxSize < 1) { throw new IllegalArgumentException("Queue and batch sizes must be greater than 1"); } this.batchMaxSize = batchMaxSize;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/logger/help.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 07 20:17:46 UTC 2024 - 6.4K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
SASL struct { Enable bool `json:"enable"` User string `json:"username"` Password string `json:"password"` Mechanism string `json:"mechanism"` } `json:"sasl"` // Queue store QueueSize int `json:"queueSize"` QueueDir string `json:"queueDir"` // Custom logger LogOnce func(ctx context.Context, err error, id string, errKind ...interface{}) `json:"-"` } // Target - Kafka target. type Target struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} this.key = ByteArray(16).apply { random.nextBytes(this) }.toByteString().base64() } override fun request(): Request = originalRequest @Synchronized override fun queueSize(): Long = queueSize override fun cancel() { call!!.cancel() } fun connect(client: OkHttpClient) { if (originalRequest.header("Sec-WebSocket-Extensions") != null) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0) -
internal/logger/target/http/http.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
return capAtMaximumSize(newCapacity, maximumSize); } /** There's no reason for the queueSize to ever be more than maxSize + 1 */ private static int capAtMaximumSize(int queueSize, int maximumSize) { return Math.min(queueSize - 1, maximumSize) + 1; // don't overflow }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 34K bytes - Viewed (0) -
guava/src/com/google/common/collect/MinMaxPriorityQueue.java
return capAtMaximumSize(newCapacity, maximumSize); } /** There's no reason for the queueSize to ever be more than maxSize + 1 */ private static int capAtMaximumSize(int queueSize, int maximumSize) { return Math.min(queueSize - 1, maximumSize) + 1; // don't overflow }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 34K bytes - Viewed (0) -
tensorflow/cc/gradients/data_flow_grad.cc
REGISTER_NO_GRADIENT_OP("QueueEnqueueMany"); REGISTER_NO_GRADIENT_OP("QueueDequeue"); REGISTER_NO_GRADIENT_OP("QueueDequeueMany"); REGISTER_NO_GRADIENT_OP("QueueDequeueUpTo"); REGISTER_NO_GRADIENT_OP("QueueClose"); REGISTER_NO_GRADIENT_OP("QueueSize"); REGISTER_NO_GRADIENT_OP("Stack"); REGISTER_NO_GRADIENT_OP("StackPush"); REGISTER_NO_GRADIENT_OP("StackPop"); REGISTER_NO_GRADIENT_OP("StackClose"); REGISTER_NO_GRADIENT_OP("GetSessionHandle");
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Jul 24 13:40:35 UTC 2021 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
var messageCount: Long = 0 while (true) { val success = webSocket.send(message) if (!success) break messageCount++ val queueSize = webSocket.queueSize() assertThat(queueSize).isBetween(0L, messageCount * message.size) // Expect to fail before enqueueing 32 MiB. assertThat(messageCount).isLessThan(32L) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0)