pub struct Coordinator { /* private fields */ }Expand description
Protocol coordinator
Implementations§
Source§impl Coordinator
impl Coordinator
Sourcepub async fn new(config: ProtocolConfig) -> Result<Self, ProtocolError>
pub async fn new(config: ProtocolConfig) -> Result<Self, ProtocolError>
Create new coordinator
Sourcepub async fn start(&mut self) -> Result<(), ProtocolError>
pub async fn start(&mut self) -> Result<(), ProtocolError>
Start coordinator
Sourcepub async fn stop(&mut self) -> Result<(), ProtocolError>
pub async fn stop(&mut self) -> Result<(), ProtocolError>
Stop coordinator
Sourcepub async fn state(&self) -> ProtocolState
pub async fn state(&self) -> ProtocolState
Get current state
Sourcepub fn is_initialized(&self) -> bool
pub fn is_initialized(&self) -> bool
Check if coordinator is initialized
Sourcepub async fn broadcast_message(
&mut self,
message: Vec<u8>,
) -> Result<(), ProtocolError>
pub async fn broadcast_message( &mut self, message: Vec<u8>, ) -> Result<(), ProtocolError>
Broadcast message
Sourcepub fn crypto_manager(&self) -> Option<&KeyPair>
pub fn crypto_manager(&self) -> Option<&KeyPair>
Get crypto manager
Sourcepub fn network_manager(&self) -> Option<&NetworkManager>
pub fn network_manager(&self) -> Option<&NetworkManager>
Get network manager
Sourcepub fn dag_manager(&self) -> Option<&QrDag>
pub fn dag_manager(&self) -> Option<&QrDag>
Get DAG manager
Auto Trait Implementations§
impl Freeze for Coordinator
impl !RefUnwindSafe for Coordinator
impl Send for Coordinator
impl Sync for Coordinator
impl Unpin for Coordinator
impl !UnwindSafe for Coordinator
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more