Spotless apply

Author: slinkydeveloper

examples/src/main/kotlin/my/restate/sdk/examples/CounterKt.kt

@@ -17,7 +17,6 @@ import dev.restate.sdk.kotlin.endpoint.*
 import kotlinx.serialization.Serializable
 import org.apache.logging.log4j.LogManager
 import org.apache.logging.log4j.Logger
-import kotlin.time.Duration.Companion.seconds
 
 @VirtualObject
 class CounterKt {
@@ -58,10 +57,6 @@ class CounterKt {
 }
 
 fun main() {
-  val endpoint = endpoint {
-    bind(CounterKt()) {
-      it.abortTimeout = 30.seconds
-    }
-  }
+  val endpoint = endpoint { bind(CounterKt()) }
   RestateHttpServer.listen(endpoint)
 }

sdk-api-kotlin/src/main/kotlin/dev/restate/sdk/kotlin/endpoint/endpoint.kt

@@ -23,20 +23,18 @@ fun endpoint(init: Endpoint.Builder.() -> Unit): Endpoint {
 }
 
 /**
- * Documentation as shown in the UI, Admin REST API, and the generated OpenAPI documentation of
- * this service.
+ * Documentation as shown in the UI, Admin REST API, and the generated OpenAPI documentation of this
+ * service.
  */
 var ServiceDefinition.Configurator.documentation: String?
   get() {
     return this.documentation()
   }
   set(value) {
-    this.documentation (value)
+    this.documentation(value)
   }
 
-/**
- * Service metadata, as propagated in the Admin REST API.
- */
+/** Service metadata, as propagated in the Admin REST API. */
 var ServiceDefinition.Configurator.metadata: Map<String, String>?
   get() {
     return this.metadata()
@@ -49,69 +47,68 @@ var ServiceDefinition.Configurator.metadata: Map<String, String>?
  * This timer guards against stalled invocations. Once it expires, Restate triggers a graceful
  * termination by asking the invocation to suspend (which preserves intermediate progress).
  *
- * The [abortTimeout] is used to abort the invocation, in case it doesn't
- * react to the request to suspend.
+ * The [abortTimeout] is used to abort the invocation, in case it doesn't react to the request to
+ * suspend.
  *
  * This overrides the default inactivity timeout configured in the restate-server for all
  * invocations to this service.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var ServiceDefinition.Configurator.inactivityTimeout: Duration?
   get() {
     return this.inactivityTimeout()?.toKotlinDuration()
   }
   set(value) {
-    this.inactivityTimeout (value?.toJavaDuration())
+    this.inactivityTimeout(value?.toJavaDuration())
   }
 
 /**
- * This timer guards against stalled service/handler invocations that are supposed to terminate.
- * The abort timeout is started after the [inactivityTimeout] has expired and
- * the service/handler invocation has been asked to gracefully terminate. Once the timer
- * expires, it will abort the service/handler invocation.
+ * This timer guards against stalled service/handler invocations that are supposed to terminate. The
+ * abort timeout is started after the [inactivityTimeout] has expired and the service/handler
+ * invocation has been asked to gracefully terminate. Once the timer expires, it will abort the
+ * service/handler invocation.
  *
- * This timer potentially *interrupts* user code. If the user code needs longer to
- * gracefully terminate, then this value needs to be set accordingly.
+ * This timer potentially *interrupts* user code. If the user code needs longer to gracefully
+ * terminate, then this value needs to be set accordingly.
  *
- * This overrides the default abort timeout configured in the restate-server for all
- * invocations to this service.
+ * This overrides the default abort timeout configured in the restate-server for all invocations to
+ * this service.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var ServiceDefinition.Configurator.abortTimeout: Duration?
   get() {
     return this.abortTimeout()?.toKotlinDuration()
   }
   set(value) {
-    this.abortTimeout( value?.toJavaDuration())
+    this.abortTimeout(value?.toJavaDuration())
   }
 
 /**
  * The retention duration of idempotent requests to this service.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var ServiceDefinition.Configurator.idempotencyRetention: Duration?
   get() {
     return this.idempotencyRetention()?.toKotlinDuration()
   }
   set(value) {
-    this.idempotencyRetention (value?.toJavaDuration())
+    this.idempotencyRetention(value?.toJavaDuration())
   }
 
 /**
- * The journal retention. When set, this applies to all requests to all handlers of this
- * service.
+ * The journal retention. When set, this applies to all requests to all handlers of this service.
  *
- * In case the request has an idempotency key, the [idempotencyRetention]
- * caps the journal retention time.
+ * In case the request has an idempotency key, the [idempotencyRetention] caps the journal retention
+ * time.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  *
  * @return this
  */
@@ -120,15 +117,15 @@ var ServiceDefinition.Configurator.journalRetention: Duration?
     return this.journalRetention()?.toKotlinDuration()
   }
   set(value) {
-    this.journalRetention ( value?.toJavaDuration())
+    this.journalRetention(value?.toJavaDuration())
   }
 
 /**
- * When set to `true`, lazy state will be enabled for all invocations to this service.
- * This is relevant only for workflows and virtual objects.
+ * When set to `true`, lazy state will be enabled for all invocations to this service. This is
+ * relevant only for workflows and virtual objects.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var ServiceDefinition.Configurator.enableLazyState: Boolean?
   get() {
@@ -139,18 +136,18 @@ var ServiceDefinition.Configurator.enableLazyState: Boolean?
   }
 
 /**
- * When set to `true` this service, with all its handlers, cannot be invoked from the
- * restate-server HTTP and Kafka ingress, but only from other services.
+ * When set to `true` this service, with all its handlers, cannot be invoked from the restate-server
+ * HTTP and Kafka ingress, but only from other services.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var ServiceDefinition.Configurator.ingressPrivate: Boolean?
   get() {
     return this.ingressPrivate()
   }
   set(value) {
-    this.ingressPrivate (value)
+    this.ingressPrivate(value)
   }
 
 /**
@@ -166,8 +163,8 @@ var HandlerDefinition.Configurator.acceptContentType: String?
   }
 
 /**
- * Documentation as shown in the UI, Admin REST API, and the generated OpenAPI documentation of
- * this handler.
+ * Documentation as shown in the UI, Admin REST API, and the generated OpenAPI documentation of this
+ * handler.
  */
 var HandlerDefinition.Configurator.documentation: String?
   get() {
@@ -177,9 +174,7 @@ var HandlerDefinition.Configurator.documentation: String?
     this.documentation(value)
   }
 
-/**
- * Handler metadata, as propagated in the Admin REST API.
- */
+/** Handler metadata, as propagated in the Admin REST API. */
 var HandlerDefinition.Configurator.metadata: Map<String, String>?
   get() {
     return this.metadata()
@@ -192,14 +187,13 @@ var HandlerDefinition.Configurator.metadata: Map<String, String>?
  * This timer guards against stalled invocations. Once it expires, Restate triggers a graceful
  * termination by asking the invocation to suspend (which preserves intermediate progress).
  *
- * The [abortTimeout] is used to abort the invocation, in case it doesn't
- * react to the request to suspend.
+ * The [abortTimeout] is used to abort the invocation, in case it doesn't react to the request to
+ * suspend.
  *
- * This overrides the inactivity timeout set for the service and the default set in
- * restate-server.
+ * This overrides the inactivity timeout set for the service and the default set in restate-server.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var HandlerDefinition.Configurator.inactivityTimeout: Duration?
   get() {
@@ -210,19 +204,17 @@ var HandlerDefinition.Configurator.inactivityTimeout: Duration?
   }
 
 /**
- * This timer guards against stalled invocations that are supposed to terminate. The abort
- * timeout is started after the [inactivityTimeout] has expired and the
- * invocation has been asked to gracefully terminate. Once the timer expires, it will abort the
- * invocation.
+ * This timer guards against stalled invocations that are supposed to terminate. The abort timeout
+ * is started after the [inactivityTimeout] has expired and the invocation has been asked to
+ * gracefully terminate. Once the timer expires, it will abort the invocation.
  *
- * This timer potentially *interrupts* user code. If the user code needs longer to
- * gracefully terminate, then this value needs to be set accordingly.
+ * This timer potentially *interrupts* user code. If the user code needs longer to gracefully
+ * terminate, then this value needs to be set accordingly.
  *
- * This overrides the abort timeout set for the service and the default set in
- * restate-server.
+ * This overrides the abort timeout set for the service and the default set in restate-server.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var HandlerDefinition.Configurator.abortTimeout: Duration?
   get() {
@@ -235,8 +227,8 @@ var HandlerDefinition.Configurator.abortTimeout: Duration?
 /**
  * The retention duration of idempotent requests to this service.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var HandlerDefinition.Configurator.idempotencyRetention: Duration?
   get() {
@@ -249,8 +241,8 @@ var HandlerDefinition.Configurator.idempotencyRetention: Duration?
 /**
  * The retention duration for this workflow handler.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var HandlerDefinition.Configurator.workflowRetention: Duration?
   get() {
@@ -263,11 +255,11 @@ var HandlerDefinition.Configurator.workflowRetention: Duration?
 /**
  * The journal retention for invocations to this handler.
  *
- * In case the request has an idempotency key, the [idempotencyRetention]
- * caps the journal retention time.
+ * In case the request has an idempotency key, the [idempotencyRetention] caps the journal retention
+ * time.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var HandlerDefinition.Configurator.journalRetention: Duration?
   get() {
@@ -278,11 +270,11 @@ var HandlerDefinition.Configurator.journalRetention: Duration?
   }
 
 /**
- * When set to `true` this handler cannot be invoked from the restate-server HTTP and
- * Kafka ingress, but only from other services.
+ * When set to `true` this handler cannot be invoked from the restate-server HTTP and Kafka ingress,
+ * but only from other services.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var HandlerDefinition.Configurator.ingressPrivate: Boolean?
   get() {
@@ -293,11 +285,11 @@ var HandlerDefinition.Configurator.ingressPrivate: Boolean?
   }
 
 /**
- * When set to `true`, lazy state will be enabled for all invocations to this handler.
- * This is relevant only for workflows and virtual objects.
+ * When set to `true`, lazy state will be enabled for all invocations to this handler. This is
+ * relevant only for workflows and virtual objects.
  *
- * *NOTE:* You can set this field only if you register this service against
- * restate-server >= 1.4, otherwise the service discovery will fail.
+ * *NOTE:* You can set this field only if you register this service against restate-server >= 1.4,
+ * otherwise the service discovery will fail.
  */
 var HandlerDefinition.Configurator.enableLazyState: Boolean?
   get() {

sdk-common/src/main/java/dev/restate/sdk/endpoint/definition/HandlerDefinition.java

@@ -457,7 +457,7 @@ public Configurator abortTimeout(@Nullable Duration abortTimeout) {
     public Configurator idempotencyRetention(@Nullable Duration idempotencyRetention) {
       if (handlerType == HandlerType.WORKFLOW) {
         throw new IllegalArgumentException(
-                "The idempotency retention cannot be set for workflow handlers. Use workflowRetention(Duration) instead");
+            "The idempotency retention cannot be set for workflow handlers. Use workflowRetention(Duration) instead");
       }
       this.idempotencyRetention = idempotencyRetention;
       return this;
@@ -482,7 +482,7 @@ public Configurator idempotencyRetention(@Nullable Duration idempotencyRetention
     public Configurator workflowRetention(@Nullable Duration workflowRetention) {
       if (handlerType != HandlerType.WORKFLOW) {
         throw new IllegalArgumentException(
-                "Workflow retention can be set only for workflow handlers");
+            "Workflow retention can be set only for workflow handlers");
       }
       this.workflowRetention = workflowRetention;
       return this;