github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-11 04:52:08 +00:00
Code Issues Projects Releases Wiki Activity

Ran gofmt -s

Browse Source
This commit is contained in:
Kenneth Shelton 2015-09-23 08:40:51 -07:00
parent 967fac0adc
commit aef8ba00e0
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
pkg/cloudprovider/providers/gce/gce.go
View File

@ -453,18 +453,18 @@ func (gce *GCECloud) EnsureTCPLoadBalancer(name, region string, loadBalancerIP n
return status, nil return status, nil
} }
// We grab all tags from all instances being added to the pool. // We grab all tags from all instances being added to the pool.
// * The longest tag that is a prefix of the instance name is used // * The longest tag that is a prefix of the instance name is used
// * If any instance has a prefix tag, all instances must // * If any instance has a prefix tag, all instances must
// * If no instances have a prefix tag, no tags are used // * If no instances have a prefix tag, no tags are used
func (gce *GCECloud) computeHostTags(hosts []string) ([]string, error) { func (gce *GCECloud) computeHostTags(hosts []string) ([]string, error) {
listCall := gce.service.Instances.List(gce.projectID, gce.zone) listCall := gce.service.Instances.List(gce.projectID, gce.zone)
// Add the filter for hosts // Add the filter for hosts
listCall = listCall.Filter("name eq (" + strings.Join(hosts, "|") + ")") listCall = listCall.Filter("name eq (" + strings.Join(hosts, "|") + ")")
// Add the fields we want // Add the fields we want
listCall = listCall.Fields("items(name,tags)") listCall = listCall.Fields("items(name,tags)")
res, err := listCall.Do() res, err := listCall.Do()
if err != nil { if err != nil {
@ -472,23 +472,23 @@ func (gce *GCECloud) computeHostTags(hosts []string) ([]string, error) {
} }
tags := sets.NewString() tags := sets.NewString()
for _, instance := range res.Items { for _, instance := range res.Items {
longest_tag := "" longest_tag := ""
for _, tag := range instance.Tags.Items { for _, tag := range instance.Tags.Items {
if strings.HasPrefix(instance.Name, tag) && len(tag) > len(longest_tag) { if strings.HasPrefix(instance.Name, tag) && len(tag) > len(longest_tag) {
longest_tag = tag longest_tag = tag
} }
} }
if len(longest_tag) > 0 { if len(longest_tag) > 0 {
tags.Insert(longest_tag) tags.Insert(longest_tag)
} else if len(tags) > 0 { } else if len(tags) > 0 {
return nil, fmt.Errorf("Some, but not all, instances have prefix tags (%s is missing)", instance.Name) return nil, fmt.Errorf("Some, but not all, instances have prefix tags (%s is missing)", instance.Name)
} }
} }
if len(tags) == 0 { if len(tags) == 0 {
glog.V(2).Info("No instances had tags, creating rule without target tags") glog.V(2).Info("No instances had tags, creating rule without target tags")
} }
return tags.List(), nil return tags.List(), nil
} }