1 package dst.ass3.messaging;
3 import java.io.Closeable;
4 import java.io.IOException;
7 public interface IWorkloadMonitor extends Closeable {
10 * Returns for each request type the amount of waiting requests.
14 Map<RequestType, Long> getRequestCount();
17 * Returns the amount of workers for each request type. This can be deduced from the amount of consumers to each
22 Map<RequestType, Long> getWorkerCount();
25 * Returns for each request type the average processing time of the last 10 recorded requests. The data comes from
26 * subscriptions to the respective topics.
30 Map<RequestType, Double> getAverageProcessingTime();
33 void close() throws IOException;