Track time when a repair run is paused

Author: Bj0rnen

src/main/java/com/spotify/reaper/core/RepairRun.java

@@ -31,6 +31,7 @@ public class RepairRun {
   private final DateTime creationTime;
   private final DateTime startTime;
   private final DateTime endTime;
+  private final DateTime pauseTime;
   private final double intensity;
 
   public long getId() {
@@ -69,6 +70,10 @@ public DateTime getEndTime() {
     return endTime;
   }
 
+  public DateTime getPauseTime() {
+    return pauseTime;
+  }
+
   public double getIntensity() {
     return intensity;
   }
@@ -91,6 +96,7 @@ private RepairRun(Builder builder, long id) {
     this.creationTime = builder.creationTime;
     this.startTime = builder.startTime;
     this.endTime = builder.endTime;
+    this.pauseTime = builder.pauseTime;
     this.intensity = builder.intensity;
   }
 
@@ -109,6 +115,7 @@ public static class Builder {
     private String owner;
     private DateTime startTime;
     private DateTime endTime;
+    private DateTime pauseTime;
 
     public Builder(String clusterName, long repairUnitId, DateTime creationTime,
         double intensity) {
@@ -129,6 +136,7 @@ private Builder(RepairRun original) {
       owner = original.owner;
       startTime = original.startTime;
       endTime = original.endTime;
+      pauseTime = original.pauseTime;
     }
 
     public Builder runState(RunState runState) {
@@ -166,6 +174,11 @@ public Builder endTime(DateTime endTime) {
       return this;
     }
 
+    public Builder pauseTime(DateTime pauseTime) {
+      this.pauseTime = pauseTime;
+      return this;
+    }
+
     public RepairRun build(long id) {
       return new RepairRun(this, id);
     }

src/main/java/com/spotify/reaper/resources/RepairRunResource.java

@@ -254,6 +254,7 @@ private Response pauseRun(RepairRun repairRun, RepairUnit repairUnit) {
     LOG.info("Pausing run {}", repairRun.getId());
     RepairRun updatedRun = repairRun.with()
         .runState(RepairRun.RunState.PAUSED)
+        .pauseTime(DateTime.now())
         .build(repairRun.getId());
     storage.updateRepairRun(updatedRun);
     return Response.ok().entity(new RepairRunStatus(repairRun, repairUnit)).build();
@@ -263,6 +264,7 @@ private Response resumeRun(RepairRun repairRun, RepairUnit repairUnit) {
     LOG.info("Resuming run {}", repairRun.getId());
     RepairRun updatedRun = repairRun.with()
         .runState(RepairRun.RunState.RUNNING)
+        .pauseTime(null)
         .build(repairRun.getId());
     storage.updateRepairRun(updatedRun);
     return Response.ok().entity(new RepairRunStatus(repairRun, repairUnit)).build();