resource usage endpoint

SingularityBase/src/main/java/com/hubspot/mesos/json/MesosTaskStatisticsObject.java

@@ -15,7 +15,8 @@ public class MesosTaskStatisticsObject {
   private final long memLimitBytes;
   private final long memMappedFileBytes;
   private final long memRssBytes;
-  private final double timestamp;
+  private final long memTotalBytes;
+  private final double timestampSeconds;
 
   @JsonCreator
   public MesosTaskStatisticsObject(@JsonProperty("cpus_limit") int cpusLimit,
@@ -29,7 +30,8 @@ public MesosTaskStatisticsObject(@JsonProperty("cpus_limit") int cpusLimit,
                                    @JsonProperty("mem_limit_bytes") long memLimitBytes,
                                    @JsonProperty("mem_mapped_file_bytes") long memMappedFileBytes,
                                    @JsonProperty("mem_rss_bytes") long memRssBytes,
-                                   @JsonProperty("timestamp") double timestamp) {
+                                   @JsonProperty("mem_total_bytes") long memTotalBytes,
+                                   @JsonProperty("timestamp") double timestampSeconds) {
     this.cpusLimit = cpusLimit;
     this.cpusNrPeriods = cpusNrPeriods;
     this.cpusNrThrottled = cpusNrThrottled;
@@ -41,7 +43,8 @@ public MesosTaskStatisticsObject(@JsonProperty("cpus_limit") int cpusLimit,
     this.memLimitBytes = memLimitBytes;
     this.memMappedFileBytes = memMappedFileBytes;
     this.memRssBytes = memRssBytes;
-    this.timestamp = timestamp;
+    this.memTotalBytes = memTotalBytes;
+    this.timestampSeconds = timestampSeconds;
   }
 
   public int getCpusLimit() {
@@ -88,8 +91,12 @@ public long getMemRssBytes() {
     return memRssBytes;
   }
 
-  public double getTimestamp() {
-    return timestamp;
+  public long getMemTotalBytes() {
+    return memTotalBytes;
+  }
+
+  public double getTimestampSeconds() {
+    return timestampSeconds;
   }
 
   @Override
@@ -106,7 +113,8 @@ public String toString() {
         ", memLimitBytes=" + memLimitBytes +
         ", memMappedFileBytes=" + memMappedFileBytes +
         ", memRssBytes=" + memRssBytes +
-        ", timestamp=" + timestamp +
+        ", memTotalBytes=" + memTotalBytes +
+        ", timestampSeconds=" + timestampSeconds +
         '}';
   }
 }

SingularityBase/src/main/java/com/hubspot/singularity/RequestUtilization.java

@@ -0,0 +1,140 @@
+package com.hubspot.singularity;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class RequestUtilization {
+  private final String requestId;
+  private final String deployId;
+
+  private long memBytesUsed = 0;
+  private long memBytesReserved = 0;
+  private double cpuUsed = 0;
+  private double cpuReserved = 0;
+  private int numTasks = 0;
+
+  private long maxMemBytesUsed = 0;
+  private long minMemBytesUsed = Long.MAX_VALUE;
+  private double maxCpuUsed = 0;
+  private double minCpuUsed = Double.MAX_VALUE;
+
+  @JsonCreator
+  public RequestUtilization(@JsonProperty("requestId") String requestId,
+                            @JsonProperty("deployId") String deployId) {
+    this.requestId = requestId;
+    this.deployId = deployId;
+  }
+
+  public RequestUtilization addMemBytesUsed(long memBytes) {
+    this.memBytesUsed += memBytes;
+    return this;
+  }
+
+  public RequestUtilization addMemBytesReserved(long memBytes) {
+    this.memBytesReserved += memBytes;
+    return this;
+  }
+
+  public RequestUtilization addCpuUsed(double cpu) {
+    this.cpuUsed += cpu;
+    return this;
+  }
+
+  public RequestUtilization addCpuReserved(double cpu) {
+    this.cpuReserved += cpu;
+    return this;
+  }
+
+  public RequestUtilization incrementTaskCount() {
+    this.numTasks++;
+    return this;
+  }
+
+  public long getMemBytesUsed() {
+    return memBytesUsed;
+  }
+
+  public long getMemBytesReserved() {
+    return memBytesReserved;
+  }
+
+  public double getCpuUsed() {
+    return cpuUsed;
+  }
+
+  public double getCpuReserved() {
+    return cpuReserved;
+  }
+
+  public int getNumTasks() {
+    return numTasks;
+  }
+
+  @JsonIgnore
+  public double getAvgMemBytesUsed() {
+    return memBytesUsed / (double) numTasks;
+  }
+
+  @JsonIgnore
+  public double getAvgCpuUsed() {
+    return cpuUsed / (double) numTasks;
+  }
+
+  public String getDeployId() {
+    return deployId;
+  }
+
+  public String getRequestId() {
+    return requestId;
+  }
+
+  public long getMaxMemBytesUsed() {
+    return maxMemBytesUsed;
+  }
+
+  public RequestUtilization setMaxMemBytesUsed(long maxMemBytesUsed) {
+    this.maxMemBytesUsed = maxMemBytesUsed;
+    return this;
+  }
+
+  public double getMaxCpuUsed() {
+    return maxCpuUsed;
+  }
+
+  public RequestUtilization setMaxCpuUsed(double maxCpuUsed) {
+    this.maxCpuUsed = maxCpuUsed;
+    return this;
+  }
+
+  public long getMinMemBytesUsed() {
+    return minMemBytesUsed;
+  }
+
+  public RequestUtilization setMinMemBytesUsed(long minMemBytesUsed) {
+    this.minMemBytesUsed = minMemBytesUsed;
+    return this;
+  }
+
+  public double getMinCpuUsed() {
+    return minCpuUsed;
+  }
+
+  public RequestUtilization setMinCpuUsed(double minCpuUsed) {
+    this.minCpuUsed = minCpuUsed;
+    return this;
+  }
+
+  @Override
+  public String toString() {
+    return "RequestUtilization{" +
+        "requestId=" + requestId +
+        ", deployId=" + deployId +
+        ", memBytesUsed=" + memBytesUsed +
+        ", memBytesReserved=" + memBytesReserved +
+        ", cpuUsed=" + cpuUsed +
+        ", cpuReserved=" + cpuReserved +
+        ", numTasks=" + numTasks +
+        '}';
+  }
+}