var ErrAPIServiceNotFound … type SpecProxier … const aggregatorUser … const specDownloadTimeout … const localDelegateChainNamePrefix … const localDelegateChainNamePattern … const openAPIV2Converter … // IsLocalAPIService returns true for local specs from delegates. func IsLocalAPIService(apiServiceName string) bool { … } // GetAPIServiceNames returns the names of APIServices recorded in apiServiceInfo. // We use this function to pass the names of local APIServices to the controller in this package, // so that the controller can periodically sync the OpenAPI spec from delegation API servers. func (s *specProxier) GetAPIServiceNames() []string { … } // BuildAndRegisterAggregator registered OpenAPI aggregator handler. This function is not thread safe as it only being called on startup. func BuildAndRegisterAggregator(downloader Downloader, delegationTarget server.DelegationTarget, aggregatorService *restful.Container, openAPIConfig *common.OpenAPIV3Config, pathHandler common.PathHandlerByGroupVersion) (SpecProxier, error) { … } // AddUpdateAPIService adds or updates the api service. It is thread safe. func (s *specProxier) AddUpdateAPIService(handler http.Handler, apiservice *v1.APIService) { … } func getGroupVersionStringFromAPIService(apiService v1.APIService) string { … } // UpdateAPIServiceSpec updates all the OpenAPI v3 specs that the APIService serves. // It is thread safe. func (s *specProxier) UpdateAPIServiceSpec(apiServiceName string) error { … } func (s *specProxier) updateAPIServiceSpecLocked(apiServiceName string) error { … } type specProxier … var _ … type openAPIV3APIServiceInfo … // RemoveAPIServiceSpec removes an api service from the OpenAPI map. If it does not exist, no error is returned. // It is thread safe. func (s *specProxier) RemoveAPIServiceSpec(apiServiceName string) { … } func (s *specProxier) getOpenAPIV3Root() handler3.OpenAPIV3Discovery { … } // handleDiscovery is the handler for OpenAPI V3 Discovery func (s *specProxier) handleDiscovery(w http.ResponseWriter, r *http.Request) { … } // handleGroupVersion is the OpenAPI V3 handler for a specified group/version func (s *specProxier) handleGroupVersion(w http.ResponseWriter, r *http.Request) { … } // Register registers the OpenAPI V3 Discovery and GroupVersion handlers func (s *specProxier) register(handler common.PathHandlerByGroupVersion) { … }
Codebase Browser
kubernetes