Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewInformerSyncHealthz (0.21 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go

    }
    
    type informerSync struct {
    	cacheSyncWaiter cacheSyncWaiter
    }
    
    var _ HealthChecker = &informerSync{}
    
    // NewInformerSyncHealthz returns a new HealthChecker that will pass only if all informers in the given cacheSyncWaiter sync.
    func NewInformerSyncHealthz(cacheSyncWaiter cacheSyncWaiter) HealthChecker {
    	return &informerSync{
    		cacheSyncWaiter: cacheSyncWaiter,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz_test.go

    		Proto:  "HTTP/1.1",
    		URL:    url,
    	}
    }
    
    func TestInformerSyncHealthChecker(t *testing.T) {
    	t.Run("test that check returns nil when all informers are started", func(t *testing.T) {
    		healthChecker := NewInformerSyncHealthz(cacheSyncWaiterStub{
    			startedByInformerType: map[reflect.Type]bool{
    				reflect.TypeOf(corev1.Pod{}): true,
    			},
    		})
    
    		err := healthChecker.Check(nil)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 15 20:43:16 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/config.go

    				return nil
    			})
    			if err != nil {
    				return nil, err
    			}
    		}
    		// TODO: Once we get rid of /healthz consider changing this to post-start-hook.
    		err := s.AddReadyzChecks(healthz.NewInformerSyncHealthz(c.SharedInformerFactory))
    		if err != nil {
    			return nil, err
    		}
    	}
    
    	const priorityAndFairnessConfigConsumerHookName = "priority-and-fairness-config-consumer"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
Back to top