- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 78 for enqueuePdb (0.14 sec)
-
pkg/controller/disruption/disruption.go
logger.V(4).Info("Add DB", "podDisruptionBudget", klog.KObj(pdb)) dc.enqueuePdb(logger, pdb) } func (dc *DisruptionController) updateDB(logger klog.Logger, old, cur interface{}) { // TODO(mml) ignore updates where 'old' is equivalent to 'cur'. pdb := cur.(*policy.PodDisruptionBudget) logger.V(4).Info("Update DB", "podDisruptionBudget", klog.KObj(pdb)) dc.enqueuePdb(logger, pdb) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* * * **Connecting:** the initial state of each web socket. Messages may be enqueued but they won't * be transmitted until the web socket is open. * * * **Open:** the web socket has been accepted by the remote peer and is fully operational. * Messages in either direction are enqueued for immediate transmission. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private val messageAndCloseQueue = ArrayDeque<Any>() /** The total size in bytes of enqueued but not yet transmitted messages. */ private var queueSize = 0L /** True if we've enqueued a close frame. No further message frames will be enqueued. */ private var enqueuedClose = false /** The close code from the peer, or -1 if this web socket has not yet read a close frame. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0) -
src/cmd/go/internal/mvs/graph.go
var queue []module.Version enqueued := make(map[module.Version]bool) for _, m := range g.roots { if m.Version != "none" { queue = append(queue, m) enqueued[m] = true } } for len(queue) > 0 { m := queue[0] queue = queue[1:] f(m) reqs, _ := g.RequiredBy(m) for _, r := range reqs { if !enqueued[r] && r.Version != "none" { queue = append(queue, r)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 01 02:52:19 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
pendingAttemptToDelete: []*node{ makeNode(badSecretReferenceWithDeploymentUID, virtual), // virtual parent enqueued for delete attempt makeNode(goodChildPod, withOwners(deployment1apps)), // good child enqueued for delete attempt }, }), // 7,8: process pending delete of virtual parent processAttemptToDelete(1), assertState(state{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
c, _, err := f.newController(ctx) if err != nil { t.Fatalf("error creating Deployment controller: %v", err) } enqueued := false c.enqueueDeployment = func(d *apps.Deployment) { if d.Name == "foo" { enqueued = true } } c.deletePod(logger, pod) if !enqueued { t.Errorf("expected deployment %q to be queued after pod deletion", foo.Name) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
interface Event<L> { /** Call a method on the listener. */ void call(L listener); } /** * Adds a listener that will be called using the given executor when events are later {@link * #enqueue enqueued} and {@link #dispatch dispatched}. */ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
pkg/kube/controllers/common_test.go
ObjectMeta: metav1.ObjectMeta{ Name: "pod", Namespace: "ns", OwnerReferences: []metav1.OwnerReference{}, }, }) if got := written.Load(); got != "" { t.Fatalf("unexpectedly enqueued %v", got) } handler(&corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod", Namespace: "ns", OwnerReferences: []metav1.OwnerReference{{ APIVersion: gvk.Deployment.GroupVersion(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 15 15:34:49 UTC 2023 - 4.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
/** Cancels the request, if possible. Requests that are already complete cannot be canceled. */ fun cancel() /** * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an * error to execute a call more than once. */ fun isExecuted(): Boolean fun isCanceled(): Boolean /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 3.6K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
package xds import ( "sync" "istio.io/istio/pilot/pkg/model" ) type PushQueue struct { cond *sync.Cond // pending stores all connections in the queue. If the same connection is enqueued again, // the PushRequest will be merged. pending map[*Connection]*model.PushRequest // queue maintains ordering of the queue queue []*Connection
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0)