AggregateSinkOptions

class AggregateSinkOptions @InternalWowApi constructor(val history: Boolean = true, val historyTtl: Duration? = null)

How the Sink keeps one aggregate type's commits.

  • history: whether it keeps every commit in <ctx>_<agg>_state_events (and every event in <ctx>_<agg>_events); when false only the current state is kept, written to <ctx>_<agg>_state directly.

  • historyTtl: how long the history is kept, by commit time; forever when null. Only with history.

Fields may be added: Wow builds it from the host's configuration, so the constructor is internal to Wow.

Constructors

Link copied to clipboard
constructor(history: Boolean = true, historyTtl: Duration? = null)

Properties

Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String