Снапшоты JOliver EventStore

Аспект моментальных снимков EventStore требует немного любви. Я попытался сделать интерфейс IStoreEvents ориентированным на работу с отдельными агрегатами. Я также попытался убедиться, что моментальные снимки не мешают и не мешают нормальному использованию.

После выпуска версии 2.0 я обратил свое внимание на версию 2.1, и я смогу внести несколько небольших изменений в API, связанных с этим. В то же время, ваш лучший вариант, вероятно, — вообще обойти IStoreEvents при создании моментальных снимков.

Другой альтернативой является запуск кода моментальных снимков вместе с вашим обычным кодом. Когда агрегат загружается, ему требуется моментальный снимок, вы можете легко передать ссылку на этот агрегат асинхронно в свой код моментального снимка. Таким образом, вам фактически не нужно делать нагрузку, потому что у вас уже есть агрегат.

Я нашел решение для себя (это определенно хак). Это все еще внеполосная съемка. Вот пример его работы.

private void CreateSnapshots(IEnumerable<StreamHead> streams)
{
    foreach (StreamHead head in streams)
    {
        //NOTE: This uses a patched version of EventStore that loads commit headers in OptimisticEventStream.PopulateStream()
        // <code>
        // this.identifiers.Add(commit.CommitId);
        // this.headers = this.headers.Union(commit.Headers).ToDictionary(k => k.Key, k => k.Value);
        // </code>
        var stream = eventStore.OpenStream(head.StreamId, int.MinValue, int.MaxValue);

        //NOTE: Nasty hack but it works.
        var aggregateType = stream.UncommittedHeaders.Where(p=>p.Key=="AggregateType").First();
        var type = aggregateTypeResolver(aggregateType.Value.ToString());

        MethodInfo methodInfo = typeof(IRepository).GetMethod("GetById");
        MethodInfo method = methodInfo.MakeGenericMethod(type);

        object o = method.Invoke(repository, new object[]{head.StreamId, head.HeadRevision});
        var aggregate = (IAggregate) o;

        IMemento memento = aggregate.GetSnapshot();

        var snapshot = new Snapshot(head.StreamId, head.HeadRevision, memento);

        eventStore.AddSnapshot(snapshot);

        observer.Notify(new SnapshotTaken(head.StreamId, head.HeadRevision));
    }
}