Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for RunPostStartHooks (0.28 sec)

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

    	if err := s.AddPreShutdownHook(name, hook); err != nil {
    		klog.Fatalf("Error registering PreShutdownHook %q: %v", name, err)
    	}
    }
    
    // RunPostStartHooks runs the PostStartHooks for the server.
    func (s *GenericAPIServer) RunPostStartHooks(ctx context.Context) {
    	s.postStartHookLock.Lock()
    	defer s.postStartHookLock.Unlock()
    	s.postStartHooksCalled = true
    
    	context := PostStartHookContext{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/config_test.go

    		defer close(wrappingPostStartHookChan)
    		return nil
    	})
    
    	wrappingServer.PrepareRun()
    	wrappingServer.RunPostStartHooks(ctx)
    
    	server := httptest.NewServer(wrappingServer.Handler)
    	defer server.Close()
    
    	// Wait for the hooks to finish before checking the response
    	<-delegatePostStartHookChan
    	<-wrappingPostStartHookChan
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go

    	s, config, assert := newMaster(t)
    
    	assert.NotNil(config.OpenAPIConfig)
    
    	server := httptest.NewServer(s.Handler.Director)
    	defer server.Close()
    
    	s.PrepareRun()
    	s.RunPostStartHooks(ctx)
    
    	// openapi is installed in PrepareRun
    	resp, err := http.Get(server.URL + "/openapi/v2")
    	assert.NoError(err)
    	assert.Equal(http.StatusOK, resp.StatusCode)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	// responsibility of the caller to close the provided channel to
    	// ensure cleanup.
    	go func() {
    		<-ctx.Done()
    		close(internalStopCh)
    	}()
    
    	s.RunPostStartHooks(ctx)
    
    	if _, err := systemd.SdNotify(true, "READY=1\n"); err != nil {
    		klog.Errorf("Unable to send systemd daemon successful start message: %v\n", err)
    	}
    
    	return stoppedCh, listenerStoppedCh, nil
    }
    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