- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for egressDialer (0.34 sec)
-
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) -
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) -
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) -
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/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) -
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) -
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)