pub struct Config;Trait Implementations§
Source§impl Actor for Config
impl Actor for Config
Source§type Msg = ConfigMessage
type Msg = ConfigMessage
The message type for this actor
Source§type State = ConfigState
type State = ConfigState
The type of state this actor manages internally
Source§type Arguments = ConfigArgs
type Arguments = ConfigArgs
Initialization arguments
Source§fn pre_start<'life0, 'async_trait>(
&'life0 self,
_myself: ActorRef<Self::Msg>,
args: Self::Arguments,
) -> Pin<Box<dyn Future<Output = Result<Self::State, ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn pre_start<'life0, 'async_trait>(
&'life0 self,
_myself: ActorRef<Self::Msg>,
args: Self::Arguments,
) -> Pin<Box<dyn Future<Output = Result<Self::State, ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Invoked when an actor is being started by the system. Read more
Source§fn post_start<'life0, 'life1, 'async_trait>(
&'life0 self,
myself: ActorRef<Self::Msg>,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn post_start<'life0, 'life1, 'async_trait>(
&'life0 self,
myself: ActorRef<Self::Msg>,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Invoked after an actor has started. Read more
Source§fn handle<'life0, 'life1, 'async_trait>(
&'life0 self,
myself: ActorRef<Self::Msg>,
message: Self::Msg,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn handle<'life0, 'life1, 'async_trait>(
&'life0 self,
myself: ActorRef<Self::Msg>,
message: Self::Msg,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Handle the incoming message from the event processing loop. Unhandled panickes will be
captured and sent to the supervisor(s) Read more
Source§fn post_stop<'life0, 'life1, 'async_trait>(
&'life0 self,
_myself: ActorRef<Self::Msg>,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn post_stop<'life0, 'life1, 'async_trait>(
&'life0 self,
_myself: ActorRef<Self::Msg>,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Invoked after an actor has been stopped to perform final cleanup. In the
event the actor is terminated with Signal::Kill or has self-panicked,
post_stop won’t be called. Read moreSource§fn handle_supervisor_evt<'life0, 'life1, 'async_trait>(
&'life0 self,
myself: ActorRef<Self::Msg>,
message: SupervisionEvent,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn handle_supervisor_evt<'life0, 'life1, 'async_trait>(
&'life0 self,
myself: ActorRef<Self::Msg>,
message: SupervisionEvent,
state: &'life1 mut Self::State,
) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Handle the incoming supervision event. Unhandled panics will be captured and
sent the the supervisor(s). The default supervision behavior is to exit the
supervisor on any child exit. To override this behavior, implement this function. Read more
Source§fn spawn<'async_trait>(
name: Option<String>,
handler: Self,
startup_args: Self::Arguments,
) -> Pin<Box<dyn Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send + 'async_trait>>where
Self: 'async_trait,
fn spawn<'async_trait>(
name: Option<String>,
handler: Self,
startup_args: Self::Arguments,
) -> Pin<Box<dyn Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send + 'async_trait>>where
Self: 'async_trait,
Spawn an actor of this type, which is unsupervised, automatically starting Read more
Source§fn spawn_linked<'async_trait>(
name: Option<String>,
handler: Self,
startup_args: Self::Arguments,
supervisor: ActorCell,
) -> Pin<Box<dyn Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send + 'async_trait>>where
Self: 'async_trait,
fn spawn_linked<'async_trait>(
name: Option<String>,
handler: Self,
startup_args: Self::Arguments,
supervisor: ActorCell,
) -> Pin<Box<dyn Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send + 'async_trait>>where
Self: 'async_trait,
Spawn an actor of this type with a supervisor, automatically starting the actor Read more
Auto Trait Implementations§
impl Freeze for Config
impl RefUnwindSafe for Config
impl Send for Config
impl Sync for Config
impl Unpin for Config
impl UnwindSafe for Config
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage