Struct zinoma::engine::target_actor::target_actor_helper::TargetActorHelper

pub struct TargetActorHelper {
    pub target_id: TargetId,
    pub termination_events: Receiver<TerminationMessage>,
    pub target_invalidated_events: Receiver<TargetInvalidatedMessage>,
    pub target_actor_input_receiver: Receiver<ActorInputMessage>,
    pub target_actor_output_sender: Sender<TargetActorOutputMessage>,
    pub to_execute: bool,
    pub executed: bool,
    pub dependencies: Vec<TargetId>,
    pub unavailable_dependencies: HashMap<ExecutionKind, HashSet<TargetId>>,
    pub requesters: HashMap<ExecutionKind, HashSet<ActorId>>,
}

Fields

target_id: TargetId

termination_events: Receiver<TerminationMessage>

target_invalidated_events: Receiver<TargetInvalidatedMessage>

target_actor_input_receiver: Receiver<ActorInputMessage>

target_actor_output_sender: Sender<TargetActorOutputMessage>

to_execute: bool

executed: bool

dependencies: Vec<TargetId>

unavailable_dependencies: HashMap<ExecutionKind, HashSet<TargetId>>

requesters: HashMap<ExecutionKind, HashSet<ActorId>>

Implementations

impl TargetActorHelper

pub fn new( target_metadata: &TargetMetadata, termination_events: Receiver<TerminationMessage>, target_invalidated_events: Receiver<TargetInvalidatedMessage>, target_actor_input_receiver: Receiver<ActorInputMessage>, target_actor_output_sender: Sender<TargetActorOutputMessage> ) -> Self

pub fn should_execute(&self, kind: ExecutionKind) -> bool

pub async fn notify_invalidated(&mut self, kind: ExecutionKind)

pub fn set_execution_started(&mut self)

pub async fn notify_execution_failed(&mut self, e: Error)

pub async fn send_to_actor(&self, dest: ActorId, msg: ActorInputMessage)

pub async fn send_to_dependencies(&self, msg: ActorInputMessage)

pub async fn send_to_requesters( &self, kind: ExecutionKind, msg: ActorInputMessage )

pub async fn notify_success(&mut self, kind: ExecutionKind)

pub async fn request_dependencies(&self, kind: ExecutionKind)

pub fn handle_unrequested( &mut self, kind: ExecutionKind, requester: ActorId ) -> bool

pub async fn unrequest_dependencies(&self, kind: ExecutionKind)