Options
All
  • Public
  • Public/Protected
  • All
Menu

Class StorePoller

Hierarchy

Index

Constructors

constructor

Properties

Protected chronologicalGroup

chronologicalGroup: string = "default"

Protected debug

debug: IDebugger

eventStore

eventStore: EventStore

Protected Optional filterAggregateTypes

filterAggregateTypes: AggregateType[]

Protected initalSleepPeriod

initalSleepPeriod: number = 10

Initial number of milliseconds to wait before polling again, after store has no more commits to yield.

Protected initialPoll

initialPoll: boolean = true

Protected isPolling

isPolling: boolean = false

Protected maxSleepPeriod

maxSleepPeriod: number = 1000

Maximum number of milliseconds to wait before polling again, after store has no more commits to yield.

Protected sleepPeriodBackoffExponent

sleepPeriodBackoffExponent: number = 2

Exponent to use when increasing sleep period from initialSleepPeriod to maxSleepPeriod

sortKeyCursor

sortKeyCursor: string | Date

Protected stopRequested

stopRequested: boolean = false

Protected Optional upcasters

Accessors

Protected shouldPoll

  • get shouldPoll(): boolean

Methods

pollingLoop

  • pollingLoop(): Promise<void>

processCommit

  • processCommit(commit: Commit): Promise<void>

start

  • start(): void

stop

  • stop(): void

Generated using TypeDoc