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

Fix the matching rule of instance ProviderID

Browse Source 
Url.Parse() can't parse ProviderID which contains ':///'.
This PR use regexp to match ProviderID.
This commit is contained in:
FengyunPan 2017-07-28 17:38:50 +08:00
parent 270206e9c3
commit c6489da70d
2 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pkg/cloudprovider/providers/openstack/openstack_instances.go
View File

@ -19,7 +19,7 @@ package openstack
import ( import (
"errors" "errors"
"fmt" "fmt"
"net/url" "regexp"
"github.com/golang/glog" "github.com/golang/glog"
"github.com/gophercloud/gophercloud" "github.com/gophercloud/gophercloud"
@ -208,14 +208,16 @@ func srvInstanceType(srv *servers.Server) (string, error) {
return "", fmt.Errorf("flavor name/id not found") return "", fmt.Errorf("flavor name/id not found")
} }
// instanceIDFromProviderID splits a provider's id and return instanceID.
// A providerID is build out of '${ProviderName}:///${instance-id}'which contains ':///'.
// See cloudprovider.GetInstanceProviderID and Instances.InstanceID.
func instanceIDFromProviderID(providerID string) (instanceID string, err error) { func instanceIDFromProviderID(providerID string) (instanceID string, err error) {
parsedID, err := url.Parse(providerID) // If Instances.InstanceID or cloudprovider.GetInstanceProviderID is changed, the regexp should be changed too.
if err != nil { var providerIdRegexp = regexp.MustCompile(`^` + ProviderName + `:///([^/]+)$`)
return "", err
}
if parsedID.Scheme != ProviderName {
return "", fmt.Errorf("unrecognized provider %q", parsedID.Scheme)
}
return parsedID.Host, nil matches := providerIdRegexp.FindStringSubmatch(providerID)
if len(matches) != 2 {
return "", fmt.Errorf("ProviderID \"%s\" didn't match expected format \"openstack:///InstanceID\"", providerID)
}
return matches[1], nil
} }

9
pkg/cloudprovider/providers/openstack/openstack_test.go
View File

@ -557,17 +557,22 @@ func TestInstanceIDFromProviderID(t *testing.T) {
fail bool fail bool
}{ }{
{ {
providerID: "openstack://7b9cf879-7146-417c-abfd-cb4272f0c935", providerID: ProviderName + "://" + "/" + "7b9cf879-7146-417c-abfd-cb4272f0c935",
instanceID: "7b9cf879-7146-417c-abfd-cb4272f0c935", instanceID: "7b9cf879-7146-417c-abfd-cb4272f0c935",
fail: false, fail: false,
}, },
{
providerID: "openstack://7b9cf879-7146-417c-abfd-cb4272f0c935",
instanceID: "",
fail: true,
},
{ {
providerID: "7b9cf879-7146-417c-abfd-cb4272f0c935", providerID: "7b9cf879-7146-417c-abfd-cb4272f0c935",
instanceID: "", instanceID: "",
fail: true, fail: true,
}, },
{ {
providerID: "other-provider://7b9cf879-7146-417c-abfd-cb4272f0c935", providerID: "other-provider:///7b9cf879-7146-417c-abfd-cb4272f0c935",
instanceID: "", instanceID: "",
fail: true, fail: true,
}, },