Add configuration plus logging

Author: Bj0rnen

src/main/java/com/spotify/reaper/ReaperApplicationConfiguration.java

@@ -4,19 +4,63 @@
 
 import org.hibernate.validator.constraints.NotEmpty;
 
+import javax.validation.constraints.Max;
+import javax.validation.constraints.Min;
+
 import io.dropwizard.Configuration;
 
 public class ReaperApplicationConfiguration extends Configuration {
 
-  private String testingValue;
+  private int segmentCount;
+
+  @NotEmpty
+  private String repairStrategy;
+
+  private boolean snapshotRepair;
+
+  private double repairIntensity;
+
+
+  @JsonProperty
+  public int getSegmentCount() {
+    return segmentCount;
+  }
+
+  @JsonProperty
+  public void setSegmentCount(int segmentCount) {
+    this.segmentCount = segmentCount;
+  }
+
+
+  @JsonProperty
+  public String getRepairStrategy() {
+    return repairStrategy;
+  }
+
+  @JsonProperty
+  public void setRepairStrategy(String repairStrategy) {
+    this.repairStrategy = repairStrategy;
+  }
+
+
+  @JsonProperty
+  public boolean getSnapshotRepair() {
+    return snapshotRepair;
+  }
+
+  @JsonProperty
+  public void setSnapshotRepair(boolean snapshotRepair) {
+    this.snapshotRepair = snapshotRepair;
+  }
+
 
   @JsonProperty
-  public String getTestingValue() {
-    return testingValue;
+  public double getRepairIntensity() {
+    return repairIntensity;
   }
 
   @JsonProperty
-  public void setTestingValue(String testingValue) {
-    this.testingValue = testingValue;
+  public void setRepairIntensity(double repairIntensity) {
+    this.repairIntensity = repairIntensity;
   }
 }

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

@@ -2,6 +2,9 @@
 
 import com.google.common.base.Optional;
 
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
+
 import javax.ws.rs.POST;
 import javax.ws.rs.Path;
 import javax.ws.rs.Produces;
@@ -12,8 +15,11 @@
 @Produces(MediaType.TEXT_PLAIN)
 public class AddClusterResource {
 
+  private static final Logger LOG = LoggerFactory.getLogger(AddClusterResource.class);
+
   @POST
   public String addCluster(@QueryParam("host") Optional<String> host) {
+    LOG.info("add_cluster called with host: {}", host);
     return String.format("Not implemented yet");
   }
 

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

@@ -16,6 +16,7 @@ public class AddTableResource {
   public String addTable(@QueryParam("host") Optional<String> host,
                          @QueryParam("keyspace") Optional<String> keyspace,
                          @QueryParam("table") Optional<String> table) {
+
     return String.format("Not implemented yet");
   }
 

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

@@ -14,6 +14,7 @@ public class RepairTableResource {
 
   @POST
   public String addTable(@QueryParam("repair_run_id") Optional<String> repairRunID) {
+
     return String.format("Not implemented yet");
   }
 

src/test/resources/cassandra-reaper.yaml

@@ -0,0 +1,13 @@
+segmentCount: 100
+repairStrategy: com.spotify.reaper.SequentialRepairStrategy
+snapshotRepair: false
+repairIntensity: 0.75
+
+logging:
+  level: INFO
+  appenders:
+    - type: syslog
+      threshold: ALL
+      timeZone: UTC
+      facility: local0
+      stackTracePrefix: \t