Fixed ktlint errors.

Signed-off-by: AWSHurneyt <[email protected]>
opensearch-project · Feb 27, 2024 · ad95376 · ad95376
1 parent 0017d44
commit ad95376
Show file tree

Hide file tree

Showing 10 changed files with 13 additions and 24 deletions.
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/model/BucketLevelTriggerRunResult.kt b/alerting/src/main/kotlin/org/opensearch/alerting/model/BucketLevelTriggerRunResult.kt
@@ -38,7 +38,7 @@ data class BucketLevelTriggerRunResult(
     override fun writeTo(out: StreamOutput) {
         super.writeTo(out)
         out.writeMap(aggregationResultBuckets, StreamOutput::writeString) {
-            valueOut: StreamOutput, aggResultBucket: AggregationResultBucket ->
+                valueOut: StreamOutput, aggResultBucket: AggregationResultBucket ->
             aggResultBucket.writeTo(valueOut)
         }
         out.writeMap(actionResultsMap as Map<String, Any>)

diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestGetAlertsAction.kt b/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestGetAlertsAction.kt
@@ -67,8 +67,7 @@ class RestGetAlertsAction : BaseRestHandler() {
         )
 
         val getAlertsRequest = GetAlertsRequest(table, severityLevel, alertState, monitorId)
-        return RestChannelConsumer {
-            channel ->
+        return RestChannelConsumer { channel ->
             client.execute(GetAlertsAction.INSTANCE, getAlertsRequest, RestToXContentListener(channel))
         }
     }

diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestGetDestinationsAction.kt b/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestGetDestinationsAction.kt
@@ -89,7 +89,7 @@ class RestGetDestinationsAction : BaseRestHandler() {
             destinationType
         )
         return RestChannelConsumer {
-            channel ->
+                channel ->
             client.execute(GetDestinationsAction.INSTANCE, getDestinationsRequest, RestToXContentListener(channel))
         }
     }

diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestGetMonitorAction.kt b/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestGetMonitorAction.kt
@@ -67,8 +67,7 @@ class RestGetMonitorAction : BaseRestHandler() {
             srcContext = FetchSourceContext.DO_NOT_FETCH_SOURCE
         }
         val getMonitorRequest = GetMonitorRequest(monitorId, RestActions.parseVersion(request), request.method(), srcContext)
-        return RestChannelConsumer {
-            channel ->
+        return RestChannelConsumer { channel ->
             client.execute(GetMonitorAction.INSTANCE, getMonitorRequest, RestToXContentListener(channel))
         }
     }

diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestIndexDestinationAction.kt b/alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestIndexDestinationAction.kt
@@ -85,8 +85,7 @@ class RestIndexDestinationAction : BaseRestHandler() {
             WriteRequest.RefreshPolicy.IMMEDIATE
         }
         val indexDestinationRequest = IndexDestinationRequest(id, seqNo, primaryTerm, refreshPolicy, request.method(), destination)
-        return RestChannelConsumer {
-            channel ->
+        return RestChannelConsumer { channel ->
             client.execute(
                 IndexDestinationAction.INSTANCE, indexDestinationRequest,
                 indexDestinationResponse(channel, request.method())

diff --git a/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexDestinationAction.kt b/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexDestinationAction.kt
@@ -305,8 +305,7 @@ class TransportIndexDestinationAction @Inject constructor(
         private fun checkShardsFailure(response: IndexResponse): String? {
             var failureReasons = StringBuilder()
             if (response.shardInfo.failed > 0) {
-                response.shardInfo.failures.forEach {
-                    entry ->
+                response.shardInfo.failures.forEach { entry ->
                     failureReasons.append(entry.reason())
                 }
                 return failureReasons.toString()

diff --git a/...ing/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexEmailAccountAction.kt b/...ing/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexEmailAccountAction.kt
@@ -300,8 +300,7 @@ class TransportIndexEmailAccountAction @Inject constructor(
         private fun checkShardsFailure(response: IndexResponse): String? {
             val failureReasons = StringBuilder()
             if (response.shardInfo.failed > 0) {
-                response.shardInfo.failures.forEach {
-                    entry ->
+                response.shardInfo.failures.forEach { entry ->
                     failureReasons.append(entry.reason())
                 }
 

diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexEmailGroupAction.kt b/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexEmailGroupAction.kt
@@ -232,8 +232,7 @@ class TransportIndexEmailGroupAction @Inject constructor(
         private fun checkShardsFailure(response: IndexResponse): String? {
             val failureReasons = StringBuilder()
             if (response.shardInfo.failed > 0) {
-                response.shardInfo.failures.forEach {
-                    entry ->
+                response.shardInfo.failures.forEach { entry ->
                     failureReasons.append(entry.reason())
                 }
 

diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexMonitorAction.kt b/alerting/src/main/kotlin/org/opensearch/alerting/transport/TransportIndexMonitorAction.kt
@@ -477,8 +477,7 @@ class TransportIndexMonitorAction @Inject constructor(
         private fun checkShardsFailure(response: IndexResponse): String? {
             val failureReasons = StringBuilder()
             if (response.shardInfo.failed > 0) {
-                response.shardInfo.failures.forEach {
-                    entry ->
+                response.shardInfo.failures.forEach { entry ->
                     failureReasons.append(entry.reason())
                 }
                 return failureReasons.toString()

diff --git a/alerting/src/test/kotlin/org/opensearch/alerting/MonitorRunnerIT.kt b/alerting/src/test/kotlin/org/opensearch/alerting/MonitorRunnerIT.kt
@@ -1006,8 +1006,7 @@ class MonitorRunnerIT : AlertingRestTestCase() {
             val response = executeMonitor(monitor, params = DRYRUN_MONITOR)
             val output = entityAsMap(response)
             @Suppress("UNCHECKED_CAST")
-            (output["trigger_results"] as HashMap<String, Any>).forEach {
-                _, v ->
+            (output["trigger_results"] as HashMap<String, Any>).forEach { _, v ->
                 assertTrue((v as HashMap<String, Boolean>)["triggered"] as Boolean)
             }
             assertEquals(monitor.name, output["monitor_name"])
@@ -1036,8 +1035,7 @@ class MonitorRunnerIT : AlertingRestTestCase() {
             val response = executeMonitor(monitor, params = DRYRUN_MONITOR)
             val output = entityAsMap(response)
             @Suppress("UNCHECKED_CAST")
-            (output["trigger_results"] as HashMap<String, Any>).forEach {
-                _, v ->
+            (output["trigger_results"] as HashMap<String, Any>).forEach { _, v ->
                 assertTrue((v as HashMap<String, Boolean>)["triggered"] as Boolean)
             }
             assertEquals(monitor.name, output["monitor_name"])
@@ -1063,8 +1061,7 @@ class MonitorRunnerIT : AlertingRestTestCase() {
             val response = executeMonitor(monitor, params = DRYRUN_MONITOR)
             val output = entityAsMap(response)
             @Suppress("UNCHECKED_CAST")
-            (output["trigger_results"] as HashMap<String, Any>).forEach {
-                _, v ->
+            (output["trigger_results"] as HashMap<String, Any>).forEach { _, v ->
                 assertTrue((v as HashMap<String, Boolean>)["triggered"] as Boolean)
             }
             @Suppress("UNCHECKED_CAST")
@@ -1092,8 +1089,7 @@ class MonitorRunnerIT : AlertingRestTestCase() {
             val response = executeMonitor(monitor, params = DRYRUN_MONITOR)
             val output = entityAsMap(response)
             @Suppress("UNCHECKED_CAST")
-            (output["trigger_results"] as HashMap<String, Any>).forEach {
-                _, v ->
+            (output["trigger_results"] as HashMap<String, Any>).forEach { _, v ->
                 assertFalse((v as HashMap<String, Boolean>)["triggered"] as Boolean)
             }
             @Suppress("UNCHECKED_CAST")