Namespace Akka.Streams.Kinesis

Classes

KinesisFlow

A container for factory methods used to build Akka.NET Streams flows to an Amazon Kinesis streams. Flows can be used to send data to Kinesis streams. They handle acknowledgments, retries and rate limiting necessary to fit into AWS Kinesis constraints.

KinesisFlowSettings

Immutable settings class to be used by KinesisFlow factory methods.

KinesisSink

A container for factory methods used to build Akka.NET Streams sinks to an Amazon Kinesis streams. Sinks can be used to send data to Kinesis streams with no acknowledgements - if you need confirmations, use KinesisFlow methods. Sinks carry about retries and rate limiting necessary to fit into AWS Kinesis constraints.

KinesisSource

A container class for factory methods used to build Akka.NET Streams sources to an Amazon Kinesis streams. This provider is realized by periodically fetching the data, accordingly to settings specified inside ShardSettings configuration.

PublishingRecordsException

ShardSettings

Immutable settings class used to configure KinesisSource.

Enums

RetryBackoffStrategy

Type of a retry backoff used by KinesisFlow when pushing the request to Amazon Kinesis streams.