Struct DefaultHook

pub struct DefaultHook { /* private fields */ }

Implementations§

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

session created

After the mqtt:: connectack message is sent, the connection is created successfully

Disconnect message received

Session terminated

subscribe check acl

publish check acl

Subscribe message received

Subscription succeeded

Unsubscribe message received

Unsubscribe succeeded

Publish message received

Message delivered

Message acked

Offline publish message

Offline inflight messages

Message expiry check

Client Keepalive

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

Converts to this type from a reference to the input type.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

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 more

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

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

Should always be Self

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

DefaultHook

Struct DefaultHook Copy item path

Implementations§

impl DefaultHook

pub fn new(manager: DefaultHookManager, s: Session) -> Self

Trait Implementations§

impl Clone for DefaultHook

fn clone(&self) -> DefaultHook

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

impl Hook for DefaultHook

fn session_created<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn client_connected<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn client_disconnected<'life0, 'async_trait>( &'life0 self, r: Reason, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn session_terminated<'life0, 'async_trait>( &'life0 self, r: Reason, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn client_subscribe_check_acl<'life0, 'life1, 'async_trait>( &'life0 self, sub: &'life1 Subscribe, ) -> Pin<Box<dyn Future<Output = Option<SubscribeAclResult>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn message_publish_check_acl<'life0, 'life1, 'async_trait>( &'life0 self, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = PublishAclResult> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn client_subscribe<'life0, 'life1, 'async_trait>( &'life0 self, sub: &'life1 Subscribe, ) -> Pin<Box<dyn Future<Output = Option<TopicFilter>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn session_subscribed<'life0, 'async_trait>( &'life0 self, subscribe: Subscribe, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn client_unsubscribe<'life0, 'life1, 'async_trait>( &'life0 self, unsub: &'life1 Unsubscribe, ) -> Pin<Box<dyn Future<Output = Option<TopicFilter>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn session_unsubscribed<'life0, 'async_trait>( &'life0 self, unsubscribe: Unsubscribe, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn message_publish<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = Option<Publish>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn message_delivered<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = Option<Publish>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn message_acked<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn offline_message<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn offline_inflight_messages<'life0, 'async_trait>( &'life0 self, inflight_messages: Vec<OutInflightMessage>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn message_expiry_check<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = MessageExpiryCheckResult> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn client_keepalive<'life0, 'async_trait>( &'life0 self, ping: IsPing, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Auto Trait Implementations§

impl Freeze for DefaultHook

impl !RefUnwindSafe for DefaultHook

impl Send for DefaultHook

impl Sync for DefaultHook

impl Unpin for DefaultHook

impl UnsafeUnpin for DefaultHook

impl !UnwindSafe for DefaultHook

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn arc(self) -> Arc<Self> ⓘwhere Self: Sized,

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> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

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

fn hash_value(self, h: u64) -> HashWrapper<Self>where Self: Sized,

fn hash_empty(self) -> EmptyHashWrapper<Self>where Self: Sized,

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> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

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

fn eq_ord(self) -> EqOrdWrapper<Self>where Self: Sized,

fn neq_ord(self) -> NeqOrdWrapper<Self>where Self: Sized,

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

fn neq_ord_hash(self, h: u64) -> NeqOrdHashWrapper<Self>where Self: Sized,

fn neq_ord_empty(self) -> NeqOrdEmptyHashWrapper<Self>where Self: Sized,

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

fn queue_stream<Item, F>(self, f: F) -> QueueStream<Self, Item, F>where Self: Sized + Unpin, F: Fn(Pin<&mut Self>, &mut Context<'_>) -> Poll<Option<Item>>,

fn queue_sender<Item, F, R>(self, f: F) -> QueueSender<Self, Item, F, R>where Self: Sized + Waker, F: Fn(&mut Self, Action<Item>) -> Reply<R>,

impl<T> Same for T

type Output = T

Struct DefaultHook

fn session_created<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn client_connected<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn client_disconnected<'life0, 'async_trait>( &'life0 self, r: Reason, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn session_terminated<'life0, 'async_trait>( &'life0 self, r: Reason, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn client_subscribe_check_acl<'life0, 'life1, 'async_trait>( &'life0 self, sub: &'life1 Subscribe, ) -> Pin<Box<dyn Future<Output = Option<SubscribeAclResult>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn message_publish_check_acl<'life0, 'life1, 'async_trait>( &'life0 self, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = PublishAclResult> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn client_subscribe<'life0, 'life1, 'async_trait>( &'life0 self, sub: &'life1 Subscribe, ) -> Pin<Box<dyn Future<Output = Option<TopicFilter>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn session_subscribed<'life0, 'async_trait>( &'life0 self, subscribe: Subscribe, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn client_unsubscribe<'life0, 'life1, 'async_trait>( &'life0 self, unsub: &'life1 Unsubscribe, ) -> Pin<Box<dyn Future<Output = Option<TopicFilter>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn session_unsubscribed<'life0, 'async_trait>( &'life0 self, unsubscribe: Unsubscribe, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn message_publish<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = Option<Publish>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn message_delivered<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = Option<Publish>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn message_acked<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn offline_message<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn offline_inflight_messages<'life0, 'async_trait>( &'life0 self, inflight_messages: Vec<OutInflightMessage>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn message_expiry_check<'life0, 'life1, 'async_trait>( &'life0 self, from: From, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = MessageExpiryCheckResult> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn client_keepalive<'life0, 'async_trait>( &'life0 self, ping: IsPing, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

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

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

fn arc(self) -> Arc<Self> ⓘ
where Self: Sized,

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> FromRef<T> for T
where T: Clone,

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

fn hash_value(self, h: u64) -> HashWrapper<Self>
where Self: Sized,

fn hash_empty(self) -> EmptyHashWrapper<Self>
where Self: Sized,

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,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

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

fn eq_ord(self) -> EqOrdWrapper<Self>
where Self: Sized,

fn neq_ord(self) -> NeqOrdWrapper<Self>
where Self: Sized,

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

fn neq_ord_hash(self, h: u64) -> NeqOrdHashWrapper<Self>
where Self: Sized,

fn neq_ord_empty(self) -> NeqOrdEmptyHashWrapper<Self>
where Self: Sized,

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

fn queue_stream<Item, F>(self, f: F) -> QueueStream<Self, Item, F>
where Self: Sized + Unpin, F: Fn(Pin<&mut Self>, &mut Context<'_>) -> Poll<Option<Item>>,

fn queue_sender<Item, F, R>(self, f: F) -> QueueSender<Self, Item, F, R>
where Self: Sized + Waker, F: Fn(&mut Self, Action<Item>) -> Reply<R>,

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>,