IReactoKinesixApp
Represents a client application that consumes records from a Kinesis stream. Please use the static method "ReactoKinesixApp.CreateNew(...)" to create a new Kinesis client application.
Instance members
| Instance member | Description |
add_OnBatchProcessed(arg1)
Signature: OnBatchProcessedDelegate -> unit
Modifiers: abstract |
Fired when a batch of records have been successfully processed |
add_OnInitialized(arg1)
Signature: OnInitializedDelegate -> unit
Modifiers: abstract |
Fired when the application has been initialized |
ChangeProcessorFactory(newFactory)
Signature: newFactory:IRecordProcessorFactory -> unit
Modifiers: abstract |
Change the processor that will be used to process received records |
OnBatchProcessed
Signature: IEvent<OnBatchProcessedDelegate,EventArgs>
Modifiers: abstract |
Fired when a batch of records have been successfully processed |
OnInitialized
Signature: IEvent<OnInitializedDelegate,EventArgs>
Modifiers: abstract |
Fired when the application has been initialized |
remove_OnBatchProcessed(arg1)
Signature: OnBatchProcessedDelegate -> unit
Modifiers: abstract |
Fired when a batch of records have been successfully processed |
remove_OnInitialized(arg1)
Signature: OnInitializedDelegate -> unit
Modifiers: abstract |
Fired when the application has been initialized |
StartProcessing(shardId)
Signature: shardId:string -> Task
Modifiers: abstract |
Force the application to try and start processing a particular shard |
StopProcessing(shardId)
Signature: shardId:string -> Task
Modifiers: abstract |
Force the application to stop processing a particuar shard |
