pub struct Subscriber;
Trait Implementations§
source§impl Subscriber for Subscriber
impl Subscriber for Subscriber
§type ConnectionContext = ()
type ConnectionContext = ()
An application provided type associated with each connection. Read more
source§fn create_connection_context(
&mut self,
_meta: &ConnectionMeta,
_info: &ConnectionInfo
) -> Self::ConnectionContext
fn create_connection_context( &mut self, _meta: &ConnectionMeta, _info: &ConnectionInfo ) -> Self::ConnectionContext
Creates a context to be passed to each connection-related event
source§fn supervisor_timeout(
&mut self,
conn_context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
context: &Context<'_>
) -> Option<Duration>
fn supervisor_timeout( &mut self, conn_context: &mut Self::ConnectionContext, meta: &ConnectionMeta, context: &Context<'_> ) -> Option<Duration>
The period at which
on_supervisor_timeout
is called Read moresource§fn on_supervisor_timeout(
&mut self,
conn_context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
context: &Context<'_>
) -> Outcome
fn on_supervisor_timeout( &mut self, conn_context: &mut Self::ConnectionContext, meta: &ConnectionMeta, context: &Context<'_> ) -> Outcome
Called for each
supervisor_timeout
to determine any action to take on the connection based on the supervisor::Outcome
Read moresource§fn on_application_protocol_information(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &ApplicationProtocolInformation<'_>
)
fn on_application_protocol_information( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &ApplicationProtocolInformation<'_> )
Called when the
ApplicationProtocolInformation
event is triggeredsource§fn on_server_name_information(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &ServerNameInformation<'_>
)
fn on_server_name_information( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &ServerNameInformation<'_> )
Called when the
ServerNameInformation
event is triggeredsource§fn on_packet_skipped(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PacketSkipped
)
fn on_packet_skipped( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PacketSkipped )
Called when the
PacketSkipped
event is triggeredsource§fn on_packet_sent(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PacketSent
)
fn on_packet_sent( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PacketSent )
Called when the
PacketSent
event is triggeredsource§fn on_packet_received(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PacketReceived
)
fn on_packet_received( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PacketReceived )
Called when the
PacketReceived
event is triggeredsource§fn on_active_path_updated(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &ActivePathUpdated<'_>
)
fn on_active_path_updated( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &ActivePathUpdated<'_> )
Called when the
ActivePathUpdated
event is triggeredsource§fn on_path_created(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PathCreated<'_>
)
fn on_path_created( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PathCreated<'_> )
Called when the
PathCreated
event is triggeredsource§fn on_frame_sent(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &FrameSent
)
fn on_frame_sent( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &FrameSent )
Called when the
FrameSent
event is triggeredsource§fn on_frame_received(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &FrameReceived<'_>
)
fn on_frame_received( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &FrameReceived<'_> )
Called when the
FrameReceived
event is triggeredsource§fn on_packet_lost(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PacketLost<'_>
)
fn on_packet_lost( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PacketLost<'_> )
Called when the
PacketLost
event is triggeredsource§fn on_recovery_metrics(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &RecoveryMetrics<'_>
)
fn on_recovery_metrics( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &RecoveryMetrics<'_> )
Called when the
RecoveryMetrics
event is triggeredsource§fn on_congestion(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &Congestion<'_>
)
fn on_congestion( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &Congestion<'_> )
Called when the
Congestion
event is triggeredsource§fn on_ack_processed(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &AckProcessed<'_>
)
fn on_ack_processed( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &AckProcessed<'_> )
👎Deprecated: use on_rx_ack_range_dropped event instead
Called when the
AckProcessed
event is triggeredsource§fn on_rx_ack_range_dropped(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &RxAckRangeDropped<'_>
)
fn on_rx_ack_range_dropped( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &RxAckRangeDropped<'_> )
Called when the
RxAckRangeDropped
event is triggeredsource§fn on_ack_range_received(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &AckRangeReceived<'_>
)
fn on_ack_range_received( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &AckRangeReceived<'_> )
Called when the
AckRangeReceived
event is triggeredsource§fn on_ack_range_sent(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &AckRangeSent
)
fn on_ack_range_sent( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &AckRangeSent )
Called when the
AckRangeSent
event is triggeredsource§fn on_packet_dropped(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PacketDropped<'_>
)
fn on_packet_dropped( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PacketDropped<'_> )
Called when the
PacketDropped
event is triggeredsource§fn on_key_update(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &KeyUpdate
)
fn on_key_update( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &KeyUpdate )
Called when the
KeyUpdate
event is triggeredsource§fn on_key_space_discarded(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &KeySpaceDiscarded
)
fn on_key_space_discarded( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &KeySpaceDiscarded )
Called when the
KeySpaceDiscarded
event is triggeredsource§fn on_connection_started(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &ConnectionStarted<'_>
)
fn on_connection_started( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &ConnectionStarted<'_> )
Called when the
ConnectionStarted
event is triggeredsource§fn on_connection_closed(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &ConnectionClosed
)
fn on_connection_closed( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &ConnectionClosed )
Called when the
ConnectionClosed
event is triggeredsource§fn on_duplicate_packet(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &DuplicatePacket<'_>
)
fn on_duplicate_packet( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &DuplicatePacket<'_> )
Called when the
DuplicatePacket
event is triggeredsource§fn on_transport_parameters_received(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &TransportParametersReceived<'_>
)
fn on_transport_parameters_received( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &TransportParametersReceived<'_> )
Called when the
TransportParametersReceived
event is triggeredsource§fn on_datagram_sent(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &DatagramSent
)
fn on_datagram_sent( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &DatagramSent )
Called when the
DatagramSent
event is triggeredsource§fn on_datagram_received(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &DatagramReceived
)
fn on_datagram_received( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &DatagramReceived )
Called when the
DatagramReceived
event is triggeredsource§fn on_datagram_dropped(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &DatagramDropped
)
fn on_datagram_dropped( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &DatagramDropped )
Called when the
DatagramDropped
event is triggeredsource§fn on_connection_id_updated(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &ConnectionIdUpdated<'_>
)
fn on_connection_id_updated( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &ConnectionIdUpdated<'_> )
Called when the
ConnectionIdUpdated
event is triggeredsource§fn on_ecn_state_changed(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &EcnStateChanged<'_>
)
fn on_ecn_state_changed( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &EcnStateChanged<'_> )
Called when the
EcnStateChanged
event is triggeredsource§fn on_connection_migration_denied(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &ConnectionMigrationDenied
)
fn on_connection_migration_denied( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &ConnectionMigrationDenied )
Called when the
ConnectionMigrationDenied
event is triggeredsource§fn on_handshake_status_updated(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &HandshakeStatusUpdated
)
fn on_handshake_status_updated( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &HandshakeStatusUpdated )
Called when the
HandshakeStatusUpdated
event is triggeredsource§fn on_tls_exporter_ready(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &TlsExporterReady<'_>
)
fn on_tls_exporter_ready( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &TlsExporterReady<'_> )
Called when the
TlsExporterReady
event is triggeredsource§fn on_path_challenge_updated(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PathChallengeUpdated<'_>
)
fn on_path_challenge_updated( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PathChallengeUpdated<'_> )
Called when the
PathChallengeUpdated
event is triggeredsource§fn on_tls_client_hello(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &TlsClientHello<'_>
)
fn on_tls_client_hello( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &TlsClientHello<'_> )
Called when the
TlsClientHello
event is triggeredsource§fn on_tls_server_hello(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &TlsServerHello<'_>
)
fn on_tls_server_hello( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &TlsServerHello<'_> )
Called when the
TlsServerHello
event is triggeredsource§fn on_rx_stream_progress(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &RxStreamProgress
)
fn on_rx_stream_progress( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &RxStreamProgress )
Called when the
RxStreamProgress
event is triggeredsource§fn on_tx_stream_progress(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &TxStreamProgress
)
fn on_tx_stream_progress( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &TxStreamProgress )
Called when the
TxStreamProgress
event is triggeredsource§fn on_keep_alive_timer_expired(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &KeepAliveTimerExpired
)
fn on_keep_alive_timer_expired( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &KeepAliveTimerExpired )
Called when the
KeepAliveTimerExpired
event is triggeredsource§fn on_mtu_updated(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &MtuUpdated
)
fn on_mtu_updated( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &MtuUpdated )
Called when the
MtuUpdated
event is triggeredsource§fn on_slow_start_exited(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &SlowStartExited
)
fn on_slow_start_exited( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &SlowStartExited )
Called when the
SlowStartExited
event is triggeredsource§fn on_delivery_rate_sampled(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &DeliveryRateSampled
)
fn on_delivery_rate_sampled( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &DeliveryRateSampled )
Called when the
DeliveryRateSampled
event is triggeredsource§fn on_pacing_rate_updated(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &PacingRateUpdated
)
fn on_pacing_rate_updated( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &PacingRateUpdated )
Called when the
PacingRateUpdated
event is triggeredsource§fn on_bbr_state_changed(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &BbrStateChanged
)
fn on_bbr_state_changed( &mut self, context: &mut Self::ConnectionContext, meta: &ConnectionMeta, event: &BbrStateChanged )
Called when the
BbrStateChanged
event is triggeredsource§fn on_version_information(
&mut self,
meta: &EndpointMeta,
event: &VersionInformation<'_>
)
fn on_version_information( &mut self, meta: &EndpointMeta, event: &VersionInformation<'_> )
Called when the
VersionInformation
event is triggeredsource§fn on_endpoint_packet_sent(
&mut self,
meta: &EndpointMeta,
event: &EndpointPacketSent
)
fn on_endpoint_packet_sent( &mut self, meta: &EndpointMeta, event: &EndpointPacketSent )
Called when the
EndpointPacketSent
event is triggeredsource§fn on_endpoint_packet_received(
&mut self,
meta: &EndpointMeta,
event: &EndpointPacketReceived
)
fn on_endpoint_packet_received( &mut self, meta: &EndpointMeta, event: &EndpointPacketReceived )
Called when the
EndpointPacketReceived
event is triggeredsource§fn on_endpoint_datagram_sent(
&mut self,
meta: &EndpointMeta,
event: &EndpointDatagramSent
)
fn on_endpoint_datagram_sent( &mut self, meta: &EndpointMeta, event: &EndpointDatagramSent )
Called when the
EndpointDatagramSent
event is triggeredsource§fn on_endpoint_datagram_received(
&mut self,
meta: &EndpointMeta,
event: &EndpointDatagramReceived
)
fn on_endpoint_datagram_received( &mut self, meta: &EndpointMeta, event: &EndpointDatagramReceived )
Called when the
EndpointDatagramReceived
event is triggeredsource§fn on_endpoint_datagram_dropped(
&mut self,
meta: &EndpointMeta,
event: &EndpointDatagramDropped
)
fn on_endpoint_datagram_dropped( &mut self, meta: &EndpointMeta, event: &EndpointDatagramDropped )
Called when the
EndpointDatagramDropped
event is triggeredsource§fn on_endpoint_connection_attempt_failed(
&mut self,
meta: &EndpointMeta,
event: &EndpointConnectionAttemptFailed
)
fn on_endpoint_connection_attempt_failed( &mut self, meta: &EndpointMeta, event: &EndpointConnectionAttemptFailed )
Called when the
EndpointConnectionAttemptFailed
event is triggeredsource§fn on_platform_tx(&mut self, meta: &EndpointMeta, event: &PlatformTx)
fn on_platform_tx(&mut self, meta: &EndpointMeta, event: &PlatformTx)
Called when the
PlatformTx
event is triggeredsource§fn on_platform_tx_error(&mut self, meta: &EndpointMeta, event: &PlatformTxError)
fn on_platform_tx_error(&mut self, meta: &EndpointMeta, event: &PlatformTxError)
Called when the
PlatformTxError
event is triggeredsource§fn on_platform_rx(&mut self, meta: &EndpointMeta, event: &PlatformRx)
fn on_platform_rx(&mut self, meta: &EndpointMeta, event: &PlatformRx)
Called when the
PlatformRx
event is triggeredsource§fn on_platform_rx_error(&mut self, meta: &EndpointMeta, event: &PlatformRxError)
fn on_platform_rx_error(&mut self, meta: &EndpointMeta, event: &PlatformRxError)
Called when the
PlatformRxError
event is triggeredsource§fn on_platform_feature_configured(
&mut self,
meta: &EndpointMeta,
event: &PlatformFeatureConfigured
)
fn on_platform_feature_configured( &mut self, meta: &EndpointMeta, event: &PlatformFeatureConfigured )
Called when the
PlatformFeatureConfigured
event is triggeredsource§fn on_platform_event_loop_wakeup(
&mut self,
meta: &EndpointMeta,
event: &PlatformEventLoopWakeup
)
fn on_platform_event_loop_wakeup( &mut self, meta: &EndpointMeta, event: &PlatformEventLoopWakeup )
Called when the
PlatformEventLoopWakeup
event is triggeredsource§fn on_platform_event_loop_sleep(
&mut self,
meta: &EndpointMeta,
event: &PlatformEventLoopSleep
)
fn on_platform_event_loop_sleep( &mut self, meta: &EndpointMeta, event: &PlatformEventLoopSleep )
Called when the
PlatformEventLoopSleep
event is triggeredsource§fn on_event<M, E>(&mut self, meta: &M, event: &E)
fn on_event<M, E>(&mut self, meta: &M, event: &E)
Called for each event that relates to the endpoint and all connections
source§fn on_connection_event<E>(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &E
)where
E: Event,
fn on_connection_event<E>(
&mut self,
context: &mut Self::ConnectionContext,
meta: &ConnectionMeta,
event: &E
)where
E: Event,
Called for each event that relates to a connection
source§fn query(
context: &Self::ConnectionContext,
query: &mut dyn Query
) -> ControlFlow
fn query( context: &Self::ConnectionContext, query: &mut dyn Query ) -> ControlFlow
Used for querying the
Subscriber::ConnectionContext
on a Subscribersource§fn query_mut(
context: &mut Self::ConnectionContext,
query: &mut dyn QueryMut
) -> ControlFlow
fn query_mut( context: &mut Self::ConnectionContext, query: &mut dyn QueryMut ) -> ControlFlow
Used for querying and mutating the
Subscriber::ConnectionContext
on a SubscriberAuto Trait Implementations§
impl Freeze for Subscriber
impl RefUnwindSafe for Subscriber
impl Send for Subscriber
impl Sync for Subscriber
impl Unpin for Subscriber
impl UnwindSafe for Subscriber
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