README

The redis events driver of laravel-microservices, on Redis Streams.

composer require mk-josias/laravel-microservices-stream-redis

Its provider is discovered and registers the driver. The shipped default stream uses it once MICROSERVICES_STREAM_DRIVER=redis:

// config/microservices.php
'default' => [
    'driver' => env('MICROSERVICES_STREAM_DRIVER', 'array'),
    'connection' => env('MICROSERVICES_STREAM_CONNECTION'), // a database.redis connection, null for `default`
    'key' => 'microservices:events', // the one Redis stream every service writes to
    'block' => 5_000,                // how long a read waits, in ms
    'count' => 50,                   // entries per read
    'claim_after' => 60_000,         // after how long a dead consumer's pending entries are taken back, in ms
    'on_failure' => 'block',         // block: a failed entry is retried before later ones; skip: later ones go on
],

What it guarantees
Order	every service writes to one Redis stream, so its entries keep the order they were published in
A cursor per consumer	one consumer group per consuming service: a new consumer disturbs none of the others
At least once	an entry is acknowledged after its handlers succeed; an unacknowledged one comes back
After a failure	`block`: the failed entry is retried before any later one; `skip`: later ones go on, it comes back after `claim_after`

It implements TracksAcknowledgements (stream:export --acknowledged) and TrimsStreams (stream:trim). Nothing is trimmed on write: run stream:trim on a schedule.

Needs Redis 5 or later, with PhpRedis or Predis.

mk-josias / laravel-microservices-stream-redis

Package info

Security

Statistics

README