Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for PollUntilContextCancel (0.62 sec)

  1. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc_test.go

    		t.Fatalf("sign claims: %v", err)
    	}
    	token, err := jws.CompactSerialize()
    	if err != nil {
    		t.Fatalf("serialize token: %v", err)
    	}
    
    	// wait for the authenticator to be healthy
    	err = wait.PollUntilContextCancel(ctx, time.Millisecond, true, func(context.Context) (bool, error) {
    		return a.HealthCheck() == nil, nil
    	})
    	if err != nil {
    		t.Fatalf("failed to initialize the authenticator: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 97.7K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    	// This waiting loop relies on the background cleanup which starts after pod workers respond
    	// true for ShouldPodRuntimeBeRemoved, which happens after `SyncTerminatingPod` is completed.
    	if err := wait.PollUntilContextCancel(ctx, 100*time.Millisecond, true, func(ctx context.Context) (bool, error) {
    		volumesExist := kl.podVolumesExist(pod.UID)
    		if volumesExist {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top