-
Notifications
You must be signed in to change notification settings - Fork 306
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Move function which generated composite URLMap to translator pkg
- Loading branch information
1 parent
32f1e04
commit ccebf6e
Showing
5 changed files
with
250 additions
and
150 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,123 @@ | ||
| /* | ||
| Copyright 2020 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 translator | ||
|
|
||
| import ( | ||
| "crypto/md5" | ||
| "encoding/hex" | ||
| "fmt" | ||
|
|
||
| "github.com/GoogleCloudPlatform/k8s-cloud-provider/pkg/cloud" | ||
| "github.com/GoogleCloudPlatform/k8s-cloud-provider/pkg/cloud/meta" | ||
| "k8s.io/ingress-gce/pkg/composite" | ||
| "k8s.io/ingress-gce/pkg/utils" | ||
| "k8s.io/ingress-gce/pkg/utils/namer" | ||
| ) | ||
|
|
||
|
|
||
| // The gce api uses the name of a path rule to match a host rule. | ||
| const hostRulePrefix = "host" | ||
|
|
||
| // ToCompositeURLMap translates the given hostname: endpoint->port mapping into a gce url map. | ||
| // | ||
| // HostRule: Conceptually contains all PathRules for a given host. | ||
| // PathMatcher: Associates a path rule with a host rule. Mostly an optimization. | ||
| // PathRule: Maps a single path regex to a backend. | ||
| // | ||
| // The GCE url map allows multiple hosts to share url->backend mappings without duplication, eg: | ||
| // Host: foo(PathMatcher1), bar(PathMatcher1,2) | ||
| // PathMatcher1: | ||
| // /a -> b1 | ||
| // /b -> b2 | ||
| // PathMatcher2: | ||
| // /c -> b1 | ||
| // This leads to a lot of complexity in the common case, where all we want is a mapping of | ||
| // host->{/path: backend}. | ||
| // | ||
| // Consider some alternatives: | ||
| // 1. Using a single backend per PathMatcher: | ||
| // Host: foo(PathMatcher1,3) bar(PathMatcher1,2,3) | ||
| // PathMatcher1: | ||
| // /a -> b1 | ||
| // PathMatcher2: | ||
| // /c -> b1 | ||
| // PathMatcher3: | ||
| // /b -> b2 | ||
| // 2. Using a single host per PathMatcher: | ||
| // Host: foo(PathMatcher1) | ||
| // PathMatcher1: | ||
| // /a -> b1 | ||
| // /b -> b2 | ||
| // Host: bar(PathMatcher2) | ||
| // PathMatcher2: | ||
| // /a -> b1 | ||
| // /b -> b2 | ||
| // /c -> b1 | ||
| // In the context of kubernetes services, 2 makes more sense, because we | ||
| // rarely want to lookup backends (service:nodeport). When a service is | ||
| // deleted, we need to find all host PathMatchers that have the backend | ||
| // and remove the mapping. When a new path is added to a host (happens | ||
| // more frequently than service deletion) we just need to lookup the 1 | ||
| // pathmatcher of the host. | ||
| func ToCompositeURLMap(g *utils.GCEURLMap, namer namer.IngressFrontendNamer, key *meta.Key) *composite.UrlMap { | ||
| defaultBackendName := g.DefaultBackend.BackendName() | ||
| key.Name = defaultBackendName | ||
| resourceID := cloud.ResourceID{ProjectID: "", Resource: "backendServices", Key: key} | ||
| m := &composite.UrlMap{ | ||
| Name: namer.UrlMap(), | ||
| DefaultService: resourceID.ResourcePath(), | ||
| } | ||
|
|
||
| for _, hostRule := range g.HostRules { | ||
| // Create a host rule | ||
| // Create a path matcher | ||
| // Add all given endpoint:backends to pathRules in path matcher | ||
| pmName := getNameForPathMatcher(hostRule.Hostname) | ||
| m.HostRules = append(m.HostRules, &composite.HostRule{ | ||
| Hosts: []string{hostRule.Hostname}, | ||
| PathMatcher: pmName, | ||
| }) | ||
|
|
||
| pathMatcher := &composite.PathMatcher{ | ||
| Name: pmName, | ||
| DefaultService: m.DefaultService, | ||
| PathRules: []*composite.PathRule{}, | ||
| } | ||
|
|
||
| // GCE ensures that matched rule with longest prefix wins. | ||
| for _, rule := range hostRule.Paths { | ||
| beName := rule.Backend.BackendName() | ||
| key.Name = beName | ||
| resourceID := cloud.ResourceID{ProjectID: "", Resource: "backendServices", Key: key} | ||
| beLink := resourceID.ResourcePath() | ||
| pathMatcher.PathRules = append(pathMatcher.PathRules, &composite.PathRule{ | ||
| Paths: []string{rule.Path}, | ||
| Service: beLink, | ||
| }) | ||
| } | ||
| m.PathMatchers = append(m.PathMatchers, pathMatcher) | ||
| } | ||
| return m | ||
| } | ||
|
|
||
| // getNameForPathMatcher returns a name for a pathMatcher based on the given host rule. | ||
| // The host rule can be a regex, the path matcher name used to associate the 2 cannot. | ||
| func getNameForPathMatcher(hostRule string) string { | ||
| hasher := md5.New() | ||
| hasher.Write([]byte(hostRule)) | ||
| return fmt.Sprintf("%v%v", hostRulePrefix, hex.EncodeToString(hasher.Sum(nil))) | ||
| } | ||
|
|
Oops, something went wrong.