Struct ActorRegistry

pub struct ActorRegistry {
    actors: HashMap<String, Box<dyn Actor + Send>>,
    new_actors: RefCell<Vec<Box<dyn Actor + Send>>>,
    old_actors: RefCell<Vec<String>>,
    script_actors: RefCell<HashMap<String, String>>,
    source_actor_names: RefCell<HashMap<PipelineId, Vec<String>>>,
    inline_source_content: RefCell<HashMap<PipelineId, String>>,
    shareable: Option<Arc<Mutex<ActorRegistry>>>,
    next: Cell<u32>,
    start_stamp: CrossProcessInstant,
}

A list of known, owned actors.

Fields

actors: HashMap<String, Box<dyn Actor + Send>>

new_actors: RefCell<Vec<Box<dyn Actor + Send>>>

old_actors: RefCell<Vec<String>>

script_actors: RefCell<HashMap<String, String>>

source_actor_names: RefCell<HashMap<PipelineId, Vec<String>>>

Lookup table for SourceActor names associated with a given PipelineId.

inline_source_content: RefCell<HashMap<PipelineId, String>>

Lookup table for inline source content associated with a given PipelineId.

shareable: Option<Arc<Mutex<ActorRegistry>>>

next: Cell<u32>

start_stamp: CrossProcessInstant

Implementations

impl ActorRegistry

pub fn new() -> ActorRegistry

Create an empty registry.

pub(crate) fn cleanup(&self, stream_id: StreamId)

pub fn create_shareable(self) -> Arc<Mutex<ActorRegistry>>

Creating shareable registry

pub fn shareable(&self) -> Arc<Mutex<ActorRegistry>>

Get shareable registry through threads

pub fn start_stamp(&self) -> CrossProcessInstant

Get start stamp when registry was started

pub fn register_script_actor(&self, script_id: String, actor: String)

pub fn script_to_actor(&self, script_id: String) -> String

pub fn script_actor_registered(&self, script_id: String) -> bool

pub fn actor_to_script(&self, actor: String) -> String

pub fn new_name(&self, prefix: &str) -> String

Create a unique name based on a monotonically increasing suffix

pub(crate) fn register(&mut self, actor: Box<dyn Actor + Send>)

Add an actor to the registry of known actors that can receive messages.

pub(crate) fn register_later(&self, actor: Box<dyn Actor + Send>)

pub fn find<'a, T: Any>(&'a self, name: &str) -> &'a T

Find an actor by registered name

pub fn find_mut<'a, T: Any>(&'a mut self, name: &str) -> &'a mut T

Find an actor by registered name

pub(crate) fn handle_message( &mut self, msg: &Map<String, Value>, stream: &mut TcpStream, stream_id: StreamId, ) -> Result<(), ()>

Attempt to process a message as directed by its to property. If the actor is not found, does not support the message, or failed to handle the message, send an error reply instead.

pub fn drop_actor(&mut self, name: String)

pub fn drop_actor_later(&self, name: String)

pub fn register_source_actor(&self, pipeline_id: PipelineId, actor_name: &str)

pub fn source_actor_names_for_pipeline( &mut self, pipeline_id: PipelineId, ) -> Vec<String>

pub fn set_inline_source_content( &mut self, pipeline_id: PipelineId, content: String, )

pub fn inline_source_content( &mut self, pipeline_id: PipelineId, ) -> Option<String>