Default Metrics collection (Spring Boot)

[bitzl]

To monitor a Flusswerk applications performance Flow has a metrics callback that calls a Consumer<FlowStatus>. Most Spring Boot based applications will have the same implementation of a Metrics class using the Micrometer library or extend a similar Metrics implementation...

The Spring Boot Starter should provide a default Metrics implementation that can be overridden by defining a custom Metrics bean.

Example

public class Metrics implements Consumer<FlowStatus> {

  private final Map<Status, Counter> executionTime;
  private final Map<Status, Counter> processedItems;

  public Metrics(MeterFactory meterFactory) {
    this.executionTime = new EnumMap<>(Status.class);
    this.processedItems = new EnumMap<>(Status.class);

    for (Status status : Status.values()) {
      processedItems.put(status, meterFactory.counter("processed.items", status));
      executionTime.put(status, meterFactory.counter("execution.time", status));
    }
  }

  public void accept(FlowStatus flowStatus) {
    var status = flowStatus.getStatus();
    processedItems.get(status).increment();
    executionTime.get(status).increment(flowStatus.duration());
  }
}