Struct ocypod::actors::monitor::MonitorActor
source · pub struct MonitorActor { /* private fields */ }
Expand description
Actor that performs periodic operations in Redis.
This includes:
- checking job timeouts
- checking job retries
- deleting expired jobs
Implementations
sourceimpl MonitorActor
impl MonitorActor
pub fn new(redis_addr: Addr<ApplicationActor>, config: &ServerConfig) -> Self
Trait Implementations
sourceimpl Actor for MonitorActor
impl Actor for MonitorActor
type Context = Context<MonitorActor>
type Context = Context<MonitorActor>
Actor execution context type
sourcefn started(&mut self, ctx: &mut Self::Context)
fn started(&mut self, ctx: &mut Self::Context)
Method is called when actor get polled first time.
sourcefn stopping(&mut self, ctx: &mut Self::Context) -> Running
fn stopping(&mut self, ctx: &mut Self::Context) -> Running
Method is called after an actor is in
Actor::Stopping
state. There
could be several reasons for stopping. Context::stop
get called
by the actor itself. All addresses to current actor get dropped and
no more evented objects left in the context. Read moresourcefn stopped(&mut self, ctx: &mut Self::Context)
fn stopped(&mut self, ctx: &mut Self::Context)
Method is called after an actor is stopped, it can be used to perform
any needed cleanup work or spawning more actors. This is final state,
after this call actor get dropped. Read more
Auto Trait Implementations
impl !RefUnwindSafe for MonitorActor
impl Send for MonitorActor
impl Sync for MonitorActor
impl Unpin for MonitorActor
impl !UnwindSafe for MonitorActor
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more