Modeling a Pub/Sub API System with F# and CQRS (on a Micro Scale)
summary
Presents an F# + CQRS design that implements a single readable domain model handling both request/response and pub/sub over HTTP, WebSockets and AMQP. Describes a concrete system using Kafka and RabbitMQ for streaming/delivery guarantees, an in-memory DB with checkpoints, and property-based testing plus nbomber for reconnection and cluster tests, applied to live sports streams servicing ~4000 operator terminals to reduce integration friction and improve reliability.
AI-written summary · about
chapters (6)
- 0:00Pub/Sub system modeling
- 10:15CQRS simplifies design
- 20:34Domain modeling in F#
- 31:34Testing CQRS systems
- 43:49Q&A: Performance trade-offs
- 1:00:42Summary
related talks
43mCommander: Better Distributed Applications through CQRS and Event Sourcing
01h 25mBuilding microservices with event sourcing and CQRS
44mFrom REST to CQRS with Clojure, Kafka, & Datomic
43mKey-Value, Event-Sourcing, Cqrs, Pub/Sub as a Service, Java, Javascript
56mDeveloping Event-driven Microservices w/Event Sourcing and CQRS
46mMicroservices Data Patterns: CQRS & Event Sourcing
26mImplementing Event-Driven Microservices Architecture (...)
58mAsync messaging deep dive with Dapr, take your pub/sub skills to the next level 📨🚀
