Directories
¶
| Path | Synopsis |
|---|---|
|
Package app wires the program together: it builds each subsystem as an appmod module, declares the order between them and hands the graph to a Manager, which starts independent modules concurrently and tears them down in reverse.
|
Package app wires the program together: it builds each subsystem as an appmod module, declares the order between them and hands the graph to a Manager, which starts independent modules concurrently and tears them down in reverse. |
|
Package broker publishes messages to the configured message brokers.
|
Package broker publishes messages to the configured message brokers. |
|
kafka
Package kafka publishes to Kafka.
|
Package kafka publishes to Kafka. |
|
postgres
Package postgres delivers messages into a table instead of to a broker.
|
Package postgres delivers messages into a table instead of to a broker. |
|
rabbitmq
Package rabbitmq publishes through AMQP 0-9-1.
|
Package rabbitmq publishes through AMQP 0-9-1. |
|
Package config loads and validates the whole configuration before anything else starts.
|
Package config loads and validates the whole configuration before anything else starts. |
|
Package core holds the outbox domain: what a message is, how a failure is classified and how the next attempt is scheduled.
|
Package core holds the outbox domain: what a message is, how a failure is classified and how the next attempt is scheduled. |
|
Package dispatch is the dispatcher's core loop: claim a batch, publish it, write the outcome back.
|
Package dispatch is the dispatcher's core loop: claim a batch, publish it, write the outcome back. |
|
Package events defines the domain events the dispatcher publishes on the in-process bus, and the topics they travel on.
|
Package events defines the domain events the dispatcher publishes on the in-process bus, and the topics they travel on. |
|
Package logging builds the application logger.
|
Package logging builds the application logger. |
|
Package observability holds the Prometheus metric set.
|
Package observability holds the Prometheus metric set. |
|
Package store is the database side of the dispatcher: claiming a batch, recording what happened to it, recovering leases their owner never released, and the housekeeping around all three.
|
Package store is the database side of the dispatcher: claiming a batch, recording what happened to it, recovering leases their owner never released, and the housekeeping around all three. |
|
migrate
Package migrate applies the embedded SQL migrations.
|
Package migrate applies the embedded SQL migrations. |
|
Package tracing turns the dispatcher into a visible stage of a producer's trace.
|
Package tracing turns the dispatcher into a visible stage of a producer's trace. |
Click to show internal directories.
Click to hide internal directories.