Enum ConnectionEvent

Source

pub enum ConnectionEvent {
    Idle,
    Authenticating,
    Connected,
    Endpoint(Box<ServerEndpoint>),
    List(Vec<ServerEndpoint>),
    Acknowledged,
    Error(String),
    Closed,
}

Expand description

Представляет различные события, происходящие в течение жизненного цикла соединения.

События генерируются асинхронно при изменении состояния соединения или в ответ на операции. Используйте Connection::wait_for_event() для ожидания конкретных событий.

§Поток событий

Idle → Начальное состояние (редко видно пользователям)
Authenticating → Когда начинается аутентификация
Connected → Успешно аутентифицирован и готов к операциям
Endpoint → Ответ на операции с конечной точкой (register, publish)
List → Ответ на операции листинга
Acknowledged → Операция успешно завершена
Error → Операция завершилась с ошибкой
Closed → Соединение прервано

Variants§

§

Idle

Начальное состояние перед установлением соединения. Это состояние обычно не наблюдается пользователями.

§

Authenticating

Идет аутентификация. Это событие генерируется, когда клиент начинает аутентификацию с сервером.

§

Connected

Успешно аутентифицирован и подключен к серверу. После этого события соединение готово к операциям.

§

Endpoint(Box<ServerEndpoint>)

Результат операции конечной точки (register, publish, ping). Содержит детали конечной точки, включая ее GUID и URL.

§

List(Vec<ServerEndpoint>)

Результат операции листинга. Содержит все зарегистрированные конечные точки с их текущим статусом.

§

Acknowledged

Операция была подтверждена сервером. Генерируется для операций, таких как stop, unpublish и clean.

§

Error(String)

Произошла ошибка во время операции. Содержит сообщение об ошибке от сервера.

§

Closed

Соединение было закрыто. Это может произойти из-за проблем с сетью, отключения сервера или явного разрыва соединения.

Enum ConnectionEvent Copy item path

§Поток событий

Variants§

Idle

Authenticating

Connected

Endpoint(Box<ServerEndpoint>)

List(Vec<ServerEndpoint>)

Acknowledged

Error(String)

Closed

Trait Implementations§

impl Clone for ConnectionEvent

fn clone(&self) -> ConnectionEvent

fn clone_from(&mut self, source: &Self)

impl Debug for ConnectionEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl PartialEq for ConnectionEvent

fn eq(&self, other: &ConnectionEvent) -> bool

fn ne(&self, other: &Rhs) -> bool

impl StructuralPartialEq for ConnectionEvent

Auto Trait Implementations§

impl Freeze for ConnectionEvent

impl RefUnwindSafe for ConnectionEvent

impl Send for ConnectionEvent

impl Sync for ConnectionEvent

impl Unpin for ConnectionEvent

impl UnwindSafe for ConnectionEvent

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> AnyEq for Twhere T: Any + PartialEq,

fn equals(&self, other: &(dyn Any + 'static)) -> bool

fn as_any(&self) -> &(dyn Any + 'static)

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

Enum ConnectionEvent

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> AnyEq for T
where T: Any + PartialEq,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> ErasedDestructor for T
where T: 'static,