- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for SetDrainedNotification (0.3 sec)
-
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) -
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) -
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) -
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) -
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)