[−][src]Struct tempest::topology::TopologyActor
Trait Implementations
impl Default for TopologyActor
[src]
fn default() -> TopologyActor
[src]
impl Actor for TopologyActor
[src]
type Context = Context<Self>
Actor execution context type
fn started(&mut self, ctx: &mut Context<Self>)
[src]
fn stopping(&mut self, ctx: &mut Self::Context) -> Running
[src]
Called after an actor is in Actor::Stopping
state. Read more
fn stopped(&mut self, ctx: &mut Self::Context)
[src]
Called after an actor is stopped. Read more
fn start(self) -> Addr<Self> where
Self: Actor<Context = Context<Self>>,
[src]
Self: Actor<Context = Context<Self>>,
Start a new asynchronous actor, returning its address. Read more
fn start_default() -> Addr<Self> where
Self: Actor<Context = Context<Self>> + Default,
[src]
Self: Actor<Context = Context<Self>> + Default,
Construct and start a new asynchronous actor, returning its address. Read more
fn start_in_arbiter<F>(arb: &Arbiter, f: F) -> Addr<Self> where
F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,
Self: Actor<Context = Context<Self>>,
[src]
F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,
Self: Actor<Context = Context<Self>>,
Start new actor in arbiter's thread.
fn create<F>(f: F) -> Addr<Self> where
F: FnOnce(&mut Context<Self>) -> Self + 'static,
Self: Actor<Context = Context<Self>>,
[src]
F: FnOnce(&mut Context<Self>) -> Self + 'static,
Self: Actor<Context = Context<Self>>,
Start a new asynchronous actor given a Context
. Read more
impl Supervised for TopologyActor
[src]
fn restarting(&mut self, ctx: &mut Self::Context)
[src]
Called when the supervisor restarts a failed actor.
impl Handler<SourceMsg> for TopologyActor
[src]
type Result = ()
The type of value that this handler will return.
fn handle(&mut self, msg: SourceMsg, _ctx: &mut Context<Self>)
[src]
impl Handler<TaskRequest> for TopologyActor
[src]
type Result = ()
The type of value that this handler will return.
fn handle(&mut self, msg: TaskRequest, _ctx: &mut Context<Self>)
[src]
impl Handler<TaskResponse> for TopologyActor
[src]
type Result = ()
The type of value that this handler will return.
fn handle(&mut self, msg: TaskResponse, _ctx: &mut Context<Self>)
[src]
impl Handler<PipelineMsg> for TopologyActor
[src]
type Result = ()
The type of value that this handler will return.
fn handle(&mut self, msg: PipelineMsg, _ctx: &mut Context<Self>)
[src]
impl Handler<Flush> for TopologyActor
[src]
type Result = ()
The type of value that this handler will return.
fn handle(&mut self, _msg: Flush, _ctx: &mut Context<Self>)
[src]
impl SystemService for TopologyActor
[src]
fn start_service(sys: &Arbiter) -> Addr<Self>
[src]
Construct and start system service
fn service_started(&mut self, ctx: &mut Context<Self>)
[src]
Method is called during service initialization.
fn from_registry() -> Addr<Self>
[src]
Get actor's address from system registry
Auto Trait Implementations
impl Send for TopologyActor
impl Unpin for TopologyActor
impl Sync for TopologyActor
impl UnwindSafe for TopologyActor
impl RefUnwindSafe for TopologyActor
Blanket Implementations
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
ⓘImportant traits for &'_ mut Wfn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Erased for T
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,