Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for ResolveEndpoint (0.35 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/webhook/serviceresolver.go

    type ServiceResolver interface {
    	ResolveEndpoint(namespace, name string, port int32) (*url.URL, error)
    }
    
    type defaultServiceResolver struct{}
    
    // NewDefaultServiceResolver creates a new default server resolver.
    func NewDefaultServiceResolver() ServiceResolver {
    	return &defaultServiceResolver{}
    }
    
    // ResolveEndpoint constructs a service URL from a given namespace and name
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/service_resolver.go

    // an error for the failResolve namespace.
    func NewServiceResolver(base url.URL) webhook.ServiceResolver {
    	return &serviceResolver{base}
    }
    
    func (f serviceResolver) ResolveEndpoint(namespace, name string, port int32) (*url.URL, error) {
    	if namespace == "failResolve" {
    		return nil, fmt.Errorf("couldn't resolve service location")
    	}
    	u := f.base
    	return &u, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 18 18:49:55 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/initializer/initializer_test.go

    )
    
    type doNothingAdmission struct{}
    
    func (doNothingAdmission) Handles(o admission.Operation) bool { return false }
    
    type fakeServiceResolver struct{}
    
    func (f *fakeServiceResolver) ResolveEndpoint(namespace, name string, port int32) (*url.URL, error) {
    	return nil, nil
    }
    
    type serviceWanter struct {
    	doNothingAdmission
    	got ServiceResolver
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 08 07:19:52 UTC 2019
    - 1.4K bytes
    - Viewed (0)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/initializer/initializer.go

    type WantsServiceResolver interface {
    	SetServiceResolver(webhook.ServiceResolver)
    }
    
    // ServiceResolver knows how to convert a service reference into an actual
    // location.
    type ServiceResolver interface {
    	ResolveEndpoint(namespace, name string, port int32) (*url.URL, error)
    }
    
    // WantsAuthenticationInfoResolverWrapper defines a function that wraps the standard AuthenticationInfoResolver
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 08 07:19:52 UTC 2019
    - 2.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/webhook/serviceresolver_test.go

    	}
    
    	// act
    	for index, scenario := range scenarios {
    		t.Run(fmt.Sprintf("scenario %d", index), func(t *testing.T) {
    			target := defaultServiceResolver{}
    			serviceURL, err := target.ResolveEndpoint(scenario.serviceNamespace, scenario.serviceName, scenario.port)
    
    			if err != nil && !scenario.expectError {
    				t.Errorf("unexpected error has occurred = %v", err)
    			}
    			if err == nil && scenario.expectError {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 08 07:19:52 UTC 2019
    - 2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. staging/src/k8s.io/apiserver/pkg/util/proxy/proxy_test.go

    			}
    		}
    
    		clusterURL, err := ResolveCluster(serviceLister, "one", "alfa", 443)
    		check("cluster", test.clusterMode, clusterURL, err)
    
    		endpointURL, err := ResolveEndpoint(serviceLister, endpointLister, "one", "alfa", 443)
    		check("endpoint", test.endpointMode, endpointURL, err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 07:16:27 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go

    	return authorizer.DecisionAllow, "", nil
    }
    
    type dummyServiceResolverImpl struct{}
    
    func (dummyServiceResolverImpl) ResolveEndpoint(namespace, name string, port int32) (*url.URL, error) {
    	return &url.URL{Scheme: "https", Host: net.JoinHostPort(name+"."+namespace+".svc", strconv.Itoa(int(port)))}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 13 15:27:39 UTC 2023
    - 34.6K bytes
    - Viewed (0)
Back to top