Build event name in Engine context

Author: vordimous

incubator/catalog-filesystem/src/main/java/io/aklivity/zilla/runtime/catalog/filesystem/internal/FilesystemEventFormatter.java

@@ -39,7 +39,7 @@ public String format(
         int length)
     {
         final EventFW event = eventRO.wrap(buffer, index, index + length);
-        final FilesystemEventExFW extension = schemaRegistryEventExRO
+        final FilesystemEventExFW extension = filesystemEventExRO
             .wrap(event.extension().buffer(), event.extension().offset(), event.extension().limit());
         String result = null;
         switch (extension.kind())

runtime/engine/src/main/java/io/aklivity/zilla/runtime/engine/EngineContext.java

@@ -134,6 +134,9 @@ String supplyQName(
     int supplyEventId(
         String name);
 
+    String supplyEventName(
+        int eventId);
+
     BindingHandler streamFactory();
 
     GuardHandler supplyGuard(

runtime/engine/src/main/java/io/aklivity/zilla/runtime/engine/internal/registry/EngineWorker.java

@@ -224,6 +224,7 @@ public class EngineWorker implements EngineContext, Agent
     private final ScalarsLayout gaugesLayout;
     private final HistogramsLayout histogramsLayout;
     private final EventsLayout eventsLayout;
+    private final Int2ObjectHashMap<String> eventNames;
     private final Supplier<MessageReader> supplyEventReader;
     private final EventFormatterFactory eventFormatterFactory;
 
@@ -311,6 +312,7 @@ public EngineWorker(
             .path(config.directory().resolve(String.format("events%d", index)))
             .capacity(config.eventsBufferCapacity())
             .build();
+        this.eventNames = new Int2ObjectHashMap<>();
 
         this.agentName = String.format("engine/data#%d", index);
         this.streamsLayout = streamsLayout;
@@ -485,6 +487,13 @@ public int supplyEventId(
         return labels.supplyLabelId(name);
     }
 
+    @Override
+    public String supplyEventName(
+            int eventId)
+    {
+        return eventNames.computeIfAbsent(eventId, this::computeEventName);
+    }
+
     @Override
     public int supplyTypeId(
         String name)
@@ -1733,6 +1742,12 @@ public EventFormatter supplyEventFormatter()
         return eventFormatterFactory.create(config, this);
     }
 
+    private String computeEventName(
+            int eventId)
+    {
+        return supplyLocalName(eventId).replace('.', '_').toUpperCase();
+    }
+
     private MessageConsumer supplyWriter(
         int index)
     {

runtime/exporter-stdout/src/main/java/io/aklivity/zilla/runtime/exporter/stdout/internal/stream/StdoutEventsStream.java

@@ -62,7 +62,7 @@ private void handleEvent(
     {
         final EventFW event = eventRO.wrap(buffer, index, index + length);
         String qname = context.supplyQName(event.namespacedId());
-        String eventName = context.supplyLocalName(event.id()).replace('.', '_').toUpperCase();
+        String eventName = context.supplyEventName(event.id());
         String extension = formatter.format(msgTypeId, buffer, index, length);
         out.format(FORMAT, qname, asDateTime(event.timestamp()), eventName, extension);
     }