Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for HealthzChecks (0.17 sec)

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

    	delegateConfig.LoopbackClientConfig = &rest.Config{}
    	clientset := fake.NewSimpleClientset()
    	if clientset == nil {
    		t.Fatal("unable to create fake client set")
    	}
    
    	delegateConfig.HealthzChecks = append(delegateConfig.HealthzChecks, healthz.NamedCheck("delegate-health", func(r *http.Request) error {
    		return fmt.Errorf("delegate failed healthcheck")
    	}))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/config.go

    // the config unless we explicitly want to add a healthcheck only to a specific health endpoint.
    func (c *Config) AddHealthChecks(healthChecks ...healthz.HealthChecker) {
    	c.HealthzChecks = append(c.HealthzChecks, healthChecks...)
    	c.LivezChecks = append(c.LivezChecks, healthChecks...)
    	c.ReadyzChecks = append(c.ReadyzChecks, healthChecks...)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
  3. cmd/kube-scheduler/app/server.go

    	pathRecorderMux := mux.NewPathRecorderMux("kube-scheduler")
    	healthz.InstallHandler(pathRecorderMux, healthzChecks...)
    	healthz.InstallLivezHandler(pathRecorderMux)
    	healthz.InstallReadyzHandler(pathRecorderMux, readyzChecks...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/options/etcd_test.go

    			}
    			if err := etcdOptions.ApplyTo(serverConfig); err != nil {
    				t.Fatalf("Failed to add healthz error: %v", err)
    			}
    
    			healthChecksAreEqual(t, tc.wantHealthzChecks, serverConfig.HealthzChecks, "healthz")
    			healthChecksAreEqual(t, tc.wantReadyzChecks, serverConfig.ReadyzChecks, "readyz")
    			healthChecksAreEqual(t, tc.wantLivezChecks, serverConfig.LivezChecks, "livez")
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/options/etcd.go

    		}
    	}
    
    	return nil
    }
    
    func addHealthChecksWithoutLivez(c *server.Config, healthChecks ...healthz.HealthChecker) {
    	c.HealthzChecks = append(c.HealthzChecks, healthChecks...)
    	c.ReadyzChecks = append(c.ReadyzChecks, healthChecks...)
    }
    
    func (s *EtcdOptions) addEtcdHealthEndpoint(c *server.Config) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 15:02:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	PostStartHooks() map[string]postStartHookEntry
    
    	// PreShutdownHooks returns the pre-stop hooks that need to be combined
    	PreShutdownHooks() map[string]preShutdownHookEntry
    
    	// HealthzChecks returns the healthz checks that need to be combined
    	HealthzChecks() []healthz.HealthChecker
    
    	// ListedPaths returns the paths for supporting an index
    	ListedPaths() []string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
Back to top