sunbeam-g2v

A ConnectRPC-based framework for building microservices in Rust.

Features

• Service trait — SunbeamService with on_start/on_stop hooks and graceful shutdown
• Configuration — Figment-based config with env-var support via ServiceConfig
• Server builders — ServerBuilder → AxumServer (or StandaloneServer) with one-shot serve()
• Middleware stack — JWT validation, Keto authorization, Prometheus metrics, request IDs, logging, tracing, panic recovery
• Database — SQLx Postgres integration with connect/connect_eager and automatic migrations
• Message queue — NATS / JetStream wrapper (NatsClient) with stream and consumer helpers
• Leader election — Pluggable LeaderElection trait with Vault and NATS implementations
• Client resiliency — ClientFactory, RetryLayer/RetryPolicy, and a full CircuitBreaker
• Health checks — HealthRouter exposing /health/live and /health/ready
• Testing — TestHarness (boots a real server on a random port), MockService, data fixtures
• Proc-macros — #[derive(Instrumented)] and #[derive(Metrics)]

Quick start

cargo add sunbeam-g2v

use sunbeam_g2v::prelude::*;

#[tokio::main]
async fn main() -> ServiceResult<()> {
    let router = ServiceRouter::new();
    ServerBuilder::new()
        .with_router(router)
        .serve()
        .await
}

See the examples/ directory for a complete working service with JWT, Keto, and health checks.

Architecture

flowchart LR
    A["ServerBuilder"] --> B["with_router"]
    B --> C["with_health"]
    C --> D["with_config"]
    D --> E["build_axum"]
    E --> F["AxumServer"]
    F --> G["serve"]

graph TB
    subgraph Middleware
        direction LR
        H["RequestIdLayer"] --> I["JwtLayer"]
        I --> J["KetoLayer"]
        J --> K["InstrumentationLayer"]
        K --> L["LoggingLayer"]
        L --> M["TracingLayer"]
        M --> N["CatchPanicLayer"]
    end

Feature flags

Default features enable: axum, metrics, tracing, logging, sqlx, sqlx-postgres, nats, jwt, keto, vault, election.

Minimal dependencies

[dependencies]
sunbeam-g2v = { version = "0.2", default-features = false, features = ["axum", "metrics", "jwt"] }

API Reference

Full API docs are published to docs.rs/sunbeam-g2v.

License

MIT