Options
All
  • Public
  • Public/Protected
  • All
Menu

Used to execute Transformations using AWS Lambda workers.

const transformer = new LamdaTransformer(
  transformation,
  {
    workerCount: 4,
    readCapacityLimit: 100,
    writeCapacityLimit: 300,
  }
)

await transformer.execute()

Hierarchy

Index

Constructors

constructor

Properties

Private activeRequests

activeRequests: Set<Request<InvocationResponse, AWSError>> = new Set()

activeWorkers

activeWorkers: number = 0

Private Optional awsConfig

awsConfig: ConfigurationOptions

Private config

Optional countersUpdatedAt

countersUpdatedAt: undefined | number

Optional executionStartedTimestamp

executionStartedTimestamp: undefined | number

Protected Optional readCapacityLimit

readCapacityLimit: undefined | number

Protected runId

runId: string

Protected Optional setupTarget

setupTarget: undefined | true | false

sourceCommitCount

sourceCommitCount: number = 0

sourceStatus

sourceStatus: StoreState = StoreState.Unknown

state

state: State = State.Idle

Protected Optional stateFilePath

stateFilePath: undefined | string

targetCommitCount

targetCommitCount: number = 0

targetStatus

targetStatus: StoreState = StoreState.Unknown

Protected Optional terminationRequestedTimestamp

terminationRequestedTimestamp: undefined | number

transformation

transformation: Transformation

Private transformationPath

transformationPath: string

workerCount

workerCount: number

Protected workerStates

workerStates: any[]

workerTimeout

workerTimeout: number = 30000

Protected Optional writeCapacityLimit

writeCapacityLimit: undefined | number

Accessors

statusDescription

  • get statusDescription(): string

Methods

Protected bumpCounters

Protected deployFunction

  • deployFunction(): Promise<void>

execute

  • execute(): Promise<void>

setup

  • setup(): Promise<void>

terminate

  • terminate(options?: object): Promise<void>

Protected updateWorkerState

  • updateWorkerState(index: number, state: any): Promise<void>

Protected workerLoop

  • workerLoop(index: number): Promise<void>

writeStateFile

  • writeStateFile(path: string): Promise<void>

Object literals

counters

counters: object

commitsDeleted

commitsDeleted: number = 0

commitsRead

commitsRead: number = 0

commitsScanned

commitsScanned: number = 0

commitsWritten

commitsWritten: number = 0

throttledReads

throttledReads: number = 0

throttledWrites

throttledWrites: number = 0

workerInvocations

workerInvocations: number = 0

Generated using TypeDoc