Struct ActorRegistry 

pub(crate) struct ActorRegistry(RwLock<ActorRegistryInner>);

Tuple Fields

0: RwLock<ActorRegistryInner>

Implementations

impl ActorRegistry

fn read(&self) -> RwLockReadGuard<'_, ActorRegistryInner>

fn write(&self) -> WriteGuard<'_>

impl ActorRegistry

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

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

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

Find an actor by registered name

pub(crate) 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(crate) fn register_script_actor(&self, script_id: String, actor: String)

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

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

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

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

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

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

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

pub(crate) fn remove(&self, _name: String)

This is a no-op, we don’t currently handle removals from the actor registry

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

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.