PersistedDecisionProvider | es-objects

A DecisionProvider that persists the latest DecisionSequence in a storage everytime an event happens.

Type parameters

T

Hierarchy

PersistedDecisionProvider

Implements

DecisionProvider<T>
Rebuildable

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new PersistedDecisionProvider(aggregate: string, reducer: Reducer<T>, storage: KeyValueStorage<DecisionSequence<T>>): PersistedDecisionProvider

- Defined in decision-provider/persisted-decision-provider.ts:12
Parameters
- aggregate: string
  
  the aggregate name
- reducer: Reducer<T>
  
  the decision reducer
- storage: KeyValueStorage<DecisionSequence<T>>
  
  where to persist our decision projections
Returns PersistedDecisionProvider

Properties

Private decisionProjection

decisionProjection: PersistedEntityReduceProjection<DecisionSequence<T>>

Private reducerWithSequence

reducerWithSequence: Reducer<DecisionSequence<T>>

Private storage

storage: KeyValueStorage<DecisionSequence<T>>

where to persist our decision projections

Methods

getDecisionSequence

getDecisionSequence(id: string): Promise<DecisionSequence<T>>

- Defined in decision-provider/persisted-decision-provider.ts:33
Get the latest DecisionSequence for an entity.

Parameters
- id: string
  
  the entity's id
Returns Promise<DecisionSequence<T>>

handleEvent

handleEvent(event: Event, decision: DecisionSequence<T>): Promise<void>

- Defined in decision-provider/persisted-decision-provider.ts:43
Update the persisted decision.

Parameters
- event: Event
  
  the event that triggered the decision change
- decision: DecisionSequence<T>
  
  the new decision to store
Returns Promise<void>

rebuildStream

rebuildStream(): Writable

- Defined in decision-provider/persisted-decision-provider.ts:50
Gets the Writable stream that rebuilds the persisted decision from a stream of {@link Events}.

Returns Writable

Generated using TypeDoc