- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 94 for IMMEDIATE (0.19 sec)
-
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
tf "k8s.io/kubernetes/pkg/scheduler/testing/framework" ) var ( immediate = storagev1.VolumeBindingImmediate waitForFirstConsumer = storagev1.VolumeBindingWaitForFirstConsumer immediateSC = &storagev1.StorageClass{ ObjectMeta: metav1.ObjectMeta{ Name: "immediate-sc", }, VolumeBindingMode: &immediate, } waitSC = &storagev1.StorageClass{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 32K bytes - Viewed (0) -
pkg/registry/core/namespace/storage/storage_test.go
} ctx = genericapirequest.WithNamespace(genericapirequest.NewContext(), namespace.Name) obj, immediate, err := storage.Delete(ctx, "foo", rest.ValidateAllObjectFunc, nil) if err != nil { t.Fatalf("unexpected error") } if immediate { t.Fatalf("unexpected immediate flag") } if ns, ok := obj.(*api.Namespace); !ok || obj == nil || ns == nil || ns.Name != namespace.Name {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 17 05:13:34 UTC 2022 - 19.8K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
} else { // The check whether there is a probe which hasn't run yet. w, exists := m.getWorker(pod.UID, c.Name, readiness) ready = !exists // no readinessProbe -> always ready if exists { // Trigger an immediate run of the readinessProbe to update ready state select { case w.manualTriggerCh <- struct{}{}: default: // Non-blocking. klog.InfoS("Failed to trigger a manual run", "probe", w.probeType.String()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
final IndexResponse response = getClient().get(c -> c.prepareIndex().setIndex(index).setId(id).setSource(source) .setOpType(opType).setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute()); setId(target, id); return response; } catch (final OpenSearchStatusException e) { if (e.status() == RestStatus.CONFLICT) {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Apr 04 09:58:36 UTC 2024 - 23.3K bytes - Viewed (0) -
src/cmd/internal/obj/ppc64/doc.go
Example: ADD R3, R4, R5 <=> add r5, r4, r3 2. Constant operands In Go asm, an operand that starts with '$' indicates a constant value. If the instruction using the constant has an immediate version of the opcode, then an immediate value is used with the opcode if possible. Example: ADD $1, R3, R4 <=> addi r4, r3, 1 3. Opcodes setting condition codes
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 21 16:47:45 UTC 2023 - 11.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
return podVolumeClaims, err } // Prebound PVCs are treated as unbound immediate binding if delayBindingMode && pvc.Spec.VolumeName == "" { // Scheduler path podVolumeClaims.unboundClaimsDelayBinding = append(podVolumeClaims.unboundClaimsDelayBinding, pvc) } else { // !delayBindingMode || pvc.Spec.VolumeName != "" // Immediate binding should have already been bound
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
src/time/tick_test.go
tim.Reset(1) assertTick() Sleep(sched) tim.Reset(10000 * Second) drainAsync() noTick() // Test that len sees an immediate tick arrive // for Reset of timer in heap. tim.Reset(1) assertLen() assertTick() // Test that len sees an immediate tick arrive // for Reset of timer NOT in heap. tim.Stop() drainAsync() tim.Reset(1) assertLen() assertTick() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
_ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath, DeleteOptions{ Recursive: false, Immediate: false, }) _ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath+".meta", DeleteOptions{ Recursive: false, Immediate: false, }) return nil }, index) } g.Wait() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
// Delete Kubernetes secret for ingress gateway c := t.Clusters().Default() var immediate int64 err := c.Kube().CoreV1().Secrets(systemNS.Name()).Delete(context.TODO(), credName, metav1.DeleteOptions{GracePeriodSeconds: &immediate}) if err != nil && !errors.IsNotFound(err) { t.Fatalf("Failed to delete secret (error: %s)", err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueService.java
bulkBuilder.add(c.prepareDelete().setIndex(index).setId(uq.getId())); } return bulkBuilder.setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute(); }); if (response.hasFailures()) { logger.warn(response.buildFailureMessage()); }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 12.9K bytes - Viewed (0)