From 417c1307c95d19eebcc9bea2badfb50f0a9a4037 Mon Sep 17 00:00:00 2001 From: Steve Gordon Date: Sat, 26 Mar 2022 15:17:52 +0000 Subject: [PATCH] Add CCR APIs --- .../_Generated/Api/ApiUrlsLookup.g.cs | 13 + .../CcrDeleteAutoFollowPatternRequest.g.cs | 67 +++ .../CcrDeleteAutoFollowPatternResponse.g.cs | 31 ++ .../Api/Ccr/CcrFollowInfoRequest.g.cs | 92 ++++ .../Api/Ccr/CcrFollowInfoResponse.g.cs | 31 ++ .../_Generated/Api/Ccr/CcrFollowRequest.g.cs | 490 ++++++++++++++++++ .../_Generated/Api/Ccr/CcrFollowResponse.g.cs | 39 ++ .../Api/Ccr/CcrFollowStatsRequest.g.cs | 92 ++++ .../Api/Ccr/CcrFollowStatsResponse.g.cs | 31 ++ .../Api/Ccr/CcrForgetFollowerRequest.g.cs | 227 ++++++++ .../Api/Ccr/CcrForgetFollowerResponse.g.cs | 31 ++ .../Ccr/CcrGetAutoFollowPatternRequest.g.cs | 67 +++ .../Ccr/CcrGetAutoFollowPatternResponse.g.cs | 31 ++ .../Ccr/CcrPauseAutoFollowPatternRequest.g.cs | 67 +++ .../CcrPauseAutoFollowPatternResponse.g.cs | 31 ++ .../Api/Ccr/CcrPauseFollowRequest.g.cs | 96 ++++ .../Api/Ccr/CcrPauseFollowResponse.g.cs | 31 ++ .../Ccr/CcrPutAutoFollowPatternRequest.g.cs | 334 ++++++++++++ .../Ccr/CcrPutAutoFollowPatternResponse.g.cs | 31 ++ .../CcrResumeAutoFollowPatternRequest.g.cs | 67 +++ .../CcrResumeAutoFollowPatternResponse.g.cs | 31 ++ .../Api/Ccr/CcrResumeFollowRequest.g.cs | 419 +++++++++++++++ .../Api/Ccr/CcrResumeFollowResponse.g.cs | 31 ++ .../_Generated/Api/Ccr/CcrStatsRequest.g.cs | 53 ++ .../_Generated/Api/Ccr/CcrStatsResponse.g.cs | 35 ++ .../Api/Ccr/CcrUnfollowRequest.g.cs | 96 ++++ .../Api/Ccr/CcrUnfollowResponse.g.cs | 31 ++ .../Client/ElasticsearchClient.Ccr.g.cs | 395 ++++++++++++++ .../Client/ElasticsearchClient.g.cs | 4 + .../Types/Ccr/AutoFollowPattern.g.cs | 37 ++ .../Types/Ccr/AutoFollowPatternSummary.g.cs | 53 ++ .../_Generated/Types/Ccr/AutoFollowStats.g.cs | 49 ++ .../Types/Ccr/AutoFollowedCluster.g.cs | 41 ++ .../Types/Ccr/FollowIndexStats.g.cs | 37 ++ .../_Generated/Types/Ccr/FollowStats.g.cs | 33 ++ .../_Generated/Types/Ccr/FollowerIndex.g.cs | 49 ++ .../Types/Ccr/FollowerIndexParameters.g.cs | 69 +++ .../_Generated/Types/Ccr/ReadException.g.cs | 41 ++ .../_Generated/Types/Ccr/ShardStats.g.cs | 145 ++++++ .../Types/Enums/Enums.Ccr.FollowInfo.g.cs | 68 +++ 40 files changed, 3616 insertions(+) create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowRequest.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowResponse.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.Ccr.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPattern.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPatternSummary.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowStats.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowedCluster.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowIndexStats.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowStats.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndex.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndexParameters.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ReadException.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ShardStats.g.cs create mode 100644 src/Elastic.Clients.Elasticsearch/_Generated/Types/Enums/Enums.Ccr.FollowInfo.g.cs diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/ApiUrlsLookup.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/ApiUrlsLookup.g.cs index 644aed632ce..eb05c61c9dc 100644 --- a/src/Elastic.Clients.Elasticsearch/_Generated/Api/ApiUrlsLookup.g.cs +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/ApiUrlsLookup.g.cs @@ -24,6 +24,19 @@ internal static class ApiUrlsLookups internal static ApiUrls AsyncSearchDelete = new ApiUrls(new[] { "/_async_search/{id}" }); internal static ApiUrls AsyncSearchGet = new ApiUrls(new[] { "/_async_search/{id}" }); internal static ApiUrls NoNamespaceBulk = new ApiUrls(new[] { "/_bulk", "/{index}/_bulk" }); + internal static ApiUrls CrossClusterReplicationDeleteAutoFollowPattern = new ApiUrls(new[] { "/_ccr/auto_follow/{name}" }); + internal static ApiUrls CrossClusterReplicationFollowInfo = new ApiUrls(new[] { "/{index}/_ccr/info" }); + internal static ApiUrls CrossClusterReplicationFollow = new ApiUrls(new[] { "/{index}/_ccr/follow" }); + internal static ApiUrls CrossClusterReplicationFollowStats = new ApiUrls(new[] { "/{index}/_ccr/stats" }); + internal static ApiUrls CrossClusterReplicationForgetFollower = new ApiUrls(new[] { "/{index}/_ccr/forget_follower" }); + internal static ApiUrls CrossClusterReplicationGetAutoFollowPattern = new ApiUrls(new[] { "/_ccr/auto_follow", "/_ccr/auto_follow/{name}" }); + internal static ApiUrls CrossClusterReplicationPauseAutoFollowPattern = new ApiUrls(new[] { "/_ccr/auto_follow/{name}/pause" }); + internal static ApiUrls CrossClusterReplicationPauseFollow = new ApiUrls(new[] { "/{index}/_ccr/pause_follow" }); + internal static ApiUrls CrossClusterReplicationPutAutoFollowPattern = new ApiUrls(new[] { "/_ccr/auto_follow/{name}" }); + internal static ApiUrls CrossClusterReplicationResumeAutoFollowPattern = new ApiUrls(new[] { "/_ccr/auto_follow/{name}/resume" }); + internal static ApiUrls CrossClusterReplicationResumeFollow = new ApiUrls(new[] { "/{index}/_ccr/resume_follow" }); + internal static ApiUrls CrossClusterReplicationStats = new ApiUrls(new[] { "/_ccr/stats" }); + internal static ApiUrls CrossClusterReplicationUnfollow = new ApiUrls(new[] { "/{index}/_ccr/unfollow" }); internal static ApiUrls NoNamespaceClosePointInTime = new ApiUrls(new[] { "/_pit" }); internal static ApiUrls ClusterAllocationExplain = new ApiUrls(new[] { "/_cluster/allocation/explain" }); internal static ApiUrls ClusterHealth = new ApiUrls(new[] { "/_cluster/health", "/_cluster/health/{index}" }); diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternRequest.g.cs new file mode 100644 index 00000000000..1232f0352e0 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternRequest.g.cs @@ -0,0 +1,67 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrDeleteAutoFollowPatternRequestParameters : RequestParameters + { + } + + public partial class CcrDeleteAutoFollowPatternRequest : PlainRequestBase + { + public CcrDeleteAutoFollowPatternRequest(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationDeleteAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.DELETE; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrDeleteAutoFollowPatternRequestDescriptor : RequestDescriptorBase + { + internal CcrDeleteAutoFollowPatternRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrDeleteAutoFollowPatternRequestDescriptor(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal CcrDeleteAutoFollowPatternRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationDeleteAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.DELETE; + protected override bool SupportsBody => false; + public CcrDeleteAutoFollowPatternRequestDescriptor Name(Elastic.Clients.Elasticsearch.Name name) + { + RouteValues.Required("name", name); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternResponse.g.cs new file mode 100644 index 00000000000..2357fda51f7 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrDeleteAutoFollowPatternResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrDeleteAutoFollowPatternResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("acknowledged")] + public bool Acknowledged { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoRequest.g.cs new file mode 100644 index 00000000000..aace2b7dbd6 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoRequest.g.cs @@ -0,0 +1,92 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrFollowInfoRequestParameters : RequestParameters + { + } + + public partial class CcrFollowInfoRequest : PlainRequestBase + { + public CcrFollowInfoRequest(Elastic.Clients.Elasticsearch.Indices indices) : base(r => r.Required("index", indices)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollowInfo; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrFollowInfoRequestDescriptor : RequestDescriptorBase, CcrFollowInfoRequestParameters> + { + internal CcrFollowInfoRequestDescriptor(Action> configure) => configure.Invoke(this); + public CcrFollowInfoRequestDescriptor(Elastic.Clients.Elasticsearch.Indices indices) : base(r => r.Required("index", indices)) + { + } + + internal CcrFollowInfoRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollowInfo; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + public CcrFollowInfoRequestDescriptor Indices(Elastic.Clients.Elasticsearch.Indices indices) + { + RouteValues.Required("index", indices); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } + + public sealed partial class CcrFollowInfoRequestDescriptor : RequestDescriptorBase + { + internal CcrFollowInfoRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrFollowInfoRequestDescriptor(Elastic.Clients.Elasticsearch.Indices indices) : base(r => r.Required("index", indices)) + { + } + + internal CcrFollowInfoRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollowInfo; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + public CcrFollowInfoRequestDescriptor Indices(Elastic.Clients.Elasticsearch.Indices indices) + { + RouteValues.Required("index", indices); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoResponse.g.cs new file mode 100644 index 00000000000..856dafed6eb --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowInfoResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrFollowInfoResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("follower_indices")] + public IReadOnlyCollection FollowerIndices { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowRequest.g.cs new file mode 100644 index 00000000000..74dc5dc67cd --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowRequest.g.cs @@ -0,0 +1,490 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrFollowRequestParameters : RequestParameters + { + [JsonIgnore] + public Elastic.Clients.Elasticsearch.WaitForActiveShards? WaitForActiveShards { get => Q("wait_for_active_shards"); set => Q("wait_for_active_shards", value); } + } + + public partial class CcrFollowRequest : PlainRequestBase + { + public CcrFollowRequest(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollow; + protected override HttpMethod HttpMethod => HttpMethod.PUT; + protected override bool SupportsBody => true; + [JsonIgnore] + public Elastic.Clients.Elasticsearch.WaitForActiveShards? WaitForActiveShards { get => Q("wait_for_active_shards"); set => Q("wait_for_active_shards", value); } + + [JsonInclude] + [JsonPropertyName("leader_index")] + public Elastic.Clients.Elasticsearch.IndexName? LeaderIndex { get; set; } + + [JsonInclude] + [JsonPropertyName("max_outstanding_read_requests")] + public long? MaxOutstandingReadRequests { get; set; } + + [JsonInclude] + [JsonPropertyName("max_outstanding_write_requests")] + public long? MaxOutstandingWriteRequests { get; set; } + + [JsonInclude] + [JsonPropertyName("max_read_request_operation_count")] + public long? MaxReadRequestOperationCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_read_request_size")] + public string? MaxReadRequestSize { get; set; } + + [JsonInclude] + [JsonPropertyName("max_retry_delay")] + public Elastic.Clients.Elasticsearch.Time? MaxRetryDelay { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_count")] + public long? MaxWriteBufferCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_size")] + public string? MaxWriteBufferSize { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_request_operation_count")] + public long? MaxWriteRequestOperationCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_request_size")] + public string? MaxWriteRequestSize { get; set; } + + [JsonInclude] + [JsonPropertyName("read_poll_timeout")] + public Elastic.Clients.Elasticsearch.Time? ReadPollTimeout { get; set; } + + [JsonInclude] + [JsonPropertyName("remote_cluster")] + public string? RemoteCluster { get; set; } + } + + public sealed partial class CcrFollowRequestDescriptor : RequestDescriptorBase, CcrFollowRequestParameters> + { + internal CcrFollowRequestDescriptor(Action> configure) => configure.Invoke(this); + public CcrFollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + public CcrFollowRequestDescriptor(TDocument document) : this(typeof(TDocument)) + { + } + + internal CcrFollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollow; + protected override HttpMethod HttpMethod => HttpMethod.PUT; + protected override bool SupportsBody => true; + public CcrFollowRequestDescriptor WaitForActiveShards(Elastic.Clients.Elasticsearch.WaitForActiveShards? waitForActiveShards) => Qs("wait_for_active_shards", waitForActiveShards); + public CcrFollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + private Elastic.Clients.Elasticsearch.IndexName? LeaderIndexValue { get; set; } + + private long? MaxOutstandingReadRequestsValue { get; set; } + + private long? MaxOutstandingWriteRequestsValue { get; set; } + + private long? MaxReadRequestOperationCountValue { get; set; } + + private string? MaxReadRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? MaxRetryDelayValue { get; set; } + + private long? MaxWriteBufferCountValue { get; set; } + + private string? MaxWriteBufferSizeValue { get; set; } + + private long? MaxWriteRequestOperationCountValue { get; set; } + + private string? MaxWriteRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? ReadPollTimeoutValue { get; set; } + + private string? RemoteClusterValue { get; set; } + + public CcrFollowRequestDescriptor LeaderIndex(Elastic.Clients.Elasticsearch.IndexName? leaderIndex) + { + LeaderIndexValue = leaderIndex; + return Self; + } + + public CcrFollowRequestDescriptor MaxOutstandingReadRequests(long? maxOutstandingReadRequests) + { + MaxOutstandingReadRequestsValue = maxOutstandingReadRequests; + return Self; + } + + public CcrFollowRequestDescriptor MaxOutstandingWriteRequests(long? maxOutstandingWriteRequests) + { + MaxOutstandingWriteRequestsValue = maxOutstandingWriteRequests; + return Self; + } + + public CcrFollowRequestDescriptor MaxReadRequestOperationCount(long? maxReadRequestOperationCount) + { + MaxReadRequestOperationCountValue = maxReadRequestOperationCount; + return Self; + } + + public CcrFollowRequestDescriptor MaxReadRequestSize(string? maxReadRequestSize) + { + MaxReadRequestSizeValue = maxReadRequestSize; + return Self; + } + + public CcrFollowRequestDescriptor MaxRetryDelay(Elastic.Clients.Elasticsearch.Time? maxRetryDelay) + { + MaxRetryDelayValue = maxRetryDelay; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteBufferCount(long? maxWriteBufferCount) + { + MaxWriteBufferCountValue = maxWriteBufferCount; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteBufferSize(string? maxWriteBufferSize) + { + MaxWriteBufferSizeValue = maxWriteBufferSize; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteRequestOperationCount(long? maxWriteRequestOperationCount) + { + MaxWriteRequestOperationCountValue = maxWriteRequestOperationCount; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteRequestSize(string? maxWriteRequestSize) + { + MaxWriteRequestSizeValue = maxWriteRequestSize; + return Self; + } + + public CcrFollowRequestDescriptor ReadPollTimeout(Elastic.Clients.Elasticsearch.Time? readPollTimeout) + { + ReadPollTimeoutValue = readPollTimeout; + return Self; + } + + public CcrFollowRequestDescriptor RemoteCluster(string? remoteCluster) + { + RemoteClusterValue = remoteCluster; + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + writer.WriteStartObject(); + if (LeaderIndexValue is not null) + { + writer.WritePropertyName("leader_index"); + JsonSerializer.Serialize(writer, LeaderIndexValue, options); + } + + if (MaxOutstandingReadRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_read_requests"); + writer.WriteNumberValue(MaxOutstandingReadRequestsValue.Value); + } + + if (MaxOutstandingWriteRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_write_requests"); + writer.WriteNumberValue(MaxOutstandingWriteRequestsValue.Value); + } + + if (MaxReadRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_read_request_operation_count"); + writer.WriteNumberValue(MaxReadRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxReadRequestSizeValue)) + { + writer.WritePropertyName("max_read_request_size"); + writer.WriteStringValue(MaxReadRequestSizeValue); + } + + if (MaxRetryDelayValue is not null) + { + writer.WritePropertyName("max_retry_delay"); + JsonSerializer.Serialize(writer, MaxRetryDelayValue, options); + } + + if (MaxWriteBufferCountValue.HasValue) + { + writer.WritePropertyName("max_write_buffer_count"); + writer.WriteNumberValue(MaxWriteBufferCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteBufferSizeValue)) + { + writer.WritePropertyName("max_write_buffer_size"); + writer.WriteStringValue(MaxWriteBufferSizeValue); + } + + if (MaxWriteRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_write_request_operation_count"); + writer.WriteNumberValue(MaxWriteRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteRequestSizeValue)) + { + writer.WritePropertyName("max_write_request_size"); + writer.WriteStringValue(MaxWriteRequestSizeValue); + } + + if (ReadPollTimeoutValue is not null) + { + writer.WritePropertyName("read_poll_timeout"); + JsonSerializer.Serialize(writer, ReadPollTimeoutValue, options); + } + + if (!string.IsNullOrEmpty(RemoteClusterValue)) + { + writer.WritePropertyName("remote_cluster"); + writer.WriteStringValue(RemoteClusterValue); + } + + writer.WriteEndObject(); + } + } + + public sealed partial class CcrFollowRequestDescriptor : RequestDescriptorBase + { + internal CcrFollowRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrFollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal CcrFollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollow; + protected override HttpMethod HttpMethod => HttpMethod.PUT; + protected override bool SupportsBody => true; + public CcrFollowRequestDescriptor WaitForActiveShards(Elastic.Clients.Elasticsearch.WaitForActiveShards? waitForActiveShards) => Qs("wait_for_active_shards", waitForActiveShards); + public CcrFollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + private Elastic.Clients.Elasticsearch.IndexName? LeaderIndexValue { get; set; } + + private long? MaxOutstandingReadRequestsValue { get; set; } + + private long? MaxOutstandingWriteRequestsValue { get; set; } + + private long? MaxReadRequestOperationCountValue { get; set; } + + private string? MaxReadRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? MaxRetryDelayValue { get; set; } + + private long? MaxWriteBufferCountValue { get; set; } + + private string? MaxWriteBufferSizeValue { get; set; } + + private long? MaxWriteRequestOperationCountValue { get; set; } + + private string? MaxWriteRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? ReadPollTimeoutValue { get; set; } + + private string? RemoteClusterValue { get; set; } + + public CcrFollowRequestDescriptor LeaderIndex(Elastic.Clients.Elasticsearch.IndexName? leaderIndex) + { + LeaderIndexValue = leaderIndex; + return Self; + } + + public CcrFollowRequestDescriptor MaxOutstandingReadRequests(long? maxOutstandingReadRequests) + { + MaxOutstandingReadRequestsValue = maxOutstandingReadRequests; + return Self; + } + + public CcrFollowRequestDescriptor MaxOutstandingWriteRequests(long? maxOutstandingWriteRequests) + { + MaxOutstandingWriteRequestsValue = maxOutstandingWriteRequests; + return Self; + } + + public CcrFollowRequestDescriptor MaxReadRequestOperationCount(long? maxReadRequestOperationCount) + { + MaxReadRequestOperationCountValue = maxReadRequestOperationCount; + return Self; + } + + public CcrFollowRequestDescriptor MaxReadRequestSize(string? maxReadRequestSize) + { + MaxReadRequestSizeValue = maxReadRequestSize; + return Self; + } + + public CcrFollowRequestDescriptor MaxRetryDelay(Elastic.Clients.Elasticsearch.Time? maxRetryDelay) + { + MaxRetryDelayValue = maxRetryDelay; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteBufferCount(long? maxWriteBufferCount) + { + MaxWriteBufferCountValue = maxWriteBufferCount; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteBufferSize(string? maxWriteBufferSize) + { + MaxWriteBufferSizeValue = maxWriteBufferSize; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteRequestOperationCount(long? maxWriteRequestOperationCount) + { + MaxWriteRequestOperationCountValue = maxWriteRequestOperationCount; + return Self; + } + + public CcrFollowRequestDescriptor MaxWriteRequestSize(string? maxWriteRequestSize) + { + MaxWriteRequestSizeValue = maxWriteRequestSize; + return Self; + } + + public CcrFollowRequestDescriptor ReadPollTimeout(Elastic.Clients.Elasticsearch.Time? readPollTimeout) + { + ReadPollTimeoutValue = readPollTimeout; + return Self; + } + + public CcrFollowRequestDescriptor RemoteCluster(string? remoteCluster) + { + RemoteClusterValue = remoteCluster; + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + writer.WriteStartObject(); + if (LeaderIndexValue is not null) + { + writer.WritePropertyName("leader_index"); + JsonSerializer.Serialize(writer, LeaderIndexValue, options); + } + + if (MaxOutstandingReadRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_read_requests"); + writer.WriteNumberValue(MaxOutstandingReadRequestsValue.Value); + } + + if (MaxOutstandingWriteRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_write_requests"); + writer.WriteNumberValue(MaxOutstandingWriteRequestsValue.Value); + } + + if (MaxReadRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_read_request_operation_count"); + writer.WriteNumberValue(MaxReadRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxReadRequestSizeValue)) + { + writer.WritePropertyName("max_read_request_size"); + writer.WriteStringValue(MaxReadRequestSizeValue); + } + + if (MaxRetryDelayValue is not null) + { + writer.WritePropertyName("max_retry_delay"); + JsonSerializer.Serialize(writer, MaxRetryDelayValue, options); + } + + if (MaxWriteBufferCountValue.HasValue) + { + writer.WritePropertyName("max_write_buffer_count"); + writer.WriteNumberValue(MaxWriteBufferCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteBufferSizeValue)) + { + writer.WritePropertyName("max_write_buffer_size"); + writer.WriteStringValue(MaxWriteBufferSizeValue); + } + + if (MaxWriteRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_write_request_operation_count"); + writer.WriteNumberValue(MaxWriteRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteRequestSizeValue)) + { + writer.WritePropertyName("max_write_request_size"); + writer.WriteStringValue(MaxWriteRequestSizeValue); + } + + if (ReadPollTimeoutValue is not null) + { + writer.WritePropertyName("read_poll_timeout"); + JsonSerializer.Serialize(writer, ReadPollTimeoutValue, options); + } + + if (!string.IsNullOrEmpty(RemoteClusterValue)) + { + writer.WritePropertyName("remote_cluster"); + writer.WriteStringValue(RemoteClusterValue); + } + + writer.WriteEndObject(); + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowResponse.g.cs new file mode 100644 index 00000000000..0caf57ccb81 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowResponse.g.cs @@ -0,0 +1,39 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrFollowResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("follow_index_created")] + public bool FollowIndexCreated { get; init; } + + [JsonInclude] + [JsonPropertyName("follow_index_shards_acked")] + public bool FollowIndexShardsAcked { get; init; } + + [JsonInclude] + [JsonPropertyName("index_following_started")] + public bool IndexFollowingStarted { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsRequest.g.cs new file mode 100644 index 00000000000..1e7bb5cd857 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsRequest.g.cs @@ -0,0 +1,92 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrFollowStatsRequestParameters : RequestParameters + { + } + + public partial class CcrFollowStatsRequest : PlainRequestBase + { + public CcrFollowStatsRequest(Elastic.Clients.Elasticsearch.Indices indices) : base(r => r.Required("index", indices)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollowStats; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrFollowStatsRequestDescriptor : RequestDescriptorBase, CcrFollowStatsRequestParameters> + { + internal CcrFollowStatsRequestDescriptor(Action> configure) => configure.Invoke(this); + public CcrFollowStatsRequestDescriptor(Elastic.Clients.Elasticsearch.Indices indices) : base(r => r.Required("index", indices)) + { + } + + internal CcrFollowStatsRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollowStats; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + public CcrFollowStatsRequestDescriptor Indices(Elastic.Clients.Elasticsearch.Indices indices) + { + RouteValues.Required("index", indices); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } + + public sealed partial class CcrFollowStatsRequestDescriptor : RequestDescriptorBase + { + internal CcrFollowStatsRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrFollowStatsRequestDescriptor(Elastic.Clients.Elasticsearch.Indices indices) : base(r => r.Required("index", indices)) + { + } + + internal CcrFollowStatsRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationFollowStats; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + public CcrFollowStatsRequestDescriptor Indices(Elastic.Clients.Elasticsearch.Indices indices) + { + RouteValues.Required("index", indices); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsResponse.g.cs new file mode 100644 index 00000000000..32ace04dc56 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrFollowStatsResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrFollowStatsResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("indices")] + public IReadOnlyCollection Indices { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerRequest.g.cs new file mode 100644 index 00000000000..d973bd959da --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerRequest.g.cs @@ -0,0 +1,227 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrForgetFollowerRequestParameters : RequestParameters + { + } + + public partial class CcrForgetFollowerRequest : PlainRequestBase + { + public CcrForgetFollowerRequest(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationForgetFollower; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => true; + [JsonInclude] + [JsonPropertyName("follower_cluster")] + public string? FollowerCluster { get; set; } + + [JsonInclude] + [JsonPropertyName("follower_index")] + public Elastic.Clients.Elasticsearch.IndexName? FollowerIndex { get; set; } + + [JsonInclude] + [JsonPropertyName("follower_index_uuid")] + public string? FollowerIndexUuid { get; set; } + + [JsonInclude] + [JsonPropertyName("leader_remote_cluster")] + public string? LeaderRemoteCluster { get; set; } + } + + public sealed partial class CcrForgetFollowerRequestDescriptor : RequestDescriptorBase, CcrForgetFollowerRequestParameters> + { + internal CcrForgetFollowerRequestDescriptor(Action> configure) => configure.Invoke(this); + public CcrForgetFollowerRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + public CcrForgetFollowerRequestDescriptor(TDocument document) : this(typeof(TDocument)) + { + } + + internal CcrForgetFollowerRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationForgetFollower; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => true; + public CcrForgetFollowerRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + private string? FollowerClusterValue { get; set; } + + private Elastic.Clients.Elasticsearch.IndexName? FollowerIndexValue { get; set; } + + private string? FollowerIndexUuidValue { get; set; } + + private string? LeaderRemoteClusterValue { get; set; } + + public CcrForgetFollowerRequestDescriptor FollowerCluster(string? followerCluster) + { + FollowerClusterValue = followerCluster; + return Self; + } + + public CcrForgetFollowerRequestDescriptor FollowerIndex(Elastic.Clients.Elasticsearch.IndexName? followerIndex) + { + FollowerIndexValue = followerIndex; + return Self; + } + + public CcrForgetFollowerRequestDescriptor FollowerIndexUuid(string? followerIndexUuid) + { + FollowerIndexUuidValue = followerIndexUuid; + return Self; + } + + public CcrForgetFollowerRequestDescriptor LeaderRemoteCluster(string? leaderRemoteCluster) + { + LeaderRemoteClusterValue = leaderRemoteCluster; + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + writer.WriteStartObject(); + if (!string.IsNullOrEmpty(FollowerClusterValue)) + { + writer.WritePropertyName("follower_cluster"); + writer.WriteStringValue(FollowerClusterValue); + } + + if (FollowerIndexValue is not null) + { + writer.WritePropertyName("follower_index"); + JsonSerializer.Serialize(writer, FollowerIndexValue, options); + } + + if (FollowerIndexUuidValue is not null) + { + writer.WritePropertyName("follower_index_uuid"); + JsonSerializer.Serialize(writer, FollowerIndexUuidValue, options); + } + + if (!string.IsNullOrEmpty(LeaderRemoteClusterValue)) + { + writer.WritePropertyName("leader_remote_cluster"); + writer.WriteStringValue(LeaderRemoteClusterValue); + } + + writer.WriteEndObject(); + } + } + + public sealed partial class CcrForgetFollowerRequestDescriptor : RequestDescriptorBase + { + internal CcrForgetFollowerRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrForgetFollowerRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal CcrForgetFollowerRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationForgetFollower; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => true; + public CcrForgetFollowerRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + private string? FollowerClusterValue { get; set; } + + private Elastic.Clients.Elasticsearch.IndexName? FollowerIndexValue { get; set; } + + private string? FollowerIndexUuidValue { get; set; } + + private string? LeaderRemoteClusterValue { get; set; } + + public CcrForgetFollowerRequestDescriptor FollowerCluster(string? followerCluster) + { + FollowerClusterValue = followerCluster; + return Self; + } + + public CcrForgetFollowerRequestDescriptor FollowerIndex(Elastic.Clients.Elasticsearch.IndexName? followerIndex) + { + FollowerIndexValue = followerIndex; + return Self; + } + + public CcrForgetFollowerRequestDescriptor FollowerIndexUuid(string? followerIndexUuid) + { + FollowerIndexUuidValue = followerIndexUuid; + return Self; + } + + public CcrForgetFollowerRequestDescriptor LeaderRemoteCluster(string? leaderRemoteCluster) + { + LeaderRemoteClusterValue = leaderRemoteCluster; + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + writer.WriteStartObject(); + if (!string.IsNullOrEmpty(FollowerClusterValue)) + { + writer.WritePropertyName("follower_cluster"); + writer.WriteStringValue(FollowerClusterValue); + } + + if (FollowerIndexValue is not null) + { + writer.WritePropertyName("follower_index"); + JsonSerializer.Serialize(writer, FollowerIndexValue, options); + } + + if (FollowerIndexUuidValue is not null) + { + writer.WritePropertyName("follower_index_uuid"); + JsonSerializer.Serialize(writer, FollowerIndexUuidValue, options); + } + + if (!string.IsNullOrEmpty(LeaderRemoteClusterValue)) + { + writer.WritePropertyName("leader_remote_cluster"); + writer.WriteStringValue(LeaderRemoteClusterValue); + } + + writer.WriteEndObject(); + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerResponse.g.cs new file mode 100644 index 00000000000..e3ca81d4596 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrForgetFollowerResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrForgetFollowerResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("_shards")] + public Elastic.Clients.Elasticsearch.ShardStatistics Shards { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternRequest.g.cs new file mode 100644 index 00000000000..9b23fbed733 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternRequest.g.cs @@ -0,0 +1,67 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrGetAutoFollowPatternRequestParameters : RequestParameters + { + } + + public partial class CcrGetAutoFollowPatternRequest : PlainRequestBase + { + public CcrGetAutoFollowPatternRequest() + { + } + + public CcrGetAutoFollowPatternRequest(Elastic.Clients.Elasticsearch.Name? name) : base(r => r.Optional("name", name)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationGetAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrGetAutoFollowPatternRequestDescriptor : RequestDescriptorBase + { + internal CcrGetAutoFollowPatternRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrGetAutoFollowPatternRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationGetAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + public CcrGetAutoFollowPatternRequestDescriptor Name(Elastic.Clients.Elasticsearch.Name? name) + { + RouteValues.Optional("name", name); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternResponse.g.cs new file mode 100644 index 00000000000..bd288446587 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrGetAutoFollowPatternResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrGetAutoFollowPatternResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("patterns")] + public IReadOnlyCollection Patterns { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternRequest.g.cs new file mode 100644 index 00000000000..2b737084054 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternRequest.g.cs @@ -0,0 +1,67 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrPauseAutoFollowPatternRequestParameters : RequestParameters + { + } + + public partial class CcrPauseAutoFollowPatternRequest : PlainRequestBase + { + public CcrPauseAutoFollowPatternRequest(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationPauseAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrPauseAutoFollowPatternRequestDescriptor : RequestDescriptorBase + { + internal CcrPauseAutoFollowPatternRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrPauseAutoFollowPatternRequestDescriptor(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal CcrPauseAutoFollowPatternRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationPauseAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + public CcrPauseAutoFollowPatternRequestDescriptor Name(Elastic.Clients.Elasticsearch.Name name) + { + RouteValues.Required("name", name); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternResponse.g.cs new file mode 100644 index 00000000000..82b101e51a5 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseAutoFollowPatternResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrPauseAutoFollowPatternResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("acknowledged")] + public bool Acknowledged { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowRequest.g.cs new file mode 100644 index 00000000000..369e53e6838 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowRequest.g.cs @@ -0,0 +1,96 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrPauseFollowRequestParameters : RequestParameters + { + } + + public partial class CcrPauseFollowRequest : PlainRequestBase + { + public CcrPauseFollowRequest(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationPauseFollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrPauseFollowRequestDescriptor : RequestDescriptorBase, CcrPauseFollowRequestParameters> + { + internal CcrPauseFollowRequestDescriptor(Action> configure) => configure.Invoke(this); + public CcrPauseFollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + public CcrPauseFollowRequestDescriptor(TDocument document) : this(typeof(TDocument)) + { + } + + internal CcrPauseFollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationPauseFollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + public CcrPauseFollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } + + public sealed partial class CcrPauseFollowRequestDescriptor : RequestDescriptorBase + { + internal CcrPauseFollowRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrPauseFollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal CcrPauseFollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationPauseFollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + public CcrPauseFollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowResponse.g.cs new file mode 100644 index 00000000000..30b6248a3b2 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPauseFollowResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrPauseFollowResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("acknowledged")] + public bool Acknowledged { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternRequest.g.cs new file mode 100644 index 00000000000..a4cc154e813 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternRequest.g.cs @@ -0,0 +1,334 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrPutAutoFollowPatternRequestParameters : RequestParameters + { + } + + public partial class CcrPutAutoFollowPatternRequest : PlainRequestBase + { + public CcrPutAutoFollowPatternRequest(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationPutAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.PUT; + protected override bool SupportsBody => true; + [JsonInclude] + [JsonPropertyName("remote_cluster")] + public string RemoteCluster { get; set; } + + [JsonInclude] + [JsonPropertyName("follow_index_pattern")] + public string? FollowIndexPattern { get; set; } + + [JsonInclude] + [JsonPropertyName("leader_index_patterns")] + public IEnumerable? LeaderIndexPatterns { get; set; } + + [JsonInclude] + [JsonPropertyName("leader_index_exclusion_patterns")] + public IEnumerable? LeaderIndexExclusionPatterns { get; set; } + + [JsonInclude] + [JsonPropertyName("max_outstanding_read_requests")] + public int? MaxOutstandingReadRequests { get; set; } + + [JsonInclude] + [JsonPropertyName("settings")] + public Dictionary? Settings { get; set; } + + [JsonInclude] + [JsonPropertyName("max_outstanding_write_requests")] + public int? MaxOutstandingWriteRequests { get; set; } + + [JsonInclude] + [JsonPropertyName("read_poll_timeout")] + public Elastic.Clients.Elasticsearch.Time? ReadPollTimeout { get; set; } + + [JsonInclude] + [JsonPropertyName("max_read_request_operation_count")] + public int? MaxReadRequestOperationCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_read_request_size")] + public Elastic.Clients.Elasticsearch.ByteSize? MaxReadRequestSize { get; set; } + + [JsonInclude] + [JsonPropertyName("max_retry_delay")] + public Elastic.Clients.Elasticsearch.Time? MaxRetryDelay { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_count")] + public int? MaxWriteBufferCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_size")] + public Elastic.Clients.Elasticsearch.ByteSize? MaxWriteBufferSize { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_request_operation_count")] + public int? MaxWriteRequestOperationCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_request_size")] + public Elastic.Clients.Elasticsearch.ByteSize? MaxWriteRequestSize { get; set; } + } + + public sealed partial class CcrPutAutoFollowPatternRequestDescriptor : RequestDescriptorBase + { + internal CcrPutAutoFollowPatternRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrPutAutoFollowPatternRequestDescriptor(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal CcrPutAutoFollowPatternRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationPutAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.PUT; + protected override bool SupportsBody => true; + public CcrPutAutoFollowPatternRequestDescriptor Name(Elastic.Clients.Elasticsearch.Name name) + { + RouteValues.Required("name", name); + return Self; + } + + private string? FollowIndexPatternValue { get; set; } + + private IEnumerable? LeaderIndexExclusionPatternsValue { get; set; } + + private IEnumerable? LeaderIndexPatternsValue { get; set; } + + private int? MaxOutstandingReadRequestsValue { get; set; } + + private int? MaxOutstandingWriteRequestsValue { get; set; } + + private int? MaxReadRequestOperationCountValue { get; set; } + + private Elastic.Clients.Elasticsearch.ByteSize? MaxReadRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? MaxRetryDelayValue { get; set; } + + private int? MaxWriteBufferCountValue { get; set; } + + private Elastic.Clients.Elasticsearch.ByteSize? MaxWriteBufferSizeValue { get; set; } + + private int? MaxWriteRequestOperationCountValue { get; set; } + + private Elastic.Clients.Elasticsearch.ByteSize? MaxWriteRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? ReadPollTimeoutValue { get; set; } + + private string RemoteClusterValue { get; set; } + + private Dictionary? SettingsValue { get; set; } + + public CcrPutAutoFollowPatternRequestDescriptor FollowIndexPattern(string? followIndexPattern) + { + FollowIndexPatternValue = followIndexPattern; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor LeaderIndexExclusionPatterns(IEnumerable? leaderIndexExclusionPatterns) + { + LeaderIndexExclusionPatternsValue = leaderIndexExclusionPatterns; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor LeaderIndexPatterns(IEnumerable? leaderIndexPatterns) + { + LeaderIndexPatternsValue = leaderIndexPatterns; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxOutstandingReadRequests(int? maxOutstandingReadRequests) + { + MaxOutstandingReadRequestsValue = maxOutstandingReadRequests; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxOutstandingWriteRequests(int? maxOutstandingWriteRequests) + { + MaxOutstandingWriteRequestsValue = maxOutstandingWriteRequests; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxReadRequestOperationCount(int? maxReadRequestOperationCount) + { + MaxReadRequestOperationCountValue = maxReadRequestOperationCount; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxReadRequestSize(Elastic.Clients.Elasticsearch.ByteSize? maxReadRequestSize) + { + MaxReadRequestSizeValue = maxReadRequestSize; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxRetryDelay(Elastic.Clients.Elasticsearch.Time? maxRetryDelay) + { + MaxRetryDelayValue = maxRetryDelay; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxWriteBufferCount(int? maxWriteBufferCount) + { + MaxWriteBufferCountValue = maxWriteBufferCount; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxWriteBufferSize(Elastic.Clients.Elasticsearch.ByteSize? maxWriteBufferSize) + { + MaxWriteBufferSizeValue = maxWriteBufferSize; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxWriteRequestOperationCount(int? maxWriteRequestOperationCount) + { + MaxWriteRequestOperationCountValue = maxWriteRequestOperationCount; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor MaxWriteRequestSize(Elastic.Clients.Elasticsearch.ByteSize? maxWriteRequestSize) + { + MaxWriteRequestSizeValue = maxWriteRequestSize; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor ReadPollTimeout(Elastic.Clients.Elasticsearch.Time? readPollTimeout) + { + ReadPollTimeoutValue = readPollTimeout; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor RemoteCluster(string remoteCluster) + { + RemoteClusterValue = remoteCluster; + return Self; + } + + public CcrPutAutoFollowPatternRequestDescriptor Settings(Func, FluentDictionary> selector) + { + SettingsValue = selector?.Invoke(new FluentDictionary()); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + writer.WriteStartObject(); + if (FollowIndexPatternValue is not null) + { + writer.WritePropertyName("follow_index_pattern"); + JsonSerializer.Serialize(writer, FollowIndexPatternValue, options); + } + + if (LeaderIndexExclusionPatternsValue is not null) + { + writer.WritePropertyName("leader_index_exclusion_patterns"); + JsonSerializer.Serialize(writer, LeaderIndexExclusionPatternsValue, options); + } + + if (LeaderIndexPatternsValue is not null) + { + writer.WritePropertyName("leader_index_patterns"); + JsonSerializer.Serialize(writer, LeaderIndexPatternsValue, options); + } + + if (MaxOutstandingReadRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_read_requests"); + writer.WriteNumberValue(MaxOutstandingReadRequestsValue.Value); + } + + if (MaxOutstandingWriteRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_write_requests"); + writer.WriteNumberValue(MaxOutstandingWriteRequestsValue.Value); + } + + if (MaxReadRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_read_request_operation_count"); + writer.WriteNumberValue(MaxReadRequestOperationCountValue.Value); + } + + if (MaxReadRequestSizeValue is not null) + { + writer.WritePropertyName("max_read_request_size"); + JsonSerializer.Serialize(writer, MaxReadRequestSizeValue, options); + } + + if (MaxRetryDelayValue is not null) + { + writer.WritePropertyName("max_retry_delay"); + JsonSerializer.Serialize(writer, MaxRetryDelayValue, options); + } + + if (MaxWriteBufferCountValue.HasValue) + { + writer.WritePropertyName("max_write_buffer_count"); + writer.WriteNumberValue(MaxWriteBufferCountValue.Value); + } + + if (MaxWriteBufferSizeValue is not null) + { + writer.WritePropertyName("max_write_buffer_size"); + JsonSerializer.Serialize(writer, MaxWriteBufferSizeValue, options); + } + + if (MaxWriteRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_write_request_operation_count"); + writer.WriteNumberValue(MaxWriteRequestOperationCountValue.Value); + } + + if (MaxWriteRequestSizeValue is not null) + { + writer.WritePropertyName("max_write_request_size"); + JsonSerializer.Serialize(writer, MaxWriteRequestSizeValue, options); + } + + if (ReadPollTimeoutValue is not null) + { + writer.WritePropertyName("read_poll_timeout"); + JsonSerializer.Serialize(writer, ReadPollTimeoutValue, options); + } + + writer.WritePropertyName("remote_cluster"); + writer.WriteStringValue(RemoteClusterValue); + if (SettingsValue is not null) + { + writer.WritePropertyName("settings"); + JsonSerializer.Serialize(writer, SettingsValue, options); + } + + writer.WriteEndObject(); + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternResponse.g.cs new file mode 100644 index 00000000000..b42834faf04 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrPutAutoFollowPatternResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrPutAutoFollowPatternResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("acknowledged")] + public bool Acknowledged { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternRequest.g.cs new file mode 100644 index 00000000000..f8983c7ac28 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternRequest.g.cs @@ -0,0 +1,67 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrResumeAutoFollowPatternRequestParameters : RequestParameters + { + } + + public partial class CcrResumeAutoFollowPatternRequest : PlainRequestBase + { + public CcrResumeAutoFollowPatternRequest(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationResumeAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrResumeAutoFollowPatternRequestDescriptor : RequestDescriptorBase + { + internal CcrResumeAutoFollowPatternRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrResumeAutoFollowPatternRequestDescriptor(Elastic.Clients.Elasticsearch.Name name) : base(r => r.Required("name", name)) + { + } + + internal CcrResumeAutoFollowPatternRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationResumeAutoFollowPattern; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + public CcrResumeAutoFollowPatternRequestDescriptor Name(Elastic.Clients.Elasticsearch.Name name) + { + RouteValues.Required("name", name); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternResponse.g.cs new file mode 100644 index 00000000000..c8d66bfb055 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeAutoFollowPatternResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrResumeAutoFollowPatternResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("acknowledged")] + public bool Acknowledged { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowRequest.g.cs new file mode 100644 index 00000000000..971f255261d --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowRequest.g.cs @@ -0,0 +1,419 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrResumeFollowRequestParameters : RequestParameters + { + } + + public partial class CcrResumeFollowRequest : PlainRequestBase + { + public CcrResumeFollowRequest(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationResumeFollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => true; + [JsonInclude] + [JsonPropertyName("max_outstanding_read_requests")] + public long? MaxOutstandingReadRequests { get; set; } + + [JsonInclude] + [JsonPropertyName("max_outstanding_write_requests")] + public long? MaxOutstandingWriteRequests { get; set; } + + [JsonInclude] + [JsonPropertyName("max_read_request_operation_count")] + public long? MaxReadRequestOperationCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_read_request_size")] + public string? MaxReadRequestSize { get; set; } + + [JsonInclude] + [JsonPropertyName("max_retry_delay")] + public Elastic.Clients.Elasticsearch.Time? MaxRetryDelay { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_count")] + public long? MaxWriteBufferCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_size")] + public string? MaxWriteBufferSize { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_request_operation_count")] + public long? MaxWriteRequestOperationCount { get; set; } + + [JsonInclude] + [JsonPropertyName("max_write_request_size")] + public string? MaxWriteRequestSize { get; set; } + + [JsonInclude] + [JsonPropertyName("read_poll_timeout")] + public Elastic.Clients.Elasticsearch.Time? ReadPollTimeout { get; set; } + } + + public sealed partial class CcrResumeFollowRequestDescriptor : RequestDescriptorBase, CcrResumeFollowRequestParameters> + { + internal CcrResumeFollowRequestDescriptor(Action> configure) => configure.Invoke(this); + public CcrResumeFollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + public CcrResumeFollowRequestDescriptor(TDocument document) : this(typeof(TDocument)) + { + } + + internal CcrResumeFollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationResumeFollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => true; + public CcrResumeFollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + private long? MaxOutstandingReadRequestsValue { get; set; } + + private long? MaxOutstandingWriteRequestsValue { get; set; } + + private long? MaxReadRequestOperationCountValue { get; set; } + + private string? MaxReadRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? MaxRetryDelayValue { get; set; } + + private long? MaxWriteBufferCountValue { get; set; } + + private string? MaxWriteBufferSizeValue { get; set; } + + private long? MaxWriteRequestOperationCountValue { get; set; } + + private string? MaxWriteRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? ReadPollTimeoutValue { get; set; } + + public CcrResumeFollowRequestDescriptor MaxOutstandingReadRequests(long? maxOutstandingReadRequests) + { + MaxOutstandingReadRequestsValue = maxOutstandingReadRequests; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxOutstandingWriteRequests(long? maxOutstandingWriteRequests) + { + MaxOutstandingWriteRequestsValue = maxOutstandingWriteRequests; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxReadRequestOperationCount(long? maxReadRequestOperationCount) + { + MaxReadRequestOperationCountValue = maxReadRequestOperationCount; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxReadRequestSize(string? maxReadRequestSize) + { + MaxReadRequestSizeValue = maxReadRequestSize; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxRetryDelay(Elastic.Clients.Elasticsearch.Time? maxRetryDelay) + { + MaxRetryDelayValue = maxRetryDelay; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteBufferCount(long? maxWriteBufferCount) + { + MaxWriteBufferCountValue = maxWriteBufferCount; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteBufferSize(string? maxWriteBufferSize) + { + MaxWriteBufferSizeValue = maxWriteBufferSize; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteRequestOperationCount(long? maxWriteRequestOperationCount) + { + MaxWriteRequestOperationCountValue = maxWriteRequestOperationCount; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteRequestSize(string? maxWriteRequestSize) + { + MaxWriteRequestSizeValue = maxWriteRequestSize; + return Self; + } + + public CcrResumeFollowRequestDescriptor ReadPollTimeout(Elastic.Clients.Elasticsearch.Time? readPollTimeout) + { + ReadPollTimeoutValue = readPollTimeout; + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + writer.WriteStartObject(); + if (MaxOutstandingReadRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_read_requests"); + writer.WriteNumberValue(MaxOutstandingReadRequestsValue.Value); + } + + if (MaxOutstandingWriteRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_write_requests"); + writer.WriteNumberValue(MaxOutstandingWriteRequestsValue.Value); + } + + if (MaxReadRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_read_request_operation_count"); + writer.WriteNumberValue(MaxReadRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxReadRequestSizeValue)) + { + writer.WritePropertyName("max_read_request_size"); + writer.WriteStringValue(MaxReadRequestSizeValue); + } + + if (MaxRetryDelayValue is not null) + { + writer.WritePropertyName("max_retry_delay"); + JsonSerializer.Serialize(writer, MaxRetryDelayValue, options); + } + + if (MaxWriteBufferCountValue.HasValue) + { + writer.WritePropertyName("max_write_buffer_count"); + writer.WriteNumberValue(MaxWriteBufferCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteBufferSizeValue)) + { + writer.WritePropertyName("max_write_buffer_size"); + writer.WriteStringValue(MaxWriteBufferSizeValue); + } + + if (MaxWriteRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_write_request_operation_count"); + writer.WriteNumberValue(MaxWriteRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteRequestSizeValue)) + { + writer.WritePropertyName("max_write_request_size"); + writer.WriteStringValue(MaxWriteRequestSizeValue); + } + + if (ReadPollTimeoutValue is not null) + { + writer.WritePropertyName("read_poll_timeout"); + JsonSerializer.Serialize(writer, ReadPollTimeoutValue, options); + } + + writer.WriteEndObject(); + } + } + + public sealed partial class CcrResumeFollowRequestDescriptor : RequestDescriptorBase + { + internal CcrResumeFollowRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrResumeFollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal CcrResumeFollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationResumeFollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => true; + public CcrResumeFollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + private long? MaxOutstandingReadRequestsValue { get; set; } + + private long? MaxOutstandingWriteRequestsValue { get; set; } + + private long? MaxReadRequestOperationCountValue { get; set; } + + private string? MaxReadRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? MaxRetryDelayValue { get; set; } + + private long? MaxWriteBufferCountValue { get; set; } + + private string? MaxWriteBufferSizeValue { get; set; } + + private long? MaxWriteRequestOperationCountValue { get; set; } + + private string? MaxWriteRequestSizeValue { get; set; } + + private Elastic.Clients.Elasticsearch.Time? ReadPollTimeoutValue { get; set; } + + public CcrResumeFollowRequestDescriptor MaxOutstandingReadRequests(long? maxOutstandingReadRequests) + { + MaxOutstandingReadRequestsValue = maxOutstandingReadRequests; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxOutstandingWriteRequests(long? maxOutstandingWriteRequests) + { + MaxOutstandingWriteRequestsValue = maxOutstandingWriteRequests; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxReadRequestOperationCount(long? maxReadRequestOperationCount) + { + MaxReadRequestOperationCountValue = maxReadRequestOperationCount; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxReadRequestSize(string? maxReadRequestSize) + { + MaxReadRequestSizeValue = maxReadRequestSize; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxRetryDelay(Elastic.Clients.Elasticsearch.Time? maxRetryDelay) + { + MaxRetryDelayValue = maxRetryDelay; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteBufferCount(long? maxWriteBufferCount) + { + MaxWriteBufferCountValue = maxWriteBufferCount; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteBufferSize(string? maxWriteBufferSize) + { + MaxWriteBufferSizeValue = maxWriteBufferSize; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteRequestOperationCount(long? maxWriteRequestOperationCount) + { + MaxWriteRequestOperationCountValue = maxWriteRequestOperationCount; + return Self; + } + + public CcrResumeFollowRequestDescriptor MaxWriteRequestSize(string? maxWriteRequestSize) + { + MaxWriteRequestSizeValue = maxWriteRequestSize; + return Self; + } + + public CcrResumeFollowRequestDescriptor ReadPollTimeout(Elastic.Clients.Elasticsearch.Time? readPollTimeout) + { + ReadPollTimeoutValue = readPollTimeout; + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + writer.WriteStartObject(); + if (MaxOutstandingReadRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_read_requests"); + writer.WriteNumberValue(MaxOutstandingReadRequestsValue.Value); + } + + if (MaxOutstandingWriteRequestsValue.HasValue) + { + writer.WritePropertyName("max_outstanding_write_requests"); + writer.WriteNumberValue(MaxOutstandingWriteRequestsValue.Value); + } + + if (MaxReadRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_read_request_operation_count"); + writer.WriteNumberValue(MaxReadRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxReadRequestSizeValue)) + { + writer.WritePropertyName("max_read_request_size"); + writer.WriteStringValue(MaxReadRequestSizeValue); + } + + if (MaxRetryDelayValue is not null) + { + writer.WritePropertyName("max_retry_delay"); + JsonSerializer.Serialize(writer, MaxRetryDelayValue, options); + } + + if (MaxWriteBufferCountValue.HasValue) + { + writer.WritePropertyName("max_write_buffer_count"); + writer.WriteNumberValue(MaxWriteBufferCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteBufferSizeValue)) + { + writer.WritePropertyName("max_write_buffer_size"); + writer.WriteStringValue(MaxWriteBufferSizeValue); + } + + if (MaxWriteRequestOperationCountValue.HasValue) + { + writer.WritePropertyName("max_write_request_operation_count"); + writer.WriteNumberValue(MaxWriteRequestOperationCountValue.Value); + } + + if (!string.IsNullOrEmpty(MaxWriteRequestSizeValue)) + { + writer.WritePropertyName("max_write_request_size"); + writer.WriteStringValue(MaxWriteRequestSizeValue); + } + + if (ReadPollTimeoutValue is not null) + { + writer.WritePropertyName("read_poll_timeout"); + JsonSerializer.Serialize(writer, ReadPollTimeoutValue, options); + } + + writer.WriteEndObject(); + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowResponse.g.cs new file mode 100644 index 00000000000..55a843178d0 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrResumeFollowResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrResumeFollowResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("acknowledged")] + public bool Acknowledged { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsRequest.g.cs new file mode 100644 index 00000000000..adb9e8e3ef6 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsRequest.g.cs @@ -0,0 +1,53 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrStatsRequestParameters : RequestParameters + { + } + + public partial class CcrStatsRequest : PlainRequestBase + { + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationStats; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrStatsRequestDescriptor : RequestDescriptorBase + { + internal CcrStatsRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrStatsRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationStats; + protected override HttpMethod HttpMethod => HttpMethod.GET; + protected override bool SupportsBody => false; + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsResponse.g.cs new file mode 100644 index 00000000000..85db22c8780 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrStatsResponse.g.cs @@ -0,0 +1,35 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrStatsResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("auto_follow_stats")] + public Elastic.Clients.Elasticsearch.Ccr.Stats.AutoFollowStats AutoFollowStats { get; init; } + + [JsonInclude] + [JsonPropertyName("follow_stats")] + public Elastic.Clients.Elasticsearch.Ccr.Stats.FollowStats FollowStats { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowRequest.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowRequest.g.cs new file mode 100644 index 00000000000..73db0db94da --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowRequest.g.cs @@ -0,0 +1,96 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport; +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrUnfollowRequestParameters : RequestParameters + { + } + + public partial class CcrUnfollowRequest : PlainRequestBase + { + public CcrUnfollowRequest(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationUnfollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + } + + public sealed partial class CcrUnfollowRequestDescriptor : RequestDescriptorBase, CcrUnfollowRequestParameters> + { + internal CcrUnfollowRequestDescriptor(Action> configure) => configure.Invoke(this); + public CcrUnfollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + public CcrUnfollowRequestDescriptor(TDocument document) : this(typeof(TDocument)) + { + } + + internal CcrUnfollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationUnfollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + public CcrUnfollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } + + public sealed partial class CcrUnfollowRequestDescriptor : RequestDescriptorBase + { + internal CcrUnfollowRequestDescriptor(Action configure) => configure.Invoke(this); + public CcrUnfollowRequestDescriptor(Elastic.Clients.Elasticsearch.IndexName index) : base(r => r.Required("index", index)) + { + } + + internal CcrUnfollowRequestDescriptor() + { + } + + internal override ApiUrls ApiUrls => ApiUrlsLookups.CrossClusterReplicationUnfollow; + protected override HttpMethod HttpMethod => HttpMethod.POST; + protected override bool SupportsBody => false; + public CcrUnfollowRequestDescriptor Index(Elastic.Clients.Elasticsearch.IndexName index) + { + RouteValues.Required("index", index); + return Self; + } + + protected override void Serialize(Utf8JsonWriter writer, JsonSerializerOptions options, IElasticsearchClientSettings settings) + { + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowResponse.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowResponse.g.cs new file mode 100644 index 00000000000..c8671a638e2 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Api/Ccr/CcrUnfollowResponse.g.cs @@ -0,0 +1,31 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using Elastic.Transport.Products.Elasticsearch; +using System.Collections.Generic; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class CcrUnfollowResponse : ElasticsearchResponseBase + { + [JsonInclude] + [JsonPropertyName("acknowledged")] + public bool Acknowledged { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.Ccr.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.Ccr.g.cs new file mode 100644 index 00000000000..60508c42611 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.Ccr.g.cs @@ -0,0 +1,395 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Threading; +using System.Threading.Tasks; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public class CcrNamespace : NamespacedClientProxy + { + internal CcrNamespace(ElasticsearchClient client) : base(client) + { + } + + public CcrDeleteAutoFollowPatternResponse DeleteAutoFollowPattern(CcrDeleteAutoFollowPatternRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task DeleteAutoFollowPatternAsync(CcrDeleteAutoFollowPatternRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrDeleteAutoFollowPatternResponse DeleteAutoFollowPattern(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null) + { + var descriptor = new CcrDeleteAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task DeleteAutoFollowPatternAsync(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrDeleteAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrFollowInfoResponse FollowInfo(CcrFollowInfoRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task FollowInfoAsync(CcrFollowInfoRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrFollowInfoResponse FollowInfo(Elastic.Clients.Elasticsearch.Indices indices, Action configureRequest = null) + { + var descriptor = new CcrFollowInfoRequestDescriptor(indices); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task FollowInfoAsync(Elastic.Clients.Elasticsearch.Indices indices, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrFollowInfoRequestDescriptor(indices); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrFollowResponse Follow(CcrFollowRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task FollowAsync(CcrFollowRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrFollowResponse Follow(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null) + { + var descriptor = new CcrFollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task FollowAsync(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrFollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrFollowStatsResponse FollowStats(CcrFollowStatsRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task FollowStatsAsync(CcrFollowStatsRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrFollowStatsResponse FollowStats(Elastic.Clients.Elasticsearch.Indices indices, Action configureRequest = null) + { + var descriptor = new CcrFollowStatsRequestDescriptor(indices); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task FollowStatsAsync(Elastic.Clients.Elasticsearch.Indices indices, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrFollowStatsRequestDescriptor(indices); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrForgetFollowerResponse ForgetFollower(CcrForgetFollowerRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task ForgetFollowerAsync(CcrForgetFollowerRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrForgetFollowerResponse ForgetFollower(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null) + { + var descriptor = new CcrForgetFollowerRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task ForgetFollowerAsync(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrForgetFollowerRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrGetAutoFollowPatternResponse GetAutoFollowPattern(CcrGetAutoFollowPatternRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task GetAutoFollowPatternAsync(CcrGetAutoFollowPatternRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrGetAutoFollowPatternResponse GetAutoFollowPattern(Action configureRequest = null) + { + var descriptor = new CcrGetAutoFollowPatternRequestDescriptor(); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task GetAutoFollowPatternAsync(Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrGetAutoFollowPatternRequestDescriptor(); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrPauseAutoFollowPatternResponse PauseAutoFollowPattern(CcrPauseAutoFollowPatternRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task PauseAutoFollowPatternAsync(CcrPauseAutoFollowPatternRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrPauseAutoFollowPatternResponse PauseAutoFollowPattern(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null) + { + var descriptor = new CcrPauseAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task PauseAutoFollowPatternAsync(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrPauseAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrPauseFollowResponse PauseFollow(CcrPauseFollowRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task PauseFollowAsync(CcrPauseFollowRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrPauseFollowResponse PauseFollow(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null) + { + var descriptor = new CcrPauseFollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task PauseFollowAsync(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrPauseFollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrPutAutoFollowPatternResponse PutAutoFollowPattern(CcrPutAutoFollowPatternRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task PutAutoFollowPatternAsync(CcrPutAutoFollowPatternRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrPutAutoFollowPatternResponse PutAutoFollowPattern(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null) + { + var descriptor = new CcrPutAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task PutAutoFollowPatternAsync(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrPutAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrResumeAutoFollowPatternResponse ResumeAutoFollowPattern(CcrResumeAutoFollowPatternRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task ResumeAutoFollowPatternAsync(CcrResumeAutoFollowPatternRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrResumeAutoFollowPatternResponse ResumeAutoFollowPattern(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null) + { + var descriptor = new CcrResumeAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task ResumeAutoFollowPatternAsync(Elastic.Clients.Elasticsearch.Name name, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrResumeAutoFollowPatternRequestDescriptor(name); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrResumeFollowResponse ResumeFollow(CcrResumeFollowRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task ResumeFollowAsync(CcrResumeFollowRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrResumeFollowResponse ResumeFollow(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null) + { + var descriptor = new CcrResumeFollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task ResumeFollowAsync(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrResumeFollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrStatsResponse Stats(CcrStatsRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task StatsAsync(CcrStatsRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrStatsResponse Stats(Action configureRequest = null) + { + var descriptor = new CcrStatsRequestDescriptor(); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task StatsAsync(Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrStatsRequestDescriptor(); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + + public CcrUnfollowResponse Unfollow(CcrUnfollowRequest request) + { + request.BeforeRequest(); + return DoRequest(request); + } + + public Task UnfollowAsync(CcrUnfollowRequest request, CancellationToken cancellationToken = default) + { + request.BeforeRequest(); + return DoRequestAsync(request, cancellationToken); + } + + public CcrUnfollowResponse Unfollow(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null) + { + var descriptor = new CcrUnfollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequest(descriptor); + } + + public Task UnfollowAsync(Elastic.Clients.Elasticsearch.IndexName index, Action configureRequest = null, CancellationToken cancellationToken = default) + { + var descriptor = new CcrUnfollowRequestDescriptor(index); + configureRequest?.Invoke(descriptor); + descriptor.BeforeRequest(); + return DoRequestAsync(descriptor); + } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.g.cs index 7f5291c0028..9c864625528 100644 --- a/src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.g.cs +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Client/ElasticsearchClient.g.cs @@ -16,6 +16,7 @@ // ------------------------------------------------ using Elastic.Clients.Elasticsearch.AsyncSearch; +using Elastic.Clients.Elasticsearch.Ccr; using Elastic.Clients.Elasticsearch.Cluster; using Elastic.Clients.Elasticsearch.Enrich; using Elastic.Clients.Elasticsearch.Eql; @@ -39,6 +40,8 @@ public partial class ElasticsearchClient { public AsyncSearchNamespace AsyncSearch { get; private set; } + public CcrNamespace Ccr { get; private set; } + public ClusterNamespace Cluster { get; private set; } public EnrichNamespace Enrich { get; private set; } @@ -66,6 +69,7 @@ public partial class ElasticsearchClient private partial void SetupNamespaces() { AsyncSearch = new AsyncSearchNamespace(this); + Ccr = new CcrNamespace(this); Cluster = new ClusterNamespace(this); Enrich = new EnrichNamespace(this); Eql = new EqlNamespace(this); diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPattern.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPattern.g.cs new file mode 100644 index 00000000000..a13ff73639b --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPattern.g.cs @@ -0,0 +1,37 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.GetAutoFollowPattern +{ + public partial class AutoFollowPattern + { + [JsonInclude] + [JsonPropertyName("name")] + public string Name { get; init; } + + [JsonInclude] + [JsonPropertyName("pattern")] + public Elastic.Clients.Elasticsearch.Ccr.GetAutoFollowPattern.AutoFollowPatternSummary Pattern { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPatternSummary.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPatternSummary.g.cs new file mode 100644 index 00000000000..0fe342a42df --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowPatternSummary.g.cs @@ -0,0 +1,53 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.GetAutoFollowPattern +{ + public partial class AutoFollowPatternSummary + { + [JsonInclude] + [JsonPropertyName("active")] + public bool Active { get; init; } + + [JsonInclude] + [JsonPropertyName("follow_index_pattern")] + public string? FollowIndexPattern { get; init; } + + [JsonInclude] + [JsonPropertyName("leader_index_exclusion_patterns")] + public IReadOnlyCollection LeaderIndexExclusionPatterns { get; init; } + + [JsonInclude] + [JsonPropertyName("leader_index_patterns")] + public IReadOnlyCollection LeaderIndexPatterns { get; init; } + + [JsonInclude] + [JsonPropertyName("max_outstanding_read_requests")] + public int MaxOutstandingReadRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("remote_cluster")] + public string RemoteCluster { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowStats.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowStats.g.cs new file mode 100644 index 00000000000..6c55ddbd688 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowStats.g.cs @@ -0,0 +1,49 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.Stats +{ + public partial class AutoFollowStats + { + [JsonInclude] + [JsonPropertyName("auto_followed_clusters")] + public IReadOnlyCollection AutoFollowedClusters { get; init; } + + [JsonInclude] + [JsonPropertyName("number_of_failed_follow_indices")] + public long NumberOfFailedFollowIndices { get; init; } + + [JsonInclude] + [JsonPropertyName("number_of_failed_remote_cluster_state_requests")] + public long NumberOfFailedRemoteClusterStateRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("number_of_successful_follow_indices")] + public long NumberOfSuccessfulFollowIndices { get; init; } + + [JsonInclude] + [JsonPropertyName("recent_auto_follow_errors")] + public IReadOnlyCollection RecentAutoFollowErrors { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowedCluster.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowedCluster.g.cs new file mode 100644 index 00000000000..b7d680afa69 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/AutoFollowedCluster.g.cs @@ -0,0 +1,41 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.Stats +{ + public partial class AutoFollowedCluster + { + [JsonInclude] + [JsonPropertyName("cluster_name")] + public string ClusterName { get; init; } + + [JsonInclude] + [JsonPropertyName("last_seen_metadata_version")] + public long LastSeenMetadataVersion { get; init; } + + [JsonInclude] + [JsonPropertyName("time_since_last_check_millis")] + public string TimeSinceLastCheckMillis { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowIndexStats.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowIndexStats.g.cs new file mode 100644 index 00000000000..1490092563c --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowIndexStats.g.cs @@ -0,0 +1,37 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class FollowIndexStats + { + [JsonInclude] + [JsonPropertyName("index")] + public string Index { get; init; } + + [JsonInclude] + [JsonPropertyName("shards")] + public IReadOnlyCollection Shards { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowStats.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowStats.g.cs new file mode 100644 index 00000000000..f58a182dac2 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowStats.g.cs @@ -0,0 +1,33 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.Stats +{ + public partial class FollowStats + { + [JsonInclude] + [JsonPropertyName("indices")] + public IReadOnlyCollection Indices { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndex.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndex.g.cs new file mode 100644 index 00000000000..dc9bbd461b1 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndex.g.cs @@ -0,0 +1,49 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.FollowInfo +{ + public partial class FollowerIndex + { + [JsonInclude] + [JsonPropertyName("follower_index")] + public string FollowerIndexTemp { get; init; } + + [JsonInclude] + [JsonPropertyName("leader_index")] + public string LeaderIndex { get; init; } + + [JsonInclude] + [JsonPropertyName("parameters")] + public Elastic.Clients.Elasticsearch.Ccr.FollowInfo.FollowerIndexParameters? Parameters { get; init; } + + [JsonInclude] + [JsonPropertyName("remote_cluster")] + public string RemoteCluster { get; init; } + + [JsonInclude] + [JsonPropertyName("status")] + public Elastic.Clients.Elasticsearch.Ccr.FollowInfo.FollowerIndexStatus Status { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndexParameters.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndexParameters.g.cs new file mode 100644 index 00000000000..6491f35b602 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/FollowerIndexParameters.g.cs @@ -0,0 +1,69 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.FollowInfo +{ + public partial class FollowerIndexParameters + { + [JsonInclude] + [JsonPropertyName("max_outstanding_read_requests")] + public int MaxOutstandingReadRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("max_outstanding_write_requests")] + public int MaxOutstandingWriteRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("max_read_request_operation_count")] + public int MaxReadRequestOperationCount { get; init; } + + [JsonInclude] + [JsonPropertyName("max_read_request_size")] + public string MaxReadRequestSize { get; init; } + + [JsonInclude] + [JsonPropertyName("max_retry_delay")] + public Elastic.Clients.Elasticsearch.Time MaxRetryDelay { get; init; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_count")] + public int MaxWriteBufferCount { get; init; } + + [JsonInclude] + [JsonPropertyName("max_write_buffer_size")] + public string MaxWriteBufferSize { get; init; } + + [JsonInclude] + [JsonPropertyName("max_write_request_operation_count")] + public int MaxWriteRequestOperationCount { get; init; } + + [JsonInclude] + [JsonPropertyName("max_write_request_size")] + public string MaxWriteRequestSize { get; init; } + + [JsonInclude] + [JsonPropertyName("read_poll_timeout")] + public Elastic.Clients.Elasticsearch.Time ReadPollTimeout { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ReadException.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ReadException.g.cs new file mode 100644 index 00000000000..e556b16a2dd --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ReadException.g.cs @@ -0,0 +1,41 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class ReadException + { + [JsonInclude] + [JsonPropertyName("exception")] + public Elastic.Clients.Elasticsearch.ErrorCause Exception { get; init; } + + [JsonInclude] + [JsonPropertyName("from_seq_no")] + public long FromSeqNo { get; init; } + + [JsonInclude] + [JsonPropertyName("retries")] + public int Retries { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ShardStats.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ShardStats.g.cs new file mode 100644 index 00000000000..4a21d579fe0 --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Ccr/ShardStats.g.cs @@ -0,0 +1,145 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Collections.Generic; +using System.Linq.Expressions; +using System.Text.Json; +using System.Text.Json.Serialization; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr +{ + public partial class ShardStats + { + [JsonInclude] + [JsonPropertyName("bytes_read")] + public long BytesRead { get; init; } + + [JsonInclude] + [JsonPropertyName("failed_read_requests")] + public long FailedReadRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("failed_write_requests")] + public long FailedWriteRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("fatal_exception")] + public Elastic.Clients.Elasticsearch.ErrorCause? FatalException { get; init; } + + [JsonInclude] + [JsonPropertyName("follower_aliases_version")] + public long FollowerAliasesVersion { get; init; } + + [JsonInclude] + [JsonPropertyName("follower_global_checkpoint")] + public long FollowerGlobalCheckpoint { get; init; } + + [JsonInclude] + [JsonPropertyName("follower_index")] + public string FollowerIndex { get; init; } + + [JsonInclude] + [JsonPropertyName("follower_mapping_version")] + public long FollowerMappingVersion { get; init; } + + [JsonInclude] + [JsonPropertyName("follower_max_seq_no")] + public long FollowerMaxSeqNo { get; init; } + + [JsonInclude] + [JsonPropertyName("follower_settings_version")] + public long FollowerSettingsVersion { get; init; } + + [JsonInclude] + [JsonPropertyName("last_requested_seq_no")] + public long LastRequestedSeqNo { get; init; } + + [JsonInclude] + [JsonPropertyName("leader_global_checkpoint")] + public long LeaderGlobalCheckpoint { get; init; } + + [JsonInclude] + [JsonPropertyName("leader_index")] + public string LeaderIndex { get; init; } + + [JsonInclude] + [JsonPropertyName("leader_max_seq_no")] + public long LeaderMaxSeqNo { get; init; } + + [JsonInclude] + [JsonPropertyName("operations_read")] + public long OperationsRead { get; init; } + + [JsonInclude] + [JsonPropertyName("operations_written")] + public long OperationsWritten { get; init; } + + [JsonInclude] + [JsonPropertyName("outstanding_read_requests")] + public int OutstandingReadRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("outstanding_write_requests")] + public int OutstandingWriteRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("read_exceptions")] + public IReadOnlyCollection ReadExceptions { get; init; } + + [JsonInclude] + [JsonPropertyName("remote_cluster")] + public string RemoteCluster { get; init; } + + [JsonInclude] + [JsonPropertyName("shard_id")] + public int ShardId { get; init; } + + [JsonInclude] + [JsonPropertyName("successful_read_requests")] + public long SuccessfulReadRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("successful_write_requests")] + public long SuccessfulWriteRequests { get; init; } + + [JsonInclude] + [JsonPropertyName("time_since_last_read_millis")] + public Elastic.Clients.Elasticsearch.EpochMillis TimeSinceLastReadMillis { get; init; } + + [JsonInclude] + [JsonPropertyName("total_read_remote_exec_time_millis")] + public Elastic.Clients.Elasticsearch.EpochMillis TotalReadRemoteExecTimeMillis { get; init; } + + [JsonInclude] + [JsonPropertyName("total_read_time_millis")] + public Elastic.Clients.Elasticsearch.EpochMillis TotalReadTimeMillis { get; init; } + + [JsonInclude] + [JsonPropertyName("total_write_time_millis")] + public Elastic.Clients.Elasticsearch.EpochMillis TotalWriteTimeMillis { get; init; } + + [JsonInclude] + [JsonPropertyName("write_buffer_operation_count")] + public long WriteBufferOperationCount { get; init; } + + [JsonInclude] + [JsonPropertyName("write_buffer_size_in_bytes")] + public Elastic.Clients.Elasticsearch.ByteSize WriteBufferSizeInBytes { get; init; } + } +} \ No newline at end of file diff --git a/src/Elastic.Clients.Elasticsearch/_Generated/Types/Enums/Enums.Ccr.FollowInfo.g.cs b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Enums/Enums.Ccr.FollowInfo.g.cs new file mode 100644 index 00000000000..cf31e34777f --- /dev/null +++ b/src/Elastic.Clients.Elasticsearch/_Generated/Types/Enums/Enums.Ccr.FollowInfo.g.cs @@ -0,0 +1,68 @@ +// Licensed to Elasticsearch B.V under one or more agreements. +// Elasticsearch B.V licenses this file to you under the Apache 2.0 License. +// See the LICENSE file in the project root for more information. +// +// ███╗ ██╗ ██████╗ ████████╗██╗ ██████╗███████╗ +// ████╗ ██║██╔═══██╗╚══██╔══╝██║██╔════╝██╔════╝ +// ██╔██╗ ██║██║ ██║ ██║ ██║██║ █████╗ +// ██║╚██╗██║██║ ██║ ██║ ██║██║ ██╔══╝ +// ██║ ╚████║╚██████╔╝ ██║ ██║╚██████╗███████╗ +// ╚═╝ ╚═══╝ ╚═════╝ ╚═╝ ╚═╝ ╚═════╝╚══════╝ +// ------------------------------------------------ +// +// This file is automatically generated. +// Please do not edit these files manually. +// +// ------------------------------------------------ + +using System; +using System.Text.Json; +using System.Text.Json.Serialization; +using System.Runtime.Serialization; +using Elastic.Transport; + +#nullable restore +namespace Elastic.Clients.Elasticsearch.Ccr.FollowInfo +{ + [JsonConverter(typeof(FollowerIndexStatusConverter))] + public enum FollowerIndexStatus + { + [EnumMember(Value = "paused")] + Paused, + [EnumMember(Value = "active")] + Active + } + + internal sealed class FollowerIndexStatusConverter : JsonConverter + { + public override FollowerIndexStatus Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options) + { + var enumString = reader.GetString(); + switch (enumString) + { + case "paused": + return FollowerIndexStatus.Paused; + case "active": + return FollowerIndexStatus.Active; + } + + ThrowHelper.ThrowJsonException(); + return default; + } + + public override void Write(Utf8JsonWriter writer, FollowerIndexStatus value, JsonSerializerOptions options) + { + switch (value) + { + case FollowerIndexStatus.Paused: + writer.WriteStringValue("paused"); + return; + case FollowerIndexStatus.Active: + writer.WriteStringValue("active"); + return; + } + + writer.WriteNullValue(); + } + } +} \ No newline at end of file