pub struct ClusterAgentHandle { /* private fields */ }Expand description
Running cluster-aware agent.
Implementations§
Source§impl ClusterAgentHandle
impl ClusterAgentHandle
pub fn agent(&self) -> &AgentHandle
pub fn cluster(&self) -> &ClusterNode
pub fn sessions(&self) -> &NodeSessionManagerHandle
pub fn server(&self) -> &DcpServer
pub fn tcp_addr(&self) -> Option<SocketAddr>
pub fn quic_addr(&self) -> Option<SocketAddr>
pub async fn shutdown(self) -> ClusterAgentResult<()>
Trait Implementations§
Source§impl Drop for ClusterAgentHandle
impl Drop for ClusterAgentHandle
Auto Trait Implementations§
impl !RefUnwindSafe for ClusterAgentHandle
impl !UnwindSafe for ClusterAgentHandle
impl Freeze for ClusterAgentHandle
impl Send for ClusterAgentHandle
impl Sync for ClusterAgentHandle
impl Unpin for ClusterAgentHandle
impl UnsafeUnpin for ClusterAgentHandle
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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