ReactoKinesixConfig

Constructors

Constructor	Description
`new()` Signature: unit -> ReactoKinesixConfig

Instance members

Instance member	Description
`CheckPendingHandoverRequestFrequency()` Signature: unit -> TimeSpan	How frequently should we check for pending handover requests for a shard. Default is 1 minute.
`CheckPendingHandoverRequestFrequency()` Signature: unit -> unit	How frequently should we check for pending handover requests for a shard. Default is 1 minute.
`CheckStreamChangesFrequency()` Signature: unit -> TimeSpan	How frequently should we check for shard merges/splits in the stream. Default is 1 minute.
`CheckStreamChangesFrequency()` Signature: unit -> unit	How frequently should we check for shard merges/splits in the stream. Default is 1 minute.
`CheckUnprocessedShardsFrequency()` Signature: unit -> TimeSpan	How frequently should we check for shards whose worker has died. Default is 1 minute.
`CheckUnprocessedShardsFrequency()` Signature: unit -> unit	How frequently should we check for shards whose worker has died. Default is 1 minute.
`DynamoDBReadThroughput()` Signature: unit -> int64	Read throughput to use for the DynamoDB table. Default is 10.
`DynamoDBReadThroughput()` Signature: unit -> unit	Read throughput to use for the DynamoDB table. Default is 10.
`DynamoDBTableSuffix` Signature: string	Suffix used to name your application's state table in DynamoDB. Default is "KinesisState" If the application name is "MyApp" and suffix is "KinesisState" then the DynamoDB table for this application will be called MyAppKinesisState.
`DynamoDBWriteThroughput()` Signature: unit -> int64	Write throughput to use for the DynamoDB table. Default is 10.
`DynamoDBWriteThroughput()` Signature: unit -> unit	Write throughput to use for the DynamoDB table. Default is 10.
`EmptyReceiveDelay()` Signature: unit -> TimeSpan	Delay in trying to pull the stream if the last pull returned no records. Default is 3 second.
`EmptyReceiveDelay()` Signature: unit -> unit	Delay in trying to pull the stream if the last pull returned no records. Default is 3 second.
`ErrorHandlingMode()` Signature: unit -> ErrorHandlingMode	How to handle errors? Default is to retry twice and then skip.
`ErrorHandlingMode()` Signature: unit -> unit	How to handle errors? Default is to retry twice and then skip.
`HandoverRequestExpiry()` Signature: unit -> TimeSpan	How much time to allow a handover request to complete. Default is 10 minutes.
`HandoverRequestExpiry()` Signature: unit -> unit	How much time to allow a handover request to complete. Default is 10 minutes.
`Heartbeat()` Signature: unit -> TimeSpan	Heartheat frequency. Default is 30 seconds.
`Heartbeat()` Signature: unit -> unit	Heartheat frequency. Default is 30 seconds.
`HeartbeatTimeout()` Signature: unit -> TimeSpan	Timeout for the heartbeat check. Default is 3 minutes.
`HeartbeatTimeout()` Signature: unit -> unit	Timeout for the heartbeat check. Default is 3 minutes.
`LoadBalanceFrequency()` Signature: unit -> TimeSpan	How frequently should we try to balance the load amongst the workers. Defaut is 3 minutes.
`LoadBalanceFrequency()` Signature: unit -> unit	How frequently should we try to balance the load amongst the workers. Defaut is 3 minutes.
`MaxBatchSize()` Signature: unit -> int	Max number of records in each batch. Default is 10000.
`MaxBatchSize()` Signature: unit -> unit	Max number of records in each batch. Default is 10000.
`MaxDynamoDBRetries()` Signature: unit -> int	Maximum number of retries on DynamoDB operations. Default is 3.
`MaxDynamoDBRetries()` Signature: unit -> unit	Maximum number of retries on DynamoDB operations. Default is 3.
`MaxKinesisRetries()` Signature: unit -> int	Maximum number of retries on Kinesis operations. Default is 3.
`MaxKinesisRetries()` Signature: unit -> unit	Maximum number of retries on Kinesis operations. Default is 3.