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

Fix error with variable re-declaration in ES logging test

Browse Source
This commit is contained in:
Satnam Singh 2015-07-09 10:08:18 -07:00
parent 98b5576a99
commit 9c82b4b6c8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/e2e/es_cluster_logging.go
View File

@ -97,9 +97,10 @@ func ClusterLevelLoggingWithElasticsearch(f *Framework) {
var statusCode float64 var statusCode float64
var esResponse map[string]interface{} var esResponse map[string]interface{}
err = nil err = nil
var body []byte
for start := time.Now(); time.Since(start) < graceTime; time.Sleep(5 * time.Second) { for start := time.Now(); time.Since(start) < graceTime; time.Sleep(5 * time.Second) {
// Query against the root URL for Elasticsearch. // Query against the root URL for Elasticsearch.
body, err := f.Client.Get(). body, err = f.Client.Get().
Namespace(api.NamespaceSystem). Namespace(api.NamespaceSystem).
Prefix("proxy"). Prefix("proxy").
Resource("services"). Resource("services").
@ -143,7 +144,6 @@ func ClusterLevelLoggingWithElasticsearch(f *Framework) {
// Now assume we really are talking to an Elasticsearch instance. // Now assume we really are talking to an Elasticsearch instance.
// Check the cluster health. // Check the cluster health.
By("Checking health of Elasticsearch service.") By("Checking health of Elasticsearch service.")
var body []byte
for start := time.Now(); time.Since(start) < graceTime; time.Sleep(5 * time.Second) { for start := time.Now(); time.Since(start) < graceTime; time.Sleep(5 * time.Second) {
body, err = f.Client.Get(). body, err = f.Client.Get().
Namespace(api.NamespaceSystem). Namespace(api.NamespaceSystem).