- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for natures (0.21 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
import static com.google.common.util.concurrent.Futures.immediateVoidFuture; import static com.google.common.util.concurrent.Futures.inCompletionOrder; import static com.google.common.util.concurrent.Futures.lazyTransform; import static com.google.common.util.concurrent.Futures.nonCancellationPropagating; import static com.google.common.util.concurrent.Futures.scheduleAsync; import static com.google.common.util.concurrent.Futures.submit;
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
import static com.google.common.util.concurrent.Futures.immediateVoidFuture; import static com.google.common.util.concurrent.Futures.inCompletionOrder; import static com.google.common.util.concurrent.Futures.lazyTransform; import static com.google.common.util.concurrent.Futures.nonCancellationPropagating; import static com.google.common.util.concurrent.Futures.scheduleAsync; import static com.google.common.util.concurrent.Futures.submit;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
*/ public static final class Peeker { private final ImmutableList<ClosingFuture<?>> futures; private volatile boolean beingCalled; private Peeker(ImmutableList<ClosingFuture<?>> futures) { this.futures = checkNotNull(futures); } /** * Returns the value of {@code closingFuture}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
*/ public static final class Peeker { private final ImmutableList<ClosingFuture<?>> futures; private volatile boolean beingCalled; private Peeker(ImmutableList<ClosingFuture<?>> futures) { this.futures = checkNotNull(futures); } /** * Returns the value of {@code closingFuture}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 98.7K bytes - Viewed (0) -
pkg/registry/batch/job/strategy_test.go
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.JobPodFailurePolicy, tc.enableJobPodFailurePolicy) featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.JobBackoffLimitPerIndex, tc.enableJobBackoffLimitPerIndex) featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.JobPodReplacementPolicy, tc.enableJobPodReplacementPolicy)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 101.5K bytes - Viewed (0) -
pkg/api/pod/util_test.go
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.AppArmor, enabled) featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.AppArmorFields, fieldsEnabled) newPod := test.pod.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 108.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
if !utilfeature.DefaultFeatureGate.Enabled(features.UserNamespacesSupport) { return defaultFirstID, defaultLen, nil } else { kernelVersion, err := utilkernel.GetVersion() if err != nil { return 0, 0, fmt.Errorf("failed to get kernel version, unable to determine if feature %s can be supported : %w", features.UserNamespacesSupport, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
kubeDeps.RemoteRuntimeService, kubeDeps.RemoteImageService, hostStatsProvider, utilfeature.DefaultFeatureGate.Enabled(features.PodAndContainerStatsFromCRI)) } eventChannel := make(chan *pleg.PodLifecycleEvent, plegChannelCapacity) if utilfeature.DefaultFeatureGate.Enabled(features.EventedPLEG) { // adjust Generic PLEG relisting period and threshold to higher value when Evented PLEG is turned on
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
discoveryType: cluster.Cluster_EDS, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { g := NewWithT(t) test.SetForTest(t, &features.FilterGatewayClusterConfig, false) test.SetForTest(t, &features.EnableRedisFilter, tt.redisEnabled) cg := NewConfigGenTest(t, TestOptions{Services: []*model.Service{service}}) clusters := cg.Clusters(cg.SetupProxy(&model.Proxy{Type: model.Router}))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
featuregatetesting.SetFeatureGateDuringTest(t, feature.DefaultFeatureGate, features.PodIndexLabel, !tc.podIndexLabelDisabled) featuregatetesting.SetFeatureGateDuringTest(t, feature.DefaultFeatureGate, features.JobPodReplacementPolicy, tc.jobPodReplacementPolicy) featuregatetesting.SetFeatureGateDuringTest(t, feature.DefaultFeatureGate, features.JobPodFailurePolicy, tc.jobPodFailurePolicy) // job manager setup
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)