akka/akka-core

Pluggable buffer for network actors

Open

#17,766 建立於 2015年6月18日

在 GitHub 查看
 (1 留言) (0 反應) (0 負責人)Scala (3,547 fork)batch import
1 - triagedhelp wantedt:cluster-tools

倉庫指標

Star
 (13,277 star)
PR 合併指標
 (平均合併 8天 19小時) (30 天內合併 10 個 PR)

描述

Cluster singleton and cluster sharding both uses an internal buffer (and not the mailbox) for when the remote actor is not available. It would be nice if that buffer was pluggable (as the mailbox were).

Use-cases:

  • If you have a retry mechanism, you may want to throw away new messages when the buffer is full. That way the retry will not effect message ordering too much.
  • If you send updates for some entries, and are only interested in the latest update for each entry, you could implement a buffer that throws away all out-of-date information and only tries to send the latest info.
  • Maybe you don't want to change the behavior when the buffer is full, you just want to notify someone (logging, back-pressure etc).

What do you think?

貢獻者指南