Changes PhaseAfterStep to take the name of the previous phase (#30756)

* Changes PhaseAfterStep to take the name of the previous phase

This changes the way the phase after step is built so its key has the
phase name of the phase that preceeds it rather than the phase that
follows it. This is more intuitive to the user since the index is in
the warm phase until the after condition for the cold phase is met.

* Fixes REST tests

x-pack/plugin/src/test/resources/rest-api-spec/test/index_lifecycle/20_m
ove_to_step.yml
x-pack/plugin/src/test/resources/rest-api-spec/test/index_lifecycle/20_m
ove_to_step.yml
This commit is contained in:
Colin Goodheart-Smithe 2018-05-24 14:01:41 +01:00 committed by GitHub
parent 84c4598e47
commit b308a4a471
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 21 additions and 14 deletions

View File

@ -178,15 +178,19 @@ public class LifecyclePolicy extends AbstractDiffable<LifecyclePolicy>
// add steps for each phase, in reverse // add steps for each phase, in reverse
while (phaseIterator.hasPrevious()) { while (phaseIterator.hasPrevious()) {
Phase previousPhase = phaseIterator.previous();
// add `after` step for phase before next // add `after` step for phase before next
if (phase != null) { if (phase != null) {
Step.StepKey afterStepKey = new Step.StepKey(phase.getName(), "pre-" + lastStepKey.getAction(), "after"); // after step should have the name of the previous phase since the index is still in the
// previous phase until the after condition is reached
Step.StepKey afterStepKey = new Step.StepKey(previousPhase.getName(), PhaseAfterStep.NAME, PhaseAfterStep.NAME);
Step phaseAfterStep = new PhaseAfterStep(nowSupplier, phase.getAfter(), afterStepKey, lastStepKey); Step phaseAfterStep = new PhaseAfterStep(nowSupplier, phase.getAfter(), afterStepKey, lastStepKey);
steps.add(phaseAfterStep); steps.add(phaseAfterStep);
lastStepKey = phaseAfterStep.getKey(); lastStepKey = phaseAfterStep.getKey();
} }
phase = phaseIterator.previous(); phase = previousPhase;
List<LifecycleAction> orderedActions = type.getOrderedActions(phase); List<LifecycleAction> orderedActions = type.getOrderedActions(phase);
ListIterator<LifecycleAction> actionIterator = orderedActions.listIterator(orderedActions.size()); ListIterator<LifecycleAction> actionIterator = orderedActions.listIterator(orderedActions.size());
// add steps for each action, in reverse // add steps for each action, in reverse
@ -203,7 +207,8 @@ public class LifecyclePolicy extends AbstractDiffable<LifecyclePolicy>
} }
if (phase != null) { if (phase != null) {
Step.StepKey afterStepKey = new Step.StepKey(phase.getName(), "pre-" + lastStepKey.getAction(), "after"); // The very first after step is in a phase before the hot phase so call this "new"
Step.StepKey afterStepKey = new Step.StepKey("new", PhaseAfterStep.NAME, PhaseAfterStep.NAME);
Step phaseAfterStep = new PhaseAfterStep(nowSupplier, phase.getAfter(), afterStepKey, lastStepKey); Step phaseAfterStep = new PhaseAfterStep(nowSupplier, phase.getAfter(), afterStepKey, lastStepKey);
steps.add(phaseAfterStep); steps.add(phaseAfterStep);
lastStepKey = phaseAfterStep.getKey(); lastStepKey = phaseAfterStep.getKey();

View File

@ -14,6 +14,7 @@ import java.util.Objects;
import java.util.function.LongSupplier; import java.util.function.LongSupplier;
public class PhaseAfterStep extends ClusterStateWaitStep { public class PhaseAfterStep extends ClusterStateWaitStep {
public static final String NAME = "after";
private final TimeValue after; private final TimeValue after;
private final LongSupplier nowSupplier; private final LongSupplier nowSupplier;

View File

@ -135,7 +135,7 @@ public class LifecyclePolicyTests extends AbstractSerializingTestCase<LifecycleP
phases.put(firstPhase.getName(), firstPhase); phases.put(firstPhase.getName(), firstPhase);
LifecyclePolicy policy = new LifecyclePolicy(TestLifecycleType.INSTANCE, lifecycleName, phases); LifecyclePolicy policy = new LifecyclePolicy(TestLifecycleType.INSTANCE, lifecycleName, phases);
StepKey firstStepKey = InitializePolicyContextStep.KEY; StepKey firstStepKey = InitializePolicyContextStep.KEY;
StepKey secondStepKey = new StepKey("test", "pre-test", "after"); StepKey secondStepKey = new StepKey("new", PhaseAfterStep.NAME, PhaseAfterStep.NAME);
List<Step> steps = policy.toSteps(client, nowSupplier); List<Step> steps = policy.toSteps(client, nowSupplier);
assertThat(steps.size(), equalTo(4)); assertThat(steps.size(), equalTo(4));
assertSame(steps.get(0).getKey(), firstStepKey); assertSame(steps.get(0).getKey(), firstStepKey);
@ -151,10 +151,11 @@ public class LifecyclePolicyTests extends AbstractSerializingTestCase<LifecycleP
Client client = mock(Client.class); Client client = mock(Client.class);
LongSupplier nowSupplier = () -> 0L; LongSupplier nowSupplier = () -> 0L;
MockStep secondActionStep = new MockStep(new StepKey("second_phase", "test2", "test"), TerminalPolicyStep.KEY); MockStep secondActionStep = new MockStep(new StepKey("second_phase", "test2", "test"), TerminalPolicyStep.KEY);
MockStep secondAfter = new MockStep(new StepKey("second_phase", "pre-test2", "after"), secondActionStep.getKey()); MockStep secondAfter = new MockStep(new StepKey("first_phase", PhaseAfterStep.NAME, PhaseAfterStep.NAME),
secondActionStep.getKey());
MockStep firstActionAnotherStep = new MockStep(new StepKey("first_phase", "test", "bar"), secondAfter.getKey()); MockStep firstActionAnotherStep = new MockStep(new StepKey("first_phase", "test", "bar"), secondAfter.getKey());
MockStep firstActionStep = new MockStep(new StepKey("first_phase", "test", "foo"), firstActionAnotherStep.getKey()); MockStep firstActionStep = new MockStep(new StepKey("first_phase", "test", "foo"), firstActionAnotherStep.getKey());
MockStep firstAfter = new MockStep(new StepKey("first_phase", "pre-test", "after"), firstActionStep.getKey()); MockStep firstAfter = new MockStep(new StepKey("new", PhaseAfterStep.NAME, PhaseAfterStep.NAME), firstActionStep.getKey());
MockStep init = new MockStep(InitializePolicyContextStep.KEY, firstAfter.getKey()); MockStep init = new MockStep(InitializePolicyContextStep.KEY, firstAfter.getKey());
lifecycleName = randomAlphaOfLengthBetween(1, 20); lifecycleName = randomAlphaOfLengthBetween(1, 20);

View File

@ -76,8 +76,8 @@ teardown:
index: "my_index" index: "my_index"
body: body:
current_step: current_step:
phase: "hot" phase: "new"
action: "pre-pre-readonly" action: "after"
name: "after" name: "after"
next_step: next_step:
phase: "warm" phase: "warm"
@ -118,8 +118,8 @@ teardown:
index: my_index index: my_index
- match: { my_index.settings.index.lifecycle.name: "my_moveable_timeseries_lifecycle" } - match: { my_index.settings.index.lifecycle.name: "my_moveable_timeseries_lifecycle" }
- match: { my_index.settings.index.lifecycle.step: "after" } - match: { my_index.settings.index.lifecycle.step: "after" }
- match: { my_index.settings.index.lifecycle.action: "pre-pre-readonly" } - match: { my_index.settings.index.lifecycle.action: "after" }
- match: { my_index.settings.index.lifecycle.phase: "hot" } - match: { my_index.settings.index.lifecycle.phase: "new" }
--- ---
"Test Invalid Move To Step With Invalid Next Step": "Test Invalid Move To Step With Invalid Next Step":
@ -130,8 +130,8 @@ teardown:
index: "my_index" index: "my_index"
body: body:
current_step: current_step:
phase: "hot" phase: "new"
action: "pre-pre-readonly" action: "after"
name: "after" name: "after"
next_step: next_step:
phase: "invalid" phase: "invalid"
@ -146,8 +146,8 @@ teardown:
index: my_index index: my_index
- match: { my_index.settings.index.lifecycle.name: "my_moveable_timeseries_lifecycle" } - match: { my_index.settings.index.lifecycle.name: "my_moveable_timeseries_lifecycle" }
- match: { my_index.settings.index.lifecycle.step: "after" } - match: { my_index.settings.index.lifecycle.step: "after" }
- match: { my_index.settings.index.lifecycle.action: "pre-pre-readonly" } - match: { my_index.settings.index.lifecycle.action: "after" }
- match: { my_index.settings.index.lifecycle.phase: "hot" } - match: { my_index.settings.index.lifecycle.phase: "new" }
--- ---
"Test Invalid Move To Step With Invalid Policy": "Test Invalid Move To Step With Invalid Policy":