Practical Microservices

Viewing Messages by Stream

The Admin Portal also lets us explore all the streams that are in the Message Store:

This view also gives us the number of messages in the stream and the globalPosition of the last message that updated the stream’s view. We could do this as a raw query on the Message Store, but that would be a hefty query to execute. We’ll instead add another Aggregator to generate this view. Let’s start with the migration that builds the database table we’ll aggregate to:

debugging-components/migrations/20190830155603_create-admin-streams.js

exports.up = function up (knex) {
  return knex.schema.createTable('admin_streams', table ...