HN へのレベル: Coerce – Rust で分配されたアクターフレームワーク

Coerce-rs は、非同期 (async/rep up for) Actor ランタイムであり、Rust 用のディスペンスデバイスフレームワークです。これにより、非常に簡単でありながら注目に値するアクターに基づいた、ほとんど分配されたデバイスの構築が可能になります。最小限のコードで、高度にスケーラブルでフォールトトレラントな、攻撃者がプッシュするスタイリッシュなユーティリティを作成できる可能性があります。

クレート

) すぐにアクセスできるメトリクスリモーティング

クラスタ内のどこからでもアクターと会話できます

アクターは、おそらく近隣または遠く離れた他のノードに展開される可能性があります

Protobuf ネットワークプロトコル

アクターがプッシュするネットワーク層

分配されたシャーディング

アクター ID は特定のシャードに解決できます。 Coerceノードのクラスターを介してすべての意図が展開される可能性があります

コンピューター化された負荷分散により、シャードはクラスターを介してすべての意図を適切に割り当てられます

ノードが失われた場合の自己回復、アクターはおそらく他の健全なノードでロボットによって再起動される可能性があります

プラガブルストレージサプライヤ (インメモリと redis に簡単にアクセスできます。MySQL は意図的に使用されます)

分配されたPubSub

アクターは、クラスター内のどこからでもプログラム可能な主題にサブスクライブできます

更新されたデバイスの通知を受信するマシンディプロマトピック (例: 一意のノードの参加、ノードの喪失など) .)

問題なく、診断に貴重な指標と記録にアクセスできます

クローンリポジトリ git clone https://github.com/leonhartley/ coerce-rs && cd coerce-rs ## poke Cargo fabricate は、例とテストの横にあるすべてのワークスペースを作成します貨物製造 ## または、ライブラリを作成したいときはいつでも、依存関係を作成し、テストを突く貨物を見てみましょう

アクターの async/rep up
これはCoerceでどのように達成されますか?
強制はTokioのMPSCチャンネルを使用します(tokio::sync::mpsc: :channel

)、作成されたすべてのアクターは、からのメッセージをリッスンするジョブを生成します) 受信者、メッセージの先端の結果を処理し、先を見通す。すべての参照 (ActorRef

 、おそらく複製される可能性があります. アクターはおそらく停止でき、アクターの参照はユーティリティのためにどこからでも ID で取得できるでしょう。  ID は String ただし、作成時に ID が常に装備されているとは限らない場合は、単数の Uuid  が生成されます。 匿名のアクターはロボットによってドロップされ (そして 停止されます 
 ) すべての参照が削除されたとき。 追跡されたアクター (world fn new_actor を使用) ) を停止する必要があります。   典型的な ActorSystem + EchoActor の例 実例
 EchoActor の impl アクター {} pub struct EchoMessage(String);  EchoMessage の impl メッセージ { type Result=String;  } # impl Handler for EchoActor { async fn handle( &mut self, message: EchoMessage, _ctx: &mut ActorContext, ) -> String { message.0.clone() } } pub async fn poke() { let mut アクター=new_actor (EchoActor {}).rep up for.unwrap();  let hello_world="こんにちは、世界".to_string();  let result=actor.ship(EchoMessage(hello_world.clone())).rep up for;  assert_eq!(結果、OK(hello_world));  }" dir="auto">

パブ構造体 EchoActor

impl   俳優  ために  EchoActor  { }  パブ 構造体  エコーメッセージ(弦)
; impl  メッセージ  ために EchoMessage   { 
形状
 結果=弦;  } #[async_trait]
  impl   ハンドラ<エコーメッセージ> ために EchoActor   {  async  fn   に対処する(  &mut  自己
, メッセージ
: EchoMessage  , 
_ctx:  & mut
ActorContext ,  ) ->  弦
{  メッセージ。0.クローン ( ) }
 }  パブ
async
 fn 
ポーク(
) {
 させて
 mut 俳優= new_actor(EchoActor ). 担当者 .
 アンラップ()
; させて hello_world=
 "こんにちは世界". to_string(
);
 させて 結果=アクター
 . )船 (EchoMessage
 (こんにちは世界. クローン()) ) .担当者
 ; assert_eq !(結果、わかりました (こんにちは世界)); }
 
タイマーインスタンス  EchoActor の impl アクター {} pub struct EchoMessage(String);  EchoMessage の impl メッセージ { form Consequence=String;  pub struct PrintTimer(String); }  PrintTimer の impl TimerTick {} # impl Handler for EchoActor { async fn serve with(&mut self, msg: PrintTimer, _ctx: &mut ActorContext) { println!("{}", msg.0);  } } pub async fn poke() { let mut アクター=new_actor(EchoActor {}).rep up for.unwrap();  let hello_world="ハローワールド!".to_string();  // "hello world!" を出力します。  5 秒ごとに let timer=Timer::birth(actor.clone(), Length::from_secs(  𝚆𝚊𝚝𝚌𝚑 𝙽𝙾𝚆 📺