Skip to content

Commit

Permalink
appease ktlint
Browse files Browse the repository at this point in the history
Signed-off-by: Shivansh Arora <hishiv@amazon.com>

.

Signed-off-by: Shivansh Arora <hishiv@amazon.com>
  • Loading branch information
shiv0408 committed Jan 15, 2025
1 parent d7c6991 commit d1e040e
Show file tree
Hide file tree
Showing 8 changed files with 13 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -610,8 +610,8 @@ class IndexManagementPlugin :
)

override fun getTransportInterceptors(
namedWriteableRegistry: NamedWriteableRegistry,
threadContext: ThreadContext
namedWriteableRegistry: NamedWriteableRegistry,
threadContext: ThreadContext,
): List<TransportInterceptor> = listOf(rollupInterceptor)

override fun getActionFilters(): List<ActionFilter> = listOf(fieldCapsFilter, indexOperationActionFilter)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -118,6 +118,6 @@ class ReindexRespParser(
return result.toString()
}

override fun buildNotificationTitle(operationResult: OperationResult): String =
override fun buildNotificationTitle(operationResult: OperationResult): String =
"Reindex operation on $sourceIndex has ${getOperationResultTitleDesc(operationResult)}"
}
Original file line number Diff line number Diff line change
Expand Up @@ -294,7 +294,7 @@ class IndexStateManagementHistory(
}

private fun shouldAddManagedIndexMetaDataToHistory(
managedIndexMetaData: ManagedIndexMetaData
managedIndexMetaData: ManagedIndexMetaData,
): Boolean = when (managedIndexMetaData.stepMetaData?.stepStatus) {
Step.StepStatus.STARTING -> false
Step.StepStatus.CONDITION_NOT_MET -> false
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -142,8 +142,8 @@ data class Destination(
}

private fun getLegacyCustomWebhookMessageURL(
customWebhook: CustomWebhook?,
compiledMessage: String
customWebhook: CustomWebhook?,
compiledMessage: String,
): String = LegacyCustomWebhookMessage.Builder("custom_webhook")
.withUrl(customWebhook?.url)
.withScheme(customWebhook?.scheme)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,9 @@ class AttemptNotificationStep(private val action: NotificationAction) : Step(nam
)

private fun compileTemplate(
scriptService: ScriptService,
template: Script,
managedIndexMetaData: ManagedIndexMetaData
scriptService: ScriptService,
template: Script,
managedIndexMetaData: ManagedIndexMetaData,
): String = scriptService.compile(template, TemplateScript.CONTEXT)
.newInstance(template.params + mapOf("ctx" to managedIndexMetaData.convertToMap()))
.execute()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,7 @@ fun deleteManagedIndexRequest(uuid: String): DeleteRequest = DeleteRequest(INDEX
fun deleteManagedIndexMetadataRequest(uuid: String): DeleteRequest = DeleteRequest(INDEX_MANAGEMENT_INDEX, managedIndexMetadataID(uuid)).routing(uuid)

fun updateManagedIndexRequest(
sweptManagedIndexConfig: SweptManagedIndexConfig
sweptManagedIndexConfig: SweptManagedIndexConfig,
): UpdateRequest = UpdateRequest(INDEX_MANAGEMENT_INDEX, sweptManagedIndexConfig.uuid)
.setIfPrimaryTerm(sweptManagedIndexConfig.primaryTerm)
.setIfSeqNo(sweptManagedIndexConfig.seqNo)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -65,8 +65,8 @@ import kotlin.coroutines.suspendCoroutine
const val OPENDISTRO_SECURITY_PROTECTED_INDICES_CONF_REQUEST = "_opendistro_security_protected_indices_conf_request"

fun contentParser(
bytesReference: BytesReference,
xContentRegistry: NamedXContentRegistry = NamedXContentRegistry.EMPTY
bytesReference: BytesReference,
xContentRegistry: NamedXContentRegistry = NamedXContentRegistry.EMPTY,
): XContentParser = XContentHelper.createParser(
xContentRegistry,
LoggingDeprecationHandler.INSTANCE,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ object RollupFieldValueExpressionResolver {

open fun getWriteIndexNameForAlias(alias: String): String? = this.clusterService.state().metadata().indicesLookup?.get(alias)?.writeIndex?.index?.name

open fun getBackingIndicesForAlias(alias: String): MutableList<IndexMetadata>? =
open fun getBackingIndicesForAlias(alias: String): MutableList<IndexMetadata>? =
this.clusterService.state().metadata().indicesLookup?.get(alias)?.indices
}
}

0 comments on commit d1e040e

Please sign in to comment.