Skip to content

Feature/ingest api #2065

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 14 commits into from
Apr 29, 2016
Merged

Feature/ingest api #2065

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
ac57660
Started on ingest API support
Mpdreamz Apr 26, 2016
1e2ab75
Fix build
gmarz Apr 26, 2016
f5c8840
updated nest project file
Mpdreamz Apr 26, 2016
2f419c0
compilation fixes
Mpdreamz Apr 26, 2016
796c020
Add processor implementations
gmarz Apr 26, 2016
d3f882e
Merge branch 'feature/ingest-api' of https://github.com/elastic/elast…
gmarz Apr 26, 2016
235c708
Finished implementing request and response bodies
gmarz Apr 26, 2016
3d61c0a
Add tests configuration option to allow skipping of plugin verification
gmarz Apr 27, 2016
54e4bd2
Full serialization tests for put pipeline and some processor fixes
gmarz Apr 27, 2016
c86734d
Pipeline simulation integration tests
gmarz Apr 28, 2016
b1080c2
Revert "Add tests configuration option to allow skipping of plugin ve…
gmarz Apr 28, 2016
105b6e9
Post revert build fix
gmarz Apr 28, 2016
db3ce48
Pipeline crud tests, working on deserializing get pipeline response
gmarz Apr 29, 2016
a1833b5
Reverted mappings of ingest back to alpha1
Mpdreamz Apr 29, 2016
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
6 changes: 6 additions & 0 deletions src/CodeGeneration/CodeGeneration.LowLevelClient/CodeGeneration.LowLevelClient.csproj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,7 @@
<None Include="RestSpecification\Core\cat.snapshots.json" />
<None Include="RestSpecification\Core\cat.thread_pool.json" />
<None Include="RestSpecification\Core\clear_scroll.json" />
<None Include="RestSpecification\Core\cluster.allocation_explain.json" />
<None Include="RestSpecification\Core\cluster.get_settings.json" />
<None Include="RestSpecification\Core\cluster.health.json" />
<None Include="RestSpecification\Core\cluster.pending_tasks.json" />
Expand Down Expand Up @@ -153,6 +154,10 @@
<None Include="RestSpecification\Core\indices.upgrade.json" />
<None Include="RestSpecification\Core\indices.validate_query.json" />
<None Include="RestSpecification\Core\info.json" />
<None Include="RestSpecification\Core\ingest.delete_pipeline.json" />
<None Include="RestSpecification\Core\ingest.get_pipeline.json" />
<None Include="RestSpecification\Core\ingest.put_pipeline.json" />
<None Include="RestSpecification\Core\ingest.simulate.json" />
<None Include="RestSpecification\Core\mget.json" />
<None Include="RestSpecification\Core\mpercolate.json" />
<None Include="RestSpecification\Core\msearch.json" />
Expand All @@ -165,6 +170,7 @@
<None Include="RestSpecification\Core\put_script.json" />
<None Include="RestSpecification\Core\put_template.json" />
<None Include="RestSpecification\Core\reindex.json" />
<None Include="RestSpecification\Core\reindex.rethrottle.json" />
<None Include="RestSpecification\Core\render_search_template.json" />
<None Include="RestSpecification\Core\scroll.json" />
<None Include="RestSpecification\Core\search.json" />
Expand Down
2 changes: 1 addition & 1 deletion src/CodeGeneration/CodeGeneration.LowLevelClient/RestSpecification/Core/ingest.simulate.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
"methods": [ "GET", "POST" ],
"url": {
"path": "/_ingest/pipeline/_simulate",
"paths": [ "/_ingest/pipeline/_simulate", "/_ingest/pipeline/{id}/_simulate/" ],
"paths": [ "/_ingest/pipeline/_simulate", "/_ingest/pipeline/{id}/_simulate" ],
"parts": {
"id": {
"type" : "string",
Expand Down
36 changes: 18 additions & 18 deletions src/Elasticsearch.Net/Domain/RequestParameters/RequestParameters.Generated.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3005,24 +3005,24 @@ public class RootNodeInfoRequestParameters : FluentRequestParameters<RootNodeInf
///https://www.elastic.co/guide/en/elasticsearch/plugins/master/ingest.html
///</pre>
///</summary>
public class IngestDeletePipelineRequestParameters : FluentRequestParameters<IngestDeletePipelineRequestParameters>
public class DeletePipelineRequestParameters : FluentRequestParameters<DeletePipelineRequestParameters>
{
public override HttpMethod DefaultHttpMethod => HttpMethod.DELETE;

///<summary>Explicit operation timeout for connection to master node</summary>
public IngestDeletePipelineRequestParameters MasterTimeout(TimeSpan master_timeout) => this.AddQueryString("master_timeout", master_timeout.ToTimeUnit());
public DeletePipelineRequestParameters MasterTimeout(TimeSpan master_timeout) => this.AddQueryString("master_timeout", master_timeout.ToTimeUnit());


///<summary>Explicit operation timeout</summary>
public IngestDeletePipelineRequestParameters Timeout(TimeSpan timeout) => this.AddQueryString("timeout", timeout.ToTimeUnit());
public DeletePipelineRequestParameters Timeout(TimeSpan timeout) => this.AddQueryString("timeout", timeout.ToTimeUnit());


///<summary>The URL-encoded request definition</summary>
public IngestDeletePipelineRequestParameters Source(string source) => this.AddQueryString("source", source);
public DeletePipelineRequestParameters Source(string source) => this.AddQueryString("source", source);


///<summary>Comma separated list of filters used to reduce the response returned by Elasticsearch</summary>
public IngestDeletePipelineRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);
public DeletePipelineRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);

}

Expand All @@ -3031,20 +3031,20 @@ public class IngestDeletePipelineRequestParameters : FluentRequestParameters<Ing
///https://www.elastic.co/guide/en/elasticsearch/plugins/master/ingest.html
///</pre>
///</summary>
public class IngestGetPipelineRequestParameters : FluentRequestParameters<IngestGetPipelineRequestParameters>
public class GetPipelineRequestParameters : FluentRequestParameters<GetPipelineRequestParameters>
{
public override HttpMethod DefaultHttpMethod => HttpMethod.GET;

///<summary>Explicit operation timeout for connection to master node</summary>
public IngestGetPipelineRequestParameters MasterTimeout(TimeSpan master_timeout) => this.AddQueryString("master_timeout", master_timeout.ToTimeUnit());
public GetPipelineRequestParameters MasterTimeout(TimeSpan master_timeout) => this.AddQueryString("master_timeout", master_timeout.ToTimeUnit());


///<summary>The URL-encoded request definition</summary>
public IngestGetPipelineRequestParameters Source(string source) => this.AddQueryString("source", source);
public GetPipelineRequestParameters Source(string source) => this.AddQueryString("source", source);


///<summary>Comma separated list of filters used to reduce the response returned by Elasticsearch</summary>
public IngestGetPipelineRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);
public GetPipelineRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);

}

Expand All @@ -3053,24 +3053,24 @@ public class IngestGetPipelineRequestParameters : FluentRequestParameters<Ingest
///https://www.elastic.co/guide/en/elasticsearch/plugins/master/ingest.html
///</pre>
///</summary>
public class IngestPutPipelineRequestParameters : FluentRequestParameters<IngestPutPipelineRequestParameters>
public class PutPipelineRequestParameters : FluentRequestParameters<PutPipelineRequestParameters>
{
public override HttpMethod DefaultHttpMethod => HttpMethod.PUT;

///<summary>Explicit operation timeout for connection to master node</summary>
public IngestPutPipelineRequestParameters MasterTimeout(TimeSpan master_timeout) => this.AddQueryString("master_timeout", master_timeout.ToTimeUnit());
public PutPipelineRequestParameters MasterTimeout(TimeSpan master_timeout) => this.AddQueryString("master_timeout", master_timeout.ToTimeUnit());


///<summary>Explicit operation timeout</summary>
public IngestPutPipelineRequestParameters Timeout(TimeSpan timeout) => this.AddQueryString("timeout", timeout.ToTimeUnit());
public PutPipelineRequestParameters Timeout(TimeSpan timeout) => this.AddQueryString("timeout", timeout.ToTimeUnit());


///<summary>The URL-encoded request definition</summary>
public IngestPutPipelineRequestParameters Source(string source) => this.AddQueryString("source", source);
public PutPipelineRequestParameters Source(string source) => this.AddQueryString("source", source);


///<summary>Comma separated list of filters used to reduce the response returned by Elasticsearch</summary>
public IngestPutPipelineRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);
public PutPipelineRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);

}

Expand All @@ -3079,20 +3079,20 @@ public class IngestPutPipelineRequestParameters : FluentRequestParameters<Ingest
///https://www.elastic.co/guide/en/elasticsearch/plugins/master/ingest.html
///</pre>
///</summary>
public class IngestSimulateRequestParameters : FluentRequestParameters<IngestSimulateRequestParameters>
public class SimulatePipelineRequestParameters : FluentRequestParameters<SimulatePipelineRequestParameters>
{
public override HttpMethod DefaultHttpMethod => HttpMethod.POST;

///<summary>Verbose mode. Display data output for each processor in executed pipeline</summary>
public IngestSimulateRequestParameters Verbose(bool verbose) => this.AddQueryString("verbose", verbose);
public SimulatePipelineRequestParameters Verbose(bool verbose) => this.AddQueryString("verbose", verbose);


///<summary>The URL-encoded request definition</summary>
public IngestSimulateRequestParameters Source(string source) => this.AddQueryString("source", source);
public SimulatePipelineRequestParameters Source(string source) => this.AddQueryString("source", source);


///<summary>Comma separated list of filters used to reduce the response returned by Elasticsearch</summary>
public IngestSimulateRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);
public SimulatePipelineRequestParameters FilterPath(string filter_path) => this.AddQueryString("filter_path", filter_path);

}

Expand Down
Loading