Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for AsNetworkContext (0.32 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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