Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for readIvy (0.36 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	defer cacher.Stop()
    
    	result := &example.PodList{}
    
    	if !utilfeature.DefaultFeatureGate.Enabled(features.ResilientWatchCacheInitialization) {
    		if err := cacher.ready.wait(context.Background()); err != nil {
    			t.Fatalf("unexpected error waiting for the cache to be ready")
    		}
    	}
    
    	// Inject error to underlying layer and check if cacher is not bypassed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  2. pkg/kube/kclient/client_test.go

    			return len(wasm.List("", klabels.Everything()))
    		}, 1)
    		tracker.WaitOrdered("add/name")
    	})
    	t.Run("CRD fully ready", func(t *testing.T) {
    		stop := test.NewStop(t)
    		c := kube.NewFakeClient()
    
    		// Only CRD is ready to go by the time we start informers
    		clienttest.MakeCRD(t, c, gvr.WasmPlugin)
    		c.RunAndWait(stop)
    
    		// Now that CRD is synced, we create the client
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 15:12:54 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  3. pkg/printers/internalversion/printers_test.go

    						{Ready: true, RestartCount: 3, State: api.ContainerState{Running: &api.ContainerStateRunning{}}},
    						{Ready: true, RestartCount: 3},
    					},
    				},
    			},
    			[]metav1.TableRow{{Cells: []interface{}{"test5", "1/2", "podReason", "6", "<unknown>"}}},
    		},
    		{
    			// Test pod has 2 containers, one is running and the other is completed, w/o ready condition
    			api.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	// Before accessing the cacher's cache, wait for the ready to be ok.
    	// This is necessary to prevent users from accessing structures that are
    	// uninitialized or are being repopulated right now.
    	// ready needs to be set to false when the cacher is paused or stopped.
    	// ready needs to be set to true when the cacher is ready to use after
    	// initialization.
    	ready *ready
    
    	// Underlying storage.Interface.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go

    		// plausible the object has a waypoint defined but that waypoint's underlying gateway is not ready, in this case we'd return nil here even if
    		// the namespace-defined waypoint is ready and would not be nil... is this OK or should we handle that? Could lead to odd behavior when
    		// o was reliant on the namespace waypoint and then get's a use-waypoint label added before that gateway is ready.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. ci/official/requirements_updater/requirements.in

    # TODO(b/304751256): Adjust the numpy pin to a single version, when ready
    numpy ~= 1.23.5 ; python_version <= "3.11"
    numpy ~= 1.26.0 ; python_version >= "3.12"
    wheel ~= 0.41.2
    h5py >= 3.10.0
    lit ~= 17.0.2
    opt_einsum == 3.3.0
    astunparse == 1.6.3
    dill == 0.3.7
    astor == 0.7.1
    typing_extensions == 4.8.0
    gast == 0.4.0
    termcolor == 2.3.0
    wrapt == 1.16.0
    tblib == 2.0.0
    ml_dtypes >= 0.4.0, < 0.5.0
    
    # Install tensorboard, and keras
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Jun 12 19:00:33 UTC 2024
    - 834 bytes
    - Viewed (0)
  7. src/os/exec_unix.go

    	switch p.pidStatus() {
    	case statusReleased:
    		return nil, syscall.EINVAL
    	}
    
    	// If we can block until Wait4 will succeed immediately, do so.
    	ready, err := p.blockUntilWaitable()
    	if err != nil {
    		return nil, err
    	}
    	if ready {
    		// Mark the process done now, before the call to Wait4,
    		// so that Process.pidSignal will not send a signal.
    		p.pidDeactivate(statusDone)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. docs/orchestration/docker-compose/docker-compose.yaml

      expose:
        - "9000"
        - "9001"
      # environment:
        # MINIO_ROOT_USER: minioadmin
        # MINIO_ROOT_PASSWORD: minioadmin
      healthcheck:
        test: ["CMD", "mc", "ready", "local"]
        interval: 5s
        timeout: 5s
        retries: 5
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 05:40:03 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  9. pilot/pkg/bootstrap/webhook.go

    		Handler:   s.httpsMux,
    		TLSConfig: tlsConfig,
    	}
    
    	// register istiodReadyHandler on the httpsMux so that readiness can also be checked remotely
    	s.httpsMux.HandleFunc("/ready", s.istiodReadyHandler)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 17:37:53 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet.go

    			handleProbeSync(kl, update, handler, "liveness", "unhealthy")
    		}
    	case update := <-kl.readinessManager.Updates():
    		ready := update.Result == proberesults.Success
    		kl.statusManager.SetContainerReadiness(update.PodUID, update.ContainerID, ready)
    
    		status := ""
    		if ready {
    			status = "ready"
    		}
    		handleProbeSync(kl, update, handler, "readiness", status)
    	case update := <-kl.startupManager.Updates():
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (1)
Back to top