Struct PluginCenter 

pub struct PluginCenter { /* private fields */ }

Implementations

impl PluginCenter

pub async fn register(plugin: JobPluginWrapper) -> Result<(), Error>

Trait Implementations

impl Actor for PluginCenter

type Mailbox = UnboundedMailbox<PluginCenter>

The mailbox type used for the actor.

fn name() -> &'static str

The name of the actor, which can be useful for logging or debugging.

fn new_mailbox() -> (<PluginCenter as Actor>::Mailbox, <<PluginCenter as Actor>::Mailbox as Mailbox<PluginCenter>>::Receiver)

Creates a new mailbox for the actor. This sets up the message queue and receiver for the actor.

fn on_start( &mut self, actor_ref: ActorRef<Self>, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

Called when the actor starts, before it processes any messages.

fn on_panic( &mut self, actor_ref: WeakActorRef<Self>, err: PanicError, ) -> impl Future<Output = Result<Option<ActorStopReason>, Box<dyn Error + Send + Sync>>> + Send

Called when the actor encounters a panic or an error during “tell” message handling.

fn on_link_died( &mut self, actor_ref: WeakActorRef<Self>, id: ActorID, reason: ActorStopReason, ) -> impl Future<Output = Result<Option<ActorStopReason>, Box<dyn Error + Send + Sync>>> + Send

Called when a linked actor dies.

fn on_stop( &mut self, actor_ref: WeakActorRef<Self>, reason: ActorStopReason, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

Called before the actor stops.

impl Clone for PluginCenter

fn clone(&self) -> PluginCenter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for PluginCenter

fn default() -> PluginCenter

Returns the “default value” for a type.

impl Message<ChangeStatusMsg> for PluginCenter

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: ChangeStatusMsg, _ctx: Context<'_, PluginCenter, <PluginCenter as Message<ChangeStatusMsg>>::Reply>, ) -> <PluginCenter as Message<ChangeStatusMsg>>::Reply

Handler for this message.

impl Message<RegisterPlugin> for PluginCenter

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: RegisterPlugin, _ctx: Context<'_, PluginCenter, <PluginCenter as Message<RegisterPlugin>>::Reply>, ) -> <PluginCenter as Message<RegisterPlugin>>::Reply

Handler for this message.

impl Message<RunHookMsg> for PluginCenter

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: RunHookMsg, _ctx: Context<'_, PluginCenter, <PluginCenter as Message<RunHookMsg>>::Reply>, ) -> <PluginCenter as Message<RunHookMsg>>::Reply

Handler for this message.