| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
JetStream.API.Publish
Description
JetStream publishing contract.
Documentation
type PublishOption = PublishConfig -> PublishConfig #
data PublishAPI #
withHeaders :: [(ByteString, ByteString)] -> PublishOption #
data PublishExpectation #
Constructors
| ExpectedLastSequence Word64 | |
| ExpectedLastSubjectSequence Word64 | |
| ExpectedLastMsgId ByteString |
Instances
| Show PublishExpectation | |
Defined in JetStream.Publish.Types Methods showsPrec :: Int -> PublishExpectation -> ShowS # show :: PublishExpectation -> String # showList :: [PublishExpectation] -> ShowS # | |
| Eq PublishExpectation | |
Defined in JetStream.Publish.Types Methods (==) :: PublishExpectation -> PublishExpectation -> Bool # (/=) :: PublishExpectation -> PublishExpectation -> Bool # | |
data PublishAck #
Instances
| FromJSON PublishAck | |
Defined in JetStream.Publish.Types | |
| Show PublishAck | |
Defined in JetStream.Publish.Types Methods showsPrec :: Int -> PublishAck -> ShowS # show :: PublishAck -> String # showList :: [PublishAck] -> ShowS # | |
| Eq PublishAck | |
Defined in JetStream.Publish.Types | |
withExpectedStream :: StreamName -> PublishOption #
withMsgId :: ByteString -> PublishOption #