diff --git a/generation_config.yaml b/generation_config.yaml index e5add8939823..0436082edd91 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,4 +1,4 @@ -googleapis_commitish: 7af3f2c7b8927cffb548fd2cf09b04c6371437ee +googleapis_commitish: db88feb4756963c6aa9b5996a880cfe5572d0320 libraries_bom_version: 26.83.0 is_monorepo: true libraries: diff --git a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequest.java b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequest.java index 02453f332248..1c2296ab5e68 100644 --- a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequest.java +++ b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequest.java @@ -398,7 +398,7 @@ public com.google.chat.v1.MessageOrBuilder getMessageOrBuilder() { * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @return The threadKey. */ @java.lang.Override @@ -432,7 +432,7 @@ public java.lang.String getThreadKey() { * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @return The bytes for threadKey. */ @java.lang.Override @@ -1543,7 +1543,7 @@ public com.google.chat.v1.MessageOrBuilder getMessageOrBuilder() { * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @return The threadKey. */ @java.lang.Deprecated @@ -1576,7 +1576,7 @@ public java.lang.String getThreadKey() { * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @return The bytes for threadKey. */ @java.lang.Deprecated @@ -1609,7 +1609,7 @@ public com.google.protobuf.ByteString getThreadKeyBytes() { * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @param value The threadKey to set. * @return This builder for chaining. */ @@ -1641,7 +1641,7 @@ public Builder setThreadKey(java.lang.String value) { * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @return This builder for chaining. */ @java.lang.Deprecated @@ -1669,7 +1669,7 @@ public Builder clearThreadKey() { * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @param value The bytes for threadKey to set. * @return This builder for chaining. */ diff --git a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequestOrBuilder.java b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequestOrBuilder.java index c55c22a111de..9c7ff66eb7e2 100644 --- a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequestOrBuilder.java +++ b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/CreateMessageRequestOrBuilder.java @@ -114,7 +114,7 @@ public interface CreateMessageRequestOrBuilder * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @return The threadKey. */ @java.lang.Deprecated @@ -137,7 +137,7 @@ public interface CreateMessageRequestOrBuilder * * * @deprecated google.chat.v1.CreateMessageRequest.thread_key is deprecated. See - * google/chat/v1/message.proto;l=617 + * google/chat/v1/message.proto;l=618 * @return The bytes for threadKey. */ @java.lang.Deprecated diff --git a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/MessageProto.java b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/MessageProto.java index 420790588d9d..56550ff3f86f 100644 --- a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/MessageProto.java +++ b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/MessageProto.java @@ -186,7 +186,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + " \003(\0132\037.google.chat.v1.AccessoryWidgetB\003\340A\001:C\352A@\n" + "\033chat.googleapis.com/Message\022!spaces/{space}/messages/{message}\"\037\n" + "\013AttachedGif\022\020\n" - + "\003uri\030\001 \001(\tB\003\340A\003\"\230\004\n" + + "\003uri\030\001 \001(\tB\003\340A\003\"\245\004\n" + "\025QuotedMessageMetadata\0221\n" + "\004name\030\001 \001(\tB#\340A\002\372A\035\n" + "\033chat.googleapis.com/Message\0229\n" @@ -197,12 +197,13 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\027quoted_message_snapshot\030\005" + " \001(\0132%.google.chat.v1.QuotedMessageSnapshotB\003\340A\003\022B\n" + "\022forwarded_metadata\030\006 \001(\0132!" - + ".google.chat.v1.ForwardedMetadataB\003\340A\003\"2\n" + + ".google.chat.v1.ForwardedMetadataB\003\340A\003\"?\n" + "\tQuoteType\022\032\n" + "\026QUOTE_TYPE_UNSPECIFIED\020\000\022\t\n" - + "\005REPLY\020\001:\201\001\352A~\n" - + ")chat.googleapis.com/QuotedMessageMetadata\022Qspaces/{space}/mess" - + "ages/{message}/quotedMessageMetadata/{quoted_message_metadata}\"\310\001\n" + + "\005REPLY\020\001\022\013\n" + + "\007FORWARD\020\002:\201\001\352A~\n" + + ")chat.googleapis.com/QuotedMessageMetadata\022Qspaces" + + "/{space}/messages/{message}/quotedMessageMetadata/{quoted_message_metadata}\"\310\001\n" + "\025QuotedMessageSnapshot\022\023\n" + "\006sender\030\001 \001(\tB\003\340A\003\022\021\n" + "\004text\030\002 \001(\tB\003\340A\003\022\033\n" @@ -218,15 +219,15 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "thread_key\030\003 \001(\tB\003\340A\001:@\352A=\n" + "\032chat.googleapis.com/Thread\022\037spaces/{space}/threads/{thread}\"\322\004\n" + "\016ActionResponse\022>\n" - + "\004type\030\001 \001" - + "(\0162+.google.chat.v1.ActionResponse.ResponseTypeB\003\340A\004\022\020\n" + + "\004type\030\001" + + " \001(\0162+.google.chat.v1.ActionResponse.ResponseTypeB\003\340A\004\022\020\n" + "\003url\030\002 \001(\tB\003\340A\004\0228\n\r" + "dialog_action\030\003 \001(\0132\034.google.chat.v1.DialogActionB\003\340A\004\022I\n" - + "\016updated_widget\030\004 \001(\0132,.googl" - + "e.chat.v1.ActionResponse.UpdatedWidgetB\003\340A\004\032R\n" + + "\016updated_widget\030\004" + + " \001(\0132,.google.chat.v1.ActionResponse.UpdatedWidgetB\003\340A\004\032R\n" + "\016SelectionItems\022@\n" - + "\005items\030\001 \003(\01321.g" - + "oogle.apps.card.v1.SelectionInput.SelectionItem\032w\n\r" + + "\005items\030\001" + + " \003(\01321.google.apps.card.v1.SelectionInput.SelectionItem\032w\n\r" + "UpdatedWidget\022D\n" + "\013suggestions\030\001" + " \001(\0132-.google.chat.v1.ActionResponse.SelectionItemsH\000\022\016\n" @@ -253,7 +254,8 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\024UpdateMessageRequest\022-\n" + "\007message\030\001 \001(\0132\027.google.chat.v1.MessageB\003\340A\002\0224\n" + "\013update_mask\030\002" - + " \001(\0132\032.google.protobuf.FieldMaskB\003\340A\002\022\032\n\r" + + " \001(\0132\032.google.protobuf.FieldMaskB\003\340A\002\022\032\n" + + "\r" + "allow_missing\030\004 \001(\010B\003\340A\001\"\210\004\n" + "\024CreateMessageRequest\0223\n" + "\006parent\030\001 \001(" @@ -261,8 +263,8 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\007message\030\004 \001(\0132\027.google.chat.v1.MessageB\003\340A\002\022\031\n\n" + "thread_key\030\006 \001(\tB\005\030\001\340A\001\022\027\n\n" + "request_id\030\007 \001(\tB\003\340A\001\022Z\n" - + "\024message_reply_option\030\010 \001(\01627.google.chat.v1.Cre" - + "ateMessageRequest.MessageReplyOptionB\003\340A\001\022\027\n\n" + + "\024message_reply_option\030\010 \001(\01627.googl" + + "e.chat.v1.CreateMessageRequest.MessageReplyOptionB\003\340A\001\022\027\n\n" + "message_id\030\t \001(\tB\003\340A\001\022b\n" + "#create_message_notification_options\030\n" + " \001(\01320.google.chat.v1.CreateMessageNotificationOptionsB\003\340A\001\"\177\n" @@ -271,8 +273,8 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "$REPLY_MESSAGE_FALLBACK_TO_NEW_THREAD\020\001\022\031\n" + "\025REPLY_MESSAGE_OR_FAIL\020\002\"\362\001\n" + " CreateMessageNotificationOptions\022\\\n" - + "\021notification_type\030\001 \001(\0162" - + "A.google.chat.v1.CreateMessageNotificationOptions.NotificationType\"p\n" + + "\021notification_type\030\001 \001(\0162A.google.chat.v1.CreateMess" + + "ageNotificationOptions.NotificationType\"p\n" + "\020NotificationType\022\032\n" + "\026NOTIFICATION_TYPE_NONE\020\000\022\"\n" + "\036NOTIFICATION_TYPE_FORCE_NOTIFY\020\002\022\034\n" @@ -297,10 +299,10 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "CardWithId\022\017\n" + "\007card_id\030\001 \001(\t\022\'\n" + "\004card\030\002 \001(\0132\031.google.apps.card.v1.CardB\245\001\n" - + "\022com.google.chat.v1B\014MessageProtoP\001Z,cloud.google.com/go/chat/apiv1" - + "/chatpb;chatpb\242\002\013DYNAPIProto\252\002\023Google.Ap" - + "ps.Chat.V1\312\002\023Google\\Apps\\Chat\\V1\352\002\026Googl" - + "e::Apps::Chat::V1b\006proto3" + + "\022com.google.chat.v1B\014MessageProtoP\001Z,cloud.google.com/" + + "go/chat/apiv1/chatpb;chatpb\242\002\013DYNAPIProt" + + "o\252\002\023Google.Apps.Chat.V1\312\002\023Google\\Apps\\Ch" + + "at\\V1\352\002\026Google::Apps::Chat::V1b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( diff --git a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/QuotedMessageMetadata.java b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/QuotedMessageMetadata.java index 9377b036a1bc..245b7d32f8de 100644 --- a/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/QuotedMessageMetadata.java +++ b/java-chat/proto-google-cloud-chat-v1/src/main/java/com/google/chat/v1/QuotedMessageMetadata.java @@ -26,10 +26,6 @@ *
* Information about a message that another message quotes.
*
- * When you create a message, you can quote messages within the same
- * thread, or quote a root message to create a new root message.
- * However, you can't quote a message reply from a different thread.
- *
* When you update a message, you can't add or replace the
* `quotedMessageMetadata` field, but you can remove it.
*
@@ -105,20 +101,32 @@ public enum QuoteType implements com.google.protobuf.ProtocolMessageEnum {
*
*
*
- * If quote_type is `REPLY`, you can do the following:
+ * When `quote_type` is `REPLY`, you can do the following:
*
* * If you're replying in a thread, you can quote another message in that
* thread.
*
* * If you're creating a root message, you can quote another root message
* in that space.
- *
- * You can't quote a message reply from a different thread.
*
*
* REPLY = 1;
*/
REPLY(1),
+ /**
+ *
+ *
+ *
+ * When `quote_type` is `FORWARD`, you can quote a:
+ *
+ * * Message from a different space.
+ *
+ * * Message reply from a different thread in the same space.
+ *
+ *
+ * FORWARD = 2;
+ */
+ FORWARD(2),
UNRECOGNIZED(-1),
;
@@ -147,21 +155,34 @@ public enum QuoteType implements com.google.protobuf.ProtocolMessageEnum {
*
*
*
- * If quote_type is `REPLY`, you can do the following:
+ * When `quote_type` is `REPLY`, you can do the following:
*
* * If you're replying in a thread, you can quote another message in that
* thread.
*
* * If you're creating a root message, you can quote another root message
* in that space.
- *
- * You can't quote a message reply from a different thread.
*
*
* REPLY = 1;
*/
public static final int REPLY_VALUE = 1;
+ /**
+ *
+ *
+ *
+ * When `quote_type` is `FORWARD`, you can quote a:
+ *
+ * * Message from a different space.
+ *
+ * * Message reply from a different thread in the same space.
+ *
+ *
+ * FORWARD = 2;
+ */
+ public static final int FORWARD_VALUE = 2;
+
public final int getNumber() {
if (this == UNRECOGNIZED) {
throw new java.lang.IllegalArgumentException(
@@ -190,6 +211,8 @@ public static QuoteType forNumber(int value) {
return QUOTE_TYPE_UNSPECIFIED;
case 1:
return REPLY;
+ case 2:
+ return FORWARD;
default:
return null;
}
@@ -770,10 +793,6 @@ protected Builder newBuilderForType(com.google.protobuf.GeneratedMessage.Builder
*
* Information about a message that another message quotes.
*
- * When you create a message, you can quote messages within the same
- * thread, or quote a root message to create a new root message.
- * However, you can't quote a message reply from a different thread.
- *
* When you update a message, you can't add or replace the
* `quotedMessageMetadata` field, but you can remove it.
*
diff --git a/java-chat/proto-google-cloud-chat-v1/src/main/proto/google/chat/v1/message.proto b/java-chat/proto-google-cloud-chat-v1/src/main/proto/google/chat/v1/message.proto
index 52a4d6f711a6..ed78f5e50c99 100644
--- a/java-chat/proto-google-cloud-chat-v1/src/main/proto/google/chat/v1/message.proto
+++ b/java-chat/proto-google-cloud-chat-v1/src/main/proto/google/chat/v1/message.proto
@@ -281,10 +281,6 @@ message AttachedGif {
// Information about a message that another message quotes.
//
-// When you create a message, you can quote messages within the same
-// thread, or quote a root message to create a new root message.
-// However, you can't quote a message reply from a different thread.
-//
// When you update a message, you can't add or replace the
// `quotedMessageMetadata` field, but you can remove it.
//
@@ -301,16 +297,21 @@ message QuotedMessageMetadata {
// Reserved. This value is unused.
QUOTE_TYPE_UNSPECIFIED = 0;
- // If quote_type is `REPLY`, you can do the following:
+ // When `quote_type` is `REPLY`, you can do the following:
//
// * If you're replying in a thread, you can quote another message in that
// thread.
//
// * If you're creating a root message, you can quote another root message
// in that space.
- //
- // You can't quote a message reply from a different thread.
REPLY = 1;
+
+ // When `quote_type` is `FORWARD`, you can quote a:
+ //
+ // * Message from a different space.
+ //
+ // * Message reply from a different thread in the same space.
+ FORWARD = 2;
}
// Required. Resource name of the message that is quoted.
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceClient.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceClient.java
index 44958a7c197f..a85a0bb8a1e5 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceClient.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceClient.java
@@ -141,6 +141,20 @@
*
*
*
+ *
+ * VerifyReferenceList
+ * VerifyReferenceList validates list content and returns line errors, if any.
+ *
+ * Request object method variants only take one parameter, a request object, which must be constructed before the call.
+ *
+ * verifyReferenceList(VerifyReferenceListRequest request)
+ *
+ * Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.
+ *
+ * verifyReferenceListCallable()
+ *
+ *
+ *
*
*
* See the individual methods for example code.
@@ -800,6 +814,70 @@ public final ReferenceList updateReferenceList(UpdateReferenceListRequest reques
return stub.updateReferenceListCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * VerifyReferenceList validates list content and returns line errors, if any.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (ReferenceListServiceClient referenceListServiceClient =
+ * ReferenceListServiceClient.create()) {
+ * VerifyReferenceListRequest request =
+ * VerifyReferenceListRequest.newBuilder()
+ * .setInstance(InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString())
+ * .setSyntaxType(ReferenceListSyntaxType.forNumber(0))
+ * .addAllEntries(new ArrayList())
+ * .build();
+ * VerifyReferenceListResponse response =
+ * referenceListServiceClient.verifyReferenceList(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final VerifyReferenceListResponse verifyReferenceList(VerifyReferenceListRequest request) {
+ return verifyReferenceListCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * VerifyReferenceList validates list content and returns line errors, if any.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (ReferenceListServiceClient referenceListServiceClient =
+ * ReferenceListServiceClient.create()) {
+ * VerifyReferenceListRequest request =
+ * VerifyReferenceListRequest.newBuilder()
+ * .setInstance(InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString())
+ * .setSyntaxType(ReferenceListSyntaxType.forNumber(0))
+ * .addAllEntries(new ArrayList())
+ * .build();
+ * ApiFuture future =
+ * referenceListServiceClient.verifyReferenceListCallable().futureCall(request);
+ * // Do something.
+ * VerifyReferenceListResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ verifyReferenceListCallable() {
+ return stub.verifyReferenceListCallable();
+ }
+
@Override
public final void close() {
stub.close();
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceSettings.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceSettings.java
index 7724d72087d5..900ef1b297ed 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceSettings.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/ReferenceListServiceSettings.java
@@ -113,6 +113,12 @@ public UnaryCallSettings getReferenceLis
return ((ReferenceListServiceStubSettings) getStubSettings()).updateReferenceListSettings();
}
+ /** Returns the object with the settings used for calls to verifyReferenceList. */
+ public UnaryCallSettings
+ verifyReferenceListSettings() {
+ return ((ReferenceListServiceStubSettings) getStubSettings()).verifyReferenceListSettings();
+ }
+
public static final ReferenceListServiceSettings create(ReferenceListServiceStubSettings stub)
throws IOException {
return new ReferenceListServiceSettings.Builder(stub.toBuilder()).build();
@@ -251,6 +257,12 @@ public Builder applyToAllUnaryMethods(
return getStubSettingsBuilder().updateReferenceListSettings();
}
+ /** Returns the builder for the settings used for calls to verifyReferenceList. */
+ public UnaryCallSettings.Builder
+ verifyReferenceListSettings() {
+ return getStubSettingsBuilder().verifyReferenceListSettings();
+ }
+
@Override
public ReferenceListServiceSettings build() throws IOException {
return new ReferenceListServiceSettings(this);
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleExecutionErrorServiceClient.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleExecutionErrorServiceClient.java
new file mode 100644
index 000000000000..5caed1c3ede5
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleExecutionErrorServiceClient.java
@@ -0,0 +1,498 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1;
+
+import com.google.api.core.ApiFuture;
+import com.google.api.core.ApiFutures;
+import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.paging.AbstractFixedSizeCollection;
+import com.google.api.gax.paging.AbstractPage;
+import com.google.api.gax.paging.AbstractPagedListResponse;
+import com.google.api.gax.rpc.PageContext;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.chronicle.v1.stub.RuleExecutionErrorServiceStub;
+import com.google.cloud.chronicle.v1.stub.RuleExecutionErrorServiceStubSettings;
+import com.google.common.util.concurrent.MoreExecutors;
+import java.io.IOException;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Service Description: RuleExecutionErrorService contains endpoints related to rule execution
+ * errors.
+ *
+ * This class provides the ability to make remote calls to the backing service through method
+ * calls that map to API methods. Sample code to get started:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create()) {
+ * InstanceName parent = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
+ * for (RuleExecutionError element :
+ * ruleExecutionErrorServiceClient.listRuleExecutionErrors(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * Note: close() needs to be called on the RuleExecutionErrorServiceClient object to clean up
+ * resources such as threads. In the example above, try-with-resources is used, which automatically
+ * calls close().
+ *
+ *
+ * Methods
+ *
+ * Method
+ * Description
+ * Method Variants
+ *
+ *
+ * ListRuleExecutionErrors
+ * Lists rule execution errors.
+ *
+ * Request object method variants only take one parameter, a request object, which must be constructed before the call.
+ *
+ * listRuleExecutionErrors(ListRuleExecutionErrorsRequest request)
+ *
+ * "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.
+ *
+ * listRuleExecutionErrors(InstanceName parent)
+ *
listRuleExecutionErrors(String parent)
+ *
+ * Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.
+ *
+ * listRuleExecutionErrorsPagedCallable()
+ *
listRuleExecutionErrorsCallable()
+ *
+ *
+ *
+ *
+ *
+ * See the individual methods for example code.
+ *
+ *
Many parameters require resource names to be formatted in a particular way. To assist with
+ * these names, this class includes a format method for each type of name, and additionally a parse
+ * method to extract the individual identifiers contained within names that are returned.
+ *
+ *
This class can be customized by passing in a custom instance of
+ * RuleExecutionErrorServiceSettings to create(). For example:
+ *
+ *
To customize credentials:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * RuleExecutionErrorServiceSettings ruleExecutionErrorServiceSettings =
+ * RuleExecutionErrorServiceSettings.newBuilder()
+ * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
+ * .build();
+ * RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create(ruleExecutionErrorServiceSettings);
+ * }
+ *
+ * To customize the endpoint:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * RuleExecutionErrorServiceSettings ruleExecutionErrorServiceSettings =
+ * RuleExecutionErrorServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
+ * RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create(ruleExecutionErrorServiceSettings);
+ * }
+ *
+ * To use REST (HTTP1.1/JSON) transport (instead of gRPC) for sending and receiving requests over
+ * the wire:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * RuleExecutionErrorServiceSettings ruleExecutionErrorServiceSettings =
+ * RuleExecutionErrorServiceSettings.newHttpJsonBuilder().build();
+ * RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create(ruleExecutionErrorServiceSettings);
+ * }
+ *
+ * Please refer to the GitHub repository's samples for more quickstart code snippets.
+ */
+@Generated("by gapic-generator-java")
+public class RuleExecutionErrorServiceClient implements BackgroundResource {
+ private final RuleExecutionErrorServiceSettings settings;
+ private final RuleExecutionErrorServiceStub stub;
+
+ /** Constructs an instance of RuleExecutionErrorServiceClient with default settings. */
+ public static final RuleExecutionErrorServiceClient create() throws IOException {
+ return create(RuleExecutionErrorServiceSettings.newBuilder().build());
+ }
+
+ /**
+ * Constructs an instance of RuleExecutionErrorServiceClient, using the given settings. The
+ * channels are created based on the settings passed in, or defaults for any settings that are not
+ * set.
+ */
+ public static final RuleExecutionErrorServiceClient create(
+ RuleExecutionErrorServiceSettings settings) throws IOException {
+ return new RuleExecutionErrorServiceClient(settings);
+ }
+
+ /**
+ * Constructs an instance of RuleExecutionErrorServiceClient, using the given stub for making
+ * calls. This is for advanced usage - prefer using create(RuleExecutionErrorServiceSettings).
+ */
+ public static final RuleExecutionErrorServiceClient create(RuleExecutionErrorServiceStub stub) {
+ return new RuleExecutionErrorServiceClient(stub);
+ }
+
+ /**
+ * Constructs an instance of RuleExecutionErrorServiceClient, using the given settings. This is
+ * protected so that it is easy to make a subclass, but otherwise, the static factory methods
+ * should be preferred.
+ */
+ protected RuleExecutionErrorServiceClient(RuleExecutionErrorServiceSettings settings)
+ throws IOException {
+ this.settings = settings;
+ this.stub = ((RuleExecutionErrorServiceStubSettings) settings.getStubSettings()).createStub();
+ }
+
+ protected RuleExecutionErrorServiceClient(RuleExecutionErrorServiceStub stub) {
+ this.settings = null;
+ this.stub = stub;
+ }
+
+ public final RuleExecutionErrorServiceSettings getSettings() {
+ return settings;
+ }
+
+ public RuleExecutionErrorServiceStub getStub() {
+ return stub;
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists rule execution errors.
+ *
+ *
Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create()) {
+ * InstanceName parent = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
+ * for (RuleExecutionError element :
+ * ruleExecutionErrorServiceClient.listRuleExecutionErrors(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The instance to list rule execution errors from. Format:
+ * projects/{project}/locations/{location}/instances/{instance}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListRuleExecutionErrorsPagedResponse listRuleExecutionErrors(InstanceName parent) {
+ ListRuleExecutionErrorsRequest request =
+ ListRuleExecutionErrorsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listRuleExecutionErrors(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists rule execution errors.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create()) {
+ * String parent = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString();
+ * for (RuleExecutionError element :
+ * ruleExecutionErrorServiceClient.listRuleExecutionErrors(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The instance to list rule execution errors from. Format:
+ * projects/{project}/locations/{location}/instances/{instance}
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListRuleExecutionErrorsPagedResponse listRuleExecutionErrors(String parent) {
+ ListRuleExecutionErrorsRequest request =
+ ListRuleExecutionErrorsRequest.newBuilder().setParent(parent).build();
+ return listRuleExecutionErrors(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists rule execution errors.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create()) {
+ * ListRuleExecutionErrorsRequest request =
+ * ListRuleExecutionErrorsRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .build();
+ * for (RuleExecutionError element :
+ * ruleExecutionErrorServiceClient.listRuleExecutionErrors(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListRuleExecutionErrorsPagedResponse listRuleExecutionErrors(
+ ListRuleExecutionErrorsRequest request) {
+ return listRuleExecutionErrorsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists rule execution errors.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create()) {
+ * ListRuleExecutionErrorsRequest request =
+ * ListRuleExecutionErrorsRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .build();
+ * ApiFuture future =
+ * ruleExecutionErrorServiceClient
+ * .listRuleExecutionErrorsPagedCallable()
+ * .futureCall(request);
+ * // Do something.
+ * for (RuleExecutionError element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listRuleExecutionErrorsPagedCallable() {
+ return stub.listRuleExecutionErrorsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists rule execution errors.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create()) {
+ * ListRuleExecutionErrorsRequest request =
+ * ListRuleExecutionErrorsRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .setFilter("filter-1274492040")
+ * .build();
+ * while (true) {
+ * ListRuleExecutionErrorsResponse response =
+ * ruleExecutionErrorServiceClient.listRuleExecutionErrorsCallable().call(request);
+ * for (RuleExecutionError element : response.getRuleExecutionErrorsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listRuleExecutionErrorsCallable() {
+ return stub.listRuleExecutionErrorsCallable();
+ }
+
+ @Override
+ public final void close() {
+ stub.close();
+ }
+
+ @Override
+ public void shutdown() {
+ stub.shutdown();
+ }
+
+ @Override
+ public boolean isShutdown() {
+ return stub.isShutdown();
+ }
+
+ @Override
+ public boolean isTerminated() {
+ return stub.isTerminated();
+ }
+
+ @Override
+ public void shutdownNow() {
+ stub.shutdownNow();
+ }
+
+ @Override
+ public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
+ return stub.awaitTermination(duration, unit);
+ }
+
+ public static class ListRuleExecutionErrorsPagedResponse
+ extends AbstractPagedListResponse<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ RuleExecutionError,
+ ListRuleExecutionErrorsPage,
+ ListRuleExecutionErrorsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext<
+ ListRuleExecutionErrorsRequest, ListRuleExecutionErrorsResponse, RuleExecutionError>
+ context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListRuleExecutionErrorsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListRuleExecutionErrorsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListRuleExecutionErrorsPagedResponse(ListRuleExecutionErrorsPage page) {
+ super(page, ListRuleExecutionErrorsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListRuleExecutionErrorsPage
+ extends AbstractPage<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ RuleExecutionError,
+ ListRuleExecutionErrorsPage> {
+
+ private ListRuleExecutionErrorsPage(
+ PageContext<
+ ListRuleExecutionErrorsRequest, ListRuleExecutionErrorsResponse, RuleExecutionError>
+ context,
+ ListRuleExecutionErrorsResponse response) {
+ super(context, response);
+ }
+
+ private static ListRuleExecutionErrorsPage createEmptyPage() {
+ return new ListRuleExecutionErrorsPage(null, null);
+ }
+
+ @Override
+ protected ListRuleExecutionErrorsPage createPage(
+ PageContext<
+ ListRuleExecutionErrorsRequest, ListRuleExecutionErrorsResponse, RuleExecutionError>
+ context,
+ ListRuleExecutionErrorsResponse response) {
+ return new ListRuleExecutionErrorsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext<
+ ListRuleExecutionErrorsRequest, ListRuleExecutionErrorsResponse, RuleExecutionError>
+ context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListRuleExecutionErrorsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ RuleExecutionError,
+ ListRuleExecutionErrorsPage,
+ ListRuleExecutionErrorsFixedSizeCollection> {
+
+ private ListRuleExecutionErrorsFixedSizeCollection(
+ List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListRuleExecutionErrorsFixedSizeCollection createEmptyCollection() {
+ return new ListRuleExecutionErrorsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListRuleExecutionErrorsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListRuleExecutionErrorsFixedSizeCollection(pages, collectionSize);
+ }
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleExecutionErrorServiceSettings.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleExecutionErrorServiceSettings.java
new file mode 100644
index 000000000000..43fab7ef825a
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleExecutionErrorServiceSettings.java
@@ -0,0 +1,230 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1;
+
+import static com.google.cloud.chronicle.v1.RuleExecutionErrorServiceClient.ListRuleExecutionErrorsPagedResponse;
+
+import com.google.api.core.ApiFunction;
+import com.google.api.core.BetaApi;
+import com.google.api.gax.core.GoogleCredentialsProvider;
+import com.google.api.gax.core.InstantiatingExecutorProvider;
+import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider;
+import com.google.api.gax.httpjson.InstantiatingHttpJsonChannelProvider;
+import com.google.api.gax.rpc.ApiClientHeaderProvider;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.ClientSettings;
+import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.TransportChannelProvider;
+import com.google.api.gax.rpc.UnaryCallSettings;
+import com.google.cloud.chronicle.v1.stub.RuleExecutionErrorServiceStubSettings;
+import java.io.IOException;
+import java.util.List;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Settings class to configure an instance of {@link RuleExecutionErrorServiceClient}.
+ *
+ * The default instance has everything set to sensible defaults:
+ *
+ *
+ * - The default service address (chronicle.googleapis.com) and default port (443) are used.
+ *
- Credentials are acquired automatically through Application Default Credentials.
+ *
- Retries are configured for idempotent methods but not for non-idempotent methods.
+ *
+ *
+ * The builder of this class is recursive, so contained classes are themselves builders. When
+ * build() is called, the tree of builders is called to create the complete settings object.
+ *
+ *
For example, to set the
+ * [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
+ * of listRuleExecutionErrors:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * RuleExecutionErrorServiceSettings.Builder ruleExecutionErrorServiceSettingsBuilder =
+ * RuleExecutionErrorServiceSettings.newBuilder();
+ * ruleExecutionErrorServiceSettingsBuilder
+ * .listRuleExecutionErrorsSettings()
+ * .setRetrySettings(
+ * ruleExecutionErrorServiceSettingsBuilder
+ * .listRuleExecutionErrorsSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setInitialRetryDelayDuration(Duration.ofSeconds(1))
+ * .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
+ * .setMaxAttempts(5)
+ * .setMaxRetryDelayDuration(Duration.ofSeconds(30))
+ * .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
+ * .setRetryDelayMultiplier(1.3)
+ * .setRpcTimeoutMultiplier(1.5)
+ * .setTotalTimeoutDuration(Duration.ofSeconds(300))
+ * .build());
+ * RuleExecutionErrorServiceSettings ruleExecutionErrorServiceSettings =
+ * ruleExecutionErrorServiceSettingsBuilder.build();
+ * }
+ *
+ * Please refer to the [Client Side Retry
+ * Guide](https://docs.cloud.google.com/java/docs/client-retries) for additional support in setting
+ * retries.
+ */
+@Generated("by gapic-generator-java")
+public class RuleExecutionErrorServiceSettings
+ extends ClientSettings {
+
+ /** Returns the object with the settings used for calls to listRuleExecutionErrors. */
+ public PagedCallSettings<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>
+ listRuleExecutionErrorsSettings() {
+ return ((RuleExecutionErrorServiceStubSettings) getStubSettings())
+ .listRuleExecutionErrorsSettings();
+ }
+
+ public static final RuleExecutionErrorServiceSettings create(
+ RuleExecutionErrorServiceStubSettings stub) throws IOException {
+ return new RuleExecutionErrorServiceSettings.Builder(stub.toBuilder()).build();
+ }
+
+ /** Returns a builder for the default ExecutorProvider for this service. */
+ public static InstantiatingExecutorProvider.Builder defaultExecutorProviderBuilder() {
+ return RuleExecutionErrorServiceStubSettings.defaultExecutorProviderBuilder();
+ }
+
+ /** Returns the default service endpoint. */
+ public static String getDefaultEndpoint() {
+ return RuleExecutionErrorServiceStubSettings.getDefaultEndpoint();
+ }
+
+ /** Returns the default service scopes. */
+ public static List getDefaultServiceScopes() {
+ return RuleExecutionErrorServiceStubSettings.getDefaultServiceScopes();
+ }
+
+ /** Returns a builder for the default credentials for this service. */
+ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() {
+ return RuleExecutionErrorServiceStubSettings.defaultCredentialsProviderBuilder();
+ }
+
+ /** Returns a builder for the default gRPC ChannelProvider for this service. */
+ public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
+ return RuleExecutionErrorServiceStubSettings.defaultGrpcTransportProviderBuilder();
+ }
+
+ /** Returns a builder for the default REST ChannelProvider for this service. */
+ @BetaApi
+ public static InstantiatingHttpJsonChannelProvider.Builder
+ defaultHttpJsonTransportProviderBuilder() {
+ return RuleExecutionErrorServiceStubSettings.defaultHttpJsonTransportProviderBuilder();
+ }
+
+ public static TransportChannelProvider defaultTransportChannelProvider() {
+ return RuleExecutionErrorServiceStubSettings.defaultTransportChannelProvider();
+ }
+
+ public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() {
+ return RuleExecutionErrorServiceStubSettings.defaultApiClientHeaderProviderBuilder();
+ }
+
+ /** Returns a new gRPC builder for this class. */
+ public static Builder newBuilder() {
+ return Builder.createDefault();
+ }
+
+ /** Returns a new REST builder for this class. */
+ public static Builder newHttpJsonBuilder() {
+ return Builder.createHttpJsonDefault();
+ }
+
+ /** Returns a new builder for this class. */
+ public static Builder newBuilder(ClientContext clientContext) {
+ return new Builder(clientContext);
+ }
+
+ /** Returns a builder containing all the values of this settings class. */
+ public Builder toBuilder() {
+ return new Builder(this);
+ }
+
+ protected RuleExecutionErrorServiceSettings(Builder settingsBuilder) throws IOException {
+ super(settingsBuilder);
+ }
+
+ /** Builder for RuleExecutionErrorServiceSettings. */
+ public static class Builder
+ extends ClientSettings.Builder {
+
+ protected Builder() throws IOException {
+ this(((ClientContext) null));
+ }
+
+ protected Builder(ClientContext clientContext) {
+ super(RuleExecutionErrorServiceStubSettings.newBuilder(clientContext));
+ }
+
+ protected Builder(RuleExecutionErrorServiceSettings settings) {
+ super(settings.getStubSettings().toBuilder());
+ }
+
+ protected Builder(RuleExecutionErrorServiceStubSettings.Builder stubSettings) {
+ super(stubSettings);
+ }
+
+ private static Builder createDefault() {
+ return new Builder(RuleExecutionErrorServiceStubSettings.newBuilder());
+ }
+
+ private static Builder createHttpJsonDefault() {
+ return new Builder(RuleExecutionErrorServiceStubSettings.newHttpJsonBuilder());
+ }
+
+ public RuleExecutionErrorServiceStubSettings.Builder getStubSettingsBuilder() {
+ return ((RuleExecutionErrorServiceStubSettings.Builder) getStubSettings());
+ }
+
+ /**
+ * Applies the given settings updater function to all of the unary API methods in this service.
+ *
+ * Note: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction, Void> settingsUpdater) {
+ super.applyToAllUnaryMethods(
+ getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
+ return this;
+ }
+
+ /** Returns the builder for the settings used for calls to listRuleExecutionErrors. */
+ public PagedCallSettings.Builder<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>
+ listRuleExecutionErrorsSettings() {
+ return getStubSettingsBuilder().listRuleExecutionErrorsSettings();
+ }
+
+ @Override
+ public RuleExecutionErrorServiceSettings build() throws IOException {
+ return new RuleExecutionErrorServiceSettings(this);
+ }
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceClient.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceClient.java
index 907f02e0393e..457c656ac7ea 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceClient.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceClient.java
@@ -165,6 +165,25 @@
*
*
*
+ * VerifyRuleText
+ * Verifies the given rule text.
+ *
+ * Request object method variants only take one parameter, a request object, which must be constructed before the call.
+ *
+ * verifyRuleText(VerifyRuleTextRequest request)
+ *
+ * "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.
+ *
+ * verifyRuleText(InstanceName instance, String ruleText)
+ *
verifyRuleText(String instance, String ruleText)
+ *
+ * Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.
+ *
+ * verifyRuleTextCallable()
+ *
+ *
+ *
+ *
* ListRuleRevisions
* Lists all revisions of the rule.
*
@@ -1029,6 +1048,130 @@ public final UnaryCallable deleteRuleCallable() {
return stub.deleteRuleCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Verifies the given rule text.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleServiceClient ruleServiceClient = RuleServiceClient.create()) {
+ * InstanceName instance = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
+ * String ruleText = "ruleText763458121";
+ * VerifyRuleTextResponse response = ruleServiceClient.verifyRuleText(instance, ruleText);
+ * }
+ * }
+ *
+ * @param instance Required. The name of the parent resource, which is the SecOps instance
+ * associated with the request. Format:
+ * `projects/{project}/locations/{location}/instances/{instance}`
+ * @param ruleText Required. The rule text to verify as a UTF-8 string.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final VerifyRuleTextResponse verifyRuleText(InstanceName instance, String ruleText) {
+ VerifyRuleTextRequest request =
+ VerifyRuleTextRequest.newBuilder()
+ .setInstance(instance == null ? null : instance.toString())
+ .setRuleText(ruleText)
+ .build();
+ return verifyRuleText(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Verifies the given rule text.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleServiceClient ruleServiceClient = RuleServiceClient.create()) {
+ * String instance = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString();
+ * String ruleText = "ruleText763458121";
+ * VerifyRuleTextResponse response = ruleServiceClient.verifyRuleText(instance, ruleText);
+ * }
+ * }
+ *
+ * @param instance Required. The name of the parent resource, which is the SecOps instance
+ * associated with the request. Format:
+ * `projects/{project}/locations/{location}/instances/{instance}`
+ * @param ruleText Required. The rule text to verify as a UTF-8 string.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final VerifyRuleTextResponse verifyRuleText(String instance, String ruleText) {
+ VerifyRuleTextRequest request =
+ VerifyRuleTextRequest.newBuilder().setInstance(instance).setRuleText(ruleText).build();
+ return verifyRuleText(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Verifies the given rule text.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleServiceClient ruleServiceClient = RuleServiceClient.create()) {
+ * VerifyRuleTextRequest request =
+ * VerifyRuleTextRequest.newBuilder()
+ * .setInstance(InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString())
+ * .setRuleText("ruleText763458121")
+ * .build();
+ * VerifyRuleTextResponse response = ruleServiceClient.verifyRuleText(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final VerifyRuleTextResponse verifyRuleText(VerifyRuleTextRequest request) {
+ return verifyRuleTextCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Verifies the given rule text.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleServiceClient ruleServiceClient = RuleServiceClient.create()) {
+ * VerifyRuleTextRequest request =
+ * VerifyRuleTextRequest.newBuilder()
+ * .setInstance(InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]").toString())
+ * .setRuleText("ruleText763458121")
+ * .build();
+ * ApiFuture future =
+ * ruleServiceClient.verifyRuleTextCallable().futureCall(request);
+ * // Do something.
+ * VerifyRuleTextResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ verifyRuleTextCallable() {
+ return stub.verifyRuleTextCallable();
+ }
+
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Lists all revisions of the rule.
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceSettings.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceSettings.java
index 1b3c90b53412..eeea68c78840 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceSettings.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/RuleServiceSettings.java
@@ -144,6 +144,11 @@ public UnaryCallSettings deleteRuleSettings() {
return ((RuleServiceStubSettings) getStubSettings()).deleteRuleSettings();
}
+ /** Returns the object with the settings used for calls to verifyRuleText. */
+ public UnaryCallSettings verifyRuleTextSettings() {
+ return ((RuleServiceStubSettings) getStubSettings()).verifyRuleTextSettings();
+ }
+
/** Returns the object with the settings used for calls to listRuleRevisions. */
public PagedCallSettings<
ListRuleRevisionsRequest, ListRuleRevisionsResponse, ListRuleRevisionsPagedResponse>
@@ -329,6 +334,12 @@ public UnaryCallSettings.Builder deleteRuleSettings()
return getStubSettingsBuilder().deleteRuleSettings();
}
+ /** Returns the builder for the settings used for calls to verifyRuleText. */
+ public UnaryCallSettings.Builder
+ verifyRuleTextSettings() {
+ return getStubSettingsBuilder().verifyRuleTextSettings();
+ }
+
/** Returns the builder for the settings used for calls to listRuleRevisions. */
public PagedCallSettings.Builder<
ListRuleRevisionsRequest, ListRuleRevisionsResponse, ListRuleRevisionsPagedResponse>
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/gapic_metadata.json b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/gapic_metadata.json
index 86e8723a51eb..e6b7c170b89b 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/gapic_metadata.json
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/gapic_metadata.json
@@ -261,6 +261,9 @@
},
"UpdateReferenceList": {
"methods": ["updateReferenceList", "updateReferenceList", "updateReferenceListCallable"]
+ },
+ "VerifyReferenceList": {
+ "methods": ["verifyReferenceList", "verifyReferenceListCallable"]
}
}
}
@@ -306,6 +309,21 @@
},
"UpdateRuleDeployment": {
"methods": ["updateRuleDeployment", "updateRuleDeployment", "updateRuleDeploymentCallable"]
+ },
+ "VerifyRuleText": {
+ "methods": ["verifyRuleText", "verifyRuleText", "verifyRuleText", "verifyRuleTextCallable"]
+ }
+ }
+ }
+ }
+ },
+ "RuleExecutionErrorService": {
+ "clients": {
+ "grpc": {
+ "libraryClient": "RuleExecutionErrorServiceClient",
+ "rpcs": {
+ "ListRuleExecutionErrors": {
+ "methods": ["listRuleExecutionErrors", "listRuleExecutionErrors", "listRuleExecutionErrors", "listRuleExecutionErrorsPagedCallable", "listRuleExecutionErrorsCallable"]
}
}
}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/package-info.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/package-info.java
index bbf0be59f2e0..0d902ffffd26 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/package-info.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/package-info.java
@@ -241,6 +241,29 @@
* Rule response = ruleServiceClient.createRule(parent, rule);
* }
* }
+ *
+ * ======================= RuleExecutionErrorServiceClient =======================
+ *
+ *
Service Description: RuleExecutionErrorService contains endpoints related to rule execution
+ * errors.
+ *
+ *
Sample for RuleExecutionErrorServiceClient:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (RuleExecutionErrorServiceClient ruleExecutionErrorServiceClient =
+ * RuleExecutionErrorServiceClient.create()) {
+ * InstanceName parent = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
+ * for (RuleExecutionError element :
+ * ruleExecutionErrorServiceClient.listRuleExecutionErrors(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
*/
@Generated("by gapic-generator-java")
package com.google.cloud.chronicle.v1;
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcReferenceListServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcReferenceListServiceStub.java
index 3610b580164b..e74496e6dc55 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcReferenceListServiceStub.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcReferenceListServiceStub.java
@@ -31,6 +31,8 @@
import com.google.cloud.chronicle.v1.ListReferenceListsResponse;
import com.google.cloud.chronicle.v1.ReferenceList;
import com.google.cloud.chronicle.v1.UpdateReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListResponse;
import com.google.longrunning.stub.GrpcOperationsStub;
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
@@ -94,6 +96,19 @@ public class GrpcReferenceListServiceStub extends ReferenceListServiceStub {
.setSampledToLocalTracing(true)
.build();
+ private static final MethodDescriptor
+ verifyReferenceListMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.chronicle.v1.ReferenceListService/VerifyReferenceList")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(VerifyReferenceListRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(VerifyReferenceListResponse.getDefaultInstance()))
+ .setSampledToLocalTracing(true)
+ .build();
+
private final UnaryCallable getReferenceListCallable;
private final UnaryCallable
listReferenceListsCallable;
@@ -103,6 +118,8 @@ public class GrpcReferenceListServiceStub extends ReferenceListServiceStub {
createReferenceListCallable;
private final UnaryCallable
updateReferenceListCallable;
+ private final UnaryCallable
+ verifyReferenceListCallable;
private final BackgroundResource backgroundResources;
private final GrpcOperationsStub operationsStub;
@@ -196,6 +213,18 @@ protected GrpcReferenceListServiceStub(
return builder.build();
})
.build();
+ GrpcCallSettings
+ verifyReferenceListTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(verifyReferenceListMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("instance", String.valueOf(request.getInstance()));
+ return builder.build();
+ })
+ .setResourceNameExtractor(request -> request.getInstance())
+ .build();
this.getReferenceListCallable =
callableFactory.createUnaryCallable(
@@ -220,6 +249,11 @@ protected GrpcReferenceListServiceStub(
updateReferenceListTransportSettings,
settings.updateReferenceListSettings(),
clientContext);
+ this.verifyReferenceListCallable =
+ callableFactory.createUnaryCallable(
+ verifyReferenceListTransportSettings,
+ settings.verifyReferenceListSettings(),
+ clientContext);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
@@ -256,6 +290,12 @@ public UnaryCallable updateReferenceL
return updateReferenceListCallable;
}
+ @Override
+ public UnaryCallable
+ verifyReferenceListCallable() {
+ return verifyReferenceListCallable;
+ }
+
@Override
public final void close() {
try {
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleExecutionErrorServiceCallableFactory.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleExecutionErrorServiceCallableFactory.java
new file mode 100644
index 000000000000..db758d5fc746
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleExecutionErrorServiceCallableFactory.java
@@ -0,0 +1,113 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1.stub;
+
+import com.google.api.gax.grpc.GrpcCallSettings;
+import com.google.api.gax.grpc.GrpcCallableFactory;
+import com.google.api.gax.grpc.GrpcStubCallableFactory;
+import com.google.api.gax.rpc.BatchingCallSettings;
+import com.google.api.gax.rpc.BidiStreamingCallable;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.ClientStreamingCallable;
+import com.google.api.gax.rpc.OperationCallSettings;
+import com.google.api.gax.rpc.OperationCallable;
+import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.ServerStreamingCallSettings;
+import com.google.api.gax.rpc.ServerStreamingCallable;
+import com.google.api.gax.rpc.StreamingCallSettings;
+import com.google.api.gax.rpc.UnaryCallSettings;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.longrunning.Operation;
+import com.google.longrunning.stub.OperationsStub;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * gRPC callable factory implementation for the RuleExecutionErrorService service API.
+ *
+ * This class is for advanced usage.
+ */
+@Generated("by gapic-generator-java")
+public class GrpcRuleExecutionErrorServiceCallableFactory implements GrpcStubCallableFactory {
+
+ @Override
+ public UnaryCallable createUnaryCallable(
+ GrpcCallSettings grpcCallSettings,
+ UnaryCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createUnaryCallable(grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ UnaryCallable createPagedCallable(
+ GrpcCallSettings grpcCallSettings,
+ PagedCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createPagedCallable(grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public UnaryCallable createBatchingCallable(
+ GrpcCallSettings grpcCallSettings,
+ BatchingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createBatchingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ OperationCallable createOperationCallable(
+ GrpcCallSettings grpcCallSettings,
+ OperationCallSettings callSettings,
+ ClientContext clientContext,
+ OperationsStub operationsStub) {
+ return GrpcCallableFactory.createOperationCallable(
+ grpcCallSettings, callSettings, clientContext, operationsStub);
+ }
+
+ @Override
+ public
+ BidiStreamingCallable createBidiStreamingCallable(
+ GrpcCallSettings grpcCallSettings,
+ StreamingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createBidiStreamingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ ServerStreamingCallable createServerStreamingCallable(
+ GrpcCallSettings grpcCallSettings,
+ ServerStreamingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createServerStreamingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ ClientStreamingCallable createClientStreamingCallable(
+ GrpcCallSettings grpcCallSettings,
+ StreamingCallSettings callSettings,
+ ClientContext clientContext) {
+ return GrpcCallableFactory.createClientStreamingCallable(
+ grpcCallSettings, callSettings, clientContext);
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleExecutionErrorServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleExecutionErrorServiceStub.java
new file mode 100644
index 000000000000..ccb6c509834c
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleExecutionErrorServiceStub.java
@@ -0,0 +1,190 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1.stub;
+
+import static com.google.cloud.chronicle.v1.RuleExecutionErrorServiceClient.ListRuleExecutionErrorsPagedResponse;
+
+import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.core.BackgroundResourceAggregation;
+import com.google.api.gax.grpc.GrpcCallSettings;
+import com.google.api.gax.grpc.GrpcStubCallableFactory;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.RequestParamsBuilder;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsRequest;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsResponse;
+import com.google.longrunning.stub.GrpcOperationsStub;
+import io.grpc.MethodDescriptor;
+import io.grpc.protobuf.ProtoUtils;
+import java.io.IOException;
+import java.util.concurrent.TimeUnit;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * gRPC stub implementation for the RuleExecutionErrorService service API.
+ *
+ * This class is for advanced usage and reflects the underlying API directly.
+ */
+@Generated("by gapic-generator-java")
+public class GrpcRuleExecutionErrorServiceStub extends RuleExecutionErrorServiceStub {
+ private static final MethodDescriptor<
+ ListRuleExecutionErrorsRequest, ListRuleExecutionErrorsResponse>
+ listRuleExecutionErrorsMethodDescriptor =
+ MethodDescriptor
+ .newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.chronicle.v1.RuleExecutionErrorService/ListRuleExecutionErrors")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(ListRuleExecutionErrorsRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(ListRuleExecutionErrorsResponse.getDefaultInstance()))
+ .setSampledToLocalTracing(true)
+ .build();
+
+ private final UnaryCallable
+ listRuleExecutionErrorsCallable;
+ private final UnaryCallable
+ listRuleExecutionErrorsPagedCallable;
+
+ private final BackgroundResource backgroundResources;
+ private final GrpcOperationsStub operationsStub;
+ private final GrpcStubCallableFactory callableFactory;
+
+ public static final GrpcRuleExecutionErrorServiceStub create(
+ RuleExecutionErrorServiceStubSettings settings) throws IOException {
+ return new GrpcRuleExecutionErrorServiceStub(settings, ClientContext.create(settings));
+ }
+
+ public static final GrpcRuleExecutionErrorServiceStub create(ClientContext clientContext)
+ throws IOException {
+ return new GrpcRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings.newBuilder().build(), clientContext);
+ }
+
+ public static final GrpcRuleExecutionErrorServiceStub create(
+ ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException {
+ return new GrpcRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings.newBuilder().build(), clientContext, callableFactory);
+ }
+
+ /**
+ * Constructs an instance of GrpcRuleExecutionErrorServiceStub, using the given settings. This is
+ * protected so that it is easy to make a subclass, but otherwise, the static factory methods
+ * should be preferred.
+ */
+ protected GrpcRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings settings, ClientContext clientContext)
+ throws IOException {
+ this(settings, clientContext, new GrpcRuleExecutionErrorServiceCallableFactory());
+ }
+
+ /**
+ * Constructs an instance of GrpcRuleExecutionErrorServiceStub, using the given settings. This is
+ * protected so that it is easy to make a subclass, but otherwise, the static factory methods
+ * should be preferred.
+ */
+ protected GrpcRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings settings,
+ ClientContext clientContext,
+ GrpcStubCallableFactory callableFactory)
+ throws IOException {
+ this.callableFactory = callableFactory;
+ this.operationsStub = GrpcOperationsStub.create(clientContext, callableFactory);
+
+ GrpcCallSettings
+ listRuleExecutionErrorsTransportSettings =
+ GrpcCallSettings
+ .newBuilder()
+ .setMethodDescriptor(listRuleExecutionErrorsMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("parent", String.valueOf(request.getParent()));
+ return builder.build();
+ })
+ .setResourceNameExtractor(request -> request.getParent())
+ .build();
+
+ this.listRuleExecutionErrorsCallable =
+ callableFactory.createUnaryCallable(
+ listRuleExecutionErrorsTransportSettings,
+ settings.listRuleExecutionErrorsSettings(),
+ clientContext);
+ this.listRuleExecutionErrorsPagedCallable =
+ callableFactory.createPagedCallable(
+ listRuleExecutionErrorsTransportSettings,
+ settings.listRuleExecutionErrorsSettings(),
+ clientContext);
+
+ this.backgroundResources =
+ new BackgroundResourceAggregation(clientContext.getBackgroundResources());
+ }
+
+ public GrpcOperationsStub getOperationsStub() {
+ return operationsStub;
+ }
+
+ @Override
+ public UnaryCallable
+ listRuleExecutionErrorsCallable() {
+ return listRuleExecutionErrorsCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listRuleExecutionErrorsPagedCallable() {
+ return listRuleExecutionErrorsPagedCallable;
+ }
+
+ @Override
+ public final void close() {
+ try {
+ backgroundResources.close();
+ } catch (RuntimeException e) {
+ throw e;
+ } catch (Exception e) {
+ throw new IllegalStateException("Failed to close resource", e);
+ }
+ }
+
+ @Override
+ public void shutdown() {
+ backgroundResources.shutdown();
+ }
+
+ @Override
+ public boolean isShutdown() {
+ return backgroundResources.isShutdown();
+ }
+
+ @Override
+ public boolean isTerminated() {
+ return backgroundResources.isTerminated();
+ }
+
+ @Override
+ public void shutdownNow() {
+ backgroundResources.shutdownNow();
+ }
+
+ @Override
+ public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
+ return backgroundResources.awaitTermination(duration, unit);
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleServiceStub.java
index 275ac4466236..eea3a005f9af 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleServiceStub.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/GrpcRuleServiceStub.java
@@ -49,6 +49,8 @@
import com.google.cloud.chronicle.v1.RuleDeployment;
import com.google.cloud.chronicle.v1.UpdateRuleDeploymentRequest;
import com.google.cloud.chronicle.v1.UpdateRuleRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextResponse;
import com.google.longrunning.Operation;
import com.google.longrunning.stub.GrpcOperationsStub;
import com.google.protobuf.Empty;
@@ -112,6 +114,18 @@ public class GrpcRuleServiceStub extends RuleServiceStub {
.setSampledToLocalTracing(true)
.build();
+ private static final MethodDescriptor
+ verifyRuleTextMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.chronicle.v1.RuleService/VerifyRuleText")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(VerifyRuleTextRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(VerifyRuleTextResponse.getDefaultInstance()))
+ .setSampledToLocalTracing(true)
+ .build();
+
private static final MethodDescriptor
listRuleRevisionsMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -197,6 +211,7 @@ public class GrpcRuleServiceStub extends RuleServiceStub {
private final UnaryCallable listRulesPagedCallable;
private final UnaryCallable updateRuleCallable;
private final UnaryCallable deleteRuleCallable;
+ private final UnaryCallable verifyRuleTextCallable;
private final UnaryCallable
listRuleRevisionsCallable;
private final UnaryCallable
@@ -312,6 +327,18 @@ protected GrpcRuleServiceStub(
})
.setResourceNameExtractor(request -> request.getName())
.build();
+ GrpcCallSettings
+ verifyRuleTextTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(verifyRuleTextMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("instance", String.valueOf(request.getInstance()));
+ return builder.build();
+ })
+ .setResourceNameExtractor(request -> request.getInstance())
+ .build();
GrpcCallSettings
listRuleRevisionsTransportSettings =
GrpcCallSettings.newBuilder()
@@ -413,6 +440,9 @@ protected GrpcRuleServiceStub(
this.deleteRuleCallable =
callableFactory.createUnaryCallable(
deleteRuleTransportSettings, settings.deleteRuleSettings(), clientContext);
+ this.verifyRuleTextCallable =
+ callableFactory.createUnaryCallable(
+ verifyRuleTextTransportSettings, settings.verifyRuleTextSettings(), clientContext);
this.listRuleRevisionsCallable =
callableFactory.createUnaryCallable(
listRuleRevisionsTransportSettings,
@@ -500,6 +530,11 @@ public UnaryCallable deleteRuleCallable() {
return deleteRuleCallable;
}
+ @Override
+ public UnaryCallable verifyRuleTextCallable() {
+ return verifyRuleTextCallable;
+ }
+
@Override
public UnaryCallable
listRuleRevisionsCallable() {
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonReferenceListServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonReferenceListServiceStub.java
index 983b1ef13fb9..56b61ca1b1cf 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonReferenceListServiceStub.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonReferenceListServiceStub.java
@@ -36,6 +36,8 @@
import com.google.cloud.chronicle.v1.ListReferenceListsResponse;
import com.google.cloud.chronicle.v1.ReferenceList;
import com.google.cloud.chronicle.v1.UpdateReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListResponse;
import com.google.protobuf.TypeRegistry;
import java.io.IOException;
import java.util.ArrayList;
@@ -208,6 +210,44 @@ public class HttpJsonReferenceListServiceStub extends ReferenceListServiceStub {
.build())
.build();
+ private static final ApiMethodDescriptor
+ verifyReferenceListMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName(
+ "google.cloud.chronicle.v1.ReferenceListService/VerifyReferenceList")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1/{instance=projects/*/locations/*/instances/*}:verifyReferenceList",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "instance", request.getInstance());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearInstance().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(VerifyReferenceListResponse.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
private final UnaryCallable getReferenceListCallable;
private final UnaryCallable
listReferenceListsCallable;
@@ -217,6 +257,8 @@ public class HttpJsonReferenceListServiceStub extends ReferenceListServiceStub {
createReferenceListCallable;
private final UnaryCallable
updateReferenceListCallable;
+ private final UnaryCallable
+ verifyReferenceListCallable;
private final BackgroundResource backgroundResources;
private final HttpJsonStubCallableFactory callableFactory;
@@ -314,6 +356,20 @@ protected HttpJsonReferenceListServiceStub(
return builder.build();
})
.build();
+ HttpJsonCallSettings
+ verifyReferenceListTransportSettings =
+ HttpJsonCallSettings
+ .newBuilder()
+ .setMethodDescriptor(verifyReferenceListMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("instance", String.valueOf(request.getInstance()));
+ return builder.build();
+ })
+ .setResourceNameExtractor(request -> request.getInstance())
+ .build();
this.getReferenceListCallable =
callableFactory.createUnaryCallable(
@@ -338,6 +394,11 @@ protected HttpJsonReferenceListServiceStub(
updateReferenceListTransportSettings,
settings.updateReferenceListSettings(),
clientContext);
+ this.verifyReferenceListCallable =
+ callableFactory.createUnaryCallable(
+ verifyReferenceListTransportSettings,
+ settings.verifyReferenceListSettings(),
+ clientContext);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
@@ -350,6 +411,7 @@ public static List getMethodDescriptors() {
methodDescriptors.add(listReferenceListsMethodDescriptor);
methodDescriptors.add(createReferenceListMethodDescriptor);
methodDescriptors.add(updateReferenceListMethodDescriptor);
+ methodDescriptors.add(verifyReferenceListMethodDescriptor);
return methodDescriptors;
}
@@ -380,6 +442,12 @@ public UnaryCallable updateReferenceL
return updateReferenceListCallable;
}
+ @Override
+ public UnaryCallable
+ verifyReferenceListCallable() {
+ return verifyReferenceListCallable;
+ }
+
@Override
public final void close() {
try {
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleExecutionErrorServiceCallableFactory.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleExecutionErrorServiceCallableFactory.java
new file mode 100644
index 000000000000..2a5112dfbd15
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleExecutionErrorServiceCallableFactory.java
@@ -0,0 +1,101 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1.stub;
+
+import com.google.api.gax.httpjson.HttpJsonCallSettings;
+import com.google.api.gax.httpjson.HttpJsonCallableFactory;
+import com.google.api.gax.httpjson.HttpJsonOperationSnapshotCallable;
+import com.google.api.gax.httpjson.HttpJsonStubCallableFactory;
+import com.google.api.gax.httpjson.longrunning.stub.OperationsStub;
+import com.google.api.gax.rpc.BatchingCallSettings;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.OperationCallSettings;
+import com.google.api.gax.rpc.OperationCallable;
+import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.ServerStreamingCallSettings;
+import com.google.api.gax.rpc.ServerStreamingCallable;
+import com.google.api.gax.rpc.UnaryCallSettings;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.longrunning.Operation;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * REST callable factory implementation for the RuleExecutionErrorService service API.
+ *
+ * This class is for advanced usage.
+ */
+@Generated("by gapic-generator-java")
+public class HttpJsonRuleExecutionErrorServiceCallableFactory
+ implements HttpJsonStubCallableFactory {
+
+ @Override
+ public UnaryCallable createUnaryCallable(
+ HttpJsonCallSettings httpJsonCallSettings,
+ UnaryCallSettings callSettings,
+ ClientContext clientContext) {
+ return HttpJsonCallableFactory.createUnaryCallable(
+ httpJsonCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ UnaryCallable createPagedCallable(
+ HttpJsonCallSettings httpJsonCallSettings,
+ PagedCallSettings callSettings,
+ ClientContext clientContext) {
+ return HttpJsonCallableFactory.createPagedCallable(
+ httpJsonCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public UnaryCallable createBatchingCallable(
+ HttpJsonCallSettings httpJsonCallSettings,
+ BatchingCallSettings callSettings,
+ ClientContext clientContext) {
+ return HttpJsonCallableFactory.createBatchingCallable(
+ httpJsonCallSettings, callSettings, clientContext);
+ }
+
+ @Override
+ public
+ OperationCallable createOperationCallable(
+ HttpJsonCallSettings httpJsonCallSettings,
+ OperationCallSettings callSettings,
+ ClientContext clientContext,
+ OperationsStub operationsStub) {
+ UnaryCallable innerCallable =
+ HttpJsonCallableFactory.createBaseUnaryCallable(
+ httpJsonCallSettings, callSettings.getInitialCallSettings(), clientContext);
+ HttpJsonOperationSnapshotCallable initialCallable =
+ new HttpJsonOperationSnapshotCallable(
+ innerCallable,
+ httpJsonCallSettings.getMethodDescriptor().getOperationSnapshotFactory());
+ return HttpJsonCallableFactory.createOperationCallable(
+ callSettings, clientContext, operationsStub.longRunningClient(), initialCallable);
+ }
+
+ @Override
+ public
+ ServerStreamingCallable createServerStreamingCallable(
+ HttpJsonCallSettings httpJsonCallSettings,
+ ServerStreamingCallSettings callSettings,
+ ClientContext clientContext) {
+ return HttpJsonCallableFactory.createServerStreamingCallable(
+ httpJsonCallSettings, callSettings, clientContext);
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleExecutionErrorServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleExecutionErrorServiceStub.java
new file mode 100644
index 000000000000..0af422521c42
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleExecutionErrorServiceStub.java
@@ -0,0 +1,228 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1.stub;
+
+import static com.google.cloud.chronicle.v1.RuleExecutionErrorServiceClient.ListRuleExecutionErrorsPagedResponse;
+
+import com.google.api.core.InternalApi;
+import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.core.BackgroundResourceAggregation;
+import com.google.api.gax.httpjson.ApiMethodDescriptor;
+import com.google.api.gax.httpjson.HttpJsonCallSettings;
+import com.google.api.gax.httpjson.HttpJsonStubCallableFactory;
+import com.google.api.gax.httpjson.ProtoMessageRequestFormatter;
+import com.google.api.gax.httpjson.ProtoMessageResponseParser;
+import com.google.api.gax.httpjson.ProtoRestSerializer;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.RequestParamsBuilder;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsRequest;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsResponse;
+import com.google.protobuf.TypeRegistry;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * REST stub implementation for the RuleExecutionErrorService service API.
+ *
+ * This class is for advanced usage and reflects the underlying API directly.
+ */
+@Generated("by gapic-generator-java")
+public class HttpJsonRuleExecutionErrorServiceStub extends RuleExecutionErrorServiceStub {
+ private static final TypeRegistry typeRegistry = TypeRegistry.newBuilder().build();
+
+ private static final ApiMethodDescriptor<
+ ListRuleExecutionErrorsRequest, ListRuleExecutionErrorsResponse>
+ listRuleExecutionErrorsMethodDescriptor =
+ ApiMethodDescriptor
+ .newBuilder()
+ .setFullMethodName(
+ "google.cloud.chronicle.v1.RuleExecutionErrorService/ListRuleExecutionErrors")
+ .setHttpMethod("GET")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1/{parent=projects/*/locations/*/instances/*}/ruleExecutionErrors",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "parent", request.getParent());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "filter", request.getFilter());
+ serializer.putQueryParam(fields, "pageSize", request.getPageSize());
+ serializer.putQueryParam(fields, "pageToken", request.getPageToken());
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(request -> null)
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(ListRuleExecutionErrorsResponse.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
+ private final UnaryCallable
+ listRuleExecutionErrorsCallable;
+ private final UnaryCallable
+ listRuleExecutionErrorsPagedCallable;
+
+ private final BackgroundResource backgroundResources;
+ private final HttpJsonStubCallableFactory callableFactory;
+
+ public static final HttpJsonRuleExecutionErrorServiceStub create(
+ RuleExecutionErrorServiceStubSettings settings) throws IOException {
+ return new HttpJsonRuleExecutionErrorServiceStub(settings, ClientContext.create(settings));
+ }
+
+ public static final HttpJsonRuleExecutionErrorServiceStub create(ClientContext clientContext)
+ throws IOException {
+ return new HttpJsonRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings.newHttpJsonBuilder().build(), clientContext);
+ }
+
+ public static final HttpJsonRuleExecutionErrorServiceStub create(
+ ClientContext clientContext, HttpJsonStubCallableFactory callableFactory) throws IOException {
+ return new HttpJsonRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings.newHttpJsonBuilder().build(),
+ clientContext,
+ callableFactory);
+ }
+
+ /**
+ * Constructs an instance of HttpJsonRuleExecutionErrorServiceStub, using the given settings. This
+ * is protected so that it is easy to make a subclass, but otherwise, the static factory methods
+ * should be preferred.
+ */
+ protected HttpJsonRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings settings, ClientContext clientContext)
+ throws IOException {
+ this(settings, clientContext, new HttpJsonRuleExecutionErrorServiceCallableFactory());
+ }
+
+ /**
+ * Constructs an instance of HttpJsonRuleExecutionErrorServiceStub, using the given settings. This
+ * is protected so that it is easy to make a subclass, but otherwise, the static factory methods
+ * should be preferred.
+ */
+ protected HttpJsonRuleExecutionErrorServiceStub(
+ RuleExecutionErrorServiceStubSettings settings,
+ ClientContext clientContext,
+ HttpJsonStubCallableFactory callableFactory)
+ throws IOException {
+ this.callableFactory = callableFactory;
+
+ HttpJsonCallSettings
+ listRuleExecutionErrorsTransportSettings =
+ HttpJsonCallSettings
+ .newBuilder()
+ .setMethodDescriptor(listRuleExecutionErrorsMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("parent", String.valueOf(request.getParent()));
+ return builder.build();
+ })
+ .setResourceNameExtractor(request -> request.getParent())
+ .build();
+
+ this.listRuleExecutionErrorsCallable =
+ callableFactory.createUnaryCallable(
+ listRuleExecutionErrorsTransportSettings,
+ settings.listRuleExecutionErrorsSettings(),
+ clientContext);
+ this.listRuleExecutionErrorsPagedCallable =
+ callableFactory.createPagedCallable(
+ listRuleExecutionErrorsTransportSettings,
+ settings.listRuleExecutionErrorsSettings(),
+ clientContext);
+
+ this.backgroundResources =
+ new BackgroundResourceAggregation(clientContext.getBackgroundResources());
+ }
+
+ @InternalApi
+ public static List getMethodDescriptors() {
+ List methodDescriptors = new ArrayList<>();
+ methodDescriptors.add(listRuleExecutionErrorsMethodDescriptor);
+ return methodDescriptors;
+ }
+
+ @Override
+ public UnaryCallable
+ listRuleExecutionErrorsCallable() {
+ return listRuleExecutionErrorsCallable;
+ }
+
+ @Override
+ public UnaryCallable
+ listRuleExecutionErrorsPagedCallable() {
+ return listRuleExecutionErrorsPagedCallable;
+ }
+
+ @Override
+ public final void close() {
+ try {
+ backgroundResources.close();
+ } catch (RuntimeException e) {
+ throw e;
+ } catch (Exception e) {
+ throw new IllegalStateException("Failed to close resource", e);
+ }
+ }
+
+ @Override
+ public void shutdown() {
+ backgroundResources.shutdown();
+ }
+
+ @Override
+ public boolean isShutdown() {
+ return backgroundResources.isShutdown();
+ }
+
+ @Override
+ public boolean isTerminated() {
+ return backgroundResources.isTerminated();
+ }
+
+ @Override
+ public void shutdownNow() {
+ backgroundResources.shutdownNow();
+ }
+
+ @Override
+ public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
+ return backgroundResources.awaitTermination(duration, unit);
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleServiceStub.java
index edc183843f74..8aa697ae16ff 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleServiceStub.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/HttpJsonRuleServiceStub.java
@@ -57,6 +57,8 @@
import com.google.cloud.chronicle.v1.RuleDeployment;
import com.google.cloud.chronicle.v1.UpdateRuleDeploymentRequest;
import com.google.cloud.chronicle.v1.UpdateRuleRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextResponse;
import com.google.common.collect.ImmutableMap;
import com.google.longrunning.Operation;
import com.google.protobuf.Empty;
@@ -260,6 +262,43 @@ public class HttpJsonRuleServiceStub extends RuleServiceStub {
.build())
.build();
+ private static final ApiMethodDescriptor
+ verifyRuleTextMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName("google.cloud.chronicle.v1.RuleService/VerifyRuleText")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1/{instance=projects/*/locations/*/instances/*}:verifyRuleText",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "instance", request.getInstance());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int");
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearInstance().build(), true))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(VerifyRuleTextResponse.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
private static final ApiMethodDescriptor
listRuleRevisionsMethodDescriptor =
ApiMethodDescriptor.newBuilder()
@@ -526,6 +565,7 @@ public class HttpJsonRuleServiceStub extends RuleServiceStub {
private final UnaryCallable listRulesPagedCallable;
private final UnaryCallable updateRuleCallable;
private final UnaryCallable deleteRuleCallable;
+ private final UnaryCallable verifyRuleTextCallable;
private final UnaryCallable
listRuleRevisionsCallable;
private final UnaryCallable
@@ -675,6 +715,19 @@ protected HttpJsonRuleServiceStub(
})
.setResourceNameExtractor(request -> request.getName())
.build();
+ HttpJsonCallSettings
+ verifyRuleTextTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(verifyRuleTextMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .setParamsExtractor(
+ request -> {
+ RequestParamsBuilder builder = RequestParamsBuilder.create();
+ builder.add("instance", String.valueOf(request.getInstance()));
+ return builder.build();
+ })
+ .setResourceNameExtractor(request -> request.getInstance())
+ .build();
HttpJsonCallSettings
listRuleRevisionsTransportSettings =
HttpJsonCallSettings.newBuilder()
@@ -785,6 +838,9 @@ protected HttpJsonRuleServiceStub(
this.deleteRuleCallable =
callableFactory.createUnaryCallable(
deleteRuleTransportSettings, settings.deleteRuleSettings(), clientContext);
+ this.verifyRuleTextCallable =
+ callableFactory.createUnaryCallable(
+ verifyRuleTextTransportSettings, settings.verifyRuleTextSettings(), clientContext);
this.listRuleRevisionsCallable =
callableFactory.createUnaryCallable(
listRuleRevisionsTransportSettings,
@@ -846,6 +902,7 @@ public static List getMethodDescriptors() {
methodDescriptors.add(listRulesMethodDescriptor);
methodDescriptors.add(updateRuleMethodDescriptor);
methodDescriptors.add(deleteRuleMethodDescriptor);
+ methodDescriptors.add(verifyRuleTextMethodDescriptor);
methodDescriptors.add(listRuleRevisionsMethodDescriptor);
methodDescriptors.add(createRetrohuntMethodDescriptor);
methodDescriptors.add(getRetrohuntMethodDescriptor);
@@ -890,6 +947,11 @@ public UnaryCallable deleteRuleCallable() {
return deleteRuleCallable;
}
+ @Override
+ public UnaryCallable verifyRuleTextCallable() {
+ return verifyRuleTextCallable;
+ }
+
@Override
public UnaryCallable
listRuleRevisionsCallable() {
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStub.java
index 138aaaf7049b..4098ead0c319 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStub.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStub.java
@@ -26,6 +26,8 @@
import com.google.cloud.chronicle.v1.ListReferenceListsResponse;
import com.google.cloud.chronicle.v1.ReferenceList;
import com.google.cloud.chronicle.v1.UpdateReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListResponse;
import javax.annotation.Generated;
// AUTO-GENERATED DOCUMENTATION AND CLASS.
@@ -59,6 +61,11 @@ public UnaryCallable updateReferenceL
throw new UnsupportedOperationException("Not implemented: updateReferenceListCallable()");
}
+ public UnaryCallable
+ verifyReferenceListCallable() {
+ throw new UnsupportedOperationException("Not implemented: verifyReferenceListCallable()");
+ }
+
@Override
public abstract void close();
}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStubSettings.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStubSettings.java
index 3c766abbc5fc..3fb340d35c36 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStubSettings.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/ReferenceListServiceStubSettings.java
@@ -51,6 +51,8 @@
import com.google.cloud.chronicle.v1.ListReferenceListsResponse;
import com.google.cloud.chronicle.v1.ReferenceList;
import com.google.cloud.chronicle.v1.UpdateReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListRequest;
+import com.google.cloud.chronicle.v1.VerifyReferenceListResponse;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
@@ -117,7 +119,11 @@ public class ReferenceListServiceStubSettings
extends StubSettings {
/** The default scopes of the service. */
private static final ImmutableList DEFAULT_SERVICE_SCOPES =
- ImmutableList.builder().add("https://www.googleapis.com/auth/cloud-platform").build();
+ ImmutableList.builder()
+ .add("https://www.googleapis.com/auth/chronicle")
+ .add("https://www.googleapis.com/auth/chronicle.readonly")
+ .add("https://www.googleapis.com/auth/cloud-platform")
+ .build();
private final UnaryCallSettings getReferenceListSettings;
private final PagedCallSettings<
@@ -127,6 +133,8 @@ public class ReferenceListServiceStubSettings
createReferenceListSettings;
private final UnaryCallSettings
updateReferenceListSettings;
+ private final UnaryCallSettings
+ verifyReferenceListSettings;
private static final PagedListDescriptor<
ListReferenceListsRequest, ListReferenceListsResponse, ReferenceList>
@@ -211,6 +219,12 @@ public UnaryCallSettings getReferenceLis
return updateReferenceListSettings;
}
+ /** Returns the object with the settings used for calls to verifyReferenceList. */
+ public UnaryCallSettings
+ verifyReferenceListSettings() {
+ return verifyReferenceListSettings;
+ }
+
public ReferenceListServiceStub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
@@ -326,6 +340,7 @@ protected ReferenceListServiceStubSettings(Builder settingsBuilder) throws IOExc
listReferenceListsSettings = settingsBuilder.listReferenceListsSettings().build();
createReferenceListSettings = settingsBuilder.createReferenceListSettings().build();
updateReferenceListSettings = settingsBuilder.updateReferenceListSettings().build();
+ verifyReferenceListSettings = settingsBuilder.verifyReferenceListSettings().build();
}
@Override
@@ -350,6 +365,8 @@ public static class Builder
createReferenceListSettings;
private final UnaryCallSettings.Builder
updateReferenceListSettings;
+ private final UnaryCallSettings.Builder
+ verifyReferenceListSettings;
private static final ImmutableMap>
RETRYABLE_CODE_DEFINITIONS;
@@ -402,13 +419,15 @@ protected Builder(ClientContext clientContext) {
listReferenceListsSettings = PagedCallSettings.newBuilder(LIST_REFERENCE_LISTS_PAGE_STR_FACT);
createReferenceListSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
updateReferenceListSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ verifyReferenceListSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
getReferenceListSettings,
listReferenceListsSettings,
createReferenceListSettings,
- updateReferenceListSettings);
+ updateReferenceListSettings,
+ verifyReferenceListSettings);
initDefaults(this);
}
@@ -419,13 +438,15 @@ protected Builder(ReferenceListServiceStubSettings settings) {
listReferenceListsSettings = settings.listReferenceListsSettings.toBuilder();
createReferenceListSettings = settings.createReferenceListSettings.toBuilder();
updateReferenceListSettings = settings.updateReferenceListSettings.toBuilder();
+ verifyReferenceListSettings = settings.verifyReferenceListSettings.toBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
getReferenceListSettings,
listReferenceListsSettings,
createReferenceListSettings,
- updateReferenceListSettings);
+ updateReferenceListSettings,
+ verifyReferenceListSettings);
}
private static Builder createDefault() {
@@ -473,6 +494,11 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_5_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_5_params"));
+ builder
+ .verifyReferenceListSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
return builder;
}
@@ -516,6 +542,12 @@ public Builder applyToAllUnaryMethods(
return updateReferenceListSettings;
}
+ /** Returns the builder for the settings used for calls to verifyReferenceList. */
+ public UnaryCallSettings.Builder
+ verifyReferenceListSettings() {
+ return verifyReferenceListSettings;
+ }
+
@Override
public ReferenceListServiceStubSettings build() throws IOException {
return new ReferenceListServiceStubSettings(this);
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleExecutionErrorServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleExecutionErrorServiceStub.java
new file mode 100644
index 000000000000..2902adc5dc0b
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleExecutionErrorServiceStub.java
@@ -0,0 +1,49 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1.stub;
+
+import static com.google.cloud.chronicle.v1.RuleExecutionErrorServiceClient.ListRuleExecutionErrorsPagedResponse;
+
+import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsRequest;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsResponse;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Base stub class for the RuleExecutionErrorService service API.
+ *
+ * This class is for advanced usage and reflects the underlying API directly.
+ */
+@Generated("by gapic-generator-java")
+public abstract class RuleExecutionErrorServiceStub implements BackgroundResource {
+
+ public UnaryCallable
+ listRuleExecutionErrorsPagedCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: listRuleExecutionErrorsPagedCallable()");
+ }
+
+ public UnaryCallable
+ listRuleExecutionErrorsCallable() {
+ throw new UnsupportedOperationException("Not implemented: listRuleExecutionErrorsCallable()");
+ }
+
+ @Override
+ public abstract void close();
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleExecutionErrorServiceStubSettings.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleExecutionErrorServiceStubSettings.java
new file mode 100644
index 000000000000..5a2edabfc46a
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleExecutionErrorServiceStubSettings.java
@@ -0,0 +1,457 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1.stub;
+
+import static com.google.cloud.chronicle.v1.RuleExecutionErrorServiceClient.ListRuleExecutionErrorsPagedResponse;
+
+import com.google.api.core.ApiFunction;
+import com.google.api.core.ApiFuture;
+import com.google.api.core.BetaApi;
+import com.google.api.core.ObsoleteApi;
+import com.google.api.gax.core.GaxProperties;
+import com.google.api.gax.core.GoogleCredentialsProvider;
+import com.google.api.gax.core.InstantiatingExecutorProvider;
+import com.google.api.gax.grpc.GaxGrpcProperties;
+import com.google.api.gax.grpc.GrpcTransportChannel;
+import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider;
+import com.google.api.gax.httpjson.GaxHttpJsonProperties;
+import com.google.api.gax.httpjson.HttpJsonTransportChannel;
+import com.google.api.gax.httpjson.InstantiatingHttpJsonChannelProvider;
+import com.google.api.gax.retrying.RetrySettings;
+import com.google.api.gax.rpc.ApiCallContext;
+import com.google.api.gax.rpc.ApiClientHeaderProvider;
+import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.LibraryMetadata;
+import com.google.api.gax.rpc.PageContext;
+import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.PagedListDescriptor;
+import com.google.api.gax.rpc.PagedListResponseFactory;
+import com.google.api.gax.rpc.StatusCode;
+import com.google.api.gax.rpc.StubSettings;
+import com.google.api.gax.rpc.TransportChannelProvider;
+import com.google.api.gax.rpc.UnaryCallSettings;
+import com.google.api.gax.rpc.UnaryCallable;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsRequest;
+import com.google.cloud.chronicle.v1.ListRuleExecutionErrorsResponse;
+import com.google.cloud.chronicle.v1.RuleExecutionError;
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.ImmutableSet;
+import com.google.common.collect.Lists;
+import java.io.IOException;
+import java.time.Duration;
+import java.util.List;
+import javax.annotation.Generated;
+
+// AUTO-GENERATED DOCUMENTATION AND CLASS.
+/**
+ * Settings class to configure an instance of {@link RuleExecutionErrorServiceStub}.
+ *
+ * The default instance has everything set to sensible defaults:
+ *
+ *
+ * - The default service address (chronicle.googleapis.com) and default port (443) are used.
+ *
- Credentials are acquired automatically through Application Default Credentials.
+ *
- Retries are configured for idempotent methods but not for non-idempotent methods.
+ *
+ *
+ * The builder of this class is recursive, so contained classes are themselves builders. When
+ * build() is called, the tree of builders is called to create the complete settings object.
+ *
+ *
For example, to set the
+ * [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
+ * of listRuleExecutionErrors:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * RuleExecutionErrorServiceStubSettings.Builder ruleExecutionErrorServiceSettingsBuilder =
+ * RuleExecutionErrorServiceStubSettings.newBuilder();
+ * ruleExecutionErrorServiceSettingsBuilder
+ * .listRuleExecutionErrorsSettings()
+ * .setRetrySettings(
+ * ruleExecutionErrorServiceSettingsBuilder
+ * .listRuleExecutionErrorsSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setInitialRetryDelayDuration(Duration.ofSeconds(1))
+ * .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
+ * .setMaxAttempts(5)
+ * .setMaxRetryDelayDuration(Duration.ofSeconds(30))
+ * .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
+ * .setRetryDelayMultiplier(1.3)
+ * .setRpcTimeoutMultiplier(1.5)
+ * .setTotalTimeoutDuration(Duration.ofSeconds(300))
+ * .build());
+ * RuleExecutionErrorServiceStubSettings ruleExecutionErrorServiceSettings =
+ * ruleExecutionErrorServiceSettingsBuilder.build();
+ * }
+ *
+ * Please refer to the [Client Side Retry
+ * Guide](https://docs.cloud.google.com/java/docs/client-retries) for additional support in setting
+ * retries.
+ */
+@Generated("by gapic-generator-java")
+@SuppressWarnings("CanonicalDuration")
+public class RuleExecutionErrorServiceStubSettings
+ extends StubSettings {
+ /** The default scopes of the service. */
+ private static final ImmutableList DEFAULT_SERVICE_SCOPES =
+ ImmutableList.builder()
+ .add("https://www.googleapis.com/auth/chronicle")
+ .add("https://www.googleapis.com/auth/chronicle.readonly")
+ .add("https://www.googleapis.com/auth/cloud-platform")
+ .build();
+
+ private final PagedCallSettings<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>
+ listRuleExecutionErrorsSettings;
+
+ private static final PagedListDescriptor<
+ ListRuleExecutionErrorsRequest, ListRuleExecutionErrorsResponse, RuleExecutionError>
+ LIST_RULE_EXECUTION_ERRORS_PAGE_STR_DESC =
+ new PagedListDescriptor<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ RuleExecutionError>() {
+ @Override
+ public String emptyToken() {
+ return "";
+ }
+
+ @Override
+ public ListRuleExecutionErrorsRequest injectToken(
+ ListRuleExecutionErrorsRequest payload, String token) {
+ return ListRuleExecutionErrorsRequest.newBuilder(payload).setPageToken(token).build();
+ }
+
+ @Override
+ public ListRuleExecutionErrorsRequest injectPageSize(
+ ListRuleExecutionErrorsRequest payload, int pageSize) {
+ return ListRuleExecutionErrorsRequest.newBuilder(payload)
+ .setPageSize(pageSize)
+ .build();
+ }
+
+ @Override
+ public Integer extractPageSize(ListRuleExecutionErrorsRequest payload) {
+ return payload.getPageSize();
+ }
+
+ @Override
+ public String extractNextToken(ListRuleExecutionErrorsResponse payload) {
+ return payload.getNextPageToken();
+ }
+
+ @Override
+ public Iterable extractResources(
+ ListRuleExecutionErrorsResponse payload) {
+ return payload.getRuleExecutionErrorsList();
+ }
+ };
+
+ private static final PagedListResponseFactory<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>
+ LIST_RULE_EXECUTION_ERRORS_PAGE_STR_FACT =
+ new PagedListResponseFactory<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>() {
+ @Override
+ public ApiFuture getFuturePagedResponse(
+ UnaryCallable
+ callable,
+ ListRuleExecutionErrorsRequest request,
+ ApiCallContext context,
+ ApiFuture futureResponse) {
+ PageContext<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ RuleExecutionError>
+ pageContext =
+ PageContext.create(
+ callable, LIST_RULE_EXECUTION_ERRORS_PAGE_STR_DESC, request, context);
+ return ListRuleExecutionErrorsPagedResponse.createAsync(pageContext, futureResponse);
+ }
+ };
+
+ /** Returns the object with the settings used for calls to listRuleExecutionErrors. */
+ public PagedCallSettings<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>
+ listRuleExecutionErrorsSettings() {
+ return listRuleExecutionErrorsSettings;
+ }
+
+ public RuleExecutionErrorServiceStub createStub() throws IOException {
+ if (getTransportChannelProvider()
+ .getTransportName()
+ .equals(GrpcTransportChannel.getGrpcTransportName())) {
+ return GrpcRuleExecutionErrorServiceStub.create(this);
+ }
+ if (getTransportChannelProvider()
+ .getTransportName()
+ .equals(HttpJsonTransportChannel.getHttpJsonTransportName())) {
+ return HttpJsonRuleExecutionErrorServiceStub.create(this);
+ }
+ throw new UnsupportedOperationException(
+ String.format(
+ "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
+ }
+
+ /** Returns the default service name. */
+ @Override
+ public String getServiceName() {
+ return "chronicle";
+ }
+
+ /** Returns a builder for the default ExecutorProvider for this service. */
+ public static InstantiatingExecutorProvider.Builder defaultExecutorProviderBuilder() {
+ return InstantiatingExecutorProvider.newBuilder();
+ }
+
+ /** Returns the default service endpoint. */
+ @ObsoleteApi("Use getEndpoint() instead")
+ public static String getDefaultEndpoint() {
+ return "chronicle.googleapis.com:443";
+ }
+
+ /** Returns the default mTLS service endpoint. */
+ public static String getDefaultMtlsEndpoint() {
+ return "chronicle.mtls.googleapis.com:443";
+ }
+
+ /** Returns the default service scopes. */
+ public static List getDefaultServiceScopes() {
+ return DEFAULT_SERVICE_SCOPES;
+ }
+
+ /** Returns a builder for the default credentials for this service. */
+ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() {
+ return GoogleCredentialsProvider.newBuilder()
+ .setScopesToApply(DEFAULT_SERVICE_SCOPES)
+ .setUseJwtAccessWithScope(true);
+ }
+
+ /** Returns a builder for the default gRPC ChannelProvider for this service. */
+ public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
+ return InstantiatingGrpcChannelProvider.newBuilder()
+ .setMaxInboundMessageSize(Integer.MAX_VALUE);
+ }
+
+ /** Returns a builder for the default REST ChannelProvider for this service. */
+ @BetaApi
+ public static InstantiatingHttpJsonChannelProvider.Builder
+ defaultHttpJsonTransportProviderBuilder() {
+ return InstantiatingHttpJsonChannelProvider.newBuilder();
+ }
+
+ public static TransportChannelProvider defaultTransportChannelProvider() {
+ return defaultGrpcTransportProviderBuilder().build();
+ }
+
+ public static ApiClientHeaderProvider.Builder defaultGrpcApiClientHeaderProviderBuilder() {
+ return ApiClientHeaderProvider.newBuilder()
+ .setGeneratedLibToken(
+ "gapic", GaxProperties.getLibraryVersion(RuleExecutionErrorServiceStubSettings.class))
+ .setTransportToken(
+ GaxGrpcProperties.getGrpcTokenName(), GaxGrpcProperties.getGrpcVersion());
+ }
+
+ public static ApiClientHeaderProvider.Builder defaultHttpJsonApiClientHeaderProviderBuilder() {
+ return ApiClientHeaderProvider.newBuilder()
+ .setGeneratedLibToken(
+ "gapic", GaxProperties.getLibraryVersion(RuleExecutionErrorServiceStubSettings.class))
+ .setTransportToken(
+ GaxHttpJsonProperties.getHttpJsonTokenName(),
+ GaxHttpJsonProperties.getHttpJsonVersion());
+ }
+
+ public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() {
+ return RuleExecutionErrorServiceStubSettings.defaultGrpcApiClientHeaderProviderBuilder();
+ }
+
+ /** Returns a new gRPC builder for this class. */
+ public static Builder newBuilder() {
+ return Builder.createDefault();
+ }
+
+ /** Returns a new REST builder for this class. */
+ public static Builder newHttpJsonBuilder() {
+ return Builder.createHttpJsonDefault();
+ }
+
+ /** Returns a new builder for this class. */
+ public static Builder newBuilder(ClientContext clientContext) {
+ return new Builder(clientContext);
+ }
+
+ /** Returns a builder containing all the values of this settings class. */
+ public Builder toBuilder() {
+ return new Builder(this);
+ }
+
+ protected RuleExecutionErrorServiceStubSettings(Builder settingsBuilder) throws IOException {
+ super(settingsBuilder);
+
+ listRuleExecutionErrorsSettings = settingsBuilder.listRuleExecutionErrorsSettings().build();
+ }
+
+ @Override
+ protected LibraryMetadata getLibraryMetadata() {
+ return LibraryMetadata.newBuilder()
+ .setArtifactName("com.google.cloud:google-cloud-chronicle")
+ .setRepository("googleapis/google-cloud-java")
+ .setVersion(Version.VERSION)
+ .build();
+ }
+
+ /** Builder for RuleExecutionErrorServiceStubSettings. */
+ public static class Builder
+ extends StubSettings.Builder {
+ private final ImmutableList> unaryMethodSettingsBuilders;
+ private final PagedCallSettings.Builder<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>
+ listRuleExecutionErrorsSettings;
+ private static final ImmutableMap>
+ RETRYABLE_CODE_DEFINITIONS;
+
+ static {
+ ImmutableMap.Builder> definitions =
+ ImmutableMap.builder();
+ definitions.put(
+ "retry_policy_4_codes",
+ ImmutableSet.copyOf(Lists.newArrayList(StatusCode.Code.UNAVAILABLE)));
+ RETRYABLE_CODE_DEFINITIONS = definitions.build();
+ }
+
+ private static final ImmutableMap RETRY_PARAM_DEFINITIONS;
+
+ static {
+ ImmutableMap.Builder definitions = ImmutableMap.builder();
+ RetrySettings settings = null;
+ settings =
+ RetrySettings.newBuilder()
+ .setInitialRetryDelayDuration(Duration.ofMillis(1000L))
+ .setRetryDelayMultiplier(1.3)
+ .setMaxRetryDelayDuration(Duration.ofMillis(600000L))
+ .setInitialRpcTimeoutDuration(Duration.ofMillis(600000L))
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeoutDuration(Duration.ofMillis(600000L))
+ .setTotalTimeoutDuration(Duration.ofMillis(600000L))
+ .build();
+ definitions.put("retry_policy_4_params", settings);
+ RETRY_PARAM_DEFINITIONS = definitions.build();
+ }
+
+ protected Builder() {
+ this(((ClientContext) null));
+ }
+
+ protected Builder(ClientContext clientContext) {
+ super(clientContext);
+
+ listRuleExecutionErrorsSettings =
+ PagedCallSettings.newBuilder(LIST_RULE_EXECUTION_ERRORS_PAGE_STR_FACT);
+
+ unaryMethodSettingsBuilders =
+ ImmutableList.>of(listRuleExecutionErrorsSettings);
+ initDefaults(this);
+ }
+
+ protected Builder(RuleExecutionErrorServiceStubSettings settings) {
+ super(settings);
+
+ listRuleExecutionErrorsSettings = settings.listRuleExecutionErrorsSettings.toBuilder();
+
+ unaryMethodSettingsBuilders =
+ ImmutableList.>of(listRuleExecutionErrorsSettings);
+ }
+
+ private static Builder createDefault() {
+ Builder builder = new Builder(((ClientContext) null));
+
+ builder.setTransportChannelProvider(defaultTransportChannelProvider());
+ builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
+ builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build());
+ builder.setMtlsEndpoint(getDefaultMtlsEndpoint());
+ builder.setSwitchToMtlsEndpointAllowed(true);
+
+ return initDefaults(builder);
+ }
+
+ private static Builder createHttpJsonDefault() {
+ Builder builder = new Builder(((ClientContext) null));
+
+ builder.setTransportChannelProvider(defaultHttpJsonTransportProviderBuilder().build());
+ builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build());
+ builder.setInternalHeaderProvider(defaultHttpJsonApiClientHeaderProviderBuilder().build());
+ builder.setMtlsEndpoint(getDefaultMtlsEndpoint());
+ builder.setSwitchToMtlsEndpointAllowed(true);
+
+ return initDefaults(builder);
+ }
+
+ private static Builder initDefaults(Builder builder) {
+ builder
+ .listRuleExecutionErrorsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_4_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_4_params"));
+
+ return builder;
+ }
+
+ /**
+ * Applies the given settings updater function to all of the unary API methods in this service.
+ *
+ * Note: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction, Void> settingsUpdater) {
+ super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
+ return this;
+ }
+
+ public ImmutableList> unaryMethodSettingsBuilders() {
+ return unaryMethodSettingsBuilders;
+ }
+
+ /** Returns the builder for the settings used for calls to listRuleExecutionErrors. */
+ public PagedCallSettings.Builder<
+ ListRuleExecutionErrorsRequest,
+ ListRuleExecutionErrorsResponse,
+ ListRuleExecutionErrorsPagedResponse>
+ listRuleExecutionErrorsSettings() {
+ return listRuleExecutionErrorsSettings;
+ }
+
+ @Override
+ public RuleExecutionErrorServiceStubSettings build() throws IOException {
+ return new RuleExecutionErrorServiceStubSettings(this);
+ }
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStub.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStub.java
index ae5392bac72c..9f16c84d7770 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStub.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStub.java
@@ -44,6 +44,8 @@
import com.google.cloud.chronicle.v1.RuleDeployment;
import com.google.cloud.chronicle.v1.UpdateRuleDeploymentRequest;
import com.google.cloud.chronicle.v1.UpdateRuleRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextResponse;
import com.google.longrunning.Operation;
import com.google.longrunning.stub.OperationsStub;
import com.google.protobuf.Empty;
@@ -90,6 +92,10 @@ public UnaryCallable deleteRuleCallable() {
throw new UnsupportedOperationException("Not implemented: deleteRuleCallable()");
}
+ public UnaryCallable verifyRuleTextCallable() {
+ throw new UnsupportedOperationException("Not implemented: verifyRuleTextCallable()");
+ }
+
public UnaryCallable
listRuleRevisionsPagedCallable() {
throw new UnsupportedOperationException("Not implemented: listRuleRevisionsPagedCallable()");
diff --git a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStubSettings.java b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStubSettings.java
index 710be4b739c3..882a026ab9a8 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStubSettings.java
+++ b/java-chronicle/google-cloud-chronicle/src/main/java/com/google/cloud/chronicle/v1/stub/RuleServiceStubSettings.java
@@ -72,6 +72,8 @@
import com.google.cloud.chronicle.v1.RuleDeployment;
import com.google.cloud.chronicle.v1.UpdateRuleDeploymentRequest;
import com.google.cloud.chronicle.v1.UpdateRuleRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextRequest;
+import com.google.cloud.chronicle.v1.VerifyRuleTextResponse;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
@@ -164,7 +166,11 @@
public class RuleServiceStubSettings extends StubSettings {
/** The default scopes of the service. */
private static final ImmutableList DEFAULT_SERVICE_SCOPES =
- ImmutableList.builder().add("https://www.googleapis.com/auth/cloud-platform").build();
+ ImmutableList.builder()
+ .add("https://www.googleapis.com/auth/chronicle")
+ .add("https://www.googleapis.com/auth/chronicle.readonly")
+ .add("https://www.googleapis.com/auth/cloud-platform")
+ .build();
private final UnaryCallSettings createRuleSettings;
private final UnaryCallSettings getRuleSettings;
@@ -172,6 +178,8 @@ public class RuleServiceStubSettings extends StubSettings updateRuleSettings;
private final UnaryCallSettings deleteRuleSettings;
+ private final UnaryCallSettings
+ verifyRuleTextSettings;
private final PagedCallSettings<
ListRuleRevisionsRequest, ListRuleRevisionsResponse, ListRuleRevisionsPagedResponse>
listRuleRevisionsSettings;
@@ -434,6 +442,11 @@ public UnaryCallSettings deleteRuleSettings() {
return deleteRuleSettings;
}
+ /** Returns the object with the settings used for calls to verifyRuleText. */
+ public UnaryCallSettings verifyRuleTextSettings() {
+ return verifyRuleTextSettings;
+ }
+
/** Returns the object with the settings used for calls to listRuleRevisions. */
public PagedCallSettings<
ListRuleRevisionsRequest, ListRuleRevisionsResponse, ListRuleRevisionsPagedResponse>
@@ -598,6 +611,7 @@ protected RuleServiceStubSettings(Builder settingsBuilder) throws IOException {
listRulesSettings = settingsBuilder.listRulesSettings().build();
updateRuleSettings = settingsBuilder.updateRuleSettings().build();
deleteRuleSettings = settingsBuilder.deleteRuleSettings().build();
+ verifyRuleTextSettings = settingsBuilder.verifyRuleTextSettings().build();
listRuleRevisionsSettings = settingsBuilder.listRuleRevisionsSettings().build();
createRetrohuntSettings = settingsBuilder.createRetrohuntSettings().build();
createRetrohuntOperationSettings = settingsBuilder.createRetrohuntOperationSettings().build();
@@ -627,6 +641,8 @@ public static class Builder extends StubSettings.Builder updateRuleSettings;
private final UnaryCallSettings.Builder deleteRuleSettings;
+ private final UnaryCallSettings.Builder
+ verifyRuleTextSettings;
private final PagedCallSettings.Builder<
ListRuleRevisionsRequest, ListRuleRevisionsResponse, ListRuleRevisionsPagedResponse>
listRuleRevisionsSettings;
@@ -725,6 +741,7 @@ protected Builder(ClientContext clientContext) {
listRulesSettings = PagedCallSettings.newBuilder(LIST_RULES_PAGE_STR_FACT);
updateRuleSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
deleteRuleSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ verifyRuleTextSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
listRuleRevisionsSettings = PagedCallSettings.newBuilder(LIST_RULE_REVISIONS_PAGE_STR_FACT);
createRetrohuntSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
createRetrohuntOperationSettings = OperationCallSettings.newBuilder();
@@ -742,6 +759,7 @@ protected Builder(ClientContext clientContext) {
listRulesSettings,
updateRuleSettings,
deleteRuleSettings,
+ verifyRuleTextSettings,
listRuleRevisionsSettings,
createRetrohuntSettings,
getRetrohuntSettings,
@@ -760,6 +778,7 @@ protected Builder(RuleServiceStubSettings settings) {
listRulesSettings = settings.listRulesSettings.toBuilder();
updateRuleSettings = settings.updateRuleSettings.toBuilder();
deleteRuleSettings = settings.deleteRuleSettings.toBuilder();
+ verifyRuleTextSettings = settings.verifyRuleTextSettings.toBuilder();
listRuleRevisionsSettings = settings.listRuleRevisionsSettings.toBuilder();
createRetrohuntSettings = settings.createRetrohuntSettings.toBuilder();
createRetrohuntOperationSettings = settings.createRetrohuntOperationSettings.toBuilder();
@@ -776,6 +795,7 @@ protected Builder(RuleServiceStubSettings settings) {
listRulesSettings,
updateRuleSettings,
deleteRuleSettings,
+ verifyRuleTextSettings,
listRuleRevisionsSettings,
createRetrohuntSettings,
getRetrohuntSettings,
@@ -835,6 +855,11 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_5_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_5_params"));
+ builder
+ .verifyRuleTextSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params"));
+
builder
.listRuleRevisionsSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_4_codes"))
@@ -938,6 +963,12 @@ public UnaryCallSettings.Builder deleteRuleSettings()
return deleteRuleSettings;
}
+ /** Returns the builder for the settings used for calls to verifyRuleText. */
+ public UnaryCallSettings.Builder
+ verifyRuleTextSettings() {
+ return verifyRuleTextSettings;
+ }
+
/** Returns the builder for the settings used for calls to listRuleRevisions. */
public PagedCallSettings.Builder<
ListRuleRevisionsRequest, ListRuleRevisionsResponse, ListRuleRevisionsPagedResponse>
diff --git a/java-chronicle/google-cloud-chronicle/src/main/resources/META-INF/native-image/com.google.cloud.chronicle.v1/reflect-config.json b/java-chronicle/google-cloud-chronicle/src/main/resources/META-INF/native-image/com.google.cloud.chronicle.v1/reflect-config.json
index 05f4d474435d..e2501d49b07f 100644
--- a/java-chronicle/google-cloud-chronicle/src/main/resources/META-INF/native-image/com.google.cloud.chronicle.v1/reflect-config.json
+++ b/java-chronicle/google-cloud-chronicle/src/main/resources/META-INF/native-image/com.google.cloud.chronicle.v1/reflect-config.json
@@ -3347,6 +3347,42 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.cloud.chronicle.v1.ListRuleExecutionErrorsRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.ListRuleExecutionErrorsRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.ListRuleExecutionErrorsResponse",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.ListRuleExecutionErrorsResponse$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.cloud.chronicle.v1.ListRuleRevisionsRequest",
"queryAllDeclaredConstructors": true,
@@ -3698,6 +3734,24 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.cloud.chronicle.v1.ReferenceListError",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.ReferenceListError$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.cloud.chronicle.v1.ReferenceListScope",
"queryAllDeclaredConstructors": true,
@@ -3860,6 +3914,24 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.cloud.chronicle.v1.RuleExecutionError",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.RuleExecutionError$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.cloud.chronicle.v1.RuleType",
"queryAllDeclaredConstructors": true,
@@ -4166,6 +4238,78 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyReferenceListRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyReferenceListRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyReferenceListResponse",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyReferenceListResponse$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyRuleTextRequest",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyRuleTextRequest$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyRuleTextResponse",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.cloud.chronicle.v1.VerifyRuleTextResponse$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.cloud.chronicle.v1.VisualMapType",
"queryAllDeclaredConstructors": true,
diff --git a/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockReferenceListServiceImpl.java b/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockReferenceListServiceImpl.java
index 2d41f2233bba..3cad3f627539 100644
--- a/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockReferenceListServiceImpl.java
+++ b/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockReferenceListServiceImpl.java
@@ -142,4 +142,26 @@ public void updateReferenceList(
Exception.class.getName())));
}
}
+
+ @Override
+ public void verifyReferenceList(
+ VerifyReferenceListRequest request,
+ StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof VerifyReferenceListResponse) {
+ requests.add(request);
+ responseObserver.onNext(((VerifyReferenceListResponse) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method VerifyReferenceList, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ VerifyReferenceListResponse.class.getName(),
+ Exception.class.getName())));
+ }
+ }
}
diff --git a/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockRuleExecutionErrorService.java b/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockRuleExecutionErrorService.java
new file mode 100644
index 000000000000..fc0fefad85ff
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockRuleExecutionErrorService.java
@@ -0,0 +1,59 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1;
+
+import com.google.api.core.BetaApi;
+import com.google.api.gax.grpc.testing.MockGrpcService;
+import com.google.protobuf.AbstractMessage;
+import io.grpc.ServerServiceDefinition;
+import java.util.List;
+import javax.annotation.Generated;
+
+@BetaApi
+@Generated("by gapic-generator-java")
+public class MockRuleExecutionErrorService implements MockGrpcService {
+ private final MockRuleExecutionErrorServiceImpl serviceImpl;
+
+ public MockRuleExecutionErrorService() {
+ serviceImpl = new MockRuleExecutionErrorServiceImpl();
+ }
+
+ @Override
+ public List getRequests() {
+ return serviceImpl.getRequests();
+ }
+
+ @Override
+ public void addResponse(AbstractMessage response) {
+ serviceImpl.addResponse(response);
+ }
+
+ @Override
+ public void addException(Exception exception) {
+ serviceImpl.addException(exception);
+ }
+
+ @Override
+ public ServerServiceDefinition getServiceDefinition() {
+ return serviceImpl.bindService();
+ }
+
+ @Override
+ public void reset() {
+ serviceImpl.reset();
+ }
+}
diff --git a/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockRuleExecutionErrorServiceImpl.java b/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockRuleExecutionErrorServiceImpl.java
new file mode 100644
index 000000000000..6567e8c2f482
--- /dev/null
+++ b/java-chronicle/google-cloud-chronicle/src/test/java/com/google/cloud/chronicle/v1/MockRuleExecutionErrorServiceImpl.java
@@ -0,0 +1,83 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.chronicle.v1;
+
+import com.google.api.core.BetaApi;
+import com.google.cloud.chronicle.v1.RuleExecutionErrorServiceGrpc.RuleExecutionErrorServiceImplBase;
+import com.google.protobuf.AbstractMessage;
+import io.grpc.stub.StreamObserver;
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Queue;
+import javax.annotation.Generated;
+
+@BetaApi
+@Generated("by gapic-generator-java")
+public class MockRuleExecutionErrorServiceImpl extends RuleExecutionErrorServiceImplBase {
+ private List requests;
+ private Queue