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