- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 58 for deliver (0.22 sec)
-
pkg/kubelet/kubelet_pods_test.go
// delivered to the pod worker via HandlePodAdditions - there is no *known* scenario that can happen, but // we want to capture it in the metric. The more likely scenario is that a static pod with a predefined // UID is updated, which causes pod config to deliver DELETE -> ADD while the old pod is still shutting
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// At this point, the pod worker is aware of which pods are not desired (SyncKnownPods). // We now look through the set of active pods for those that the pod worker is not aware of // and deliver an update. The most common reason a pod is not known is because the pod was // deleted and recreated with the same UID while the pod worker was driving its lifecycle (very
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
<fields> <field> <name>type</name> <version>4.0.0+</version> <defaultValue>mail</defaultValue> <type>String</type> <description>The mechanism used to deliver notifications.</description> </field> <field> <name>sendOnError</name> <version>4.0.0+</version> <defaultValue>true</defaultValue> <type>boolean</type>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Apr 23 13:29:46 UTC 2024 - 115.1K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// notifies the podWorkers to reconcile the state of the pod (for instance, if a container dies and needs to // be restarted). pleg pleg.PodLifecycleEventGenerator // eventedPleg supplements the pleg to deliver edge-driven container changes with low-latency. eventedPleg pleg.PodLifecycleEventGenerator // Store kubecontainer.PodStatus for all pods. podCache kubecontainer.Cache
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} }; ClosingFuture<V> derived = new ClosingFuture<>(futureCombiner().call(callable, executor)); derived.closeables.add(closeables, directExecutor()); return derived; } /** * Returns a new {@code ClosingFuture} pipeline step derived from the inputs by applying a
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
src/cmd/internal/obj/ppc64/asm9.go
{as: ACOPY, a1: C_REG, a6: C_REG, type_: 92, size: 4}, /* copy/paste facility, x-form */ {as: ADARN, a1: C_U15CON, a6: C_REG, type_: 92, size: 4}, /* deliver random number, x-form */ {as: AMADDHD, a1: C_REG, a2: C_REG, a3: C_REG, a6: C_REG, type_: 83, size: 4}, /* multiply-add high/low doubleword, va-form */
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 13:55:28 UTC 2024 - 156.1K bytes - Viewed (0) -
src/database/sql/sql.go
var connectionRequestQueueSize = 1000000 type dsnConnector struct { dsn string driver driver.Driver } func (t dsnConnector) Connect(_ context.Context) (driver.Conn, error) { return t.driver.Open(t.dsn) } func (t dsnConnector) Driver() driver.Driver { return t.driver } // OpenDB opens a database using a [driver.Connector], allowing drivers to // bypass a string based data source name. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
return secondary; } }; ListenableFuture<Integer> derived = catchingAsync(primary, Throwable.class, fallback, directExecutor()); secondary.set(1); assertEquals(1, (int) getDone(derived)); } public void testCatchingAsync_resultInterruptedBeforeFallback() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
return secondary; } }; ListenableFuture<Integer> derived = catchingAsync(primary, Throwable.class, fallback, directExecutor()); secondary.set(1); assertEquals(1, (int) getDone(derived)); } public void testCatchingAsync_resultInterruptedBeforeFallback() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
api/openapi-spec/v3/apis__storage.k8s.io__v1alpha1_openapi.json
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 117.5K bytes - Viewed (0)