| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
JetStream.Client
Description
High-level client implementation for JetStream.
Synopsis
- newJetStream :: Client -> [JetStreamOption] -> JetStream
- data JetStream = JetStream {}
- type JetStreamOption = JetStreamConfig -> JetStreamConfig
- withDomain :: ByteString -> JetStreamOption
- withRequestTimeoutMicros :: Int -> JetStreamOption
Documentation
newJetStream :: Client -> [JetStreamOption] -> JetStream Source #
Build a JetStream capability record from an existing NATS client.
JetStream capabilities for streams, consumers, publishing, and pull message workflows.
Constructors
| JetStream | |
Fields
| |
type JetStreamOption = JetStreamConfig -> JetStreamConfig #
withDomain :: ByteString -> JetStreamOption #