/* 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.
*/
/*
* Modifications Copyright OpenSearch Contributors. See
* GitHub history for details.
*
* Licensed to Elasticsearch B.V. under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch B.V. licenses this file to you under
* the Apache License, Version 2.0 (the "License"); you may
* not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
using System;
using System.Runtime.Serialization;
namespace OpenSearch.Client
{
[MapsApi("update_by_query.json")]
public partial interface IUpdateByQueryRequest
{
///
/// Parallelize the update process by splitting a query into
/// multiple slices.
///
[DataMember(Name ="slice")]
ISlicedScroll Slice { get; set; }
///
/// Query to select documents to update
///
[DataMember(Name ="query")]
QueryContainer Query { get; set; }
///
/// A script specifying the update to make
///
[DataMember(Name ="script")]
IScript Script { get; set; }
///
/// Limit the number of processed documents
///
[DataMember(Name ="max_docs")]
long? MaximumDocuments { get; set; }
}
// ReSharper disable once UnusedMember.Global
// ReSharper disable once UnusedTypeParameter
public partial interface IUpdateByQueryRequest where TDocument : class { }
public partial class UpdateByQueryRequest
{
///
public ISlicedScroll Slice { get; set; }
///
public QueryContainer Query { get; set; }
///
public IScript Script { get; set; }
///
public long? MaximumDocuments { get; set; }
}
// ReSharper disable once UnusedTypeParameter
public partial class UpdateByQueryRequest where TDocument : class
{
}
public partial class UpdateByQueryDescriptor
where TDocument : class
{
QueryContainer IUpdateByQueryRequest.Query { get; set; }
IScript IUpdateByQueryRequest.Script { get; set; }
long? IUpdateByQueryRequest.MaximumDocuments { get; set; }
ISlicedScroll IUpdateByQueryRequest.Slice { get; set; }
///
/// Query that selects all documents
///
public UpdateByQueryDescriptor MatchAll() => Assign(new QueryContainerDescriptor().MatchAll(), (a, v) => a.Query = v);
///
public UpdateByQueryDescriptor Query(Func, QueryContainer> querySelector) =>
Assign(querySelector, (a, v) => a.Query = v?.Invoke(new QueryContainerDescriptor()));
///
public UpdateByQueryDescriptor Script(string script) => Assign((InlineScript)script, (a, v) => a.Script = v);
///
public UpdateByQueryDescriptor Script(Func scriptSelector) =>
Assign(scriptSelector, (a, v) => a.Script = v?.Invoke(new ScriptDescriptor()));
///
public UpdateByQueryDescriptor MaximumDocuments(long? maximumDocuments) =>
Assign(maximumDocuments, (a, v) => a.MaximumDocuments = v);
///
public UpdateByQueryDescriptor Slice(Func, ISlicedScroll> selector) =>
Assign(selector, (a, v) => a.Slice = v?.Invoke(new SlicedScrollDescriptor()));
}
}