StreamReceiveHealthEvent class final

This node stopped, or resumed, receiving from one peer on a stream.

Local, not a message: it reports the receiving end on this node (see InletHealth), so fromNodeUId is this node. One is emitted for every failure of the receiver, and one with healthy true when it is working again. While the last event for a (streamName, sourceId) pair has healthy false, samples that peer sends on that stream are not arriving here; if willRetry is also false, nothing is going to fix that by itself.

Inheritance

Constructors

StreamReceiveHealthEvent({required String streamName, required String sourceId, required bool healthy, required int consecutiveFailures, required bool willRetry, String? error, required String fromNodeUId, String? messageId, String? parentMessageId, DateTime? timestamp, MessageTiming? timing})

Properties

consecutiveFailures → int
Failures in a row at the time of this event. Zero when healthy.
final
error → String?
What ended the receiver, or null when healthy.
final
fromNodeUId → String
finalinherited
hashCode → int
The hash code for this object.
no setterinherited
healthy → bool
Whether samples from sourceId are being received.
final
messageId → String
finalinherited
parentMessageId → String?
finalinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
sourceId → String
The peer's source on that stream.
final
streamName → String
The stream; the coordination stream's own name for that one.
final
timestamp → DateTime
finalinherited
timing → MessageTiming?
How long this event's message took to reach us, as the transport measured it — see MessageTiming.
finalinherited
willRetry → bool
Whether the transport is restarting the receiver by itself.
final

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toString() → String
A string representation of this object.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited