Class LambdaDynamoStreamHandler

class: LambdaDynamoStreamHandler

default DynamoDBStream Handler w/ event-listeners.

Hierarchy

LambdaSubHandler<DynamoStreamHandler>
- LambdaDynamoStreamHandler

Index

Constructors

Properties

$lastResult handle lambda listeners type REPORT_ERROR

Methods

addListener createSyncToElastic6

Constructors

constructor

new LambdaDynamoStreamHandler(lambda: LambdaHandler, register?: boolean): LambdaDynamoStreamHandler
default constructor w/ registering self.
Parameters
- lambda: LambdaHandler
- Optional register: boolean
Returns LambdaDynamoStreamHandler
Overrides LambdaSubHandler.constructor
- Defined in src/cores/lambda/lambda-dynamo-stream-handler.ts:69

Properties

`Protected` $lastResult

$lastResult: any = null

handle

handle: DynamoStreamHandler = ...

Default Handler.

`Protected` lambda

lambda: LambdaHandler

`Protected` listeners

listeners: DynamoStreamNextHandler<any>[] = []

`Protected` type

type: string

`Static` REPORT_ERROR

REPORT_ERROR: boolean = LambdaHandler.REPORT_ERROR

Methods

addListener

addListener(handler: DynamoStreamNextHandler<any>): void
add listener of cron-event.
Parameters
- handler: DynamoStreamNextHandler<any>
Returns void
- Defined in src/cores/lambda/lambda-dynamo-stream-handler.ts:79

`Static` createSyncToElastic6

createSyncToElastic6<T>(options: DynamoOption, service: Elastic6Service<T>, filter?: DynamoStreamFilter<T>, onBeforeSync?: DynamoStreamCallback<T>, onAfterSync?: DynamoStreamCallback<T>): DynamoStreamNextHandler<any>
create synchronizer to elastic6 via dynamo-stream.
- procedure: (filter) -> (onBeforeSync) -> synchronization -> (onAfterSync)
Type Parameters
- T extends Elastic6Item
Parameters
- options: DynamoOption
  
  options of dynamo table.
- service: Elastic6Service<T>
  
  Elastic6Service instance
- Optional filter: DynamoStreamFilter<T>
  
  filter function
- Optional onBeforeSync: DynamoStreamCallback<T>
  
  callback function invoked before synchronization
- Optional onAfterSync: DynamoStreamCallback<T>
  
  callback function invoked after synchronization
Returns DynamoStreamNextHandler<any>
- Defined in src/cores/lambda/lambda-dynamo-stream-handler.ts:149

Generated using TypeDoc