Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for RegisterMuxAndDiscoveryCompleteSignal (0.58 sec)

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

    	assert.NoError(err)
    	if len(root.MuxAndDiscoveryCompleteSignals()) != 0 {
    		assert.Error(fmt.Errorf("unexpected signals %v registered in the root server", root.MuxAndDiscoveryCompleteSignals()))
    	}
    	root.RegisterMuxAndDiscoveryCompleteSignal("rootTestSignal", make(chan struct{}))
    	if len(root.MuxAndDiscoveryCompleteSignals()) != 1 {
    		assert.Error(fmt.Errorf("unexpected signals %v registered in the root server", root.MuxAndDiscoveryCompleteSignals()))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go

    	hasCRDInformerSyncedSignal := make(chan struct{})
    	if err := genericServer.RegisterMuxAndDiscoveryCompleteSignal("CRDInformerHasNotSynced", hasCRDInformerSyncedSignal); err != nil {
    		return nil, err
    	}
    
    	s := &CustomResourceDefinitions{
    		GenericAPIServer: genericServer,
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 14:31:43 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	return s.delegationTarget
    }
    
    // RegisterMuxAndDiscoveryCompleteSignal registers the given signal that will be used to determine if all known
    // HTTP paths have been registered. It is okay to call this method after instantiating the generic server but before running.
    func (s *GenericAPIServer) RegisterMuxAndDiscoveryCompleteSignal(signalName string, signal <-chan struct{}) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/config.go

    			return nil, err
    		}
    	}
    
    	// register mux signals from the delegated server
    	for k, v := range delegationTarget.MuxAndDiscoveryCompleteSignals() {
    		if err := s.RegisterMuxAndDiscoveryCompleteSignal(k, v); err != nil {
    			return nil, err
    		}
    	}
    
    	genericApiServerHookName := "generic-apiserver-start-informers"
    	if c.SharedInformerFactory != nil {
    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