Remove InfluxDB path prefix test
This tests a feature that is not yet on this branch and the test was mistakenly backported.
This commit is contained in:
parent
588f0c77f8
commit
8011109466
|
@ -299,37 +299,3 @@ func TestGzipCompression(t *testing.T) {
|
||||||
|
|
||||||
assert.Equal(t, []byte(influxLine), uncompressed.Bytes())
|
assert.Equal(t, []byte(influxLine), uncompressed.Bytes())
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestHTTPClient_PathPrefix(t *testing.T) {
|
|
||||||
prefix := "/some/random/prefix"
|
|
||||||
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
switch r.URL.Path {
|
|
||||||
case prefix + "/write":
|
|
||||||
w.WriteHeader(http.StatusNoContent)
|
|
||||||
w.Header().Set("Content-Type", "application/json")
|
|
||||||
case prefix + "/query":
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
w.Header().Set("Content-Type", "application/json")
|
|
||||||
fmt.Fprintln(w, `{"results":[{}]}`)
|
|
||||||
default:
|
|
||||||
w.WriteHeader(http.StatusNotFound)
|
|
||||||
msg := fmt.Sprintf("Path not found: %s", r.URL.Path)
|
|
||||||
fmt.Fprintln(w, msg)
|
|
||||||
}
|
|
||||||
}))
|
|
||||||
defer ts.Close()
|
|
||||||
|
|
||||||
config := HTTPConfig{
|
|
||||||
URL: ts.URL + prefix,
|
|
||||||
}
|
|
||||||
wp := WriteParams{
|
|
||||||
Database: "test",
|
|
||||||
}
|
|
||||||
client, err := NewHTTP(config, wp)
|
|
||||||
defer client.Close()
|
|
||||||
assert.NoError(t, err)
|
|
||||||
err = client.Query("CREATE DATABASE test")
|
|
||||||
assert.NoError(t, err)
|
|
||||||
err = client.WriteStream(bytes.NewReader([]byte("cpu value=99\n")))
|
|
||||||
assert.NoError(t, err)
|
|
||||||
}
|
|
||||||
|
|
Loading…
Reference in New Issue