Safe Haskell	None
Language	Haskell2010

JetStream.API.Message

Description

JetStream message consumption and acknowledgement contract.

Documentation

data Message #

Instances

Instances details

Show Message
Instance details Defined in JetStream.Message.Types Methods showsPrec :: Int -> Message -> ShowS # show :: Message -> String # showList :: [Message] -> ShowS #
Eq Message
Instance details Defined in JetStream.Message.Types Methods (==) :: Message -> Message -> Bool # (/=) :: Message -> Message -> Bool #

type Headers = [(ByteString, ByteString)] #

type FetchOption = CallOption PullRequest #

data OrderedConsumer #

data PullStatus #

Constructors

PullNoMessages (Maybe ByteString)
PullRequestTimeout (Maybe ByteString)
PullStatusError ByteString (Maybe ByteString)

Instances

Instances details

Show PullStatus
Instance details Defined in JetStream.Message.Types Methods showsPrec :: Int -> PullStatus -> ShowS # show :: PullStatus -> String # showList :: [PullStatus] -> ShowS #
Eq PullStatus
Instance details Defined in JetStream.Message.Types Methods (==) :: PullStatus -> PullStatus -> Bool # (/=) :: PullStatus -> PullStatus -> Bool #

messageMetadata :: Message -> Maybe MessageMetadata #

data MessageMetadata #

Instances

Instances details

Show MessageMetadata
Instance details Defined in JetStream.Message.Types Methods showsPrec :: Int -> MessageMetadata -> ShowS # show :: MessageMetadata -> String # showList :: [MessageMetadata] -> ShowS #
Eq MessageMetadata
Instance details Defined in JetStream.Message.Types Methods (==) :: MessageMetadata -> MessageMetadata -> Bool # (/=) :: MessageMetadata -> MessageMetadata -> Bool #

data FetchWait #

Constructors

FetchExpiresMicros Int
FetchNoWaitMicros Int

Instances

Instances details

Show FetchWait
Instance details Defined in JetStream.Message.Types Methods showsPrec :: Int -> FetchWait -> ShowS # show :: FetchWait -> String # showList :: [FetchWait] -> ShowS #
Eq FetchWait
Instance details Defined in JetStream.Message.Types Methods (==) :: FetchWait -> FetchWait -> Bool # (/=) :: FetchWait -> FetchWait -> Bool #

data MessageAPI #

data NakDelay #

Instances

Instances details

Show NakDelay
Instance details Defined in JetStream.Message.Types Methods showsPrec :: Int -> NakDelay -> ShowS # show :: NakDelay -> String # showList :: [NakDelay] -> ShowS #
Eq NakDelay
Instance details Defined in JetStream.Message.Types Methods (==) :: NakDelay -> NakDelay -> Bool # (/=) :: NakDelay -> NakDelay -> Bool #

type OrderedConsumerOption = CallOption OrderedConsumerConfig #

data PullEvent #

Constructors

PullMessage Message
PullStatusMessage PullStatus

Instances

Instances details

Show PullEvent
Instance details Defined in JetStream.Message.Types Methods showsPrec :: Int -> PullEvent -> ShowS # show :: PullEvent -> String # showList :: [PullEvent] -> ShowS #
Eq PullEvent
Instance details Defined in JetStream.Message.Types Methods (==) :: PullEvent -> PullEvent -> Bool # (/=) :: PullEvent -> PullEvent -> Bool #

data PullResponse #

Instances

Instances details

Show PullResponse
Instance details Defined in JetStream.Message.Types Methods showsPrec :: Int -> PullResponse -> ShowS # show :: PullResponse -> String # showList :: [PullResponse] -> ShowS #
Eq PullResponse
Instance details Defined in JetStream.Message.Types Methods (==) :: PullResponse -> PullResponse -> Bool # (/=) :: PullResponse -> PullResponse -> Bool #

data PullSubscription #

type PushConsumeOption = CallOption PushConsumeConfig #

data PushSubscription #

nakDelay :: NominalDiffTime -> Maybe NakDelay #

withFetchBatch :: Int -> FetchOption #

withFetchWait :: FetchWait -> FetchOption #

withOrderedConsumerDeliverPolicy :: DeliverPolicy -> OrderedConsumerOption #

withOrderedConsumerFilter :: ConsumerFilter -> OrderedConsumerOption #

withOrderedConsumerHeadersOnly :: Bool -> OrderedConsumerOption #

withOrderedConsumerInactiveThreshold :: NominalDiffTime -> OrderedConsumerOption #

withOrderedConsumerNamePrefix :: ConsumerName -> OrderedConsumerOption #

withOrderedConsumerReplayPolicy :: ReplayPolicy -> OrderedConsumerOption #

withPushQueueGroup :: Subject -> PushConsumeOption #