Options
All
  • Public
  • Public/Protected
  • All
Menu

Class InMemoryEventStore

Simple {EventStore} implementation that stores events in memory.

Hierarchy

  • InMemoryEventStore

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Private Readonly commandCache

commandCache: LRUMap<CacheKey, CommandIncoming>

Private Readonly commandSer

commandSer: RRD = new RRD(60 * 5, 12 * 3)

Private Readonly eventCache

eventCache: LRUMap<CacheKey, EventIncoming>

Private Readonly eventSer

eventSer: RRD = new RRD(60 * 5, 12 * 3)

Private Readonly messageCache

messageCache: LRUMap<CacheKey, any>

Methods

commandSeries

  • commandSeries(): [number[], number[]]

commands

  • commands(from?: number): any[]

eventSeries

  • eventSeries(): [number[], number[]]

events

  • events(from?: number): any[]

messages

  • messages(from?: number): any[]

recordCommand

recordEvent

recordMessage

  • recordMessage(id: string, correlationId: string, message: any): string

Generated using TypeDoc