- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for queue (0.13 sec)
-
build-logic-commons/module-identity/src/main/kotlin/gradlebuild.module-jar.gradle.kts
val seen = mutableSetOf<ResolvedVariantResult>() val queue = ArrayDeque<DependencyResult>() val rootDependencies = rootComponent.getDependenciesForVariant(rootVariant) seen.add(rootVariant) queue.addAll(rootDependencies) while (queue.isNotEmpty()) { val dependency = when (val result = queue.removeFirst()) { is ResolvedDependencyResult -> result
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Mar 28 20:26:58 GMT 2024 - 4.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
systemNamespace string queue controllers.Queue pods kclient.Client[*corev1.Pod] namespaces kclient.Client[*corev1.Namespace] } func setupHandlers(ctx context.Context, kubeClient kube.Client, dataplane MeshDataplane, systemNamespace string) *InformerHandlers { s := &InformerHandlers{ctx: ctx, dataplane: dataplane, systemNamespace: systemNamespace} s.queue = controllers.NewQueue("ambient",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10SymbolDeclarationOverridesProvider.kt
): Collection<CallableMemberDescriptor> { val overriddenDescriptors = LinkedHashSet<CallableMemberDescriptor>() val queue = ArrayDeque<CallableMemberDescriptor>().apply { addAll(descriptor.overriddenDescriptors) } while (queue.isNotEmpty()) { val current = queue.removeFirst() if (current.kind != CallableMemberDescriptor.Kind.FAKE_OVERRIDE) { overriddenDescriptors.add(current)
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Wed Mar 13 16:31:41 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/event/targetlist.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/event/target/redis.go
) // Redis constants const ( RedisFormat = "format" RedisAddress = "address" RedisPassword = "password" RedisUser = "user" RedisKey = "key" RedisQueueDir = "queue_dir" RedisQueueLimit = "queue_limit" EnvRedisEnable = "MINIO_NOTIFY_REDIS_ENABLE" EnvRedisFormat = "MINIO_NOTIFY_REDIS_FORMAT" EnvRedisAddress = "MINIO_NOTIFY_REDIS_ADDRESS"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TreeTraverser.java
implements PeekingIterator<T> { private final Queue<T> queue; BreadthFirstIterator(T root) { this.queue = new ArrayDeque<>(); queue.add(root); } @Override public boolean hasNext() { return !queue.isEmpty(); } @Override public T peek() { return queue.element(); } @Override public T next() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/metrics-v3-cluster-audit.go
auditTargetQueueLength = "target_queue_length" auditTotalMessages = "total_messages" targetID = "target_id" ) var ( auditFailedMessagesMD = NewCounterMD(auditFailedMessages, "Total number of messages that failed to send since start", targetID) auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength, "Number of unsent messages in queue for target", targetID)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 09:18:02 GMT 2024 - 1.9K bytes - Viewed (0) -
internal/logger/help.go
Description: "Number of events per HTTP send to webhook target", Optional: true, Type: "number", }, config.HelpKV{ Key: QueueSize, Description: "configure channel queue size for webhook targets", Optional: true, Type: "number", }, config.HelpKV{ Key: QueueDir, Description: `staging dir for undelivered logger messages e.g. '/home/logger-events'`,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 20:17:46 GMT 2024 - 6.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/crypto/CachedCipher.java
protected String transformation = RSA; protected String key; protected String charsetName = CoreLibConstants.UTF_8; protected Queue<Cipher> encryptoQueue = new ConcurrentLinkedQueue<>(); protected Queue<Cipher> decryptoQueue = new ConcurrentLinkedQueue<>(); public byte[] encrypto(final byte[] data) { final Cipher cipher = pollEncryptoCipher(); byte[] encrypted;
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8.1K bytes - Viewed (0) -
.github/workflows/feedback.yml
jobs: feedback: permissions: issues: write pull-requests: write runs-on: ubuntu-latest steps: # Feedback loop: ask for something on PR/Issue and close if not provided or return to the queue on update. # https://github.com/gradle/issue-management-action/blob/main/src/feedback.ts - uses: gradle/issue-management-action@v1 with:
Others - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Thu May 02 09:13:16 GMT 2024 - 516 bytes - Viewed (0)