Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 118 for syncAt (0.53 sec)

  1. pkg/kube/krt/join.go

    	return res
    }
    
    func (j *join[T]) Register(f func(o Event[T])) Syncer {
    	return registerHandlerAsBatched[T](j, f)
    }
    
    func (j *join[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer {
    	sync := multiSyncer{}
    	for _, c := range j.collections {
    		sync.syncers = append(sync.syncers, c.RegisterBatch(f, runExistingState))
    	}
    	return sync
    }
    
    // nolint: unused // (not true, its to implement an interface)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. pkg/kube/krt/static.go

    	return maps.Values(s.vals)
    }
    
    func (s *staticList[T]) Register(f func(o Event[T])) Syncer {
    	return registerHandlerAsBatched(s, f)
    }
    
    func (s *staticList[T]) Synced() Syncer {
    	return alwaysSynced{}
    }
    
    func (s *staticList[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer {
    	if runExistingState {
    		f(slices.Map(s.List(), func(e T) Event[T] {
    			return Event[T]{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. pkg/kube/krt/informer.go

    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")
    	for _, obj := range i.inf.List(metav1.NamespaceAll, klabels.Everything()) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. pkg/kube/krt/core.go

    	// using krt), registering directly is expected.
    	Register(f func(o Event[T])) Syncer
    
    	// Synced returns a Syncer which can be used to determine if the collection has synced. Once its synced, all dependencies have
    	// been processed, and all handlers have been called with the results.
    	Synced() Syncer
    
    	// RegisterBatch registers a handler that accepts multiple events at once. This can be useful as an optimization.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. pkg/kube/krt/singleton.go

    	v := d.val.Load()
    	if v == nil {
    		return nil
    	}
    	return []T{*v}
    }
    
    func (d *static[T]) Register(f func(o Event[T])) Syncer {
    	return registerHandlerAsBatched[T](d, f)
    }
    
    func (d *static[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer {
    	d.eventHandlers.Insert(f)
    	if runExistingState {
    		v := d.val.Load()
    		if v != nil {
    			f([]Event[T]{{
    				New:   v,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go

    		return false
    	}
    	defer ec.queue.Done(key)
    
    	err := ec.syncFn(key)
    	if err == nil {
    		ec.queue.Forget(key)
    		return true
    	}
    
    	utilruntime.HandleError(fmt.Errorf("%v failed with: %v", key, err))
    	ec.queue.AddRateLimited(key)
    
    	return true
    }
    
    // sync is used to turn CRDs into the Established state.
    func (ec *EstablishingController) sync(key string) error {
    	cachedCRD, err := ec.crdLister.Get(key)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go

    	// To allow injection for testing.
    	syncFn func(key string) error
    
    	queue workqueue.TypedRateLimitingInterface[string]
    
    	// last protectedAnnotation value this controller updated the condition per CRD name (to avoid two
    	// different version of the apiextensions-apiservers in HA to fight for the right message)
    	lastSeenProtectedAnnotationLock sync.Mutex
    	lastSeenProtectedAnnotation     map[string]string
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

    	crdsSynced cache.InformerSynced
    
    	// To allow injection for testing.
    	syncFn func(string) error
    
    	queue workqueue.TypedRateLimitingInterface[string]
    
    	staticSpec *spec.Swagger
    
    	openAPIService *handler.OpenAPIService
    
    	// specs by name. The specs are lazily constructed on request.
    	// The lock is for the map only.
    	lock        sync.Mutex
    	specsByName map[string]*specCache
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go

    	crdSynced cache.InformerSynced
    
    	// To allow injection for testing.
    	syncFn func(key string) error
    
    	queue workqueue.TypedRateLimitingInterface[string]
    
    	// last generation this controller updated the condition per CRD name (to avoid two
    	// different version of the apiextensions-apiservers in HA to fight for the right message)
    	lastSeenGenerationLock sync.Mutex
    	lastSeenGeneration     map[string]int64
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go

    	crdLister  listers.CustomResourceDefinitionLister
    	crdsSynced cache.InformerSynced
    
    	// To allow injection for testing.
    	syncFn func(string) error
    
    	queue workqueue.TypedRateLimitingInterface[string]
    
    	openAPIV3Service *handler3.OpenAPIService
    
    	// specs per version and per CRD name
    	lock             sync.Mutex
    	specsByGVandName map[schema.GroupVersion]map[string]*spec3.OpenAPI
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top