Directories
¶
| Path | Synopsis |
|---|---|
|
Package aggregate provides engine components that orchestrate the execution of aggregate message handlers.
|
Package aggregate provides engine components that orchestrate the execution of aggregate message handlers. |
|
Package application binds the database to a single Dogma application.
|
Package application binds the database to a single Dogma application. |
|
Package concurrency provides utilities for enforcing a handler's concurrency preference.
|
Package concurrency provides utilities for enforcing a handler's concurrency preference. |
|
Package contexthook provides utilities for adding request-scoped testing hooks to contexts.
|
Package contexthook provides utilities for adding request-scoped testing hooks to contexts. |
|
Package eventstream provides a catalog of the event streams that the engine consumes, both this application's own and those of remote engines.
|
Package eventstream provides a catalog of the event streams that the engine consumes, both this application's own and those of remote engines. |
|
internal/cache
Package cache provides a cache of an event stream's most recent events.
|
Package cache provides a cache of an event stream's most recent events. |
|
source
Package source defines where an event stream's events come from, the contract by which a source delivers them, and the gRPC service that provides a source's event streams to remote engines.
|
Package source defines where an event stream's events come from, the contract by which a source delivers them, and the gRPC service that provides a source's event streams to remote engines. |
|
Package grpcserver serves the engine's gRPC services to other engines.
|
Package grpcserver serves the engine's gRPC services to other engines. |
|
Package integration provides engine components that orchestrate the execution of integration message handlers.
|
Package integration provides engine components that orchestrate the execution of integration message handlers. |
|
Package messagepump generalizes a message pump that acquires messages for processing and dispatches them to a worker pool.
|
Package messagepump generalizes a message pump that acquires messages for processing and dispatches them to a worker pool. |
|
Package process provides engine components that orchestrate the execution of process message handlers.
|
Package process provides engine components that orchestrate the execution of process message handlers. |
|
Package projection provides engine components that orchestrate the execution of projection message handlers.
|
Package projection provides engine components that orchestrate the execution of projection message handlers. |
|
Package remoteengine provides engine components that connect the engine to remote engines.
|
Package remoteengine provides engine components that connect the engine to remote engines. |
|
Package schema defines the PostgreSQL schema used by the engine.
|
Package schema defines the PostgreSQL schema used by the engine. |
|
Package signal provides a mechanism for waking components when something they are interested in changes, using the PostgreSQL LISTEN/NOTIFY feature.
|
Package signal provides a mechanism for waking components when something they are interested in changes, using the PostgreSQL LISTEN/NOTIFY feature. |
|
Package supervisor runs fallible functions until they succeed, retrying with exponential backoff when they fail.
|
Package supervisor runs fallible functions until they succeed, retrying with exponential backoff when they fail. |
|
x
|
|
|
xerrors
Package xerrors provides utilities for error handling.
|
Package xerrors provides utilities for error handling. |
|
xsql
Package xsql provides utilities for working with SQL databases.
|
Package xsql provides utilities for working with SQL databases. |
|
xtesting
Package xtesting provides utilities for testing.
|
Package xtesting provides utilities for testing. |
Click to show internal directories.
Click to hide internal directories.