Struct Router 

pub struct Router<State = ()> { /* private fields */ }

Router mapping command names to handlers.

Implementations

impl<State> Router<State>

where State: Default + Send + Sync + 'static,

pub fn new() -> Self

Create a new router using State::default().

Examples found in repository

examples/router.rs (line 26)

pub async fn main() -> Result<()> {
    let app: Router<()> = Router::new().route("PING", ping);
    Server::bind("0.0.0.0:6379")
        .with_hooks(Hooks)
        .serve(app)
        .await
}

impl<State> Router<State>

where State: Send + Sync + 'static,

pub fn from_state(state: State) -> Self

Create a new router with the provided state.

Examples found in repository

examples/history.rs (line 45)

pub async fn main() -> Result<()> {
    let addr = env::args()
        .nth(1)
        .unwrap_or_else(|| "0.0.0.0:6379".to_string());

    let app = Router::from_state(AppState::default())
        .route("HISTORY", history)
        .route("COMMAND", history)
        .route("PING", ping);

    Server::bind(&addr)
        .with_graceful_shutdown(async {
            let _ = signal::ctrl_c().await;
        })
        .serve(app)
        .await
}

pub fn with_state(self, state: State) -> Self

Replace the state while keeping existing routes.

pub fn route<H, Args>(self, command: &'static str, handler: H) -> Self

where H: IntoHandler<State, Args>,

Register a command handler.

The handler must be an async function or Fn that returns a Send + 'static future.

Examples found in repository

examples/router.rs (line 26)

pub async fn main() -> Result<()> {
    let app: Router<()> = Router::new().route("PING", ping);
    Server::bind("0.0.0.0:6379")
        .with_hooks(Hooks)
        .serve(app)
        .await
}

examples/history.rs (line 46)

pub async fn main() -> Result<()> {
    let addr = env::args()
        .nth(1)
        .unwrap_or_else(|| "0.0.0.0:6379".to_string());

    let app = Router::from_state(AppState::default())
        .route("HISTORY", history)
        .route("COMMAND", history)
        .route("PING", ping);

    Server::bind(&addr)
        .with_graceful_shutdown(async {
            let _ = signal::ctrl_c().await;
        })
        .serve(app)
        .await
}

Trait Implementations

impl<State> Clone for Router<State>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<State> Default for Router<State>

where State: Default + Send + Sync + 'static,

fn default() -> Self

Returns the “default value” for a type.