-
public final class StreamEventAggregationPolicy<T extends Object>Complete aggregation configuration for StreamEventAggregator.
Combines behavior (how to extract types and deserialize) with tuning (thresholds, windows, queue capacity). Once created via a factory method, the policy is guaranteed valid — all invariants are checked at construction time.
The primary constructor is private. Create instances through the from factory method.
aggregationThreshold > 0maxWindowMs > 0dispatchQueueCapacity > 0
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classStreamEventAggregationPolicy.Companion
-
Field Summary
Fields Modifier and Type Field Description private final Function1<String, String>extractTypeprivate final Function1<String, Result<T>>deserializeprivate final IntegeraggregationThresholdprivate final LongmaxWindowMsprivate final IntegerdispatchQueueCapacity
-
Method Summary
Modifier and Type Method Description final Function1<String, String>getExtractType()final Function1<String, Result<T>>getDeserialize()final IntegergetAggregationThreshold()final LonggetMaxWindowMs()final IntegergetDispatchQueueCapacity()-
-
Method Detail
-
getExtractType
final Function1<String, String> getExtractType()
-
getDeserialize
final Function1<String, Result<T>> getDeserialize()
-
getAggregationThreshold
final Integer getAggregationThreshold()
-
getMaxWindowMs
final Long getMaxWindowMs()
-
getDispatchQueueCapacity
final Integer getDispatchQueueCapacity()
-
-
-
-