Skip to content

x-cellent/decs

BranchesTags

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

3 Commits
mq
mq
 
 
nats
nats
 
 
nsq
nsq
 
 
testdata
testdata
 
 
README.md
README.md
 
 
clearing.go
clearing.go
 
 
command.go
command.go
 
 
commandbus.go
commandbus.go
 
 
commandbus_blackbox_test.go
commandbus_blackbox_test.go
 
 
commandbus_test.go
commandbus_test.go
 
 
commandqueue.go
commandqueue.go
 
 
commandstore.go
commandstore.go
 
 
configuring.go
configuring.go
 
 
consumerproxy.go
consumerproxy.go
 
 
defining.go
defining.go
 
 
delegating.go
delegating.go
 
 
doing.go
doing.go
 
 
event.go
event.go
 
 
eventbus.go
eventbus.go
 
 
filtering.go
filtering.go
 
 
flowing.go
flowing.go
 
 
go.mod
go.mod
 
 
go.sum
go.sum
 
 
guards.go
guards.go
 
 
handling.go
handling.go
 
 
idgen.go
idgen.go
 
 
message.go
message.go
 
 
persisting.go
persisting.go
 
 
player.go
player.go
 
 
producerproxy.go
producerproxy.go
 
 
publishing.go
publishing.go
 
 
recorder.go
recorder.go
 
 
redoing.go
redoing.go
 
 
registering.go
registering.go
 
 
subscribing.go
subscribing.go
 
 
topics.go
topics.go
 
 
undoing.go
undoing.go
 
 
unmarshalling.go
unmarshalling.go
 
 
unmashalling_test.go
unmashalling_test.go
 
 
versioning.go
versioning.go
 
 

Repository files navigation

DECS - Distributed Event and Command Sourcing toolkit

Architecture

NATS/STAN

Doing

                                                                 +-----------------------+
                                                                 |             NATS/STAN |
                                                                 |                       |
                                           marshal               |    +-------------+    |
                           +----------------------------------------->+ Topic Queue |    |
          Command          |                                     |    +------+------+    |
             +             |                                     |           |           |
             |             |                                     |         +-+-+         |
             |(1)          |(3.1)                                |         |   |         |
             |             |                                     +-----------------------+
             v             |                                               |   |
          +--+--+          |                                               |   |
+---------+ Do  +----------------------------------------------+           |   |
|         +--+--+          |                     Command Bus A |           |   |
|            |             |                                   +---+    (4)|   |(4)+
|            |   (2)   +---+---+  (3.2)  +----------------+    | B |       |   |
|            +-------->+ Guard +-------->+ Undoable Stack |    |   |       |   |
|                      +-+-+-+-+         +----------------+    |   |       |   |
|                        | | |                                 |   |       |   |
|                   (3)' | | |                                 |   |       |   |
|                X<------+ | |       (5)' +--------------+     |   |       |   |
|                          | |    X<------+ Local Filter +<----------------+   |
|                          | |            +-------+------+     |   | unmarshal |
|                          | |(3.3)               |            |   <-----------+
|                          | |                    |(5)         |   |
|                          | +--------------------+            |   |
|                          |                      |            |   |
|                          |                      v            |   |
|                          |                  +---+---+        |   |
|                          |(3.3)'            | Queue |        |   |
|            +-------+     |                  +---+---+        |   |
|            | Store |     |                      |            |   |
|            +---+---+     |                      |(6)         |   |
|                ^         +----------------------+            |   |
|                |(8.1)                           |            |   |
|                |                                v            |   |
|      (9)  +----+----+         (7)        +------+------+     |   |
|    +----->+ Handler +<-------------------+ I/C Filters |     |   |
|    |      +--+---+--+                    +------+------+     |   |
|    |         |   |                              |            |   |
|    |         |   |    (8.2)*               (7)' |            |   |
|    |   (8.3)*|   +-------------+        X<------+            |   |
|    |         |        Event    |                             |   |
|    |         v                 v                             |   |
|    |   +-----+----+      +-----+-----+                       |   |
|    +---+ Delegate |      | Event Bus |                       |   |
|        +----------+      +-----------+                       |   |
|                                                              |   |
+---+----------------------------------------------------------+   |
    |                                                              |
    +--------------------------------------------------------------+

Undoing

                                                             +-----------------------+
                                                             |             NATS/STAN |
                                                             |                       |
                                       marshal               |    +-------------+    |
                       +----------------------------------------->+ Topic Queue |    |
                       |                                     |    +------+------+    |
         +             |                                     |           |           |
         |             |                                     |         +-+-+         |
         |(1)          |(2.1)                                |         |   |         |
         |             |                                     +-----------------------+
         v             |                                               |   |
     +---+---+         |                                               |   |
+----+ Undo  +---------------------------------------------+           |   |
|    +-+-+-+-+         |                     Command Bus A |           |   |
|      | | | |         |                                   +---+    (3)|   |(3)+
|      | | | +---------+                                   | B |       |   |
|      | | |                  (2.2)  +----------------+    |   |       |   |
|      | | +------------------------>+ Redoable Stack |    |   |       |   |
|      | |                           +----------------+    |   |       |   |
|      | |                                                 |   |       |   |
|      | |                                                 |   |       |   |
|      | |(2.3)                  (4)' +--------------+     |   |       |   |
|      | |                    X<------+ Local Filter +<----------------+   |
|      | |                            +-------+------+     |   | unmarshal |
|      | |                                    |            |   <-----------+
|      | |                                    |(4)         |   |
|      | +------------------------------------+            |   |
|      |                                      |            |   |
|      +-----+                                |            |   |
|            |                                |            |   |
|            |(2.3)'                          |            |   |
|            |                                |            |   |
|            v                                v            |   |
|    +-------+------+         (5)         +---+---+        |   |
|    | Undo Handler +<--------------------+ Queue |        |   |
|    +-------+------+                     +-------+        |   |
|            |                                             |   |
|            |                                             |   |
|            |                                             |   |
|            |(6)*                                         |   |
|            |                                             |   |
|            |                          +-----------+      |   |
|            +------------------------->+ Event Bus |      |   |
|                       Event           +-----------+      |   |
|                                                          |   |
+---+------------------------------------------------------+   |
    |                                                          |
    +----------------------------------------------------------+

NSQ

     +-----------------------------------------------+
     |                                           NSQ |
     |      (1)       +-------------+                |
+-------------------->+ Topic Queue |                |
     |                +------+------+                |
     |                       |                       |
     |          +------------+------------+          |
     |          |                         |          |
     |       (2)|                         |(2+)      |
     |          v                         v          |
     |    +-----+-----+             +-----+-----+    |
     |    | Channel A +----+   +----+ Channel B +    |
     |    +-----------+    |   |    +-----------+    |
     |                     |   |                     |
     |                  (3)|   |(3+)                 |
     |                     |   |                     |
     +-----------------------------------------------+
                           |   |
                           v   v

About

No description, website, or topics provided.

Resources

Readme
Activity
Custom properties

Stars

0 stars

Watchers

8 watching

Forks

0 forks
Report repository

Releases 2

command-sourcing Latest
Apr 12, 2019
+ 1 release

Packages

No packages published

Languages