- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ResolveEndpoint (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy.go
return &svcPort, nil } } return nil, errors.NewServiceUnavailable(fmt.Sprintf("no service port %d found for service %q", port, svc.Name)) } // ResolveEndpoint returns a URL to which one can send traffic for the specified service. func ResolveEndpoint(services listersv1.ServiceLister, endpoints listersv1.EndpointsLister, namespace, id string, port int32) (*url.URL, error) { svc, err := services.Services(namespace).Get(id)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/options/options.go
} type serviceResolver struct { services corev1.ServiceLister } func (r *serviceResolver) ResolveEndpoint(namespace, name string, port int32) (*url.URL, error) { return proxy.ResolveCluster(r.services, namespace, name, port)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/client.go
var d net.Dialer delegateDialer = d.DialContext } cfg.Dial = func(ctx context.Context, network, addr string) (net.Conn, error) { if addr == host { u, err := cm.serviceResolver.ResolveEndpoint(cc.Service.Namespace, cc.Service.Name, port) if err != nil { return nil, err } addr = u.Host } return delegateDialer(ctx, network, addr) } return complete(cfg) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 09:09:10 UTC 2024 - 7.3K bytes - Viewed (0)