| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Nats.JetStream.Message
Description
JetStream message consumption and acknowledgement.
Documentation
type Headers = [(ByteString, ByteString)] #
Constructors
| FetchExpiresMicros Int | |
| FetchNoWaitMicros Int |
Instances
type FetchOption = CallOption PullRequest #
data MessageAPI #
data MessageMetadata #
Instances
| Show MessageMetadata | |
Defined in JetStream.Message.Types Methods showsPrec :: Int -> MessageMetadata -> ShowS # show :: MessageMetadata -> String # showList :: [MessageMetadata] -> ShowS # | |
| Eq MessageMetadata | |
Defined in JetStream.Message.Types Methods (==) :: MessageMetadata -> MessageMetadata -> Bool # (/=) :: MessageMetadata -> MessageMetadata -> Bool # | |
data OrderedConsumer #
type OrderedConsumerOption = CallOption OrderedConsumerConfig #
data PullStatus #
Constructors
| PullNoMessages (Maybe ByteString) | |
| PullRequestTimeout (Maybe ByteString) | |
| PullStatusError ByteString (Maybe ByteString) |
Instances
| Show PullStatus | |
Defined in JetStream.Message.Types Methods showsPrec :: Int -> PullStatus -> ShowS # show :: PullStatus -> String # showList :: [PullStatus] -> ShowS # | |
| Eq PullStatus | |
Defined in JetStream.Message.Types | |
data PullResponse #
Instances
| Show PullResponse | |
Defined in JetStream.Message.Types Methods showsPrec :: Int -> PullResponse -> ShowS # show :: PullResponse -> String # showList :: [PullResponse] -> ShowS # | |
| Eq PullResponse | |
Defined in JetStream.Message.Types | |
type PushConsumeOption = CallOption PushConsumeConfig #
data PushSubscription #
withFetchBatch :: Int -> FetchOption #
withFetchWait :: FetchWait -> FetchOption #