Struct ActorRegistry 

pub(crate) struct ActorRegistry {
    actors: ActorRegistryType,
    script_actors: AtomicRefCell<HashMap<String, String>>,
    source_actor_names: AtomicRefCell<HashMap<PipelineId, Vec<String>>>,
    inline_source_content: AtomicRefCell<HashMap<PipelineId, String>>,
    next: AtomicU32,
}

A list of known, owned actors.

Fields

actors: ActorRegistryType

script_actors: AtomicRefCell<HashMap<String, String>>

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

Lookup table for SourceActor names associated with a given PipelineId.

inline_source_content: AtomicRefCell<HashMap<PipelineId, String>>

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

next: AtomicU32

Implementations

impl ActorRegistry

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

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 base_name<T: Actor>() -> &'static str

Create a name prefix for each actor type. While not needed for unique ids as each actor already has a different suffix, it can be used to visually identify actors in the logs.

pub fn new_name<T: Actor>(&self) -> String

Create a unique name based on a monotonically increasing suffix TODO: Merge this with register and don’t allow to create new names without registering an actor.

pub(crate) fn register<T: Actor>(&self, actor: T)

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

pub fn find<T: Actor>(&self, name: &str) -> DowncastableActorArc<T>

Find an actor by registered name

pub fn encode<T: ActorEncode<S>, S: Serialize>(&self, name: &str) -> S

Find an actor by registered name and return its serialization

pub(crate) fn handle_message( &self, msg: &Map<String, Value>, stream: &mut DevtoolsConnection, 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 remove(&self, name: String)

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

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

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

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

Trait Implementations

impl Default for ActorRegistry

fn default() -> ActorRegistry

Returns the “default value” for a type.

impl MallocSizeOf for ActorRegistry

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.