File tree 3 files changed +3
-7
lines changed
main/java/com/faunadb/client/types
test/java/com/faunadb/client
faunadb-scala/src/test/scala/faunadb
3 files changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -51,12 +51,10 @@ public enum Metrics {
51
51
QUERY_BYTES_IN ("x-query-bytes-in" ),
52
52
QUERY_BYTES_OUT ("x-query-bytes-out" ),
53
53
QUERY_TIME ("x-query-time" ),
54
- READ_OPS ("x-read-ops" ),
55
54
STORAGE_BYTES_READ ("x-storage-bytes-read" ),
56
55
STORAGE_BYTES_WRITE ("x-storage-bytes-write" ),
57
56
TXN_RETRIES ("x-txn-retries" ),
58
- TXN_TIME ("x-txn-time" ),
59
- WRITE_OPS ("x-write-ops" );
57
+ TXN_TIME ("x-txn-time" );
60
58
61
59
private final String metric ;
62
60
Original file line number Diff line number Diff line change @@ -325,12 +325,10 @@ public void shouldReturnMetricsData() throws Exception {
325
325
Optional <String > queryBytesIn = metricsResponse .getMetric (MetricsResponse .Metrics .QUERY_BYTES_IN );
326
326
Optional <String > queryBytesOut = metricsResponse .getMetric (MetricsResponse .Metrics .QUERY_BYTES_OUT );
327
327
Optional <String > queryTime = metricsResponse .getMetric (MetricsResponse .Metrics .QUERY_TIME );
328
- Optional <String > readOps = metricsResponse .getMetric (MetricsResponse .Metrics .READ_OPS );
329
328
Optional <String > storageBytesRead = metricsResponse .getMetric (MetricsResponse .Metrics .STORAGE_BYTES_READ );
330
329
Optional <String > storageBytesWrite = metricsResponse .getMetric (MetricsResponse .Metrics .STORAGE_BYTES_WRITE );
331
330
Optional <String > txnRetries = metricsResponse .getMetric (MetricsResponse .Metrics .TXN_RETRIES );
332
331
Optional <String > txnTime = metricsResponse .getMetric (MetricsResponse .Metrics .TXN_TIME );
333
- Optional <String > writeOps = metricsResponse .getMetric (MetricsResponse .Metrics .WRITE_OPS );
334
332
335
333
assertThat (byteReadOps .isPresent (), is (true ));
336
334
assertThat (byteWriteOps .isPresent (), is (true ));
@@ -3171,7 +3169,7 @@ public void streamFailsIfTargetDoesNotExist() throws Exception {
3171
3169
@ Test
3172
3170
public void streamFailsIfQueryIsNotReadOnly () throws Exception {
3173
3171
thrown .expectCause (isA (BadRequestException .class ));
3174
- thrown .expectMessage (containsString ("invalid expression: Write effect in read-only query expression ." ));
3172
+ thrown .expectMessage (containsString ("invalid expression: Call performs a write, which is not allowed in stream requests ." ));
3175
3173
3176
3174
adminClient .stream (CreateCollection (Collection ("spells" ))).get ();
3177
3175
}
Original file line number Diff line number Diff line change @@ -2163,7 +2163,7 @@ class ClientSpec
2163
2163
it should " stream return error if the query is not readonly" in {
2164
2164
val err = client.stream(Create (Collection (" spells" ), Obj (" data" -> Obj (" testField" -> " testValue0" )))).failed.futureValue
2165
2165
err shouldBe a[BadRequestException ]
2166
- err.getMessage should include(" Write effect in read-only query expression ." )
2166
+ err.getMessage should include(" Call performs a write, which is not allowed in stream requests ." )
2167
2167
}
2168
2168
2169
2169
it should " stream on document reference contains `document` field by default" in {
You can’t perform that action at this time.
0 commit comments