- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for absDate (0.21 sec)
-
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
func (c *PeerEndpointLeaseController) Run(stopCh <-chan struct{}) { // wait until process is ready wait.PollImmediateUntil(100*time.Millisecond, func() (bool, error) { var code int c.client.CoreV1().RESTClient().Get().AbsPath("/readyz").Do(context.TODO()).StatusCode(&code) return code == http.StatusOK, nil }, stopCh) wait.NonSlidingUntil(func() { if err := c.UpdatePeerEndpointLeases(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
context.Background(), constants.KubernetesAPICallRetryInterval, w.timeout, true, func(ctx context.Context) (bool, error) { healthStatus := 0 w.client.Discovery().RESTClient().Get().AbsPath("/healthz").Do(ctx).StatusCode(&healthStatus) if healthStatus != http.StatusOK { return false, nil } return true, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kube-apiserver/app/testing/testserver.go
err = wait.Poll(100*time.Millisecond, time.Minute, func() (bool, error) { select { case err := <-errCh: return false, err default: } req := client.CoreV1().RESTClient().Get().AbsPath("/healthz") // The storage version bootstrap test wraps the storage version post-start // hook, so the hook won't become health when the server bootstraps if instanceOptions.StorageVersionWrapFunc != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/DefaultModelRegistry.java
} @Override public <T> T realize(ModelPath path, ModelType<T> type) { return toType(type, require(path), "get(ModelPath, ModelType)"); } public ModelNode atState(ModelPath path, ModelNode.State state) { return atStateOrMaybeLater(path, state, false); } @Override public ModelNode atStateOrLater(ModelPath path, ModelNode.State state) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 15:40:00 UTC 2024 - 45.7K bytes - Viewed (0) -
build/root/Makefile
# # Example: # make kubectl kube-proxy endef #TODO: make EXCLUDE_TARGET auto-generated when there are other files in cmd/ EXCLUDE_TARGET=OWNERS CMD_TARGET = $(filter-out %$(EXCLUDE_TARGET),$(notdir $(abspath $(wildcard cmd/*/)))) .PHONY: $(CMD_TARGET) ifeq ($(PRINT_HELP),y) $(CMD_TARGET): echo "$$CMD_HELP_INFO" else $(CMD_TARGET): hack/make-rules/build.sh cmd/$@ endif define HELP_INFO
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 16:43:08 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/kube-scheduler/app/options/options_test.go
t.Error("unexpected nil client") return } // test the client talks to the endpoint we expect with the credentials we expect username = "" _, err = config.Client.Discovery().RESTClient().Get().AbsPath("/").DoRaw(context.TODO()) if err != nil { t.Error(err) return } if username != tc.expectedUsername { t.Errorf("expected server call with user %q, got %q", tc.expectedUsername, username)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 30.3K bytes - Viewed (0)