Options
All
  • Public
  • Public/Protected
  • All
Menu

For transformations operating on the Commit level. Is most useful when used in conjunction with a Transformer.

export default new CommitTransformation({
  name: 'Do something',

  source: new AwsEventStore({tableName: 'tableA'}),
  target: new AwsEventStore({tableName: 'tableB'}),

  async transform(commit: Commit) {
    // return the output commits of this commit transformation
    return [commit]
  },
})

Hierarchy

Index

Constructors

constructor

Properties

Optional aggregateTypes

aggregateTypes: AggregateType[]

Protected hardInternalDeadline

hardInternalDeadline: number

Optional marshalled

marshalled: undefined | true | false

Optional marshalledKeyProps

marshalledKeyProps: [string, string]

name

name: string

Protected softInternalDeadline

softInternalDeadline: number

source

source: EventStore

target

target: EventStore

transform

transform: function

Type declaration

Optional transformerConfig

transformerConfig: any

Accessors

isInPlaceTransformation

  • get isInPlaceTransformation(): boolean

Methods

perform

Generated using TypeDoc