Skip to content

Initial NEST code gen #5627

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Apr 26, 2021
Merged

Initial NEST code gen #5627

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
b56a8f1
Initial NEST code gen
stevejgordon Apr 23, 2021
bc5d280
Update tests
stevejgordon Apr 23, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions src/Nest/Descriptors.Cat.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -494,6 +494,8 @@ public partial class CatNodesDescriptor : RequestDescriptorBase<CatNodesDescript
public CatNodesDescriptor Headers(params string[] headers) => Qs("h", headers);
///<summary>Return help information</summary>
public CatNodesDescriptor Help(bool? help = true) => Qs("help", help);
///<summary>If set to true segment stats will include stats for segments that are not currently loaded into memory</summary>
public CatNodesDescriptor IncludeUnloadedSegments(bool? includeunloadedsegments = true) => Qs("include_unloaded_segments", includeunloadedsegments);
///<summary>Calculate the selected nodes using the local cluster state rather than the state from master node (default: false)</summary>
[Obsolete("Scheduled to be removed in 8.0, Deprecated as of: 7.6.0, reason: This parameter does not cause this API to act locally.")]
public CatNodesDescriptor Local(bool? local = true) => Qs("local", local);
Expand Down
2 changes: 1 addition & 1 deletion src/Nest/Descriptors.Cluster.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public partial class DeleteVotingConfigExclusionsDescriptor : RequestDescriptorB
public DeleteVotingConfigExclusionsDescriptor WaitForRemoval(bool? waitforremoval = true) => Qs("wait_for_removal", waitforremoval);
}

///<summary>Descriptor for GetSettings <para>https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html</para></summary>
///<summary>Descriptor for GetSettings <para>https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html</para></summary>
public partial class ClusterGetSettingsDescriptor : RequestDescriptorBase<ClusterGetSettingsDescriptor, ClusterGetSettingsRequestParameters, IClusterGetSettingsRequest>, IClusterGetSettingsRequest
{
internal override ApiUrls ApiUrls => ApiUrlsLookups.ClusterGetSettings;
Expand Down
2 changes: 1 addition & 1 deletion src/Nest/Descriptors.Indices.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ public CloseIndexDescriptor Index<TOther>()
public CloseIndexDescriptor MasterTimeout(Time mastertimeout) => Qs("master_timeout", mastertimeout);
///<summary>Explicit operation timeout</summary>
public CloseIndexDescriptor Timeout(Time timeout) => Qs("timeout", timeout);
///<summary>Sets the number of active shards to wait for before the operation returns.</summary>
///<summary>Sets the number of active shards to wait for before the operation returns. Set to `index-setting` to wait according to the index setting `index.write.wait_for_active_shards`, or `all` to wait for all shards, or an integer. Defaults to `0`.</summary>
public CloseIndexDescriptor WaitForActiveShards(string waitforactiveshards) => Qs("wait_for_active_shards", waitforactiveshards);
}

Expand Down
2 changes: 2 additions & 0 deletions src/Nest/Descriptors.Ingest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,8 @@ public GetPipelineDescriptor(Id id): base(r => r.Optional("id", id))
// Request parameters
///<summary>Explicit operation timeout for connection to master node</summary>
public GetPipelineDescriptor MasterTimeout(Time mastertimeout) => Qs("master_timeout", mastertimeout);
///<summary>Return pipelines without their definitions (default: false)</summary>
public GetPipelineDescriptor Summary(bool? summary = true) => Qs("summary", summary);
}

///<summary>Descriptor for GrokProcessorPatterns <para>https://www.elastic.co/guide/en/elasticsearch/reference/master/grok-processor.html#grok-processor-rest-get</para></summary>
Expand Down
11 changes: 6 additions & 5 deletions src/Nest/Descriptors.MachineLearning.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -756,19 +756,20 @@ public partial class PreviewDatafeedDescriptor : RequestDescriptorBase<PreviewDa
{
internal override ApiUrls ApiUrls => ApiUrlsLookups.MachineLearningPreviewDatafeed;
///<summary>/_ml/datafeeds/{datafeed_id}/_preview</summary>
///<param name = "datafeedId">this parameter is required</param>
public PreviewDatafeedDescriptor(Id datafeedId): base(r => r.Required("datafeed_id", datafeedId))
///<param name = "datafeedId">Optional, accepts null</param>
public PreviewDatafeedDescriptor(Id datafeedId): base(r => r.Optional("datafeed_id", datafeedId))
{
}

///<summary>Used for serialization purposes, making sure we have a parameterless constructor</summary>
[SerializationConstructor]
protected PreviewDatafeedDescriptor(): base()
///<summary>/_ml/datafeeds/_preview</summary>
public PreviewDatafeedDescriptor(): base()
{
}

// values part of the url path
Id IPreviewDatafeedRequest.DatafeedId => Self.RouteValues.Get<Id>("datafeed_id");
///<summary>The ID of the datafeed to preview</summary>
public PreviewDatafeedDescriptor DatafeedId(Id datafeedId) => Assign(datafeedId, (a, v) => a.RouteValues.Optional("datafeed_id", v));
// Request parameters
}

Expand Down
2 changes: 2 additions & 0 deletions src/Nest/Descriptors.NoNamespace.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1323,6 +1323,8 @@ public SearchDescriptor<TInferDocument> Index<TOther>()
public SearchDescriptor<TInferDocument> Lenient(bool? lenient = true) => Qs("lenient", lenient);
///<summary>The number of concurrent shard requests per node this search executes concurrently. This value should be used to limit the impact of the search on the cluster in order to limit the number of concurrent shard requests</summary>
public SearchDescriptor<TInferDocument> MaxConcurrentShardRequests(long? maxconcurrentshardrequests) => Qs("max_concurrent_shard_requests", maxconcurrentshardrequests);
///<summary>The minimum compatible version that all shards involved in search should have for this request to be successful</summary>
public SearchDescriptor<TInferDocument> MinCompatibleShardNode(string mincompatibleshardnode) => Qs("min_compatible_shard_node", mincompatibleshardnode);
///<summary>A threshold that enforces a pre-filter roundtrip to prefilter search shards based on query rewriting if the number of shards the search request expands to exceeds the threshold. This filter roundtrip can limit the number of shards significantly if for instance a shard can not match any documents based on its rewrite method ie. if date filters are mandatory to match but the shard bounds and the query are disjoint.</summary>
public SearchDescriptor<TInferDocument> PreFilterShardSize(long? prefiltershardsize) => Qs("pre_filter_shard_size", prefiltershardsize);
///<summary>Specify the node or shard the operation should be performed on (default: random)</summary>
Expand Down
2 changes: 2 additions & 0 deletions src/Nest/Descriptors.Nodes.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -203,6 +203,8 @@ public NodesStatsDescriptor Fields<T>(params Expression<Func<T, object>>[] field
public NodesStatsDescriptor Groups(bool? groups = true) => Qs("groups", groups);
///<summary>Whether to report the aggregated disk usage of each one of the Lucene index files (only applies if segment stats are requested)</summary>
public NodesStatsDescriptor IncludeSegmentFileSizes(bool? includesegmentfilesizes = true) => Qs("include_segment_file_sizes", includesegmentfilesizes);
///<summary>If set to true segment stats will include stats for segments that are not currently loaded into memory</summary>
public NodesStatsDescriptor IncludeUnloadedSegments(bool? includeunloadedsegments = true) => Qs("include_unloaded_segments", includeunloadedsegments);
///<summary>Return indices stats aggregated at index, node or shard level</summary>
public NodesStatsDescriptor Level(Level? level) => Qs("level", level);
///<summary>Explicit operation timeout</summary>
Expand Down
2 changes: 2 additions & 0 deletions src/Nest/Descriptors.Snapshot.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -209,6 +209,8 @@ protected GetSnapshotDescriptor(): base()
// Request parameters
///<summary>Whether to ignore unavailable snapshots, defaults to false which means a SnapshotMissingException is thrown</summary>
public GetSnapshotDescriptor IgnoreUnavailable(bool? ignoreunavailable = true) => Qs("ignore_unavailable", ignoreunavailable);
///<summary>Whether to include details of each index in the snapshot, if those details are available. Defaults to false.</summary>
public GetSnapshotDescriptor IndexDetails(bool? indexdetails = true) => Qs("index_details", indexdetails);
///<summary>Explicit operation timeout for connection to master node</summary>
public GetSnapshotDescriptor MasterTimeout(Time mastertimeout) => Qs("master_timeout", mastertimeout);
///<summary>Whether to show verbose snapshot info or only show the basic info found in the repository index blob</summary>
Expand Down
8 changes: 4 additions & 4 deletions src/Nest/ElasticClient.Cluster.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -87,25 +87,25 @@ internal ClusterNamespace(ElasticClient client): base(client)
/// <summary>
/// <c>GET</c> request to the <c>cluster.get_settings</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html</a>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html</a>
/// </summary>
public ClusterGetSettingsResponse GetSettings(Func<ClusterGetSettingsDescriptor, IClusterGetSettingsRequest> selector = null) => GetSettings(selector.InvokeOrDefault(new ClusterGetSettingsDescriptor()));
/// <summary>
/// <c>GET</c> request to the <c>cluster.get_settings</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html</a>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html</a>
/// </summary>
public Task<ClusterGetSettingsResponse> GetSettingsAsync(Func<ClusterGetSettingsDescriptor, IClusterGetSettingsRequest> selector = null, CancellationToken ct = default) => GetSettingsAsync(selector.InvokeOrDefault(new ClusterGetSettingsDescriptor()), ct);
/// <summary>
/// <c>GET</c> request to the <c>cluster.get_settings</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html</a>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html</a>
/// </summary>
public ClusterGetSettingsResponse GetSettings(IClusterGetSettingsRequest request) => DoRequest<IClusterGetSettingsRequest, ClusterGetSettingsResponse>(request, request.RequestParameters);
/// <summary>
/// <c>GET</c> request to the <c>cluster.get_settings</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html</a>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html">https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html</a>
/// </summary>
public Task<ClusterGetSettingsResponse> GetSettingsAsync(IClusterGetSettingsRequest request, CancellationToken ct = default) => DoRequestAsync<IClusterGetSettingsRequest, ClusterGetSettingsResponse>(request, request.RequestParameters, ct);
/// <summary>
Expand Down
16 changes: 8 additions & 8 deletions src/Nest/ElasticClient.MachineLearning.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -759,28 +759,28 @@ public Task<EstimateModelMemoryResponse> EstimateModelMemoryAsync<TDocument>(Fun
/// </summary>
public Task<PostJobDataResponse> PostJobDataAsync(IPostJobDataRequest request, CancellationToken ct = default) => DoRequestAsync<IPostJobDataRequest, PostJobDataResponse>(request, request.RequestParameters, ct);
/// <summary>
/// <c>GET</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <c>POST</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html">https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html</a>
/// </summary>
public PreviewDatafeedResponse<TDocument> PreviewDatafeed<TDocument>(Id datafeedId, Func<PreviewDatafeedDescriptor, IPreviewDatafeedRequest> selector = null)
where TDocument : class => PreviewDatafeed<TDocument>(selector.InvokeOrDefault(new PreviewDatafeedDescriptor(datafeedId: datafeedId)));
public PreviewDatafeedResponse<TDocument> PreviewDatafeed<TDocument>(Func<PreviewDatafeedDescriptor, IPreviewDatafeedRequest> selector = null)
where TDocument : class => PreviewDatafeed<TDocument>(selector.InvokeOrDefault(new PreviewDatafeedDescriptor()));
/// <summary>
/// <c>GET</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <c>POST</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html">https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html</a>
/// </summary>
public Task<PreviewDatafeedResponse<TDocument>> PreviewDatafeedAsync<TDocument>(Id datafeedId, Func<PreviewDatafeedDescriptor, IPreviewDatafeedRequest> selector = null, CancellationToken ct = default)
where TDocument : class => PreviewDatafeedAsync<TDocument>(selector.InvokeOrDefault(new PreviewDatafeedDescriptor(datafeedId: datafeedId)), ct);
public Task<PreviewDatafeedResponse<TDocument>> PreviewDatafeedAsync<TDocument>(Func<PreviewDatafeedDescriptor, IPreviewDatafeedRequest> selector = null, CancellationToken ct = default)
where TDocument : class => PreviewDatafeedAsync<TDocument>(selector.InvokeOrDefault(new PreviewDatafeedDescriptor()), ct);
/// <summary>
/// <c>GET</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <c>POST</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html">https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html</a>
/// </summary>
public PreviewDatafeedResponse<TDocument> PreviewDatafeed<TDocument>(IPreviewDatafeedRequest request)
where TDocument : class => DoRequest<IPreviewDatafeedRequest, PreviewDatafeedResponse<TDocument>>(request, ResponseBuilder(request.RequestParameters, PreviewDatafeedResponseBuilder<TDocument>.Instance));
/// <summary>
/// <c>GET</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <c>POST</c> request to the <c>ml.preview_datafeed</c> API, read more about this API online:
/// <para></para>
/// <a href = "https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html">https://www.elastic.co/guide/en/elasticsearch/reference/current/ml-preview-datafeed.html</a>
/// </summary>
Expand Down
7 changes: 7 additions & 0 deletions src/Nest/Requests.Cat.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1160,6 +1160,13 @@ public bool? Help
set => Q("help", value);
}

///<summary>If set to true segment stats will include stats for segments that are not currently loaded into memory</summary>
public bool? IncludeUnloadedSegments
{
get => Q<bool? >("include_unloaded_segments");
set => Q("include_unloaded_segments", value);
}

///<summary>Calculate the selected nodes using the local cluster state rather than the state from master node (default: false)</summary>
[Obsolete("Scheduled to be removed in 8.0, Deprecated as of: 7.6.0, reason: This parameter does not cause this API to act locally.")]
public bool? Local
Expand Down
2 changes: 1 addition & 1 deletion src/Nest/Requests.Cluster.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ public partial interface IClusterGetSettingsRequest : IRequest<ClusterGetSetting
{
}

///<summary>Request for GetSettings <para>https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-update-settings.html</para></summary>
///<summary>Request for GetSettings <para>https://www.elastic.co/guide/en/elasticsearch/reference/master/cluster-get-settings.html</para></summary>
public partial class ClusterGetSettingsRequest : PlainRequestBase<ClusterGetSettingsRequestParameters>, IClusterGetSettingsRequest
{
protected IClusterGetSettingsRequest Self => this;
Expand Down
5 changes: 4 additions & 1 deletion src/Nest/Requests.Indices.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -356,7 +356,10 @@ public Time Timeout
set => Q("timeout", value);
}

///<summary>Sets the number of active shards to wait for before the operation returns.</summary>
///<summary>
/// Sets the number of active shards to wait for before the operation returns. Set to `index-setting` to wait according to the index setting
/// `index.write.wait_for_active_shards`, or `all` to wait for all shards, or an integer. Defaults to `0`.
///</summary>
public string WaitForActiveShards
{
get => Q<string>("wait_for_active_shards");
Expand Down
7 changes: 7 additions & 0 deletions src/Nest/Requests.Ingest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -113,6 +113,13 @@ public Time MasterTimeout
get => Q<Time>("master_timeout");
set => Q("master_timeout", value);
}

///<summary>Return pipelines without their definitions (default: false)</summary>
public bool? Summary
{
get => Q<bool? >("summary");
set => Q("summary", value);
}
}

[InterfaceDataContract]
Expand Down
9 changes: 4 additions & 5 deletions src/Nest/Requests.MachineLearning.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1289,14 +1289,13 @@ public partial class PreviewDatafeedRequest : PlainRequestBase<PreviewDatafeedRe
protected IPreviewDatafeedRequest Self => this;
internal override ApiUrls ApiUrls => ApiUrlsLookups.MachineLearningPreviewDatafeed;
///<summary>/_ml/datafeeds/{datafeed_id}/_preview</summary>
///<param name = "datafeedId">this parameter is required</param>
public PreviewDatafeedRequest(Id datafeedId): base(r => r.Required("datafeed_id", datafeedId))
///<param name = "datafeedId">Optional, accepts null</param>
public PreviewDatafeedRequest(Id datafeedId): base(r => r.Optional("datafeed_id", datafeedId))
{
}

///<summary>Used for serialization purposes, making sure we have a parameterless constructor</summary>
[SerializationConstructor]
protected PreviewDatafeedRequest(): base()
///<summary>/_ml/datafeeds/_preview</summary>
public PreviewDatafeedRequest(): base()
{
}

Expand Down
7 changes: 7 additions & 0 deletions src/Nest/Requests.NoNamespace.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2825,6 +2825,13 @@ public long? MaxConcurrentShardRequests
set => Q("max_concurrent_shard_requests", value);
}

///<summary>The minimum compatible version that all shards involved in search should have for this request to be successful</summary>
public string MinCompatibleShardNode
{
get => Q<string>("min_compatible_shard_node");
set => Q("min_compatible_shard_node", value);
}

///<summary>
/// A threshold that enforces a pre-filter roundtrip to prefilter search shards based on query rewriting if the number of shards the search
/// request expands to exceeds the threshold. This filter roundtrip can limit the number of shards significantly if for instance a shard can
Expand Down
7 changes: 7 additions & 0 deletions src/Nest/Requests.Nodes.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -317,6 +317,13 @@ public bool? IncludeSegmentFileSizes
set => Q("include_segment_file_sizes", value);
}

///<summary>If set to true segment stats will include stats for segments that are not currently loaded into memory</summary>
public bool? IncludeUnloadedSegments
{
get => Q<bool? >("include_unloaded_segments");
set => Q("include_unloaded_segments", value);
}

///<summary>Return indices stats aggregated at index, node or shard level</summary>
public Level? Level
{
Expand Down
7 changes: 7 additions & 0 deletions src/Nest/Requests.Snapshot.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -383,6 +383,13 @@ public bool? IgnoreUnavailable
set => Q("ignore_unavailable", value);
}

///<summary>Whether to include details of each index in the snapshot, if those details are available. Defaults to false.</summary>
public bool? IndexDetails
{
get => Q<bool? >("index_details");
set => Q("index_details", value);
}

///<summary>Explicit operation timeout for connection to master node</summary>
public Time MasterTimeout
{
Expand Down
Loading