Update gRPC after changes in FIT

Change-Id: Id88a63e671aee616b5e1426fa6d5443a3f7d4fcb
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/181672
Tested-by: <[email protected]>
Reviewed-by: Sergey Avseyev <[email protected]>
Reviewed-by: Graham Pople <[email protected]>

Author: Couch-Matt

java-fit-performer/src/main/java/com/couchbase/PerformerService.java

@@ -359,7 +359,7 @@ public void clientRecordProcess(ClientRecordProcessRequest request,
             ClientRecordProcessResponse.Builder response = ClientRecordProcessResponse.newBuilder();
 
             try {
-                ClientRecordDetails result = cr.processClient(request.getClientUUID(),
+                ClientRecordDetails result = cr.processClient(request.getClientUuid(),
                                 collection,
                                 config,
                                 null)
@@ -375,7 +375,7 @@ public void clientRecordProcess(ClientRecordProcessRequest request,
                         .setOverrideEnabled(result.overrideEnabled())
                         .setOverrideExpires(result.overrideExpires())
                         .setCasNowNanos(result.casNow())
-                        .setClientUUID(request.getClientUUID())
+                        .setClientUuid(request.getClientUuid())
                         .build();
             }
             catch (RuntimeException err) {

java-fit-performer/src/main/java/com/couchbase/twoway/TwoWayTransactionBlocking.java

@@ -149,10 +149,10 @@ private void performOperation(ClusterConnection connection,
                                   TransactionCommand op,
                                   @Nullable StreamObserver<TransactionStreamPerformerToDriver> toTest,
                                   boolean performanceMode) {
-        if (op.getWaitMSecs() != 0) {
+        if (op.getWaitMsecs() != 0) {
             try {
-                logger.info("Sleeping for Msecs: "+op.getWaitMSecs());
-                Thread.sleep(op.getWaitMSecs());
+                logger.info("Sleeping for Msecs: "+op.getWaitMsecs());
+                Thread.sleep(op.getWaitMsecs());
             } catch (InterruptedException e) {
                 throw new InternalPerformerFailure(new RuntimeException(e));
             }
@@ -318,26 +318,26 @@ private void performOperation(ClusterConnection connection,
             performCommandBatch(request, (parallelOp) -> Mono.fromRunnable(() -> {
                 performOperation(connection, ctx, parallelOp, toTest, performanceMode);
             }).then()).block();
-        } else if (op.hasInsertRegularKV()) {
-            final CommandInsertRegularKV request = op.getInsertRegularKV();
+        } else if (op.hasInsertRegularKv()) {
+            final CommandInsertRegularKV request = op.getInsertRegularKv();
             final Collection collection = connection.collection(request.getDocId());
 
             performOperation("KV insert " + request.getDocId().getDocId(), ctx, Collections.singletonList(EXPECT_SUCCESS), op.getDoNotPropagateError(), performanceMode,
                     () -> {
                         JsonObject content = JsonObject.fromJson(request.getContentJson());
                         collection.insert(request.getDocId().getDocId(), content);
                     });
-        } else if (op.hasReplaceRegularKV()) {
-            final CommandReplaceRegularKV request = op.getReplaceRegularKV();
+        } else if (op.hasReplaceRegularKv()) {
+            final CommandReplaceRegularKV request = op.getReplaceRegularKv();
             final Collection collection = connection.collection(request.getDocId());
 
             performOperation("KV replace " + request.getDocId().getDocId(), ctx, Collections.singletonList(EXPECT_SUCCESS), op.getDoNotPropagateError(), performanceMode,
                     () -> {
                         JsonObject content = JsonObject.fromJson(request.getContentJson());
                         collection.replace(request.getDocId().getDocId(), content);
                     });
-        } else if (op.hasRemoveRegularKV()) {
-            final CommandRemoveRegularKV request = op.getRemoveRegularKV();
+        } else if (op.hasRemoveRegularKv()) {
+            final CommandRemoveRegularKV request = op.getRemoveRegularKv();
             final Collection collection = connection.collection(request.getDocId());
 
             performOperation("KV remove " + request.getDocId().getDocId(), ctx, Collections.singletonList(EXPECT_SUCCESS), op.getDoNotPropagateError(), performanceMode,

java-fit-performer/src/main/java/com/couchbase/twoway/TwoWayTransactionReactive.java

@@ -135,8 +135,8 @@ private Mono<?> performOperation(ClusterConnection connection,
                                   TransactionCommand op,
                                   @Nullable StreamObserver<TransactionStreamPerformerToDriver> toTest,
                                   boolean performanceMode) {
-        Mono<Void> waitIfNeeded = op.getWaitMSecs() == 0 ? Mono.empty()
-                : Mono.delay(Duration.ofMillis(op.getWaitMSecs())).then();
+        Mono<Void> waitIfNeeded = op.getWaitMsecs() == 0 ? Mono.empty()
+                : Mono.delay(Duration.ofMillis(op.getWaitMsecs())).then();
 
         if (op.hasInsert()) {
             final CommandInsert request = op.getInsert();
@@ -242,26 +242,26 @@ private Mono<?> performOperation(ClusterConnection connection,
             final CommandBatch request = op.getParallelize();
 
             return waitIfNeeded.then(performCommandBatch(request, (parallelOp) -> performOperation(connection, ctx, parallelOp, toTest, performanceMode)));
-        } else if (op.hasInsertRegularKV()) {
-            final CommandInsertRegularKV request = op.getInsertRegularKV();
+        } else if (op.hasInsertRegularKv()) {
+            final CommandInsertRegularKV request = op.getInsertRegularKv();
             final Collection collection = connection.collection(request.getDocId());
 
             return performOperation(waitIfNeeded, "KV insert " + request.getDocId().getDocId(), ctx, Collections.singletonList(EXPECT_SUCCESS), op.getDoNotPropagateError(), performanceMode,
                     () -> {
                         JsonObject content = JsonObject.fromJson(request.getContentJson());
                         return collection.reactive().insert(request.getDocId().getDocId(), content).then();
                     });
-        } else if (op.hasReplaceRegularKV()) {
-            final CommandReplaceRegularKV request = op.getReplaceRegularKV();
+        } else if (op.hasReplaceRegularKv()) {
+            final CommandReplaceRegularKV request = op.getReplaceRegularKv();
             final Collection collection = connection.collection(request.getDocId());
 
             return performOperation(waitIfNeeded, "KV replace " + request.getDocId().getDocId(), ctx, Collections.singletonList(EXPECT_SUCCESS), op.getDoNotPropagateError(), performanceMode,
                     () -> {
                         JsonObject content = JsonObject.fromJson(request.getContentJson());
                         return collection.reactive().replace(request.getDocId().getDocId(), content).then();
                     });
-        } else if (op.hasRemoveRegularKV()) {
-            final CommandRemoveRegularKV request = op.getRemoveRegularKV();
+        } else if (op.hasRemoveRegularKv()) {
+            final CommandRemoveRegularKV request = op.getRemoveRegularKv();
             final Collection collection = connection.collection(request.getDocId());
 
             return performOperation(waitIfNeeded, "KV remove " + request.getDocId().getDocId(), ctx, Collections.singletonList(EXPECT_SUCCESS), op.getDoNotPropagateError(), performanceMode,