| /* |
| Copyright 2017 The Kubernetes Authors. |
| |
| Licensed under the Apache License, Version 2.0 (the "License"); |
| you may not use this file except in compliance with the License. |
| You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and |
| limitations under the License. |
| */ |
| |
| package webhook |
| |
| import ( |
| "errors" |
| "fmt" |
| "net/url" |
| ) |
| |
| // ServiceResolver knows how to convert a service reference into an actual location. |
| 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 |
| // note that the name, namespace, and port are required and by default all |
| // created addresses use HTTPS scheme. |
| // for example: |
| // name=ross namespace=andromeda resolves to https://ross.andromeda.svc:443 |
| func (sr defaultServiceResolver) ResolveEndpoint(namespace, name string, port int32) (*url.URL, error) { |
| if len(name) == 0 || len(namespace) == 0 || port == 0 { |
| return nil, errors.New("cannot resolve an empty service name or namespace or port") |
| } |
| return &url.URL{Scheme: "https", Host: fmt.Sprintf("%s.%s.svc:%d", name, namespace, port)}, nil |
| } |