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