rustapi-grpc

rustapi-grpc provides gRPC integration helpers for RustAPI with Tonic.

What it gives you

• run_concurrently(http, grpc): run two server futures together.
• run_rustapi_and_grpc(app, http_addr, grpc): convenience helper for RustAPI + gRPC side-by-side.
• run_rustapi_and_grpc_with_shutdown(app, http_addr, signal, grpc_with_shutdown): shared shutdown signal for both servers.
• Re-exports: tonic, prost.

Example

use rustapi_rs::grpc::{run_rustapi_and_grpc, tonic};
use rustapi_rs::prelude::*;

#[rustapi_rs::get("/health")]
async fn health() -> &'static str { "ok" }

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let http_app = RustApi::new().route("/health", get(health));

    let grpc_addr = "127.0.0.1:50051".parse()?;
    let grpc_server = tonic::transport::Server::builder()
        .add_service(MyGreeterServer::new(MyGreeter::default()))
        .serve(grpc_addr);

    run_rustapi_and_grpc(http_app, "127.0.0.1:8080", grpc_server).await?;
    Ok(())
}

Shared shutdown (Ctrl+C)

use rustapi_rs::grpc::{run_rustapi_and_grpc_with_shutdown, tonic};

let grpc_addr = "127.0.0.1:50051".parse()?;

run_rustapi_and_grpc_with_shutdown(
    http_app,
    "127.0.0.1:8080",
    tokio::signal::ctrl_c(),
    move |shutdown| {
        tonic::transport::Server::builder()
            .add_service(MyGreeterServer::new(MyGreeter::default()))
            .serve_with_shutdown(grpc_addr, shutdown)
    },
).await?;