Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ResolveEndpoint (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top