EventFlow.Example - GitLite

KO | EN

gitlite — search

#python #react #typescript #golang #go #rust #docker #nodejs #java #vue #awesome-list #mcp #openai #open-source

EventFlow.Example

(★ 204)

DDD+CQRS+Event-sourcing examples using EventFlow following CQRS-ES architecture. It is configured with RabbitMQ, MongoDB(Snapshot store), PostgreSQL(Read store), EventStore(GES). It's targeted to .Net Core 2.2 and include docker compose file.

File Explorer

Download Latest Version (.zip)

- - dotnetcore.yml
- docker-compose.yml
- - ExampleAggregate.cs
- - ExampleJobs.cs
- - CommandReturnResult.cs
- EventFlow.Example.csproj
- Program.cs
- PublishCommand.cs
- EventFlow.Tests.csproj
- IntegrationTestBase.cs
- IntegrationTests.cs
- EventStore.csproj
- EventStoreExtension.cs
- architecture_diagram.png
- ExampleAggregate.cs
- ExampleEvent.cs
- ExampleSyncSubscriber.cs
- Program.cs
- SyncEventHandler.csproj
.dockerignore
.gitignore
_config.yml
EventFlowExamples.sln
LICENSE
README.md

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# EventFlow.Example
![Hits](https://hitcounter.pythonanywhere.com/count/tag.svg?url=https://github.com/OKTAYKIR/EventFlow.Example)
![GitHub issues](https://img.shields.io/github/issues/OKTAYKIR/EventFlow.Example)
![Build Status](https://github.com/OKTAYKIR/EventFlow.Example/workflows/CI/badge.svg)
[![PRs Welcome](https://img.shields.io/badge/PRs-welcome-brightgreen.svg)](https://raw.githubusercontent.com/OKTAYKIR/EventFlow.Example/master/)

DDD+CQRS+Event-sourcing examples using EventFlow following CQRS-ES architecture. It is configured with RabbitMQ, MongoDB(Snapshot store), PostgreSQL(Read store), EventStore(GES). It's targeted to .Net Core 2.2 and include [docker compose file](/build/docker-compose.yml).

## Event Sourcing/CQRS Architecture
The most common CQRS/ES architecture would look like following diagram
![OverallArchitecture](https://github.com/OKTAYKIR/EventFlow.Example/blob/master/Images/architecture_diagram.png)

The example consists of the following concepts, each shown below

- Aggregates
- Command bus and commands
- Synchronous subscriber
- Event store ([GES](https://eventstore.com/))
- In-memory read model.
- Snapshots ([MongoDb](https://www.mongodb.com/))
- Sagas
- Event publising (In-memory, [RabbitMq](https://www.rabbitmq.com/))
- Metadata
- Command bus decorator, custom value object, custom execution result, ...

## Configuration
```csharp
var resolver = EventFlowOptions.New
    .UseAutofacContainerBuilder(new ContainerBuilder())
    .Configure(c => c.ThrowSubscriberExceptions = true)
    .AddEvents(typeof(ExampleEvent))
    .AddEvents(typeof(ResetEvent))
    .AddCommands(typeof(ExampleCommand))
    .AddCommands(typeof(ResetCommand))
    .AddCommandHandlers(typeof(ExampleCommandHandler))
    .AddCommandHandlers(typeof(ResetCommandHandler))
    .ConfigureEventStore()
    .ConfigureMongoDb(client, SNAPSHOT_CONTAINER_NAME)
    .AddSnapshots(typeof(ExampleSnaphost))
    .UseMongoDbSnapshotStore()
    .RegisterServices(sr => sr.Register(i => SnapshotEveryFewVersionsStrategy.Default))
    .RegisterServices(DecorateCommandBus)
    .PublishToRabbitMq(RabbitMqConfiguration.With(new Uri(@"amqp://test:test@localhost:5672"), true, 4, "eventflow"))
    .UseInMemoryReadStoreFor<Aggregates.ReadModels.ExampleReadModel>()
    .AddJobs(typeof(ExampleJob))
    .CreateResolver());
```

## 📦 Stack
* [EventFlow](https://github.com/eventflow/EventFlow)
* [EventStore](https://eventstore.com)
* [RabbitMQ](https://www.rabbitmq.com)
* [MongoDB](https://www.mongodb.com)
* [PostgreSQL](https://www.postgresql.org)
* [Docker](https://www.docker.com)

## 🤝 Contributing
1. Fork it ( https://github.com/OKTAYKIR/EventFlow.Example/fork )
2. Create your feature branch (`git checkout -b my-new-feature`)
3. Commit your changes (`git commit -am 'Add some feature'`)
4. Push to the branch (`git push origin my-new-feature`)
5. Create a new Pull Request

## ✨ Contributors
![GitHub Contributors Image](https://contrib.rocks/image?repo=OKTAYKIR/EventFlow.Example)

## Show your support
Please ⭐️ this repository if this project helped you!

## 📝 License
Apache-2.0 © [Oktay Kır](https://www.linkedin.com/in/oktay-kır-phd-9402955a)