kubernetes/staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

type Controller …

type specCache …

func (s *specCache) update(crd *apiextensionsv1.CustomResourceDefinition) { … }

func createSpecCache(crd *apiextensionsv1.CustomResourceDefinition) *specCache { … }

// NewController creates a new Controller with input CustomResourceDefinition informer
func NewController(crdInformer informers.CustomResourceDefinitionInformer) *Controller { … }

// Run sets openAPIAggregationManager and starts workers
func (c *Controller) Run(staticSpec *spec.Swagger, openAPIService *handler.OpenAPIService, stopCh <-chan struct{ … }

func (c *Controller) runWorker() { … }

func (c *Controller) processNextWorkItem() bool { … }

func (c *Controller) sync(name string) error { … }

// updateSpecLocked updates the cached spec graph.
func (c *Controller) updateSpecLocked() { … }

func (c *Controller) addCustomResourceDefinition(obj interface{ … }

func (c *Controller) updateCustomResourceDefinition(oldObj, newObj interface{ … }

func (c *Controller) deleteCustomResourceDefinition(obj interface{ … }

func (c *Controller) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { … }

func generateCRDHash(crd *apiextensionsv1.CustomResourceDefinition) string { … }