- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 218 for Informer (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
// NewInformerSyncHealthz returns a new HealthChecker that will pass only if all informers in the given cacheSyncWaiter sync. func NewInformerSyncHealthz(cacheSyncWaiter cacheSyncWaiter) HealthChecker { return &informerSync{ cacheSyncWaiter: cacheSyncWaiter, } } func (i *informerSync) Name() string { return "informer-sync" } type shutdown struct { stopCh <-chan struct{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/controlplane/apiserver/aggregator.go
aggregatorscheme "k8s.io/kube-aggregator/pkg/apiserver/scheme" apiregistrationclient "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/typed/apiregistration/v1" informers "k8s.io/kube-aggregator/pkg/client/informers/externalversions/apiregistration/v1" "k8s.io/kube-aggregator/pkg/controllers/autoregister" "k8s.io/kubernetes/pkg/controlplane/apiserver/options"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0) -
pilot/pkg/model/extensions.go
var ok bool // Make a deep copy since we are going to mutate the resource later for secret env variable. // We do not want to mutate the underlying resource at informer cache. plugin := originPlugin.DeepCopy() var wasmPlugin *extensions.WasmPlugin if wasmPlugin, ok = plugin.Spec.(*extensions.WasmPlugin); !ok { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 11K bytes - Viewed (0) -
pilot/pkg/credentials/kube/secrets.go
secrets := kclient.NewFiltered[*v1.Secret](kc, kclient.Filter{ FieldSelector: fieldSelector, }) for _, h := range handlers { h := h // register handler before informer starts secrets.AddEventHandler(controllers.ObjectHandler(func(o controllers.Object) { h(o.GetName(), o.GetNamespace()) })) } return &CredentialsController{ secrets: secrets,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 10K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission.go
expiry time.Time items []*corev1.LimitRange } // SetExternalKubeInformerFactory registers an informer factory into the LimitRanger func (l *LimitRanger) SetExternalKubeInformerFactory(f informers.SharedInformerFactory) { limitRangeInformer := f.Core().V1().LimitRanges() l.SetReadyFunc(limitRangeInformer.Informer().HasSynced) l.lister = limitRangeInformer.Lister() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 13:04:39 UTC 2023 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz_test.go
if err != nil { t.Errorf("Got %v, expected no error", err) } }) t.Run("test that check returns err when there is not started informer", func(t *testing.T) { healthChecker := NewInformerSyncHealthz(cacheSyncWaiterStub{ startedByInformerType: map[reflect.Type]bool{ reflect.TypeOf(corev1.Pod{}): true, reflect.TypeOf(corev1.Service{}): false, reflect.TypeOf(corev1.Node{}): true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 20:43:16 UTC 2023 - 11.4K bytes - Viewed (0) -
plugin/pkg/admission/podtolerationrestriction/admission_test.go
t.Errorf("expected no error, got: %v", err) } } // newHandlerForTest returns the admission controller configured for testing. func newHandlerForTest(c kubernetes.Interface) (*Plugin, informers.SharedInformerFactory, error) { f := informers.NewSharedInformerFactory(c, 5*time.Minute) pluginConfig, err := loadConfiguration(nil) // must not fail if err != nil { return nil, nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/testcase.go
informerFactory := informers.NewSharedInformerFactory(client, 0) return client, informerFactory } // NewFakeMutatingDataSource returns a mock client and informer returning the given webhooks. func NewFakeMutatingDataSource(name string, webhooks []registrationv1.MutatingWebhook, stopCh <-chan struct{}) (clientset kubernetes.Interface, factory informers.SharedInformerFactory) { var objs = []runtime.Object{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 03 06:51:04 UTC 2023 - 47.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
pli := fci.PriorityLevelConfigurations() fsi := fci.FlowSchemas() cfgCtlr.plLister = pli.Lister() cfgCtlr.plInformerSynced = pli.Informer().HasSynced cfgCtlr.fsLister = fsi.Lister() cfgCtlr.fsInformerSynced = fsi.Informer().HasSynced pli.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { pl := obj.(*flowcontrol.PriorityLevelConfiguration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
func setupNewController(ctx context.Context, fakeClientSet *fake.Clientset) (*Controller, cache.Indexer, cache.Indexer) { informerFactory := informers.NewSharedInformerFactory(fakeClientSet, 0) podIndexer := informerFactory.Core().V1().Pods().Informer().GetIndexer() nodeIndexer := informerFactory.Core().V1().Nodes().Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0)