Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 339 for queues (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Optional;
    import java.util.OptionalDouble;
    import java.util.OptionalInt;
    import java.util.OptionalLong;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 21.4K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // contract.
        // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could
        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  3. internal/event/target/nsq.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of NSQ `%s`: %w", id, err)
    		}
    	}
    
    	target := &NSQTarget{
    		id:         event.TargetID{ID: id, Name: "nsq"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  4. docs/es/docs/advanced/sub-applications.md

    # Sub Aplicaciones - Mounts { #sub-applications-mounts }
    
    Si necesitas tener dos aplicaciones de **FastAPI** independientes, cada una con su propio OpenAPI independiente y su propia interfaz de docs, puedes tener una aplicación principal y "montar" una (o más) sub-aplicación(es).
    
    ## Montar una aplicación **FastAPI** { #mounting-a-fastapi-application }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  5. cmd/metrics-v3-api.go

    	apiRejectedInvalidTotalMD = NewCounterMD(apiRejectedInvalidTotal,
    		"Total number of invalid requests", "type")
    
    	apiRequestsWaitingTotalMD = NewGaugeMD(apiRequestsWaitingTotal,
    		"Total number of requests in the waiting queue", "type")
    	apiRequestsIncomingTotalMD = NewGaugeMD(apiRequestsIncomingTotal,
    		"Total number of incoming requests", "type")
    
    	apiRequestsInFlightTotalMD = NewGaugeMD(apiRequestsInFlightTotal,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 9.4K bytes
    - Click Count (0)
  6. cmd/bucket-lifecycle.go

    		return restoreObjStatus{}, errRestoreHDRMalformed
    	}
    
    	switch progressTokens[1] {
    	case "true", `"true"`: // true without double quotes is deprecated in Feb 2022
    		if len(tokens) == 1 {
    			return ongoingRestoreObj(), nil
    		}
    	case "false", `"false"`: // false without double quotes is deprecated in Feb 2022
    		if len(tokens) != 2 {
    			return restoreObjStatus{}, errRestoreHDRMalformed
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  7. internal/event/target/amqp.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of AMQP `%s`: %w", id, err)
    		}
    	}
    
    	target := &AMQPTarget{
    		id:         event.TargetID{ID: id, Name: "amqp"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  8. docs/fr/docs/history-design-future.md

    > Quelle est l'histoire de ce projet ? Il semble être sorti de nulle part et est devenu génial en quelques semaines [...].
    
    Voici un petit bout de cette histoire.
    
    ## Alternatives
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  9. cmd/site-replication.go

    			sm.ActiveWorkers.Max += peer.ActiveWorkers.Max
    		}
    		sm.Queued.Avg.Bytes += peer.Queued.Avg.Bytes
    		sm.Queued.Avg.Count += peer.Queued.Avg.Count
    		sm.Queued.Curr.Bytes += peer.Queued.Curr.Bytes
    		sm.Queued.Curr.Count += peer.Queued.Curr.Count
    		if peer.Queued.Max.Count > sm.Queued.Max.Count {
    			sm.Queued.Max.Bytes = peer.Queued.Max.Bytes
    			sm.Queued.Max.Count = peer.Queued.Max.Count
    		}
    		sm.ReplicaCount += peer.ReplicaCount
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  10. internal/event/target/mqtt.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of MQTT `%s`: %w", id, err)
    		}
    	}
    
    	target := &MQTTTarget{
    		id:         event.TargetID{ID: id, Name: "mqtt"},
    		args:       args,
    		store:      queueStore,
    		quitCh:     make(chan struct{}),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
Back to Top