Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 407 for Informer (0.12 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/informer.go

    // as they will be casted.
    func NewInformer[T runtime.Object](informe cache.SharedIndexInformer) Informer[T] {
    	return informer[T]{
    		SharedIndexInformer: informe,
    		lister:              NewLister[T](informe.GetIndexer()),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  2. pkg/kube/krt/informer.go

    	}
    	return a
    }
    
    var _ internalCollection[controllers.Object] = &informer[controllers.Object]{}
    
    func (i *informer[I]) _internalHandler() {}
    
    func (i *informer[I]) Synced() Syncer {
    	return channelSyncer{
    		name:   i.collectionName,
    		synced: i.synced,
    	}
    }
    
    // nolint: unused // (not true, its to implement an interface)
    func (i *informer[I]) dump() {
    	i.log.Errorf(">>> BEGIN DUMP")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go

    	if exists {
    		return informer
    	}
    
    	resyncPeriod, exists := f.customResync[informerType]
    	if !exists {
    		resyncPeriod = f.defaultResync
    	}
    
    	informer = newFunc(f.client, resyncPeriod)
    	informer.SetTransform(f.transform)
    	f.informers[informerType] = informer
    
    	return informer
    }
    
    // SharedInformerFactory provides shared informers for resources in all known
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go

    	if exists {
    		return informer
    	}
    
    	resyncPeriod, exists := f.customResync[informerType]
    	if !exists {
    		resyncPeriod = f.defaultResync
    	}
    
    	informer = newFunc(f.client, resyncPeriod)
    	informer.SetTransform(f.transform)
    	f.informers[informerType] = informer
    
    	return informer
    }
    
    // SharedInformerFactory provides shared informers for resources in all known
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 9K bytes
    - Viewed (0)
  5. pkg/scheduler/util/assumecache/assume_cache_test.go

    	// Some error cases (don't occur in practice).
    	informer.add(1)
    	verify(ktesting.WithStep(tCtx, "after nop add"), cache, key, newObj, newObj)
    	informer.add(nil)
    	verify(ktesting.WithStep(tCtx, "after nil add"), cache, key, newObj, newObj)
    	informer.update(oldObj)
    	verify(ktesting.WithStep(tCtx, "after nop update"), cache, key, newObj, newObj)
    	informer.update(nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go

    			nil,
    		)
    		go informer.Informer().Run(instanceContext.Done())
    	}
    
    	klog.Infof("informer started for %v", *paramSource)
    	ret := &paramInfo{
    		mapping:    *mapping,
    		cancelFunc: instanceCancel,
    		informer:   informer,
    	}
    	s.paramsCRDControllers[*paramSource] = ret
    	return ret.informer, mapping.Scope, nil
    }
    
    // For testing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 21 23:07:34 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  7. pkg/kube/kclient/interfaces.go

    	// to the underlying informer are not touched
    	ShutdownHandlers()
    	// Start starts just this informer. Typically, this is not used. Instead, the `kube.Client.Run()` is
    	// used to start all informers at once.
    	// However, in some cases we need to run individual informers directly.
    	// This function should only be called once. It does not wait for the informer to become ready nor does it block,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 07 05:09:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go

    	}()
    
    	// Wait for controller and informer to start up
    	require.True(t, cache.WaitForCacheSync(testContext.Done(), myController.HasSynced))
    
    	// Stop the controller and informer
    	testCancel()
    
    	// Wait for controller and informer to stop
    	wg.Wait()
    
    	// Ensure the event handler was cleaned up
    	require.Empty(t, informer.registrations)
    
    	verifyNoMoreEvents()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go

    		wh.SetExternalKubeClientSet(client)
    		wh.SetExternalKubeInformerFactory(informer)
    
    		informer.Start(stopCh)
    		informer.WaitForCacheSync(stopCh)
    
    		if err = wh.ValidateInitialization(); err != nil {
    			t.Errorf("%s: failed to validate initialization: %v", tt.Name, err)
    			continue
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:52 UTC 2024
    - 11K bytes
    - Viewed (0)
  10. pkg/scheduler/util/assumecache/assume_cache.go

    //   - The pointer to the informer object.
    //   - The pointer to the latest object, which could be the same as
    //     the informer object, or an in-memory object.
    //
    // An informer update always overrides the latest object pointer.
    //
    // Assume() only updates the latest object pointer.
    // Restore() sets the latest object pointer back to the informer object.
    // Get/List() always returns the latest object pointer.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top