EdgeStream
Real-time pub/sub message pipeline for BizFirstGO — SignalR, WebSocket, and SSE transports with hooks, plugins, and React bindings.
Overview
10 packages, three transports, core concepts — topics, messages, hooks, subscribers, plugins.
Message Pipeline
Message lifecycle: Normalization → Pre-pipeline → Transport → Delivery → Post-pipeline.
Hooks
6 hook types: Normalization, PrePipeline, PostPipeline, Incoming, Outgoing, HookActivityLogger.
Subscribers
SubscriptionManager, TopicMatcher (wildcards), SubscriptionRegistry — reactive listeners.
Servers
EdgeStreamServer, SignalR hub, client groups, IEdgeStreamPublisher backend service.
Transports
SignalR (default), WebSocket, SSE — automatic fallback chain, transport selection.
Observability
HooksMonitor, SubscribersMonitor, getMetrics() — message rates and subscription counts.
React Bindings
useSubscription(), useMessage(), EdgeStreamProvider — React hooks and context.
Message Plugins
IEdgeStreamPlugin interface, plugin lifecycle, registration patterns.
Available Plugins
Auth, Reconnect, Compression, TypeValidation, Logging, Retry — built-in plugins.
Dev Tools
Message inspector, topic explorer, hook visualizer, replay, and message injection.