spring-boot/me.ahoo.wow.spring.boot/EventQueryBackend

EventQueryBackend

class EventQueryBackend(store: (AggregateType) -> String? = { null }, prepare: (AggregateType) -> Unit = {}, indexes: (AggregateType, QueryIndexPlan) -> QueryIndexReport? = null, manages: (AggregateType) -> Boolean = { true }, val bindings: QueryBindings<AggregateType>)

The events query backend of the node: the bindings of each aggregate type's events backend and storage facts, none for a type no backend serves (its events are then not queried), and the store its queries run on, null for the application's own backend. For a store whose events queries manage indexes (me.ahoo.wow.query.store.EventQueries), how it prepares a type's log and manages the indexes of its access attributes at startup. It is not itself QueryBindings, so that it is never taken for the application's snapshot bindings bean.

Constructors

EventQueryBackend

constructor(store: (AggregateType) -> String? = { null }, prepare: (AggregateType) -> Unit = {}, indexes: (AggregateType, QueryIndexPlan) -> QueryIndexReport? = null, manages: (AggregateType) -> Boolean = { true }, bindings: QueryBindings<AggregateType>)

Types

Companion

@InternalWowApi

object Companion

Properties

bindings

val bindings: QueryBindings<AggregateType>

managesIndexes

val managesIndexes: Boolean

Whether the host manages this backend's indexes; an application's own backend manages its own.

Functions

binding

fun binding(type: AggregateType): QueryBackendBinding<QueryBackend>?

The binding of type's events backend, or null when none serves them.

manageIndexes

fun manageIndexes(type: AggregateType, plan: QueryIndexPlan): QueryIndexReport

Manages plan, the indexes of type's access attributes on its events model, as its store's ddl says.

managesIndexes

fun managesIndexes(type: AggregateType): Boolean

Whether the host manages the indexes of type's log: its events queries run on a store that manages them, not an index a Sink writes (Elasticsearch's), whose mapping indexes the attributes itself.

prepare

fun prepare(type: AggregateType)

Makes sure type's log exists, so an index has a table or a collection to be on.

storeOf

fun storeOf(type: AggregateType): String?

The store type's events queries run on, or null when the host does not know it.