DeltaBufferPolicy

scalus.cardano.node.stream.DeltaBufferPolicy
See theDeltaBufferPolicy companion enum

Attributes

Companion
enum
Graph
Supertypes
trait Sum
trait Mirror
class Object
trait Matchable
class Any
Self type

Members list

Type members

Inherited and Abstract types

type MirroredElemLabels <: Tuple

The names of the product elements

The names of the product elements

Attributes

Inherited from:
Mirror
type MirroredLabel <: String

The name of the type

The name of the type

Attributes

Inherited from:
Mirror

Value members

Concrete fields

Bounded rather than unbounded, on the same principle as the rest of this policy: a subscriber that falls hopelessly behind gets a ScalusBufferOverflowException naming its subscription, instead of an out-of-memory error naming nothing.

Bounded rather than unbounded, on the same principle as the rest of this policy: a subscriber that falls hopelessly behind gets a ScalusBufferOverflowException naming its subscription, instead of an out-of-memory error naming nothing.

Attributes

val defaultBound: Int

Live events a delta subscription may fall behind by before it is failed.

Live events a delta subscription may fall behind by before it is failed.

Sized so that only a broken consumer reaches it. Mainnet produces a block roughly every 20 seconds, so even a subscription matching every transaction accumulates on the order of tens of events per block; 10,000 is hours of falling behind, while a subscriber that is merely bursty is nowhere near it. The snapshot seed does not count against it — see StreamingEmulator.bufferSize.

Attributes