macula_direct_routing (macula v0.20.5)

Direct Routing Table - Bypass bootstrap for known subscriber endpoints.

Problem: Every publish goes through bootstrap even for known subscribers. Solution: Cache {NodeId, Endpoint} mappings and route directly via QUIC.

Design: - ETS table for O(1) lookup by NodeId - TTL-based expiration (default 5 minutes) - Automatic cleanup of stale entries - Thread-safe concurrent reads

Expected improvement: - 3-5x latency reduction for messages to known subscribers - Reduced load on bootstrap gateway

Configuration Options: - ttl_ms: Route entry TTL (default: 300000ms = 5 minutes) - cleanup_interval_ms: How often to clean stale entries (default: 60000ms)

Summary

Functions

clear_all()

Clear all routing entries.

handle_call(Request, From, State)

handle_cast(Msg, State)

handle_info(Info, State)

init(Opts)

lookup(NodeId)

Look up endpoint for a node ID. Returns {ok, Endpoint} on hit, or miss on cache miss/expired.

remove(NodeId)

Remove routing entry for a node ID.

start_link()

Start the direct routing table with default options.

start_link(Opts)

Start the direct routing table with options. Options: - ttl_ms: Route entry TTL in milliseconds (default: 300000) - cleanup_interval_ms: Cleanup interval (default: 60000)

stats()

Get routing table statistics.

store(NodeId, Endpoint)

Store endpoint for a node ID. Entry will expire after TTL.

store_from_subscriber(_)

Store routing info from a subscriber map (from DHT lookup). Extracts node_id and endpoint from subscriber info.

terminate(Reason, State)