Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for genericapiserver (0.3 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/testing/testserver.go

    	namer := openapinamer.NewDefinitionNamer(extensionsapiserver.Scheme)
    	config.GenericConfig.OpenAPIConfig = genericapiserver.DefaultOpenAPIConfig(getOpenAPIDefinitions, namer)
    
    	completedConfig := config.Complete()
    	server, err := completedConfig.New(genericapiserver.NewEmptyDelegate())
    	if err != nil {
    		return result, fmt.Errorf("failed to create server: %v", err)
    	}
    
    	errCh = make(chan error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 9K bytes
    - Viewed (1)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/options/options.go

    	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
    	utilerrors "k8s.io/apimachinery/pkg/util/errors"
    	openapinamer "k8s.io/apiserver/pkg/endpoints/openapi"
    	genericregistry "k8s.io/apiserver/pkg/registry/generic"
    	genericapiserver "k8s.io/apiserver/pkg/server"
    	genericoptions "k8s.io/apiserver/pkg/server/options"
    	storagevalue "k8s.io/apiserver/pkg/storage/value"
    	flowcontrolrequest "k8s.io/apiserver/pkg/util/flowcontrol/request"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. pkg/controlplane/apiserver/peer.go

    limitations under the License.
    */
    
    package apiserver
    
    import (
    	"fmt"
    	"net"
    	"strconv"
    	"time"
    
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apiserver/pkg/reconcilers"
    	genericapiserver "k8s.io/apiserver/pkg/server"
    	serverstorage "k8s.io/apiserver/pkg/server/storage"
    	"k8s.io/apiserver/pkg/storageversion"
    	utilpeerproxy "k8s.io/apiserver/pkg/util/peerproxy"
    	clientgoinformers "k8s.io/client-go/informers"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 08:15:02 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. cmd/kube-apiserver/app/aggregator.go

    )
    
    // The proper way to resolve this letting the aggregator know the desired group and version-within-group order of the underlying servers
    // is to refactor the genericapiserver.DelegationTarget to include a list of priorities based on which APIs were installed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 17:44:20 UTC 2024
    - 3.6K bytes
    - Viewed (0)
Back to top