- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for ResolveEndpoint (0.21 sec)
-
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) -
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) -
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) -
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/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) -
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) -
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) -
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:16:27 UTC 2023 - 8.6K bytes - Viewed (0) -
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)