Options
All
  • Public
  • Public/Protected
  • All
Menu

Class AwsEventStore

Interface for EventStore powered by AWS DynamoDB

Hierarchy

Index

Constructors

constructor

Properties

Optional autoscaling

autoscaling: AutoscalingConfig

Optional awsConfig

awsConfig: ConfigurationOptions

dynamodb

dynamodb: DynamoDB

Optional dynamodbClientConfiguration

dynamodbClientConfiguration: DynamoDB.ClientConfiguration

tableName

tableName: string

Accessors

Protected tableSpecification

  • get tableSpecification(): object
  • Returns object

    • AttributeDefinitions: object[]
    • GlobalSecondaryIndexes: (object | object)[]
    • KeySchema: object[]
    • TableName: string
    • ProvisionedThroughput: object
      • ReadCapacityUnits: number
      • WriteCapacityUnits: number

Methods

bestEffortCount

  • bestEffortCount(): Promise<number>

chronologicalQuery

  • Retrieve commits from the store chronologically

    Parameters

    • params: object
      • Optional descending?: undefined | true | false
      • Optional exclusiveMax?: undefined | true | false
      • Optional exclusiveMin?: undefined | true | false
      • Optional filterAggregateTypes?: AggregateType[]
      • Optional group?: undefined | string
      • Optional limit?: undefined | number
      • Optional max?: string | Date
      • min: string | Date
      • Optional timeDriftCompensation?: undefined | number

    Returns AwsEventStoreQueryResponse

commit

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

createBatchMutator

getAggregateHeadCommit

getHeadCommit

  • getHeadCommit(chronologicalGroup?: undefined | string, startDate?: Date): Promise<null | Commit>

queryAggregateCommits

Protected request

  • request(type: "scan" | "query", params?: StoreQueryParams & object | object): AsyncIterableIterator<QueryOutput & object>

scan

scanAggregateInstances

setup

  • setup(): Promise<void>

teardown

  • teardown(): Promise<void>

toString

  • toString(): string

Object literals

initialCapacity

initialCapacity: object

chronologicalRead

chronologicalRead: number = 2

chronologicalWrite

chronologicalWrite: number = 2

instancesRead

instancesRead: number = 1

instancesWrite

instancesWrite: number = 1

tableRead

tableRead: number = 2

tableWrite

tableWrite: number = 2

Generated using TypeDoc