Skip to content

Commit eb7d6a9

Browse files
MpdreamzMpdreamz
committed
Created all the infra for the CCR api's (request/response/client methods)
1 parent aac2dd4 commit eb7d6a9

35 files changed

+1176
-265
lines changed

‎src/Elasticsearch.Net/Domain/RequestParameters/RequestParameters.Generated.cs‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -2181,37 +2181,37 @@ public partial class UpdateByQueryRequestParameters : RequestParameters<UpdateBy
21812181
public long? Slices { get => Q<long?>("slices"); set => Q("slices", value); }
21822182
}
21832183
///<summary>Request options for CcrDeleteAutoFollowPattern<pre>https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-delete-auto-follow-pattern.html</pre></summary>
2184-
public partial class CcrDeleteAutoFollowPatternRequestParameters : RequestParameters<CcrDeleteAutoFollowPatternRequestParameters>
2184+
public partial class DeleteAutoFollowPatternRequestParameters : RequestParameters<DeleteAutoFollowPatternRequestParameters>
21852185
{
21862186
public override HttpMethod DefaultHttpMethod => HttpMethod.DELETE;
21872187
}
21882188
///<summary>Request options for CcrFollow<pre>https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-put-follow.html</pre></summary>
2189-
public partial class CcrFollowRequestParameters : RequestParameters<CcrFollowRequestParameters>
2189+
public partial class CreateFollowIndexRequestParameters : RequestParameters<CreateFollowIndexRequestParameters>
21902190
{
21912191
public override HttpMethod DefaultHttpMethod => HttpMethod.PUT;
21922192
}
21932193
///<summary>Request options for CcrFollowStats<pre>https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-follow-stats.html</pre></summary>
2194-
public partial class CcrFollowStatsRequestParameters : RequestParameters<CcrFollowStatsRequestParameters>
2194+
public partial class FollowIndexStatsRequestParameters : RequestParameters<FollowIndexStatsRequestParameters>
21952195
{
21962196
public override HttpMethod DefaultHttpMethod => HttpMethod.GET;
21972197
}
21982198
///<summary>Request options for CcrGetAutoFollowPattern<pre>https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-get-auto-follow-pattern.html</pre></summary>
2199-
public partial class CcrGetAutoFollowPatternRequestParameters : RequestParameters<CcrGetAutoFollowPatternRequestParameters>
2199+
public partial class GetAutoFollowPatternRequestParameters : RequestParameters<GetAutoFollowPatternRequestParameters>
22002200
{
22012201
public override HttpMethod DefaultHttpMethod => HttpMethod.GET;
22022202
}
22032203
///<summary>Request options for CcrPauseFollow<pre>https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-pause-follow.html</pre></summary>
2204-
public partial class CcrPauseFollowRequestParameters : RequestParameters<CcrPauseFollowRequestParameters>
2204+
public partial class PauseFollowIndexRequestParameters : RequestParameters<PauseFollowIndexRequestParameters>
22052205
{
22062206
public override HttpMethod DefaultHttpMethod => HttpMethod.POST;
22072207
}
22082208
///<summary>Request options for CcrPutAutoFollowPattern<pre>https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-put-auto-follow-pattern.html</pre></summary>
2209-
public partial class CcrPutAutoFollowPatternRequestParameters : RequestParameters<CcrPutAutoFollowPatternRequestParameters>
2209+
public partial class CreateAutoFollowPatternRequestParameters : RequestParameters<CreateAutoFollowPatternRequestParameters>
22102210
{
22112211
public override HttpMethod DefaultHttpMethod => HttpMethod.PUT;
22122212
}
22132213
///<summary>Request options for CcrResumeFollow<pre>https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-resume-follow.html</pre></summary>
2214-
public partial class CcrResumeFollowRequestParameters : RequestParameters<CcrResumeFollowRequestParameters>
2214+
public partial class ResumeFollowIndexRequestParameters : RequestParameters<ResumeFollowIndexRequestParameters>
22152215
{
22162216
public override HttpMethod DefaultHttpMethod => HttpMethod.POST;
22172217
}
@@ -2221,7 +2221,7 @@ public partial class CcrStatsRequestParameters : RequestParameters<CcrStatsReque
22212221
public override HttpMethod DefaultHttpMethod => HttpMethod.GET;
22222222
}
22232223
///<summary>Request options for CcrUnfollow<pre>http://www.elastic.co/guide/en/elasticsearch/reference/current</pre></summary>
2224-
public partial class CcrUnfollowRequestParameters : RequestParameters<CcrUnfollowRequestParameters>
2224+
public partial class UnfollowIndexRequestParameters : RequestParameters<UnfollowIndexRequestParameters>
22252225
{
22262226
public override HttpMethod DefaultHttpMethod => HttpMethod.POST;
22272227
}

‎src/Elasticsearch.Net/ElasticLowLevelClient.Generated.cs‎

Lines changed: 18 additions & 18 deletions
Large diffs are not rendered by default.

‎src/Elasticsearch.Net/IElasticLowLevelClient.Generated.cs‎

Lines changed: 18 additions & 18 deletions
Large diffs are not rendered by default.

‎src/Nest/Cluster/ClusterSettings/ClusterPutSettings/RemoteClusterConfiguration.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ private static Dictionary<string, object> Combine(IDictionary<string, object> le
3838
if (right == null) return new Dictionary<string, object>(left);
3939

4040
foreach (var kv in right) left[kv.Key] = kv.Value;
41-
return left;
41+
return new Dictionary<string, object>(left);
4242
}
4343
}
4444
}

‎src/Nest/Nest.csproj‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,4 @@
1212
<ItemGroup>
1313
<PackageReference Include="Newtonsoft.Json" Version="12.0.1" />
1414
</ItemGroup>
15-
<ItemGroup>
16-
<Folder Include="XPack\CrossClusterReplication" />
17-
</ItemGroup>
1815
</Project>

‎src/Nest/XPack/CrossClusterReplication/AutoFollow/CreateAutoFollowPattern/CreateAutoFollowPatternRequest.cs‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
using System;
2+
using Newtonsoft.Json;
3+
4+
namespace Nest
5+
{
6+
[MapsApi("ccr.put_auto_follow_pattern.json")]
7+
[ContractJsonConverter(typeof(ReadAsTypeJsonConverter<CreateAutoFollowPatternRequest>))]
8+
public partial interface ICreateAutoFollowPatternRequest
9+
{
10+
/// <summary>
11+
///
12+
/// <para>
13+
/// </para>
14+
/// </summary>
15+
[JsonProperty("cursor")]
16+
string Cursor { get; set; }
17+
}
18+
19+
public partial class CreateAutoFollowPatternRequest
20+
{
21+
/// <inheritdoc cref="ICreateAutoFollowPatternRequest.Cursor" />
22+
public string Cursor { get; set; }
23+
}
24+
25+
public partial class CreateAutoFollowPatternDescriptor
26+
{
27+
string ICreateAutoFollowPatternRequest.Cursor { get; set; }
28+
29+
/// <inheritdoc cref="ICreateAutoFollowPatternRequest.Cursor" />
30+
public CreateAutoFollowPatternDescriptor Cursor(string cursor) => Assign(a => a.Cursor = cursor);
31+
}
32+
}

‎src/Nest/XPack/CrossClusterReplication/AutoFollow/CreateAutoFollowPattern/CreateAutoFollowResponse.cs‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
using System.Collections.Generic;
2+
using Newtonsoft.Json;
3+
4+
namespace Nest
5+
{
6+
public interface ICreateAutoFollowPatternResponse : IResponse
7+
{
8+
/// <summary>
9+
///
10+
/// </summary>
11+
[JsonProperty("columns")]
12+
IReadOnlyCollection<SqlColumn> Columns { get; }
13+
}
14+
15+
public class CreateAutoFollowPatternResponse : ResponseBase, ICreateAutoFollowPatternResponse
16+
{
17+
/// <inheritdoc cref="ICreateAutoFollowPatternResponse.Columns" />
18+
public IReadOnlyCollection<SqlColumn> Columns { get; internal set; } = EmptyReadOnly<SqlColumn>.Collection;
19+
}
20+
}

‎src/Nest/XPack/CrossClusterReplication/AutoFollow/CreateAutoFollowPattern/ElasticClient-CreateAutoFollowPattern.cs‎

Lines changed: 52 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,52 @@
1+
using System;
2+
using System.Threading;
3+
using System.Threading.Tasks;
4+
using Elasticsearch.Net;
5+
6+
namespace Nest
7+
{
8+
public partial interface IElasticClient
9+
{
10+
/// <summary></summary>
11+
ICreateAutoFollowPatternResponse CreateAutoFollowPattern(Name name, Func<CreateAutoFollowPatternDescriptor, ICreateAutoFollowPatternRequest> selector);
12+
13+
/// <inheritdoc cref="CreateAutoFollowPattern(System.Func{Nest.CreateAutoFollowPatternDescriptor,Nest.ICreateAutoFollowPatternRequest})" />
14+
ICreateAutoFollowPatternResponse CreateAutoFollowPattern(ICreateAutoFollowPatternRequest request);
15+
16+
/// <inheritdoc cref="CreateAutoFollowPattern(System.Func{Nest.CreateAutoFollowPatternDescriptor,Nest.ICreateAutoFollowPatternRequest})" />
17+
Task<ICreateAutoFollowPatternResponse> CreateAutoFollowPatternAsync(Name name, Func<CreateAutoFollowPatternDescriptor, ICreateAutoFollowPatternRequest> selector,
18+
CancellationToken cancellationToken = default(CancellationToken)
19+
);
20+
21+
/// <inheritdoc cref="CreateAutoFollowPattern(System.Func{Nest.CreateAutoFollowPatternDescriptor,Nest.ICreateAutoFollowPatternRequest})" />
22+
Task<ICreateAutoFollowPatternResponse> CreateAutoFollowPatternAsync(ICreateAutoFollowPatternRequest request, CancellationToken cancellationToken = default(CancellationToken));
23+
}
24+
25+
public partial class ElasticClient
26+
{
27+
/// <inheritdoc cref="CreateAutoFollowPattern(System.Func{Nest.CreateAutoFollowPatternDescriptor,Nest.ICreateAutoFollowPatternRequest})" />
28+
public ICreateAutoFollowPatternResponse CreateAutoFollowPattern(Name name, Func<CreateAutoFollowPatternDescriptor, ICreateAutoFollowPatternRequest> selector) =>
29+
CreateAutoFollowPattern(selector.InvokeOrDefault(new CreateAutoFollowPatternDescriptor(name)));
30+
31+
/// <inheritdoc cref="CreateAutoFollowPattern(System.Func{Nest.CreateAutoFollowPatternDescriptor,Nest.ICreateAutoFollowPatternRequest})" />
32+
public ICreateAutoFollowPatternResponse CreateAutoFollowPattern(ICreateAutoFollowPatternRequest request) =>
33+
Dispatcher.Dispatch<ICreateAutoFollowPatternRequest, CreateAutoFollowPatternRequestParameters, CreateAutoFollowPatternResponse>(
34+
request,
35+
(p, d) => LowLevelDispatch.CcrPutAutoFollowPatternDispatch<CreateAutoFollowPatternResponse>(p, d)
36+
);
37+
38+
/// <inheritdoc cref="CreateAutoFollowPattern(System.Func{Nest.CreateAutoFollowPatternDescriptor,Nest.ICreateAutoFollowPatternRequest})" />
39+
public Task<ICreateAutoFollowPatternResponse> CreateAutoFollowPatternAsync(Name name, Func<CreateAutoFollowPatternDescriptor, ICreateAutoFollowPatternRequest> selector,
40+
CancellationToken cancellationToken = default(CancellationToken)
41+
) =>
42+
CreateAutoFollowPatternAsync(selector.InvokeOrDefault(new CreateAutoFollowPatternDescriptor(name)), cancellationToken);
43+
44+
/// <inheritdoc cref="CreateAutoFollowPattern(System.Func{Nest.CreateAutoFollowPatternDescriptor,Nest.ICreateAutoFollowPatternRequest})" />
45+
public Task<ICreateAutoFollowPatternResponse> CreateAutoFollowPatternAsync(ICreateAutoFollowPatternRequest request, CancellationToken cancellationToken = default(CancellationToken)) =>
46+
Dispatcher.DispatchAsync<ICreateAutoFollowPatternRequest, CreateAutoFollowPatternRequestParameters, CreateAutoFollowPatternResponse, ICreateAutoFollowPatternResponse>(
47+
request,
48+
cancellationToken,
49+
(p, d, c) => LowLevelDispatch.CcrPutAutoFollowPatternDispatchAsync<CreateAutoFollowPatternResponse>(p, d, c)
50+
);
51+
}
52+
}

‎src/Nest/XPack/CrossClusterReplication/AutoFollow/DeleteAutoFollowPattern/DeleteAutoFollowPatternRequest.cs‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
using System;
2+
using Newtonsoft.Json;
3+
4+
namespace Nest
5+
{
6+
[MapsApi("ccr.delete_auto_follow_pattern.json")]
7+
[ContractJsonConverter(typeof(ReadAsTypeJsonConverter<DeleteAutoFollowPatternRequest>))]
8+
public partial interface IDeleteAutoFollowPatternRequest
9+
{
10+
/// <summary>
11+
///
12+
/// <para>
13+
/// </para>
14+
/// </summary>
15+
[JsonProperty("cursor")]
16+
string Cursor { get; set; }
17+
}
18+
19+
public partial class DeleteAutoFollowPatternRequest
20+
{
21+
/// <inheritdoc cref="IDeleteAutoFollowPatternRequest.Cursor" />
22+
public string Cursor { get; set; }
23+
}
24+
25+
public partial class DeleteAutoFollowPatternDescriptor
26+
{
27+
string IDeleteAutoFollowPatternRequest.Cursor { get; set; }
28+
29+
/// <inheritdoc cref="IDeleteAutoFollowPatternRequest.Cursor" />
30+
public DeleteAutoFollowPatternDescriptor Cursor(string cursor) => Assign(a => a.Cursor = cursor);
31+
}
32+
}

‎src/Nest/XPack/CrossClusterReplication/AutoFollow/DeleteAutoFollowPattern/DeleteAutoFollowPatternResponse.cs‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
using System.Collections.Generic;
2+
using Newtonsoft.Json;
3+
4+
namespace Nest
5+
{
6+
public interface IDeleteAutoFollowPatternResponse : IResponse
7+
{
8+
/// <summary>
9+
///
10+
/// </summary>
11+
[JsonProperty("columns")]
12+
IReadOnlyCollection<SqlColumn> Columns { get; }
13+
}
14+
15+
public class DeleteAutoFollowPatternResponse : ResponseBase, IDeleteAutoFollowPatternResponse
16+
{
17+
/// <inheritdoc cref="IDeleteAutoFollowPatternResponse.Columns" />
18+
public IReadOnlyCollection<SqlColumn> Columns { get; internal set; } = EmptyReadOnly<SqlColumn>.Collection;
19+
}
20+
}

0 commit comments

Comments
 (0)