- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for QueueSize (0.59 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/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) -
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) -
internal/grid/connection.go
continue } } if len(queue) < maxMergeMessages && queueSize+len(toSend) < writeBufferSize-1024 && len(c.outQueue) > 0 { queue = append(queue, toSend) queueSize += len(toSend) continue } c.outMessages.Add(int64(len(queue) + 1)) if c.outgoingBytes != nil { c.outgoingBytes(int64(len(toSend) + queueSize)) } c.connChange.L.Lock() for { state := c.State()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc
func::FuncOp ret = queue_.front(); queue_.pop(); queue_set_.erase(ret); return ret; } // Returns the current size of the queue. std::queue<func::FuncOp>::size_type QueueSize() const { return queue_.size(); } Dialect* const tf_dialect_; private: // Returns whether the result of an operation could be updated to a new
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Jun 08 07:28:49 UTC 2024 - 134.1K bytes - Viewed (0) -
okhttp/api/okhttp.api
} public abstract interface class okhttp3/WebSocket { public abstract fun cancel ()V public abstract fun close (ILjava/lang/String;)Z public abstract fun queueSize ()J public abstract fun request ()Lokhttp3/Request; public abstract fun send (Ljava/lang/String;)Z public abstract fun send (Lokio/ByteString;)Z }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0)