kameo

Related from one month ago: Kameo - https://github.com/tqwewe/kameo Show HN: Kameo – Fault-tolerant async actors built on Tokio - https://news.ycombinator.com/item?id=41723569 - October 2024 (58 comments)

https://github.com/tqwewe/kameo/blob/main/examples/remote.rs // Bootstrap the actor swarm if is_host { ActorSwarm::bootstrap()? .listen_on("/ip4/0.0.0.0/udp/8020/quic-v1".parse()?) .await?; } else { ActorSwarm::bootstrap()?.dial( DialOpts::unknown_peer_id() .address("/ip4/0.0.0.0/udp/8020/quic-v1".parse()?) .build(), ); } let remote_actor_ref = RemoteActorRef::<MyActor>::lookup("my_actor").await?; match remote_actor_ref { Some(remote_actor_ref) => { let count = remote_actor_ref.ask(&Inc { amount: 10 }).send().await?; println!("Incremented! Count is {count}"); } ...

Hi HN, I’m excited to share Kameo, a lightweight Rust library that helps you build fault-tolerant, distributed, and asynchronous actors. If you're working on distributed systems, microservices, or real-time applications, Kameo offers a simple yet powerful API for handling concurrency, panic recovery, and remote messaging between nodes. Key Features: - Async Rust: Each actor runs as a separate Tokio task, making concurrency management simple. - Remote Messaging: Seamlessly send messages to actors across different nodes. - Supervision and Fault Tolerance: Create self-healing systems with actor hierarchies. - Backpressure Support: Supports bounded and unbounded mpsc messaging. I built Kameo because I wanted a more intuitive, scalable solution for distributed Rust applications. I’d love feedback from the HN community and contributions from an