Creates a new KinesisBackgroundWriter
Allows up to concurrency payloads to be in progress before
write will block until a payload completes.
KinesisBackgroundWriter options
Optional concurrency?: numberNumber of payloads to accept for background writing before requiring the caller to wait for one to complete.
4
Required - Can be KinesisClient or KinesisRetrier
Private Readonly _errorsPrivate Readonly _kinesisPrivate Readonly _writertrue if .onIdle() has been called and finished all background writes
Accept a request for sending in the background if a concurrency slot is available. Else, do not return until a concurrency slot is freed up.
This provides concurrency background writes with back pressure to prevent the caller from getting too far ahead.
Individual PutRecordsCommand records that fail after retries are added to the errors property.
MUST await onIdle for background send's to finish
SHOULD periodically check errors for any individual record failures from send's
Private workerGenerated using TypeDoc
Accepts payloads for writing to Kinesis in the background, up to a limit