Options
All
  • Public
  • Public/Protected
  • All
Menu

Class AwsEventStoreBatchMutator

Hierarchy

Index

Constructors

constructor

Properties

Protected bufferSize

bufferSize: number = 100

Protected Optional capacityLimit

capacityLimit: undefined | number

deleteCount

deleteCount: number = 0

Protected maxItemsPerRequest

maxItemsPerRequest: number = 25

Protected processQueueRunning

processQueueRunning: boolean = false

Protected queue

queue: Set<AwsEventStoreBatchMutatorQueueItem> = new Set()

Protected Optional remainingCapacity

remainingCapacity: undefined | object

Protected store

throttleCount

throttleCount: number = 0

writeCount

writeCount: number = 0

Accessors

drained

  • get drained(): Promise<undefined>

itemsBeingProcessed

  • get itemsBeingProcessed(): AwsEventStoreBatchMutatorQueueItem[]

pendingItems

  • get pendingItems(): AwsEventStoreBatchMutatorQueueItem[]

saturated

  • get saturated(): boolean

Methods

Private addToQueue

  • addToQueue(item: object, capacityUnits: number): Promise<any>

Protected asIterable

Private capacityUnitsForItem

delete

Private processQueue

  • processQueue(): Promise<void>

put

Private sendRequest

  • sendRequest(queueItemsToSend: AwsEventStoreBatchMutatorQueueItem[]): void

Generated using TypeDoc