Search pipelines added

model/opensearch.smithy

@@ -101,6 +101,7 @@ service OpenSearch {
         CreateUser,
         Create_Post,
         Create_Put,
+        CreateSearchPipeline,
         DanglingIndicesDeleteDanglingIndex,
         DanglingIndicesImportDanglingIndex,
         DanglingIndicesListDanglingIndices,
@@ -143,6 +144,7 @@ service OpenSearch {
         GetRoles,
         GetRoleMapping,
         GetRoleMappings,
+        GetSearchPipeline,
         GetTenant,
         GetTenants,
         GetUser,

model/search_pipeline/create_search_pipeline/operations.smithy

@@ -0,0 +1,23 @@
+// SPDX-License-Identifier: Apache-2.0
+//
+//  The OpenSearch Contributors require contributions made to
+//  this file be licensed under the Apache-2.0 license or a
+//  compatible open source license.
+
+$version: "2"
+namespace OpenSearch
+
+@externalDocumentation(
+    "API Reference": "https://opensearch.org/docs/latest/search-plugins/search-pipelines/creating-search-pipeline/"
+)
+
+@xOperationGroup("search_pipeline.create_search_pipeline")
+@xVersionAdded("2.9")
+@idempotent
+@suppress(["HttpUriConflict"])
+@http(method: "PUT", uri: "/_search/pipeline/{pipeline}")
+@documentation("Creates or replaces the specified search pipeline.")
+operation CreateSearchPipeline {
+    input: CreateSearchPipeline_Input,
+    output: CreateSearchPipeline_Output
+}

model/search_pipeline/create_search_pipeline/structures.smithy

@@ -0,0 +1,24 @@
+// SPDX-License-Identifier: Apache-2.0
+//
+//  The OpenSearch Contributors require contributions made to
+//  this file be licensed under the Apache-2.0 license or a
+//  compatible open source license.
+
+$version: "2"
+namespace OpenSearch
+
+
+@input
+structure CreateSearchPipeline_Input{
+    @required
+    @httpLabel
+    pipeline: String
+    @required
+    @httpPayload
+    content: SearchPipeline
+}
+
+@output
+structure CreateSearchPipeline_Output {
+    acknowledged: Boolean
+}

model/search_pipeline/get_search_pipeline/operations.smithy

@@ -0,0 +1,23 @@
+// SPDX-License-Identifier: Apache-2.0
+//
+//  The OpenSearch Contributors require contributions made to
+//  this file be licensed under the Apache-2.0 license or a
+//  compatible open source license.
+
+$version: "2"
+namespace OpenSearch
+
+@externalDocumentation(
+    "API Reference": "https://opensearch.org/docs/latest/search-plugins/search-pipelines/index/"
+)
+
+@xOperationGroup("search_pipeline.get_search_pipeline")
+@xVersionAdded("2.9")
+@readonly
+@suppress(["HttpUriConflict"])
+@http(method: "GET", uri: "/_search/pipeline/{pipeline}")
+@documentation("Retrieves information about a specified search pipeline.")
+operation GetSearchPipeline {
+    input: GetSearchPipeline_Input,
+    output: GetSearchPipeline_Output
+}

model/search_pipeline/get_search_pipeline/structures.smithy

@@ -0,0 +1,20 @@
+// SPDX-License-Identifier: Apache-2.0
+//
+//  The OpenSearch Contributors require contributions made to
+//  this file be licensed under the Apache-2.0 license or a
+//  compatible open source license.
+
+$version: "2"
+namespace OpenSearch
+
+@input
+structure GetSearchPipeline_Input {
+    @required
+    @httpLabel
+    pipeline: String,
+}
+
+structure GetSearchPipeline_Output {
+    @httpPayload
+    content: SearchPipeline
+}

model/search_pipeline/search_pipeline.smithy

@@ -0,0 +1,80 @@
+// SPDX-License-Identifier: Apache-2.0
+//
+//  The OpenSearch Contributors require contributions made to
+//  this file be licensed under the Apache-2.0 license or a
+//  compatible open source license.
+
+$version: "2"
+namespace OpenSearch
+
+structure SearchPipeline{
+    version: Integer,
+    request_processors: RequestProcessorsList,
+    response_processors: ResponseProcessorsList
+}
+
+list RequestProcessorsList {
+    member: RequestProcessors
+}
+
+list ResponseProcessorsList {
+    member: RequestProcessors
+}
+
+
+structure RequestProcessors {
+    filter_query: FilterQuery,
+    neural_query_enricher: NeuralQueryEnricher,
+    script: SearchScript
+}
+
+structure ResponseProcessors {
+    personalize_search_ranking: PersonalizeSearchRanking,
+    rename_field: RenameField,
+}
+
+structure FilterQuery {
+    query: UserDefinedObjectStructure,
+    tag: String,
+    description: String,
+    ignore_failure: Boolean
+}
+
+structure NeuralQueryEnricher {
+    default_model_id: String,
+    neural_field_default_id: NeuralFieldMap
+    tag: String,
+    description: String,
+}
+
+structure SearchScript {
+    source: String,
+    lang: String,
+    tag: String,
+    description: String,
+    ignore_failure: Boolean
+}
+
+structure PersonalizeSearchRanking {
+    campaign_arn: String,
+    recipe: String,
+    weight: Float,
+    item_id_field: String,
+    iam_role_arn: String,
+    tag: String,
+    description: String,
+    ignore_failure: Boolean
+}
+
+structure RenameField {
+    field: String,
+    target_field: String,
+    tag: String,
+    description: String,
+    ignore_failure: Boolean
+}
+
+map NeuralFieldMap {
+  key: String,
+  value: String
+}