Absinthe

Are you an Actor & Async junkie? Then your app needs some Absinthe!

Absinthe in action

use absinthe::prelude::*;

// Actorize any async function with the #[absinthe::actor] attribute
#[absinthe::actor]
async fn add(a: i32, b: i32) -> i32 {
    a + b
}

// It works with generics too!
// Don't think about async requirements, Absinthe will handle it for you
#[absinthe::actor]
async fn sub<T>(a: T, b: T) 
where 
    T: std::ops::Sub<Output = i32>
{
    a - b
}

#[tokio::main]
async fn main() {
    let add_actor = add();
    let sub_actor = sub::<i32>();

    // send! a message to the actor, and await the response
    // notify! the actor when you don't care about the response
    let res = absinthe::send!(add_actor, 1, 2).await;
    let res = absinthe::send!(sub_actor, res, 2).await;

    assert_eq!(res, 1);
}

Roadmap

• Actor functions
• Generic Actor functions
• Tracing
• Blocking Actor functions
• Topic based Actor binding
• Structs as Actor context
• Context Actor methods
• Actor lifecycle trait
• Lambda Actor wrapper
• Actor supervision
• Multi-instance actors
• Circuit breaker
• UDP bridge
• Ciphered tunnel
• Actor Healthcheck
• Node Healthcheck
• Actor discovery
• Actor discovery with UDP
• RabbitMQ bridge
• Stomp bridge