kubernetes/pkg/controller/storageversiongc/gc_controller.go

type Controller …

// NewStorageVersionGC creates a new Controller.
func NewStorageVersionGC(ctx context.Context, clientset kubernetes.Interface, leaseInformer coordinformers.LeaseInformer, storageVersionInformer apiserverinternalinformers.StorageVersionInformer) *Controller { … }

// Run starts one worker.
func (c *Controller) Run(ctx context.Context) { … }

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

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

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

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

func (c *Controller) processDeletedLease(ctx context.Context, name string) error { … }

func (c *Controller) syncStorageVersion(ctx context.Context, name string) error { … }

func (c *Controller) onAddStorageVersion(logger klog.Logger, obj interface{ … }

func (c *Controller) onUpdateStorageVersion(logger klog.Logger, oldObj, newObj interface{ … }

// enqueueStorageVersion enqueues the storage version if it has entry for invalid apiserver
func (c *Controller) enqueueStorageVersion(logger klog.Logger, obj *apiserverinternalv1alpha1.StorageVersion) { … }

func (c *Controller) onDeleteLease(logger klog.Logger, obj interface{ … }

func (c *Controller) enqueueLease(obj *coordinationv1.Lease) { … }

func (c *Controller) updateOrDeleteStorageVersion(ctx context.Context, sv *apiserverinternalv1alpha1.StorageVersion, serverStorageVersions []apiserverinternalv1alpha1.ServerStorageVersion) error { … }