PacketsDropped

data class PacketsDropped(val flow: DroppedFlow, val count: Int) : MeshEvent(source)

A flow dropped messages due to subscriber backpressure.

Indicates that the subscriber could not keep up with the engine's emission rate. The engine applies backpressure selectively: the named DroppedFlow exceeded its buffer and the oldest queued item was dropped.

This event is emitted at most once per drop burst to avoid log spam.

Parameters

flow

which flow experienced the drop

count

how many items were dropped

Constructors

Link copied to clipboard
constructor(flow: DroppedFlow, count: Int)

Properties

Link copied to clipboard
val count: Int
Link copied to clipboard