Access Event Store

Use Event Store directly
In some cases you may want to access Event Store directly. 
Event Store is auto registered in your Dependency Container, so you can fetch it like any other service or inject it directly to any Handler.
use Ecotone\EventSourcing\EventStore;
    
    #[QueryHandler(self::GET_CURRENT_BALANCE_QUERY)]
    public function getCurrentBalance(#[Reference] EventStore $eventStore): array
    {
        $streamName = "wallet";
        if (!$eventStore->hasStream($streamName)) {
            return [];
        }
​
        /** @var Event[] $event */
        $events = $eventStore->load($streamName, count: 10);
​
        return $events;
    }

Projection CLI Actions

Emitting events

Last modified 7mo ago