Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for AsNetworkContext (0.45 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/webhook/authentication.go

    				}
    				if feature.DefaultFeatureGate.Enabled(features.APIServerTracing) {
    					ret.Wrap(tracing.WrapperFor(tp))
    				}
    
    				if egressSelector != nil {
    					networkContext := egressselector.ControlPlane.AsNetworkContext()
    					var egressDialer utilnet.DialFunc
    					egressDialer, err = egressSelector.Lookup(networkContext)
    
    					if err != nil {
    						return nil, err
    					}
    
    					ret.Dial = egressDialer
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 9.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/options/tracing.go

    	if es != nil {
    		// Only use the egressselector dialer if egressselector is enabled.
    		// Endpoint is on the "ControlPlane" network
    		egressDialer, err := es.Lookup(egressselector.ControlPlane.AsNetworkContext())
    		if err != nil {
    			return err
    		}
    		if egressDialer != nil {
    			otelDialer := func(ctx context.Context, addr string) (net.Conn, error) {
    				return egressDialer(ctx, "tcp", addr)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 21:39:39 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector.go

    		return "controlplane"
    	case Etcd:
    		return "etcd"
    	case Cluster:
    		return "cluster"
    	default:
    		return "invalid"
    	}
    }
    
    // AsNetworkContext is a helper function to make it easy to get the basic NetworkContext objects.
    func (s EgressType) AsNetworkContext() NetworkContext {
    	return NetworkContext{EgressSelectionName: s}
    }
    
    func lookupServiceName(name string) (EgressType, error) {
    	switch strings.ToLower(name) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  4. pkg/kubelet/client/kubelet_client.go

    	}
    
    	if config.Lookup != nil {
    		// Assuming EgressSelector if SSHTunnel is not turned on.
    		// We will not get a dialer if egress selector is disabled.
    		networkContext := egressselector.Cluster.AsNetworkContext()
    		dialer, err := config.Lookup(networkContext)
    		if err != nil {
    			return nil, fmt.Errorf("failed to get context dialer for 'cluster': got %v", err)
    		}
    		if dialer != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 07 01:34:49 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  5. cmd/kube-apiserver/app/server.go

    		// Use the config.ControlPlane.Generic.EgressSelector lookup as the transport used by the "proxy" subresources.
    		networkContext := egressselector.Cluster.AsNetworkContext()
    		dialer, err := config.ControlPlane.Generic.EgressSelector.Lookup(networkContext)
    		if err != nil {
    			return nil, nil, nil, err
    		}
    		c := config.ControlPlane.Extra.ProxyTransport.Clone()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 17:44:20 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  6. pkg/controlplane/apiserver/config.go

    		return nil, nil, false, err
    	}
    	if authorizationConfig == nil {
    		return nil, nil, false, nil
    	}
    
    	if egressSelector != nil {
    		egressDialer, err := egressSelector.Lookup(egressselector.ControlPlane.AsNetworkContext())
    		if err != nil {
    			return nil, nil, false, err
    		}
    		authorizationConfig.CustomDial = egressDialer
    	}
    
    	enablesRBAC := false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    	// for non-secure connections, update the implicit variable
    	if len(c.CertFile) == 0 && len(c.KeyFile) == 0 && len(c.TrustedCAFile) == 0 {
    		tlsConfig = nil
    	}
    	networkContext := egressselector.Etcd.AsNetworkContext()
    	var egressDialer utilnet.DialFunc
    	if c.EgressLookup != nil {
    		egressDialer, err = c.EgressLookup(networkContext)
    		if err != nil {
    			return nil, err
    		}
    	}
    	dialOptions := []grpc.DialOption{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:56:39 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/options/audit.go

    		} else {
    			if c.EgressSelector != nil {
    				var egressDialer utilnet.DialFunc
    				egressDialer, err = c.EgressSelector.Lookup(egressselector.ControlPlane.AsNetworkContext())
    				if err != nil {
    					return err
    				}
    				webhookBackend, err = o.WebhookOptions.newUntruncatedBackend(egressDialer)
    			} else {
    				webhookBackend, err = o.WebhookOptions.newUntruncatedBackend(nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 24 06:30:04 UTC 2022
    - 20.3K bytes
    - Viewed (0)
  9. pkg/kubeapiserver/options/authentication.go

    			versionedInformer.Core().V1().Secrets().Lister().Secrets(metav1.NamespaceSystem),
    		)
    	}
    
    	if egressSelector != nil {
    		egressDialer, err := egressSelector.Lookup(egressselector.ControlPlane.AsNetworkContext())
    		if err != nil {
    			return err
    		}
    		authenticatorConfig.CustomDial = egressDialer
    	}
    
    	// var openAPIV3SecuritySchemes spec3.SecuritySchemes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 22:40:22 UTC 2024
    - 32.4K bytes
    - Viewed (0)
Back to top