mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-06 11:42:14 +00:00
fix
This commit is contained in:
@@ -124,7 +124,7 @@ for version in "${kube_api_versions[@]}"; do
|
|||||||
-s "http://127.0.0.1:${API_PORT}"
|
-s "http://127.0.0.1:${API_PORT}"
|
||||||
--match-server-version
|
--match-server-version
|
||||||
)
|
)
|
||||||
[ "$(kubectl get nodes -t '{{ .apiVersion }}' "${kube_flags[@]}")" == "v1beta3" ]
|
[ "$(kubectl get nodes -t '{{ .apiVersion }}' "${kube_flags[@]}")" == "v1" ]
|
||||||
else
|
else
|
||||||
kube_flags=(
|
kube_flags=(
|
||||||
-s "http://127.0.0.1:${API_PORT}"
|
-s "http://127.0.0.1:${API_PORT}"
|
||||||
|
@@ -672,7 +672,7 @@ func TestUpdateWithRetries(t *testing.T) {
|
|||||||
Codec: codec,
|
Codec: codec,
|
||||||
Client: client.HTTPClientFunc(func(req *http.Request) (*http.Response, error) {
|
Client: client.HTTPClientFunc(func(req *http.Request) (*http.Response, error) {
|
||||||
switch p, m := req.URL.Path, req.Method; {
|
switch p, m := req.URL.Path, req.Method; {
|
||||||
case p == "/api/"+latest.Version+"/namespaces/default/replicationcontrollers/rc" && m == "PUT":
|
case p == testapi.ResourcePath("replicationcontrollers", "default", "rc") && m == "PUT":
|
||||||
update := updates[0]
|
update := updates[0]
|
||||||
updates = updates[1:]
|
updates = updates[1:]
|
||||||
// We should always get an update with a valid rc even when the get fails. The rc should always
|
// We should always get an update with a valid rc even when the get fails. The rc should always
|
||||||
@@ -685,7 +685,7 @@ func TestUpdateWithRetries(t *testing.T) {
|
|||||||
delete(c.Spec.Selector, "baz")
|
delete(c.Spec.Selector, "baz")
|
||||||
}
|
}
|
||||||
return update, nil
|
return update, nil
|
||||||
case p == "/api/"+latest.Version+"/namespaces/default/replicationcontrollers/rc" && m == "GET":
|
case p == testapi.ResourcePath("replicationcontrollers", "default", "rc") && m == "GET":
|
||||||
get := gets[0]
|
get := gets[0]
|
||||||
gets = gets[1:]
|
gets = gets[1:]
|
||||||
return get, nil
|
return get, nil
|
||||||
@@ -695,7 +695,7 @@ func TestUpdateWithRetries(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}),
|
}),
|
||||||
}
|
}
|
||||||
clientConfig := &client.Config{Version: latest.Version}
|
clientConfig := &client.Config{Version: testapi.Version()}
|
||||||
client := client.NewOrDie(clientConfig)
|
client := client.NewOrDie(clientConfig)
|
||||||
client.Client = fakeClient.Client
|
client.Client = fakeClient.Client
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user