Apache ShenYu-Client-Rust

The Apache ShenYu Rust Client SDK is a Rust library for interacting with the Apache ShenYu gateway. This SDK allows you to easily integrate your Rust applications with the ShenYu gateway, providing a seamless way to manage and route your API requests.

Installation

To use the Apache ShenYu Rust Client SDK in your project, add the following dependencies to your Cargo.toml file:

[dependencies]
serde = "1.0.190"
serde_json = "1.0.80"
reqwest = "0.12.5"
axum = "0.5"
tokio = { version = "1", features = ["full"] }

Usage

Below is an example of how to create an Axum service using ShenYuRouter and integrate it with the ShenYu Gateway.

Example

#![cfg(feature = "axum")]
use axum::routing::post;
use axum::{routing::get, Router};
use shenyu_client_rust::axum_impl::ShenYuRouter;
use shenyu_client_rust::config::ShenYuConfig;
use shenyu_client_rust::{core::ShenyuClient, IRouter};
use tokio::signal;

async fn health_handler() -> &'static str {
    "OK"
}

async fn create_user_handler() -> &'static str {
    "User created"
}

#[tokio::main]
async fn main() {
    let app = ShenYuRouter::<()>::new("shenyu_client_app")
        .nest("/api", ShenYuRouter::new("api"))
        .route("/health", get(health_handler))
        .route("/users", post(create_user_handler));
    let config = ShenYuConfig::from_yaml_file("examples/config.yml").unwrap();
    let client = ShenyuClient::from(config, app.app_name(), app.uri_infos(), 9527)
        .await
        .unwrap();

    let axum_app: Router = app.into();
    client
        .register_all_metadata(true)
        .await
        .expect("TODO: panic message");
    client.register_uri().await.expect("TODO: panic message");
    client
        .register_discovery_config()
        .await
        .expect("TODO: panic message");

    // Start Axum server
    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
    axum::serve(listener, axum_app)
        .with_graceful_shutdown(async move {
            signal::ctrl_c().await.expect("failed to listen for event");
            client.offline_register().await;
        })
        .await
        .unwrap();
}

This example demonstrates how to set up a basic Axum service using ShenYuRouter and register it with the ShenYu Gateway. health_handler and create_user_handler are simple asynchronous functions that handle HTTP requests.

License

This project is licensed under the Apache License 2.0. For more details, see the LICENSE file.