ReactoKinesix
ReactoKinesix Namespace
| Type | Description |
| 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. |
| IRecordProcessor | Represents a processor that is responsible for processing any records received from the stream. |
| IRecordProcessorFactory | Factory for record processor |
| ReactoKinesixApp |
ReactoKinesix.Model Namespace
| Type | Description |
| ErrorHandlingMode | Representing the different modes in which to handle errors when processing records |
| HandoverRequest | |
| OnBatchProcessedDelegate | |
| OnInitializedDelegate | |
| ProcessRecordsResult | Result of processing a batch of records |
| ReactoKinesixConfig | |
| Record | Represents a record received from the stream |
| Status |
| Module | Description |
| Exceptions |
ReactoKinesix.Utils Namespace
| Type | Description |
| Agent<'T> | Type alias for F# mailbox processor type |
