| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Nats.JetStream
Description
JetStream client construction and capabilities.
Stream, consumer, publish, and message-specific APIs are also available
from the corresponding Nats.JetStream.* modules.
Synopsis
- module JetStream.API
- newJetStream :: Client -> [JetStreamOption] -> Either JetStreamConfigError JetStream
- data JetStreamOption
- data JetStreamConfigError
- withDomain :: ByteString -> JetStreamOption
- withRequestTimeoutMicros :: Int -> JetStreamOption
Documentation
module JetStream.API
newJetStream :: Client -> [JetStreamOption] -> Either JetStreamConfigError JetStream Source #
Build JetStream capabilities from an existing NATS client.
data JetStreamOption #
data JetStreamConfigError #
Constructors
| EmptyJetStreamDomain | |
| InvalidJetStreamRequestTimeout Int |
Instances
| Show JetStreamConfigError | |
Defined in JetStream.Options Methods showsPrec :: Int -> JetStreamConfigError -> ShowS # show :: JetStreamConfigError -> String # showList :: [JetStreamConfigError] -> ShowS # | |
| Eq JetStreamConfigError | |
Defined in JetStream.Options Methods (==) :: JetStreamConfigError -> JetStreamConfigError -> Bool # (/=) :: JetStreamConfigError -> JetStreamConfigError -> Bool # | |
withDomain :: ByteString -> JetStreamOption #