pub struct ActorSlot<R: Reactor> {
pub path: ActorPath,
pub addr: AddrHash,
pub mailbox_tx: MailboxSender,
pub ctrl_tx: UnboundedSender<LifecycleSignal<R>>,
pub task_handle: Arc<Mutex<Option<Box<dyn SpawnHandle>>>>,
pub supervisor_addr: Option<AddrHash>,
pub running: Arc<AtomicBool>,
pub restart_count: Arc<AtomicU32>,
pub message_count: Arc<AtomicU64>,
pub compute_time_ns: Arc<AtomicU64>,
}Expand description
A slot in the actor registry.
Fields§
§path: ActorPath§addr: AddrHash§mailbox_tx: MailboxSender§ctrl_tx: UnboundedSender<LifecycleSignal<R>>§task_handle: Arc<Mutex<Option<Box<dyn SpawnHandle>>>>§supervisor_addr: Option<AddrHash>§running: Arc<AtomicBool>§restart_count: Arc<AtomicU32>Times this actor path has been restarted by its supervisor.
message_count: Arc<AtomicU64>Total successful on_message completions. Shared with the actor task
so the task can increment without holding the registry lock.
compute_time_ns: Arc<AtomicU64>Total wall-clock nanoseconds spent in lifecycle hooks.
Auto Trait Implementations§
impl<R> Freeze for ActorSlot<R>
impl<R> !RefUnwindSafe for ActorSlot<R>
impl<R> Send for ActorSlot<R>
impl<R> Sync for ActorSlot<R>
impl<R> Unpin for ActorSlot<R>
impl<R> UnsafeUnpin for ActorSlot<R>
impl<R> !UnwindSafe for ActorSlot<R>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more