[−][src]Struct quix::node::NodeControl
Fields
dispatch: HashMap<u64, NodeHandler>
Dispatcher for unaddressed messages.
Messages which are sent to process id of 00000000000000000.... are considered unadressed, and are dispatched from here
listeners: HashMap<Uuid, Recipient<NodeUpdate>>
Trait Implementations
impl Actor for NodeControl
[src]
type Context = Context<Self>
Actor execution context type
fn started(&mut self, ctx: &mut Self::Context)
[src]
fn stopping(&mut self, ctx: &mut Self::Context) -> Running
[src]
fn stopped(&mut self, ctx: &mut Self::Context)
[src]
fn start(self) -> Addr<Self> where
Self: Actor<Context = Context<Self>>,
[src]
Self: Actor<Context = Context<Self>>,
fn start_default() -> Addr<Self> where
Self: Actor<Context = Context<Self>> + Default,
[src]
Self: Actor<Context = Context<Self>> + Default,
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>>,
fn create<F>(f: F) -> Addr<Self> where
F: FnOnce(&mut Context<Self>) -> Self,
Self: Actor<Context = Context<Self>>,
[src]
F: FnOnce(&mut Context<Self>) -> Self,
Self: Actor<Context = Context<Self>>,
impl Default for NodeControl
[src]
impl Handler<Broadcast> for NodeControl
[src]
type Result = ()
The type of value that this handler will return. Read more
fn handle(&mut self, msg: Broadcast, ctx: &mut Self::Context) -> Self::Result
[src]
impl Handler<Connect> for NodeControl
[src]
type Result = ResponseActFuture<Self, Addr<NodeLink>>
The type of value that this handler will return. Read more
fn handle(&mut self, msg: Connect, ctx: &mut Self::Context) -> Self::Result
[src]
impl Handler<NodeUpdate> for NodeControl
[src]
type Result = ()
The type of value that this handler will return. Read more
fn handle(&mut self, msg: NodeUpdate, ctx: &mut Self::Context) -> Self::Result
[src]
impl Handler<RecvFromNode<Dispatch>> for NodeControl
[src]
type Result = ()
The type of value that this handler will return. Read more
fn handle(
&mut self,
msg: RecvFromNode<Dispatch>,
ctx: &mut Self::Context
) -> Self::Result
[src]
&mut self,
msg: RecvFromNode<Dispatch>,
ctx: &mut Self::Context
) -> Self::Result
impl Handler<RegisterRecipient<NodeUpdate>> for NodeControl
[src]
type Result = Result<Uuid, Infallible>
The type of value that this handler will return. Read more
fn handle(
&mut self,
msg: RegisterRecipient<NodeUpdate>,
ctx: &mut Self::Context
) -> Self::Result
[src]
&mut self,
msg: RegisterRecipient<NodeUpdate>,
ctx: &mut Self::Context
) -> Self::Result
impl Handler<RegisterSystemHandler> for NodeControl
[src]
type Result = ()
The type of value that this handler will return. Read more
fn handle(
&mut self,
msg: RegisterSystemHandler,
ctx: &mut Context<Self>
) -> Self::Result
[src]
&mut self,
msg: RegisterSystemHandler,
ctx: &mut Context<Self>
) -> Self::Result
impl Handler<SendToNode> for NodeControl
[src]
type Result = Response<Bytes, DispatchError>
The type of value that this handler will return. Read more
fn handle(&mut self, msg: SendToNode, ctx: &mut Self::Context) -> Self::Result
[src]
impl StreamHandler<Result<TcpStream, Error>> for NodeControl
[src]
fn handle(&mut self, item: Result<TcpStream>, ctx: &mut Context<Self>)
[src]
fn started(&mut self, ctx: &mut Self::Context)
[src]
fn finished(&mut self, ctx: &mut Self::Context)
[src]
fn add_stream<S>(fut: S, ctx: &mut Self::Context) -> SpawnHandle where
I: 'static,
S: Stream<Item = I> + 'static,
Self::Context: AsyncContext<Self>,
[src]
I: 'static,
S: Stream<Item = I> + 'static,
Self::Context: AsyncContext<Self>,
impl Supervised for NodeControl
[src]
fn restarting(&mut self, ctx: &mut Self::Context)
[src]
impl SystemService for NodeControl
[src]
fn start_service(sys: &Arbiter) -> Addr<Self>
[src]
fn service_started(&mut self, ctx: &mut Context<Self>)
[src]
fn from_registry() -> Addr<Self>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for NodeControl
impl Send for NodeControl
impl !Sync for NodeControl
impl Unpin for NodeControl
impl !UnwindSafe for NodeControl
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut Tⓘ
[src]
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.
pub 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.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,