org.sigilaris.node.gossip.GossipProducerPolling
Utility for batching available gossip events according to QoS constraints.
Attributes
-
Source
-
ProducerSession.scala
-
Graph
-
-
Supertypes
-
class Object
trait Matchable
class Any
-
Self type
-
Members list
Selects events from the candidate pool for delivery, respecting batch size, flush interval, and limit.
Selects events from the candidate pool for delivery, respecting batch size, flush interval, and limit.
Type parameters
-
A
-
the artifact payload type
Value parameters
-
candidates
-
the available events to consider
-
forceFlush
-
if true, bypasses flush interval check
-
limit
-
maximum number of events to return
-
now
-
the current instant
-
qos
-
the producer QoS settings
Attributes
-
Returns
-
the selected events for delivery
-
Source
-
ProducerSession.scala