Struct coerce::actor::scheduler::ActorScheduler

pub struct ActorScheduler { /* private fields */ }

Implementations

impl ActorScheduler

pub fn new( system_id: Uuid, system_name: Arc<str> ) -> LocalActorRef<ActorScheduler>

Trait Implementations

impl Actor for ActorScheduler

fn started<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once the Actor has been started

fn stopped<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once the Actor has stopped

fn new_context( &self, system: Option<ActorSystem>, status: ActorStatus, boxed_ref: BoxedActorRef ) -> ActorContext

Creates a new ActorContext, allowing actor implementations to override specific parts of the ActorContext, before the actor is started.

fn on_child_stopped<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, _id: &'life1 ActorId, _ctx: &'life2 mut ActorContext ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a supervised actor has stopped

fn actor_ref(&self, ctx: &ActorContext) -> LocalActorRef<Self>where Self: Sized,

Returns a LocalActorRef<Self> instance of the current actor, automatically casting from the ActorContext’s BoxedActorRef.

fn type_name() -> &'static strwhere Self: Sized,

Returns the actor’s type name string

fn tags(&self, ctx: &ActorContext) -> ActorTags

const DEFAULT_TAGS: ActorTags = { ActorTags::None }

Default tags used when creating the actor

impl Handler<ActorCount> for ActorScheduler

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, __arg1: ActorCount, _ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<DeregisterActor> for ActorScheduler

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: DeregisterActor, _ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<DescribeAll> for ActorScheduler

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, message: DescribeAll, ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl<A> Handler<GetActor<A>> for ActorSchedulerwhere A: 'static + Sync + Send + Actor,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, message: GetActor<A>, _ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = Option<LocalActorRef<A>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl<A> Handler<RegisterActor<A>> for ActorSchedulerwhere A: 'static + Sync + Send + Actor,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, message: RegisterActor<A>, _ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<SetRemote> for ActorScheduler

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, message: SetRemote, _ctx: &'life1 mut ActorContext ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,