[Backport 2.x] bump ktlint 1.1.0 to 1.5.0 (#1338)

* bump ktlint from 1.1.0 to 1.5.0 (#1336)

Signed-off-by: Shivansh Arora <hishiv@amazon.com>

* appease ktlint

Signed-off-by: Shivansh Arora <hishiv@amazon.com>

.

Signed-off-by: Shivansh Arora <hishiv@amazon.com>

---------

Signed-off-by: Shivansh Arora <hishiv@amazon.com>

Author: shiv0408

build.gradle

@@ -216,7 +216,7 @@ dependencies {
     testImplementation "com.nhaarman.mockitokotlin2:mockito-kotlin:2.2.0"
     testImplementation "org.mockito:mockito-core:${versions.mockito}"
 
-    add("ktlint", "com.pinterest.ktlint:ktlint-cli:1.1.0") {
+    add("ktlint", "com.pinterest.ktlint:ktlint-cli:1.5.0") {
         attributes {
             attribute(Bundling.BUNDLING_ATTRIBUTE, objects.named(Bundling, Bundling.EXTERNAL))
         }

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/IndexManagementExtension.kt

@@ -27,9 +27,7 @@ interface IndexManagementExtension {
      * should represent if the extension is enabled or disabled, and should not represent extension health or the availability of some extension
      * dependency.
      */
-    fun statusChecker(): StatusChecker {
-        return DefaultStatusChecker()
-    }
+    fun statusChecker(): StatusChecker = DefaultStatusChecker()
 
     /**
      * Name of the extension
@@ -41,17 +39,13 @@ interface IndexManagementExtension {
      * indices provide the metadata service that can provide the index metadata for these indices. An extension need to label the metadata service
      * with a type string which is used to distinguish indices in IndexManagement plugin
      */
-    fun getIndexMetadataService(): Map<String, IndexMetadataService> {
-        return mapOf()
-    }
+    fun getIndexMetadataService(): Map<String, IndexMetadataService> = mapOf()
 
     /**
      * Caution: Experimental and can be removed in future
      *
      * If extension wants IndexManagement to determine cluster state indices UUID based on custom index setting if
      * present of cluster state override this method.
      */
-    fun overrideClusterStateIndexUuidSetting(): String? {
-        return null
-    }
+    fun overrideClusterStateIndexUuidSetting(): String? = null
 }

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/Action.kt

@@ -20,7 +20,8 @@ import java.time.Instant
 abstract class Action(
     val type: String,
     val actionIndex: Int,
-) : ToXContentObject, Writeable {
+) : ToXContentObject,
+    Writeable {
 
     var configTimeout: ActionTimeout? = null
     var configRetry: ActionRetry? = ActionRetry(DEFAULT_RETRIES)

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/StatusChecker.kt

@@ -12,19 +12,15 @@ interface StatusChecker {
     /**
      * checks and returns the status of the extension
      */
-    fun check(clusterState: ClusterState): Status {
-        return Status.ENABLED
-    }
+    fun check(clusterState: ClusterState): Status = Status.ENABLED
 }
 
 enum class Status(private val value: String) {
     ENABLED("enabled"),
     DISABLED("disabled"),
     ;
 
-    override fun toString(): String {
-        return value
-    }
+    override fun toString(): String = value
 }
 
 class DefaultStatusChecker : StatusChecker

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/Step.kt

@@ -38,16 +38,14 @@ abstract class Step(val name: String, val isSafeToDisableOn: Boolean = true) {
 
     abstract fun isIdempotent(): Boolean
 
-    final fun getStepStartTime(metadata: ManagedIndexMetaData): Instant {
-        return when {
-            metadata.stepMetaData == null -> Instant.now()
-            metadata.stepMetaData.name != this.name -> Instant.now()
-            // The managed index metadata is a historical snapshot of the metadata and refers to what has happened from the previous
-            // execution, so if we ever see it as COMPLETED it means we are always going to be in a new step, this specifically
-            // helps with the Transition -> Transition (empty state) sequence which the above do not capture
-            metadata.stepMetaData.stepStatus == StepStatus.COMPLETED -> Instant.now()
-            else -> Instant.ofEpochMilli(metadata.stepMetaData.startTime)
-        }
+    final fun getStepStartTime(metadata: ManagedIndexMetaData): Instant = when {
+        metadata.stepMetaData == null -> Instant.now()
+        metadata.stepMetaData.name != this.name -> Instant.now()
+        // The managed index metadata is a historical snapshot of the metadata and refers to what has happened from the previous
+        // execution, so if we ever see it as COMPLETED it means we are always going to be in a new step, this specifically
+        // helps with the Transition -> Transition (empty state) sequence which the above do not capture
+        metadata.stepMetaData.stepStatus == StepStatus.COMPLETED -> Instant.now()
+        else -> Instant.ofEpochMilli(metadata.stepMetaData.startTime)
     }
 
     final fun getStartingStepMetaData(metadata: ManagedIndexMetaData): StepMetaData = StepMetaData(name, getStepStartTime(metadata).toEpochMilli(), StepStatus.STARTING)
@@ -60,18 +58,14 @@ abstract class Step(val name: String, val isSafeToDisableOn: Boolean = true) {
         TIMED_OUT("timed_out"),
         ;
 
-        override fun toString(): String {
-            return status
-        }
+        override fun toString(): String = status
 
         override fun writeTo(out: StreamOutput) {
             out.writeString(status)
         }
 
         companion object {
-            fun read(streamInput: StreamInput): StepStatus {
-                return valueOf(streamInput.readString().uppercase(Locale.ROOT))
-            }
+            fun read(streamInput: StreamInput): StepStatus = valueOf(streamInput.readString().uppercase(Locale.ROOT))
         }
     }
 }

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/Validate.kt

@@ -30,18 +30,14 @@ abstract class Validate(
         FAILED("failed"),
         ;
 
-        override fun toString(): String {
-            return status
-        }
+        override fun toString(): String = status
 
         override fun writeTo(out: StreamOutput) {
             out.writeString(status)
         }
 
         companion object {
-            fun read(streamInput: StreamInput): ValidationStatus {
-                return valueOf(streamInput.readString().uppercase(Locale.ROOT))
-            }
+            fun read(streamInput: StreamInput): ValidationStatus = valueOf(streamInput.readString().uppercase(Locale.ROOT))
         }
     }
 }

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/model/ActionMetaData.kt

@@ -30,7 +30,8 @@ data class ActionMetaData(
     val consumedRetries: Int,
     val lastRetryTime: Long?,
     val actionProperties: ActionProperties?,
-) : Writeable, ToXContentFragment {
+) : Writeable,
+    ToXContentFragment {
 
     override fun writeTo(out: StreamOutput) {
         out.writeString(name)
@@ -61,9 +62,7 @@ data class ActionMetaData(
         return builder
     }
 
-    fun getMapValueString(): String {
-        return Strings.toString(XContentType.JSON, this)
-    }
+    fun getMapValueString(): String = Strings.toString(XContentType.JSON, this)
 
     companion object {
         const val ACTION = "action"

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/model/ActionProperties.kt

@@ -25,7 +25,8 @@ data class ActionProperties(
     val hasRollupFailed: Boolean? = null,
     val shrinkActionProperties: ShrinkActionProperties? = null,
     val transformActionProperties: TransformActionProperties? = null,
-) : Writeable, ToXContentFragment {
+) : Writeable,
+    ToXContentFragment {
 
     override fun writeTo(out: StreamOutput) {
         out.writeOptionalInt(maxNumSegments)

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/model/ActionRetry.kt

@@ -24,7 +24,8 @@ data class ActionRetry(
     val count: Long,
     val backoff: Backoff = Backoff.EXPONENTIAL,
     val delay: TimeValue = TimeValue.timeValueMinutes(1),
-) : ToXContentFragment, Writeable {
+) : ToXContentFragment,
+    Writeable {
 
     init {
         require(count >= 0) { "Count for ActionRetry must be a non-negative number" }
@@ -110,9 +111,7 @@ data class ActionRetry(
 
         private val logger = LogManager.getLogger(javaClass)
 
-        override fun toString(): String {
-            return type
-        }
+        override fun toString(): String = type
 
         @Suppress("ReturnCount")
         fun shouldBackoff(actionMetaData: ActionMetaData?, actionRetry: ActionRetry?): Pair<Boolean, Long?> {

spi/src/main/kotlin/org.opensearch.indexmanagement.spi/indexstatemanagement/model/ActionTimeout.kt

@@ -15,11 +15,11 @@ import org.opensearch.core.xcontent.XContentBuilder
 import org.opensearch.core.xcontent.XContentParser
 import java.io.IOException
 
-data class ActionTimeout(val timeout: TimeValue) : ToXContentFragment, Writeable {
+data class ActionTimeout(val timeout: TimeValue) :
+    ToXContentFragment,
+    Writeable {
 
-    override fun toXContent(builder: XContentBuilder, params: ToXContent.Params): XContentBuilder {
-        return builder.field(TIMEOUT_FIELD, timeout.stringRep)
-    }
+    override fun toXContent(builder: XContentBuilder, params: ToXContent.Params): XContentBuilder = builder.field(TIMEOUT_FIELD, timeout.stringRep)
 
     @Throws(IOException::class)
     constructor(sin: StreamInput) : this(