Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for egressDialer (0.34 sec)

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

    				}
    
    				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
    				}
    				return ret, nil
    			},
    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

    		// 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/storage/storagebackend/factory/etcd3.go

    	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)
  4. 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)
  5. pkg/controlplane/apiserver/config.go

    	}
    	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
    	for _, a := range authorizationConfig.AuthorizationConfiguration.Authorizers {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K 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)
  7. staging/src/k8s.io/apiserver/pkg/server/egressselector/metrics/metrics.go

    package metrics
    
    import (
    	"time"
    
    	"k8s.io/component-base/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    	"k8s.io/utils/clock"
    )
    
    const (
    	namespace = "apiserver"
    	subsystem = "egress_dialer"
    
    	// ProtocolHTTPConnect means that the proxy protocol is http-connect.
    	ProtocolHTTPConnect = "http_connect"
    	// ProtocolGRPC means that the proxy protocol is the GRPC protocol.
    	ProtocolGRPC = "grpc"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 01 23:36:51 UTC 2022
    - 4.3K bytes
    - Viewed (0)
Back to top