Remove experimental tag from Nexus (#2454)

Author: Quinn-With-Two-Ns

temporal-sdk/src/main/java/io/temporal/nexus/Nexus.java

@@ -20,12 +20,10 @@
 
 package io.temporal.nexus;
 
-import io.temporal.common.Experimental;
 import io.temporal.internal.nexus.NexusInternal;
 import io.temporal.internal.sync.WorkflowInternal;
 
 /** This class contains methods exposing Temporal APIs for Nexus Operations */
-@Experimental
 public final class Nexus {
   /**
    * Can be used to get information about a Nexus Operation. This static method relies on a

temporal-sdk/src/main/java/io/temporal/nexus/NexusOperationContext.java

@@ -22,14 +22,12 @@
 
 import com.uber.m3.tally.Scope;
 import io.temporal.client.WorkflowClient;
-import io.temporal.common.Experimental;
 import io.temporal.serviceclient.WorkflowServiceStubsOptions;
 
 /**
  * Context object passed to a Nexus operation implementation. Use {@link
  * Nexus#getOperationContext()} from a Nexus Operation implementation to access.
  */
-@Experimental
 public interface NexusOperationContext {
 
   /**

temporal-sdk/src/main/java/io/temporal/nexus/WorkflowRunOperation.java

@@ -22,20 +22,21 @@
 
 import io.nexusrpc.handler.*;
 import io.nexusrpc.handler.OperationHandler;
+import io.temporal.api.enums.v1.WorkflowIdConflictPolicy;
 import io.temporal.client.WorkflowOptions;
-import io.temporal.common.Experimental;
 
 /**
  * WorkflowRunOperation can be used to map a workflow run to a Nexus operation
  *
+ * <h3>Pre-release feature: Attaching multiple Nexus callers to an underlying handler Workflow:</h3>
+ *
  * <p>{@link WorkflowOptions#getWorkflowIdConflictPolicy()} is by default set to fail if a workflow
  * is already running. That is, if a caller executes another operation that starts the same
  * workflow, it will fail. You can set it to {@link
- * io.temporal.api.enums.v1.WorkflowIdConflictPolicy#WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING} to
- * attach the caller's callback to the existing running workflow. This way, all attached callers
- * will be notified when the workflow completes.
+ * WorkflowIdConflictPolicy#WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING} to attach the caller's
+ * callback to the existing running workflow. This way, all attached callers will be notified when
+ * the workflow completes.
  */
-@Experimental
 public final class WorkflowRunOperation {
   /**
    * Maps a workflow method to an {@link io.nexusrpc.handler.OperationHandler}.

temporal-sdk/src/main/java/io/temporal/workflow/NexusOperationHandle.java

@@ -20,13 +20,10 @@
 
 package io.temporal.workflow;
 
-import io.temporal.common.Experimental;
-
 /**
  * OperationHandle is used to interact with a scheduled nexus operation. Created through {@link
  * Workflow#startNexusOperation}.
  */
-@Experimental
 public interface NexusOperationHandle<R> {
   /**
    * Returns a promise that is resolved when the operation reaches the STARTED state. For

temporal-sdk/src/main/java/io/temporal/workflow/NexusOperationOptions.java

@@ -30,7 +30,6 @@
  *
  * <p>Use {@link NexusOperationOptions#newBuilder()} to construct an instance.
  */
-@Experimental
 public final class NexusOperationOptions {
   public static NexusOperationOptions.Builder newBuilder() {
     return new NexusOperationOptions.Builder();

temporal-sdk/src/main/java/io/temporal/workflow/NexusServiceOptions.java

@@ -21,7 +21,6 @@
 package io.temporal.workflow;
 
 import com.google.common.base.Preconditions;
-import io.temporal.common.Experimental;
 import java.util.Collections;
 import java.util.Map;
 import java.util.Objects;
@@ -31,7 +30,6 @@
  *
  * <p>Use {@link NexusServiceOptions#newBuilder()} to construct an instance.
  */
-@Experimental
 public final class NexusServiceOptions {
 
   public static NexusServiceOptions.Builder newBuilder() {

temporal-sdk/src/main/java/io/temporal/workflow/NexusServiceStub.java

@@ -20,7 +20,6 @@
 
 package io.temporal.workflow;
 
-import io.temporal.common.Experimental;
 import java.lang.reflect.Type;
 
 /**
@@ -29,7 +28,6 @@
  * to execute operations implemented in other languages. Created through {@link
  * Workflow#newNexusServiceStub(Class)}.
  */
-@Experimental
 public interface NexusServiceStub {
 
   /**

temporal-sdk/src/main/java/io/temporal/workflow/Workflow.java

@@ -1310,7 +1310,6 @@ public static boolean isEveryHandlerFinished() {
    *
    * @param service interface that given service implements.
    */
-  @Experimental
   public static <T> T newNexusServiceStub(Class<T> service) {
     return WorkflowInternal.newNexusServiceStub(service, null);
   }
@@ -1322,7 +1321,6 @@ public static <T> T newNexusServiceStub(Class<T> service) {
    * @param service interface that given service implements.
    * @param options options passed to the Nexus service.
    */
-  @Experimental
   public static <T> T newNexusServiceStub(Class<T> service, NexusServiceOptions options) {
     return WorkflowInternal.newNexusServiceStub(service, options);
   }
@@ -1333,7 +1331,6 @@ public static <T> T newNexusServiceStub(Class<T> service, NexusServiceOptions op
    * @param service name of the service the operation is part of.
    * @param options options passed to the Nexus service.
    */
-  @Experimental
   public static NexusServiceStub newUntypedNexusServiceStub(
       String service, NexusServiceOptions options) {
     return WorkflowInternal.newUntypedNexusServiceStub(service, options);
@@ -1347,7 +1344,6 @@ public static NexusServiceStub newUntypedNexusServiceStub(
    * @param arg operation argument
    * @return OperationHandle a handle to the operation.
    */
-  @Experimental
   public static <T, R> NexusOperationHandle<R> startNexusOperation(
       Functions.Func1<T, R> operation, T arg) {
     return WorkflowInternal.startNexusOperation(operation, arg);
@@ -1360,7 +1356,6 @@ public static <T, R> NexusOperationHandle<R> startNexusOperation(
    *     #newNexusServiceStub(Class)}.
    * @return OperationHandle a handle to the operation.
    */
-  @Experimental
   public static <R> NexusOperationHandle<R> startNexusOperation(Functions.Func<R> operation) {
     return WorkflowInternal.startNexusOperation(operation);
   }

temporal-testing/src/main/java/io/temporal/testing/TestWorkflowEnvironment.java

@@ -24,7 +24,6 @@
 import io.temporal.api.enums.v1.IndexedValueType;
 import io.temporal.api.nexus.v1.Endpoint;
 import io.temporal.client.WorkflowClient;
-import io.temporal.common.Experimental;
 import io.temporal.common.WorkflowExecutionHistory;
 import io.temporal.serviceclient.OperatorServiceStubs;
 import io.temporal.serviceclient.WorkflowServiceStubs;
@@ -168,15 +167,13 @@ static TestWorkflowEnvironment newInstance(TestEnvironmentOptions options) {
    * @param taskQueue Task Queue to be used for the endpoint
    * @return Endpoint object
    */
-  @Experimental
   Endpoint createNexusEndpoint(String name, String taskQueue);
 
   /**
    * Delete a Nexus Endpoint on the server.
    *
    * @param endpoint current endpoint to be deleted
    */
-  @Experimental
   void deleteNexusEndpoint(Endpoint endpoint);
 
   /**

temporal-testing/src/main/java/io/temporal/testing/TestWorkflowExtension.java

@@ -28,7 +28,6 @@
 import io.temporal.client.WorkflowClient;
 import io.temporal.client.WorkflowClientOptions;
 import io.temporal.client.WorkflowOptions;
-import io.temporal.common.Experimental;
 import io.temporal.common.metadata.POJOWorkflowImplMetadata;
 import io.temporal.common.metadata.POJOWorkflowInterfaceMetadata;
 import io.temporal.serviceclient.WorkflowServiceStubsOptions;
@@ -407,7 +406,6 @@ public Builder registerWorkflowImplementationTypes(
      *
      * @see Worker#registerNexusServiceImplementation(Object...)
      */
-    @Experimental
     public Builder setNexusServiceImplementation(Object... nexusServiceImplementations) {
       this.nexusServiceImplementations = nexusServiceImplementations;
       return this;
@@ -482,7 +480,6 @@ public Builder setDoNotStart(boolean doNotStart) {
      * When set to true the {@link TestWorkflowEnvironment} will not automatically create a Nexus
      * Endpoint. This is useful when you want to manually create a Nexus Endpoint for your test.
      */
-    @Experimental
     public Builder setDoNotSetupNexusEndpoint(boolean doNotSetupNexusEndpoint) {
       this.doNotSetupNexusEndpoint = doNotSetupNexusEndpoint;
       return this;

temporal-testing/src/main/java/io/temporal/testing/TestWorkflowRule.java

@@ -32,7 +32,6 @@
 import io.temporal.client.WorkflowClientOptions;
 import io.temporal.client.WorkflowOptions;
 import io.temporal.client.WorkflowStub;
-import io.temporal.common.Experimental;
 import io.temporal.common.SearchAttributeKey;
 import io.temporal.common.interceptors.WorkerInterceptor;
 import io.temporal.internal.common.env.DebugModeUtils;
@@ -259,7 +258,6 @@ public Builder setWorkflowTypes(
      *
      * @see Worker#registerNexusServiceImplementation(Object...)
      */
-    @Experimental
     public Builder setNexusServiceImplementation(Object... nexusServiceImplementations) {
       this.nexusServiceImplementations = nexusServiceImplementations;
       return this;
@@ -348,7 +346,6 @@ public Builder setDoNotStart(boolean doNotStart) {
      * When set to true the {@link TestWorkflowEnvironment} will not automatically create a Nexus
      * Endpoint. This is useful when you want to manually create a Nexus Endpoint for your test.
      */
-    @Experimental
     public Builder setDoNotSetupNexusEndpoint(boolean doNotSetupNexusEndpoint) {
       this.doNotSetupNexusEndpoint = doNotSetupNexusEndpoint;
       return this;