The Problem
Building a typical CRUD application requires writing the same boilerplate over and over: entity struct, create DTO, update DTO, response DTO, row struct, repository trait, SQL implementation, and 6+ From implementations.
That's 200+ lines of boilerplate for a single entity.
The Solution
Done. The macro generates everything else.
Installation
[]
= { = "0.8", = ["postgres", "api"] }
Feature flags
| Feature | Default | What it does |
|---|---|---|
postgres |
✓ | Generate sqlx::PgPool-backed repository implementations |
events |
✓ | Generate {Entity}Event enum (Created / Updated / Deleted variants) |
commands |
✓ | CQRS command pattern: command structs + dispatcher (#[entity(commands)], #[command(...)]) |
hooks |
✓ | {Entity}Hooks trait with before/after lifecycle methods |
transactions |
✓ | {Entity}TransactionRepo adapter + transaction builder helpers (#[entity(transactions)]) |
aggregate_root |
✓ | New{Entity} constructor type and transactional save() (#[entity(aggregate_root)]) |
migrations |
✓ | Compile-time MIGRATION_UP / MIGRATION_DOWN SQL constants (#[entity(migrations)]) |
projections |
✓ | Projection structs and find_by_id_<projection> lookups (#[projection(...)]) |
clickhouse |
Generate ClickHouse-backed repositories (planned) | |
mongodb |
Generate MongoDB-backed repositories (planned) | |
streams |
{Entity}Subscriber using Postgres LISTEN/NOTIFY (pulls in events) |
|
api |
Generate HTTP handlers (axum) and utoipa OpenAPI schemas |
|
validate |
Wire up validator::Validate on generated DTOs |
|
tracing |
Wrap every generated async method in #[tracing::instrument] carrying entity + op span fields |
Default features cover the full entity-attribute surface so existing projects work without changes. For lean builds, opt out of what you don't need:
[]
# Just repositories — no events, hooks, commands, etc.
= { = "0.8", = false, = ["postgres"] }
If you use an entity attribute whose feature is disabled (e.g. #[entity(commands)] without features = ["commands"]), the macro emits a compile_error! at the attribute pointing to the missing feature.
Enable extras alongside the defaults:
[]
= { = "0.8", = ["postgres", "api", "tracing", "streams"] }
= "0.1"
= "0.3"
Features
| Feature | Description |
|---|---|
| Zero Runtime Cost | All code generation at compile time |
| Type Safe | Change a field once, everything updates |
| Auto HTTP Handlers | api(handlers) generates CRUD endpoints + router |
OpenAPI Docs |
Auto-generated Swagger/OpenAPI documentation |
| Query Filtering | Type-safe #[filter], #[filter(like)], #[filter(range)] |
| Relations | #[belongs_to] and #[has_many] |
| Aggregate Roots | #[entity(aggregate_root)] with New{T} DTOs and transactional save |
| Transactions | Multi-entity atomic operations |
| Lifecycle Events | Created, Updated, Deleted events |
| Real-Time Streams | Postgres LISTEN/NOTIFY integration |
| Lifecycle Hook Traits | {Entity}Hooks trait emitted with before_create / after_update / etc.; invocation is currently manual at your service layer (tracking auto-invocation: #127) |
| CQRS Commands | Business-oriented command pattern |
| Soft Delete | deleted_at timestamp support |
| Structured Logging | Opt-in tracing feature wraps every generated async method in #[tracing::instrument] with entity + op fields |
Documentation
| Topic | Languages |
|---|---|
| Getting Started | |
| Attributes | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Examples | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Features | |
| Filtering | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Relations | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Events | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Streams | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Hooks | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Commands | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Advanced | |
| Custom SQL | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Web Frameworks | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
| Best Practices | 🇬🇧 🇷🇺 🇰🇷 🇪🇸 🇨🇳 |
Quick Reference
Entity Attributes
Field Attributes
// Primary key (auto-generated UUID)
// Auto-generated (timestamps)
// Include in CreateRequest
// Include in UpdateRequest
// Include in Response
// Exclude from all DTOs
// Exact match filter
// ILIKE pattern filter
// Range filter (from/to)
// Foreign key relation
// One-to-many relation
// Partial view
Transactions
Mark each participating entity with #[entity(table = "…", transactions)] and
drive a multi-entity transaction through Transaction::run. The closure
receives &mut TransactionContext; run commits on Ok and rolls back on
Err (or any panic) automatically:
use Transaction;
new
.run
.await?;
Need conditional commit/rollback inside the closure? Use
run_with_commit
— it takes TransactionContext by value so the closure can call
ctx.commit().await (or ctx.rollback().await) itself.
Tracing
Opt-in with the tracing feature. Every generated async method
(create, find_by_id, update, delete, list, find_by_<field>,
projections, transaction adapters, stream subscribers) is wrapped in
#[tracing::instrument(skip_all, fields(entity, op), err(Debug))].
= { = "0.8", = ["postgres", "tracing"] }
= "0.1"
= { = "0.3", = ["env-filter"] }
With a subscriber initialized, a failed User::create surfaces as:
ERROR entity.User.create: error=database error: duplicate key value violates unique constraint
in entity.User.create with entity="User" op="create"
When the feature is off, generated code is byte-for-byte identical to a build without the attribute — zero runtime cost.