Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for AsyncTracker (0.14 sec)

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

    	reconciler func(namespace, name string, newObj T) error
    
    	options ControllerOptions
    
    	// must hold a func() bool or nil
    	notificationsDelivered atomic.Value
    
    	hasProcessed synctrack.AsyncTracker[string]
    }
    
    type ControllerOptions struct {
    	Name    string
    	Workers uint
    }
    
    func (c *controller[T]) Informer() Informer[T] {
    	return c.informer
    }
    
    func NewController[T runtime.Object](
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top