package firehose
- Source
- firehose.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- firehose
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- trait Firehose[F[_]] extends AnyRef
- final class FirehoseOps[F[_]] extends AnyVal
- trait FirehoseOpsSyntax extends AnyRef
- trait ProducerSettings[F[_]] extends AnyRef
- final class RecordOps[T] extends AnyVal
- trait RecordOpsSyntax extends AnyRef
- trait Serializer[A] extends AnyRef
Value Members
- def produce[F[_], T](settings: ProducerSettings[F])(client: Firehose[F])(implicit arg0: Concurrent[F], arg1: Temporal[F], arg2: Serializer[T]): Pipe[F, T, PutRecordBatchResult]
- object ErrorUtils
- object Firehose
- object JavaConversions extends AsJavaExtensions with AsScalaExtensions
- object ProducerSettings
- object Serializer
- object implicits extends FirehoseOpsSyntax with RecordOpsSyntax
Amazon Kinesis Data Firehose bindings for fs2
Links: