Skip to content

Commit 4be57c3

Browse files
committed
Add conflicts to Reindex API
closes #2219
1 parent 6823728 commit 4be57c3

File tree

4 files changed

+17
-3
lines changed

4 files changed

+17
-3
lines changed

build/scripts/Testing.fsx

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,8 @@ open Projects
1111
module Tests =
1212
let private testProjectJson parallelization =
1313
let p = Paths.Source "Tests/project.json"
14-
Tooling.DotNet.Exec ["restore"; p;]
14+
Tooling.DotNet.Exec ["restore"; p; "--verbosity Warning"]
15+
Tooling.DotNet.Exec ["build"; p; "--configuration Release"; "-f"; "netcoreapp1.0"]
1516
Tooling.DotNet.Exec ["test"; p; "-parallel"; parallelization; "-xml"; Paths.Output("TestResults-Core-Clr.xml")]
1617

1718
let private testDesktopClr parallelization =

src/Nest/Document/Multiple/ReindexOnServer/ReindexOnServerRequest.cs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
using System;
22
using System.CodeDom;
3+
using Elasticsearch.Net;
34
using Newtonsoft.Json;
5+
using Newtonsoft.Json.Converters;
46

57
namespace Nest
68
{
@@ -17,6 +19,10 @@ public partial interface IReindexOnServerRequest
1719

1820
[JsonProperty("size")]
1921
long? Size { get; set; }
22+
23+
[JsonProperty("conflicts")]
24+
[JsonConverter(typeof(StringEnumConverter))]
25+
Conflicts? Conflicts { get; set; }
2026
}
2127

2228
public partial class ReindexOnServerRequest
@@ -25,6 +31,7 @@ public partial class ReindexOnServerRequest
2531
public IReindexDestination Destination { get; set; }
2632
public IScript Script { get; set; }
2733
public long? Size { get; set; }
34+
public Conflicts? Conflicts { get; set; }
2835
}
2936

3037
[DescriptorFor("Reindex")]
@@ -34,6 +41,7 @@ public partial class ReindexOnServerDescriptor
3441
IReindexDestination IReindexOnServerRequest.Destination { get; set; }
3542
IScript IReindexOnServerRequest.Script { get; set; }
3643
long? IReindexOnServerRequest.Size { get; set; }
44+
Conflicts? IReindexOnServerRequest.Conflicts { get; set; }
3745

3846
public ReindexOnServerDescriptor Source(Func<ReindexSourceDescriptor, IReindexSource> selector = null) =>
3947
Assign(a => a.Source = selector.InvokeOrDefault(new ReindexSourceDescriptor()));
@@ -47,5 +55,7 @@ public ReindexOnServerDescriptor Script(Func<ScriptDescriptor, IScript> scriptSe
4755
Assign(a => a.Script = scriptSelector?.Invoke(new ScriptDescriptor()));
4856

4957
public ReindexOnServerDescriptor Size(long? size) => Assign(a => a.Size = size);
58+
59+
public ReindexOnServerDescriptor Conflicts(Conflicts conflicts) => Assign(a => a.Conflicts = conflicts);
5060
}
5161
}

src/Tests/Document/Multiple/ReindexOnServer/ReindexOnServerApiTests.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@ protected override LazyResponses ClientUsage() => Calls(
7272
.Routing(ReindexRouting.Discard)
7373
)
7474
.Script(_script)
75+
.Conflicts(Conflicts.Proceed)
7576
.Refresh();
7677

7778
protected override ReindexOnServerRequest Initializer => new ReindexOnServerRequest()
@@ -94,6 +95,7 @@ protected override LazyResponses ClientUsage() => Calls(
9495
Routing = ReindexRouting.Discard
9596
},
9697
Script = new InlineScript(_script),
98+
Conflicts = Conflicts.Proceed,
9799
Refresh = true,
98100
};
99101

@@ -133,7 +135,8 @@ protected override void ExpectResponse(IReindexOnServerResponse response)
133135
sort = new [] { new { id = new { order = "asc" } } },
134136
type = new [] { "test" },
135137
size = 100
136-
}
138+
},
139+
conflicts = "proceed"
137140
};
138141
}
139142
}

src/Tests/tests.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
# mode either u (unit test), i (integration test) or m (mixed mode)
2-
mode: u
2+
mode: m
33
# the elasticsearch version that should be started
44
elasticsearch_version: 2.3.5
55
# whether we want to forcefully reseed on the node, if you are starting the tests with a node already running

0 commit comments

Comments
 (0)