kubernetes/staging/src/k8s.io/dynamic-resource-allocation/resourceslice/resourceslicecontroller.go

const resyncPeriod …

const poolNameIndex …

const defaultMutationCacheTTL …

const defaultSyncDelay …

type Controller …

type DriverResources …

type Pool …

type Slice …

type Owner …

// StartController constructs a new controller and starts it.
func StartController(ctx context.Context, options Options) (*Controller, error) { … }

type Options …

// Stop cancels all background activity and blocks until the controller has stopped.
func (c *Controller) Stop() { … }

// Update sets the new desired state of the resource information.
//
// The controller is doing a deep copy, so the caller may update
// the instance once Update returns.
func (c *Controller) Update(resources *DriverResources) { … }

// GetStats provides some insights into operations of the controller.
func (c *Controller) GetStats() Stats { … }

type Stats …

// newController creates a new controller.
func newController(ctx context.Context, options Options) (*Controller, error) { … }

// initInformer initializes the informer used to watch for changes to the resources slice.
func (c *Controller) initInformer(ctx context.Context) error { … }

// run is running in the background.
func (c *Controller) run(ctx context.Context) { … }

func (c *Controller) processNextWorkItem(ctx context.Context) bool { … }

// syncPool processes one pool. Only runs inside a single worker, so there
// is no need for locking except when accessing c.resources, which may
// be updated at any time by the user of the controller.
func (c *Controller) syncPool(ctx context.Context, poolName string) error { … }

func sameSlice(existingSlice *resourceapi.ResourceSlice, desiredSlice *Slice) bool { … }