added micrometer for observability

Author: vanrogu

pom.xml

@@ -33,7 +33,7 @@
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
-		<sliceworkz.eventstore.version>0.3.5</sliceworkz.eventstore.version>
+		<sliceworkz.eventstore.version>0.4.0</sliceworkz.eventstore.version>
 
 		<maven.minimal-version>3.6.3</maven.minimal-version>
 

sliceworkz-eventmodeling-api/src/main/java/org/sliceworkz/eventmodeling/boundedcontext/BoundedContextBuilder.java

@@ -29,6 +29,8 @@
 import org.sliceworkz.eventmodeling.slices.FeatureSliceConfiguration;
 import org.sliceworkz.eventstore.spi.EventStorage;
 
+import io.micrometer.core.instrument.MeterRegistry;
+
 public interface BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> {
 
 	BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> name(String name);
@@ -40,6 +42,8 @@ BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE
 
 	BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> instance(Instance instance);
 
+	BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> meterRegistry(MeterRegistry meterRegistry);
+
 	BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> featureDeployFilter(Predicate<FeatureSliceConfiguration<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE>> featureDeployFilter);
 
 	BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> eventStorage(EventStorage eventStorage);

sliceworkz-eventmodeling-impl/src/main/java/org/sliceworkz/eventmodeling/module/boundedcontext/BoundedContextBuilderImpl.java

@@ -55,6 +55,9 @@
 import org.sliceworkz.eventstore.stream.EventStream;
 import org.sliceworkz.eventstore.stream.EventStreamId;
 
+import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.Metrics;
+
 public class BoundedContextBuilderImpl<DOMAIN_EVENT_TYPE,INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> implements BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> {
 
 	static {
@@ -77,6 +80,8 @@ public class BoundedContextBuilderImpl<DOMAIN_EVENT_TYPE,INBOUND_EVENT_TYPE, OUT
 	private Class<INBOUND_EVENT_TYPE> inboundEventRootType;
 	private Class<OUTBOUND_EVENT_TYPE> outboundEventRootType;
 
+	private MeterRegistry meterRegistry = Metrics.globalRegistry;
+	
 	private EventStorage eventStorage;
 
 	private Instance instance;
@@ -105,6 +110,12 @@ public BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVE
 		return this;
 	}
 
+	@Override
+	public BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> meterRegistry ( MeterRegistry meterRegistry ) {
+		this.meterRegistry = meterRegistry;
+		return this;
+	}
+
 	@Override
 	public BoundedContextBuilder<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND_EVENT_TYPE> rootPackage ( Package rootPackage ) {
 		this.rootPackage = rootPackage;
@@ -213,7 +224,7 @@ public <T extends BoundedContext<DOMAIN_EVENT_TYPE, INBOUND_EVENT_TYPE, OUTBOUND
 		EventStream<OUTBOUND_EVENT_TYPE> outboundEventStream;
 		EventStream<KernelEvent> observabilityEventStream; 
 
-		EventStore eventStore = EventStoreFactory.get().eventStore(eventStorage);
+		EventStore eventStore = EventStoreFactory.get().eventStore(eventStorage, meterRegistry);
 		domainEventStream = eventStore.getEventStream(EventStreamId.forContext(name).withPurpose("domain"), domainEventRootType);
 		inboundEventStream = eventStore.getEventStream(EventStreamId.forContext(name).withPurpose("inbound"), inboundEventRootType);
 		outboundEventStream = eventStore.getEventStream(EventStreamId.forContext(name).withPurpose("outbound"), outboundEventRootType);

sliceworkz-eventmodeling-parent-pom/pom.xml

@@ -38,6 +38,7 @@
 		<slf4j.version>2.0.17</slf4j.version>
 		<junit-jupiter.version>6.0.1</junit-jupiter.version>
 		<postgresql.jdbc.version>42.7.8</postgresql.jdbc.version>
+		<micrometer.version>1.16.0</micrometer.version>
 
 		<testcontainers.postgresql.version>1.21.3</testcontainers.postgresql.version>
 		<archunit.version>1.4.1</archunit.version>
@@ -110,6 +111,14 @@
 			    <scope>test</scope>
 			</dependency>
 
+			<!-- micrometer -->
+			<dependency>
+			    <groupId>io.micrometer</groupId>
+			    <artifactId>micrometer-core</artifactId>
+			    <version>${micrometer.version}</version>
+			    <optional>true</optional>
+			</dependency>
+			
 		</dependencies>
 	</dependencyManagement>
 
@@ -130,7 +139,14 @@
 		    <artifactId>slf4j-simple</artifactId>
 		    <scope>test</scope>
 		</dependency>
-
+		
+		<!-- micrometer -->
+		<dependency>
+		    <groupId>io.micrometer</groupId>
+		    <artifactId>micrometer-core</artifactId>
+		    <optional>true</optional>
+		</dependency>
+		
 	</dependencies>
 
 	<build>