distributed 4.5.0

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

# Thin entrypoint for the canonical celld 0.4 + Queue + NATS local profile.
# State persists in worker/.celld/dev across reloads and ordinary shutdowns.

.PHONY: up reload logs down test help

PROFILE_DIR := ../e2e-ui
CELLD_HTTP_PORT ?= 18080
CELLD_URL ?= http://127.0.0.1:$(CELLD_HTTP_PORT)
NATS_PORT ?= 14222
NATS_URL ?= nats://127.0.0.1:$(NATS_PORT)
DISTRIBUTED_INTERNAL_SECRET ?= test-only-internal-secret-change-me-2026
export DISTRIBUTED_INTERNAL_SECRET

PROFILE_VARS = \
	CELLD_HTTP_PORT="$(CELLD_HTTP_PORT)" \
	CELLD_URL="$(CELLD_URL)" \
	NATS_PORT="$(NATS_PORT)" \
	NATS_URL="$(NATS_URL)"

up:
	$(MAKE) -C $(PROFILE_DIR) up-celld-nats $(PROFILE_VARS)

reload: up

logs:
	tail -F $(PROFILE_DIR)/.make-celld.log $(PROFILE_DIR)/.make-celld-relay.log

down:
	$(MAKE) -C $(PROFILE_DIR) down-celld $(PROFILE_VARS)
	$(MAKE) -C $(PROFILE_DIR) down-celld-nats $(PROFILE_VARS)

test:
	$(MAKE) -C $(PROFILE_DIR) test-celld $(PROFILE_VARS)

help:
	@echo "celld 0.4 + Queue + NATS profile"
	@echo "  make up      build/register both Workers and start the shared local profile"
	@echo "  make reload  rebuild and restart without deleting worker/.celld/dev"
	@echo "  make logs    follow aggregate and relay registration logs"
	@echo "  make down    stop celld and NATS; preserve worker/.celld/dev"
	@echo "  make test    validate the already-running profile"