Test that data is queryable across restarts
parent
b12bae0fb8
commit
cc46d0225e
|
@ -1170,6 +1170,8 @@ func TestHandler_serveWriteSeriesNonZeroTime(t *testing.T) {
|
|||
}
|
||||
time.Sleep(100 * time.Millisecond) // Ensure data node picks up write.
|
||||
|
||||
srvr.Restart() // Ensure data is queryable across restarts.
|
||||
|
||||
query := map[string]string{"db": "foo", "q": "select value from cpu"}
|
||||
status, body := MustHTTP("GET", s.URL+`/query`, query, nil, "")
|
||||
if status != http.StatusOK {
|
||||
|
@ -1212,6 +1214,8 @@ func TestHandler_serveWriteSeriesZeroTime(t *testing.T) {
|
|||
}
|
||||
time.Sleep(100 * time.Millisecond) // Ensure data node picks up write.
|
||||
|
||||
srvr.Restart() // Ensure data is queryable across restarts.
|
||||
|
||||
query := map[string]string{"db": "foo", "q": "select value from cpu"}
|
||||
status, body := MustHTTP("GET", s.URL+`/query`, query, nil, "")
|
||||
|
||||
|
@ -1260,6 +1264,8 @@ func TestHandler_serveWriteSeriesStringValues(t *testing.T) {
|
|||
}
|
||||
time.Sleep(100 * time.Millisecond) // Ensure data node picks up write.
|
||||
|
||||
srvr.Restart() // Ensure data is queryable across restarts.
|
||||
|
||||
query := map[string]string{"db": "foo", "q": "select event from logs"}
|
||||
status, body := MustHTTP("GET", s.URL+`/query`, query, nil, "")
|
||||
if status != http.StatusOK {
|
||||
|
@ -1301,6 +1307,8 @@ func TestHandler_serveWriteSeriesBoolValues(t *testing.T) {
|
|||
}
|
||||
time.Sleep(100 * time.Millisecond) // Ensure data node picks up write.
|
||||
|
||||
srvr.Restart() // Ensure data is queryable across restarts.
|
||||
|
||||
query := map[string]string{"db": "foo", "q": "select full from disk"}
|
||||
status, body := MustHTTP("GET", s.URL+`/query`, query, nil, "")
|
||||
if status != http.StatusOK {
|
||||
|
|
Loading…
Reference in New Issue