Directories
¶
| Path | Synopsis |
|---|---|
|
ChannelBus is an in-process event bus that dispatches events to subscribers via goroutines.
|
ChannelBus is an in-process event bus that dispatches events to subscribers via goroutines. |
|
Package commands holds internal Asynx commands that are dispatched by the library itself rather than by application code.
|
Package commands holds internal Asynx commands that are dispatched by the library itself rather than by application code. |
|
Package eventstore provides the persistence layer for Asynx aggregates.
|
Package eventstore provides the persistence layer for Asynx aggregates. |
|
Package processor coordinates command routing and execution lifecycle for Asynx.
|
Package processor coordinates command routing and execution lifecycle for Asynx. |
|
exec
Package exec implements the command execution pipeline for Asynx.
|
Package exec implements the command execution pipeline for Asynx. |
|
models
Package models defines data structures shared across processor sub-packages.
|
Package models defines data structures shared across processor sub-packages. |
|
pool
Package pool implements shard-based concurrent command execution.
|
Package pool implements shard-based concurrent command execution. |
|
queue
Package queue implements consistent shard routing for Asynx commands.
|
Package queue implements consistent shard routing for Asynx commands. |
|
Package store provides in-memory implementations of models.Store for use in tests.
|
Package store provides in-memory implementations of models.Store for use in tests. |
Click to show internal directories.
Click to hide internal directories.