runtime/me.ahoo.wow.runtime.store/StoreLayout

StoreLayout

class StoreLayout(val log: String, val snapshot: String = log, logs: Map<AggregateType, String> = emptyMap(), snapshots: Map<AggregateType, String> = emptyMap(), placements: Map<AggregateType, SnapshotPlacement> = snapshots.mapValues { SnapshotPlacement(listOf(it.value)) }, val snapshotDefault: SnapshotPlacement = SnapshotPlacement(listOf(snapshot)))

Where each aggregate's log and snapshots are: its log on the store log names (wow.log.store) unless the logs map names another for its type (wow.aggregates.[<context>.<aggregate>].log.store); its snapshots on the stores of its placement (.snapshot.stores, .snapshot.primary), else of snapshotDefault (wow.snapshot.stores, wow.snapshot.primary, the snapshot store alone by default). The snapshot store (the first of wow.snapshot.stores) is each context's default one, whose subscription is wow.snapshot.

Constructors

StoreLayout

constructor(log: String, snapshot: String = log, logs: Map<AggregateType, String> = emptyMap(), snapshots: Map<AggregateType, String> = emptyMap(), placements: Map<AggregateType, SnapshotPlacement> = snapshots.mapValues { SnapshotPlacement(listOf(it.value)) }, snapshotDefault: SnapshotPlacement = SnapshotPlacement(listOf(snapshot)))

Types

Companion

@InternalWowApi

object Companion

Properties

log

val log: String

logStores

val logStores: Set<String>

The stores some log is on.

snapshot

val snapshot: String

snapshotDefault

val snapshotDefault: SnapshotPlacement

snapshotStores

val snapshotStores: Set<String>

The stores some snapshots are on.

Functions

logStoreOf

fun logStoreOf(type: AggregateType): String

The store of type's log: its log group.

open

fun open(context: String, stores: Map<String, Store>, partitions: Int): ContextBackends

The stores of context among stores, each opened as this layout says: its default log group on log, with the checkpoints, leases, failure ledger, reservations and timers of that store; a log group per other store its aggregates' logs are on, with that store's reservations and timers; its snapshot targets, each type's as its placement says.

snapshotPlacementOf

fun snapshotPlacementOf(type: AggregateType): SnapshotPlacement

Where type's snapshots are written.

snapshotStoreOf

fun snapshotStoreOf(type: AggregateType): String

The store of type's snapshots its snapshot queries read: its primary target.