Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for SetDrainedNotification (0.3 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/admission.go

    		stopCh:        nil,
    		numEvaluators: numEvaluators,
    		config:        config,
    		quotaAccessor: quotaAccessor,
    	}, nil
    }
    
    // SetDrainedNotification sets the stop channel into QuotaAdmission.
    func (a *QuotaAdmission) SetDrainedNotification(stopCh <-chan struct{}) {
    	a.stopCh = stopCh
    }
    
    // SetExternalKubeClientSet registers the client into QuotaAdmission
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 23 10:34:50 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go

    	// First tell the plugin about drained notification, so it can pass it to further initializations.
    	if wants, ok := plugin.(WantsDrainedNotification); ok {
    		wants.SetDrainedNotification(i.stopCh)
    	}
    
    	// Second tell the plugin about enabled features, so it can decide whether to start informers or not
    	if wants, ok := plugin.(WantsFeatures); ok {
    		wants.InspectFeatureGates(i.featureGates)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/initializer/interfaces.go

    // has already been drained for admission plugins that need it.
    // After receiving that notification, Admit/Validate calls won't be called anymore.
    type WantsDrainedNotification interface {
    	SetDrainedNotification(<-chan struct{})
    	admission.InitializationValidator
    }
    
    // WantsFeatureGate defines a function which passes the featureGates for inspection by an admission plugin.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 19:11:10 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/plugin.go

    func (c *Plugin[H]) SetRESTMapper(mapper meta.RESTMapper) {
    	c.restMapper = mapper
    }
    
    func (c *Plugin[H]) SetDynamicClient(client dynamic.Interface) {
    	c.dynamicClient = client
    }
    
    func (c *Plugin[H]) SetDrainedNotification(stopCh <-chan struct{}) {
    	c.stopCh = stopCh
    }
    
    func (c *Plugin[H]) SetAuthorizer(authorizer authorizer.Authorizer) {
    	c.authorizer = authorizer
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 19:11:10 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go

    // WantDrainedNotification is a test stub that filfills the WantsDrainedNotification interface.
    type WantDrainedNotification struct {
    	stopCh <-chan struct{}
    }
    
    func (self *WantDrainedNotification) SetDrainedNotification(stopCh <-chan struct{}) {
    	self.stopCh = stopCh
    }
    func (self *WantDrainedNotification) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	return nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top