Akka & Monix: Controlling Power Plants
summary
E.On monitoring/control software models asset behavior as pure state machines that return a list of effect-descriptions, not perform side effects; actors only handle messaging and call context.become, while effects are materialized to a global effects queue for persistence, alerts and dispatch. Monix Observable provides backpressure, hot/cold sources and repeatable ticks, scan implements time-windowed fault detection (e.g. require one minute of repeated failure before declaring a fault). A past outage from unbounded queues leads to limited buffers with drop-on-full and redundant retries.
AI-written summary · about
chapters (23)
- 0:00Intro
- 0:37MY WORK AT E.ON
- 3:13ASYNCHRONY
- 4:01THE BAD PARTS
- 8:20ANTI-PATTERN: INTERNAL MESSAGES
- 9:12ANTI-PATTERN: CAPTURING INTERNALS
- 9:57ASYNCHRONOUS BLOCKING
- 10:56EVOLUTIONS & CONTEXT.BECOME
- 12:24EXPLICIT TIME 1/2
- 13:58PURELY FUNCTIONAL STATE (1/5)
- 18:03HIGH LEVEL OVERVIEW
- 20:27DECOUPLING PHILOSOPHY
- 21:43BACK-PRESSURE (1/3)
- 22:46BEST PRACTICE: BACK-PRESSURE (2/3)
- 24:51MONIX SUB-PROJECTS
- 26:46OBSERVABLE: SAMPLE
- 27:45OBSERVABLE: BUILDERS (4/4)
- 29:18HOT OBSERVABLE 1/2
- 30:11POLLING
- 30:41SCAN: FILTERING DATA 2/2
- 31:37TIMEOUT GATE (1/4)
- 32:51MONIX OBSERVABLE
- 33:17CATS INTEGRATION CHALLENGES
