- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for AsNetworkContext (0.45 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)