- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for genericapiserver (0.91 sec)
-
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
Destroy() } func (s *GenericAPIServer) UnprotectedHandler() http.Handler { // when we delegate, we need the server we're delegating to choose whether or not to use gorestful return s.Handler.Director } func (s *GenericAPIServer) PostStartHooks() map[string]postStartHookEntry { return s.postStartHooks } func (s *GenericAPIServer) PreShutdownHooks() map[string]preShutdownHookEntry {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
pkg/controlplane/apiserver/server.go
}) if c.Extra.PeerProxy != nil { s.GenericAPIServer.AddPostStartHookOrDie("unknown-version-proxy-filter", func(context genericapiserver.PostStartHookContext) error { err := c.Extra.PeerProxy.WaitForCacheSync(context.StopCh) return err }) } } s.GenericAPIServer.AddPostStartHookOrDie("start-cluster-authentication-info-controller", func(hookContext genericapiserver.PostStartHookContext) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:24:41 UTC 2024 - 11K bytes - Viewed (0) -
pkg/controlplane/apiserver/apis.go
func (s *Server) InstallAPIs(restStorageProviders ...RESTStorageProvider) error { nonLegacy := []*genericapiserver.APIGroupInfo{} // used later in the loop to filter the served resource by those that have expired. resourceExpirationEvaluator, err := genericapiserver.NewResourceExpirationEvaluator(*s.GenericAPIServer.Version) if err != nil { return err } for _, restStorageBuilder := range restStorageProviders {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 6.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz.go
// since readyz should fail until boot fully completes. func (s *GenericAPIServer) AddBootSequenceHealthChecks(checks ...healthz.HealthChecker) error { return s.addHealthChecks(s.livezGracePeriod, checks...) } // addHealthChecks adds health checks to healthz, livez, and readyz. The delay passed in will set // a corresponding grace period on livez.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/hooks.go
func (s *GenericAPIServer) AddPostStartHookOrDie(name string, hook PostStartHookFunc) { if err := s.AddPostStartHook(name, hook); err != nil { klog.Fatalf("Error registering PostStartHook %q: %v", name, err) } } // AddPreShutdownHook allows you to add a PreShutdownHook. func (s *GenericAPIServer) AddPreShutdownHook(name string, hook PreShutdownHookFunc) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/server.go
config, err := o.Config() if err != nil { return err } server, err := config.Complete().New(genericapiserver.NewEmptyDelegate()) if err != nil { return err } return server.GenericAPIServer.PrepareRun().RunWithContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 1.6K bytes - Viewed (0) -
pkg/controlplane/apiserver/aggregator.go
// target resources' storage versions are up-to-date. genericConfig.BuildHandlerChainFunc = genericapiserver.BuildHandlerChainWithStorageVersionPrecondition } if peerProxy != nil { originalHandlerChainBuilder := genericConfig.BuildHandlerChainFunc genericConfig.BuildHandlerChainFunc = func(apiHandler http.Handler, c *genericapiserver.Config) http.Handler { // Add peer proxy handler to aggregator-apiserver.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/main.go
limitations under the License. */ package main import ( "os" "k8s.io/apiextensions-apiserver/pkg/cmd/server" genericapiserver "k8s.io/apiserver/pkg/server" "k8s.io/component-base/cli" ) func main() { ctx := genericapiserver.SetupSignalContext() cmd := server.NewServerCommand(ctx, os.Stdout, os.Stderr) code := cli.Run(cmd) os.Exit(code)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 888 bytes - Viewed (0) -
pkg/controlplane/apiserver/config.go
SystemNamespaces []string VersionedInformers clientgoinformers.SharedInformerFactory } // BuildGenericConfig takes the generic controlplane apiserver options and produces // the genericapiserver.Config associated with it. The genericapiserver.Config is // often shared between multiple delegated apiservers. func BuildGenericConfig( s options.CompletedOptions, schemes []*runtime.Scheme,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controlplane/apiserver/completion.go
limitations under the License. */ package apiserver import ( "k8s.io/apiserver/pkg/endpoints/discovery" genericapiserver "k8s.io/apiserver/pkg/server" ) type completedConfig struct { Generic genericapiserver.CompletedConfig *Extra } // CompletedConfig embeds a private pointer that cannot be instantiated outside of this package type CompletedConfig struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 06:13:43 UTC 2024 - 1.3K bytes - Viewed (0)