- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 220 for queue (0.16 sec)
-
cmd/bucket-stats.go
// Total number of completed operations ReplicatedCount int64 `json:"replicationCount"` // Total number of replica received ReplicaCount int64 `json:"replicaCount"` // in Queue stats for bucket - from qCache QStat InQueueMetric `json:"queued"` // Deprecated fields // Pending size in bytes PendingSize int64 `json:"pendingReplicationSize"` // Failed size in bytes FailedSize int64 `json:"failedReplicationSize"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
Avg: a.Avg, Max: a.Max, } return w } // QStat holds queue stats for replication type QStat struct { Count float64 `json:"count"` Bytes float64 `json:"bytes"` } func (q *QStat) add(o QStat) QStat { return QStat{Bytes: q.Bytes + o.Bytes, Count: q.Count + o.Count} } // InQueueMetric holds queue stats for replication type InQueueMetric struct { Curr QStat `json:"curr" msg:"cq"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/QueueTestSuiteBuilder.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.ArrayList; import java.util.List; /** * Creates, based on your criteria, a JUnit test suite that exhaustively tests a queue * implementation. * * @author Jared Levy */ @GwtIncompatible public final class QueueTestSuiteBuilder<E> extends AbstractCollectionTestSuiteBuilder<QueueTestSuiteBuilder<E>, E> {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Feb 26 19:46:10 GMT 2024 - 2.5K bytes - Viewed (0) -
architecture/networking/controllers.md
Construction should create informers (via `kclient.New`), setup a queue (via `controllers.NewQueue`), and register event handlers on the informers. Often, these handlers are adding something to the queue like `client.AddEventHandler(controllers.ObjectHandler(queue.AddObject))`. Construction should NOT actually start running all of these things, do I/O, or block in anyway.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Feb 09 17:41:25 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
}) c.queue = controllers.NewQueue("repair pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
internal/logger/config.go
EnvKafkaVersion = "MINIO_AUDIT_KAFKA_VERSION" EnvKafkaQueueDir = "MINIO_AUDIT_KAFKA_QUEUE_DIR" EnvKafkaQueueSize = "MINIO_AUDIT_KAFKA_QUEUE_SIZE" loggerTargetNamePrefix = "logger-" auditTargetNamePrefix = "audit-" ) var ( errInvalidQueueSize = errors.New("invalid queue_size value") errInvalidBatchSize = errors.New("invalid batch_size value") )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
intervalControlHelper.delayByRules(); if (logger.isDebugEnabled()) { logger.debug("Processing documents in IndexUpdater queue."); } updateTime = systemHelper.getCurrentTimeAsLong(); List<EsAccessResult> arList = getAccessResultList(cb, cleanupTime);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 24.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
import static org.junit.Assert.assertThrows; import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; import com.google.common.collect.Queues; import java.util.List; import java.util.Queue; import java.util.concurrent.CountDownLatch; import java.util.concurrent.CyclicBarrier; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/QueueTestSuiteBuilder.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.ArrayList; import java.util.List; /** * Creates, based on your criteria, a JUnit test suite that exhaustively tests a queue * implementation. * * @author Jared Levy */ @GwtIncompatible public final class QueueTestSuiteBuilder<E> extends AbstractCollectionTestSuiteBuilder<QueueTestSuiteBuilder<E>, E> {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Feb 26 19:46:10 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
c, err := NewRepairController(tt.client, tt.config) assert.NoError(t, err) t.Cleanup(func() { assert.NoError(t, c.queue.WaitForClose(time.Second)) }) stop := test.NewStop(t) tt.client.RunAndWait(stop) go c.Run(stop) kube.WaitForCacheSync("test", stop, c.queue.HasSynced) assert.EventuallyEqual(t, func() map[string]string { havePods := c.pods.List(metav1.NamespaceAll, klabels.Everything())
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 24 03:31:28 GMT 2023 - 10.6K bytes - Viewed (0)