pub struct ActorTask {
pub actor_id: String,
pub generation: u32,
pub lifecycle_inbox: UnboundedReceiver<LifecycleCommand>,
pub dispatch_inbox: UnboundedReceiver<DispatchCommand>,
pub lifecycle_events: UnboundedReceiver<LifecycleEvent>,
pub lifecycle: LifecycleState,
pub factory: Arc<ActorFactory>,
pub ctx: ActorContext,
pub start_input: Option<Vec<u8>>,
pub state_save_deadline: Option<Instant>,
pub inspector_serialize_state_deadline: Option<Instant>,
pub sleep_deadline: Option<Instant>,
/* private fields */
}Fields§
§actor_id: String§generation: u32§lifecycle_inbox: UnboundedReceiver<LifecycleCommand>Lifecycle commands (Start / Stop / FireAlarm) sent by the registry
in response to engine-driven EnvoyCallbacks from the envoy client.
dispatch_inbox: UnboundedReceiver<DispatchCommand>Client-originated work sent by RegistryDispatcher in
registry/dispatch.rs (Action, OpenWebSocket, Workflow*) and
registry/http.rs (Http, QueueSend).
lifecycle_events: UnboundedReceiver<LifecycleEvent>Internal self-events the actor enqueues onto itself via ActorContext
hooks (save/inspector/activity notifications from
actor/state.rs, actor/connection.rs, actor/context.rs).
lifecycle: LifecycleState§factory: Arc<ActorFactory>§ctx: ActorContext§start_input: Option<Vec<u8>>§state_save_deadline: Option<Instant>Next deadline at which on_state_save_tick should flush a deferred
state save. Cleared while no save is requested.
inspector_serialize_state_deadline: Option<Instant>Next deadline at which an inspector-driven SerializeState should
fire. Debounces inspector overlay refreshes.
sleep_deadline: Option<Instant>Next deadline at which the actor becomes eligible for sleep if it stays idle. Cleared on activity and during sleep grace.