Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for NewNonInteractiveDeferredLoadingClientConfig (0.6 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/options/coreapi.go

    	var kubeconfig *rest.Config
    	var err error
    	if len(o.CoreAPIKubeconfigPath) > 0 {
    		loadingRules := &clientcmd.ClientConfigLoadingRules{ExplicitPath: o.CoreAPIKubeconfigPath}
    		loader := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, &clientcmd.ConfigOverrides{})
    		kubeconfig, err = loader.ClientConfig()
    		if err != nil {
    			return fmt.Errorf("failed to load kubeconfig at %q: %v", o.CoreAPIKubeconfigPath, err)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 16:55:02 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go

    	loadingRules := clientcmd.NewDefaultClientConfigLoadingRules()
    	loadingRules.ExplicitPath = kubeConfigFile
    	loader := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, &clientcmd.ConfigOverrides{})
    
    	clientConfig, err := loader.ClientConfig()
    	if err != nil {
    		return nil, err
    	}
    
    	clientConfig.Dial = customDial
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 19:02:55 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/authorization.go

    	var clientConfig *rest.Config
    	var err error
    	if len(s.RemoteKubeConfigFile) > 0 {
    		loadingRules := &clientcmd.ClientConfigLoadingRules{ExplicitPath: s.RemoteKubeConfigFile}
    		loader := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, &clientcmd.ConfigOverrides{})
    
    		clientConfig, err = loader.ClientConfig()
    	} else {
    		// without the remote kubeconfig file, try to use the in-cluster config.  Most addon API servers will
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 9.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/webhook/authentication.go

    		return &defaultAuthenticationInfoResolver{}, nil
    	}
    
    	loadingRules := clientcmd.NewDefaultClientConfigLoadingRules()
    	loadingRules.ExplicitPath = kubeconfigFile
    	loader := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, &clientcmd.ConfigOverrides{})
    	clientConfig, err := loader.RawConfig()
    	if err != nil {
    		return nil, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 9.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags.go

    	}
    
    	if f.Timeout != nil {
    		overrides.Timeout = *f.Timeout
    	}
    
    	// we only have an interactive prompt when a password is allowed
    	if f.Password == nil {
    		return &clientConfig{clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, overrides)}
    	}
    	return &clientConfig{clientcmd.NewInteractiveDeferredLoadingClientConfig(loadingRules, overrides, os.Stdin)}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 11 15:04:11 UTC 2023
    - 16.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/options/authentication.go

    	var clientConfig *rest.Config
    	var err error
    	if len(s.RemoteKubeConfigFile) > 0 {
    		loadingRules := &clientcmd.ClientConfigLoadingRules{ExplicitPath: s.RemoteKubeConfigFile}
    		loader := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, &clientcmd.ConfigOverrides{})
    
    		clientConfig, err = loader.ClientConfig()
    	} else {
    		// without the remote kubeconfig file, try to use the in-cluster config.  Most addon API servers will
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 21 14:51:22 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  7. pkg/kube/util.go

    		ClusterDefaults: clientcmd.ClusterDefaults,
    		CurrentContext:  context,
    	}
    
    	for _, fn := range overrides {
    		fn(configOverrides)
    	}
    
    	return clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, configOverrides)
    }
    
    // NewUntrustedRestConfig returns the rest.Config for the given kube config context.
    // This is suitable for access to remote clusters from untrusted kubeConfig inputs.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  8. cmd/kubelet/app/server.go

    		if err := bootstrap.LoadClientCert(ctx, s.KubeConfig, s.BootstrapKubeconfig, s.CertDirectory, nodeName); err != nil {
    			return nil, nil, err
    		}
    	}
    
    	clientConfig, err := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(
    		&clientcmd.ClientConfigLoadingRules{ExplicitPath: s.KubeConfig},
    		&clientcmd.ConfigOverrides{},
    	).ClientConfig()
    	if err != nil {
    		return nil, nil, fmt.Errorf("invalid kubeconfig: %w", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:34 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  9. cmd/kube-proxy/app/server.go

    	} else {
    		// This creates a client, first loading any specified kubeconfig
    		// file, and then overriding the Master flag, if non-empty.
    		kubeConfig, err = clientcmd.NewNonInteractiveDeferredLoadingClientConfig(
    			&clientcmd.ClientConfigLoadingRules{ExplicitPath: config.Kubeconfig},
    			&clientcmd.ConfigOverrides{ClusterInfo: clientcmdapi.Cluster{Server: masterOverride}}).ClientConfig()
    	}
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
Back to top