Safe Haskell	None
Language	Haskell2010

JetStream.API

Description

Capability record for the JetStream client surface.

Documentation

data JetStream #

streams :: JetStream -> StreamAPI #

consumers :: JetStream -> ConsumerAPI #

publisher :: JetStream -> PublishAPI #

messages :: JetStream -> MessageAPI #

accountInfo :: JetStream -> [JetStreamRequestOption] -> IO (Either JetStreamError AccountInfo) #

data JetStreamRequestOption #

withRequestTimeout :: NominalDiffTime -> JetStreamRequestOption #

data Sequence #

Instances

Instances details

FromJSON Sequence
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser Sequence # parseJSONList :: Value -> Parser [Sequence] # omittedField :: Maybe Sequence #
ToJSON Sequence
Instance details Defined in JetStream.Types Methods toJSON :: Sequence -> Value # toEncoding :: Sequence -> Encoding # toJSONList :: [Sequence] -> Value # toEncodingList :: [Sequence] -> Encoding # omitField :: Sequence -> Bool #
Bounded Sequence
Instance details Defined in JetStream.Types Methods minBound :: Sequence # maxBound :: Sequence #
Enum Sequence
Instance details Defined in JetStream.Types Methods succ :: Sequence -> Sequence # pred :: Sequence -> Sequence # toEnum :: Int -> Sequence # fromEnum :: Sequence -> Int # enumFrom :: Sequence -> [Sequence] # enumFromThen :: Sequence -> Sequence -> [Sequence] # enumFromTo :: Sequence -> Sequence -> [Sequence] # enumFromThenTo :: Sequence -> Sequence -> Sequence -> [Sequence] #
Num Sequence
Instance details Defined in JetStream.Types Methods (+) :: Sequence -> Sequence -> Sequence # (-) :: Sequence -> Sequence -> Sequence # (*) :: Sequence -> Sequence -> Sequence # negate :: Sequence -> Sequence # abs :: Sequence -> Sequence # signum :: Sequence -> Sequence # fromInteger :: Integer -> Sequence #
Integral Sequence
Instance details Defined in JetStream.Types Methods quot :: Sequence -> Sequence -> Sequence # rem :: Sequence -> Sequence -> Sequence # div :: Sequence -> Sequence -> Sequence # mod :: Sequence -> Sequence -> Sequence # quotRem :: Sequence -> Sequence -> (Sequence, Sequence) # divMod :: Sequence -> Sequence -> (Sequence, Sequence) # toInteger :: Sequence -> Integer #
Real Sequence
Instance details Defined in JetStream.Types Methods toRational :: Sequence -> Rational #
Show Sequence
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> Sequence -> ShowS # show :: Sequence -> String # showList :: [Sequence] -> ShowS #
Eq Sequence
Instance details Defined in JetStream.Types Methods (==) :: Sequence -> Sequence -> Bool # (/=) :: Sequence -> Sequence -> Bool #
Ord Sequence
Instance details Defined in JetStream.Types Methods compare :: Sequence -> Sequence -> Ordering # (<) :: Sequence -> Sequence -> Bool # (<=) :: Sequence -> Sequence -> Bool # (>) :: Sequence -> Sequence -> Bool # (>=) :: Sequence -> Sequence -> Bool # max :: Sequence -> Sequence -> Sequence # min :: Sequence -> Sequence -> Sequence #

sequenceFromWord64 :: Word64 -> Sequence #

sequenceToWord64 :: Sequence -> Word64 #

data AccountAPIStats #

Instances

Instances details

FromJSON AccountAPIStats
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser AccountAPIStats # parseJSONList :: Value -> Parser [AccountAPIStats] # omittedField :: Maybe AccountAPIStats #
ToJSON AccountAPIStats
Instance details Defined in JetStream.Types Methods toJSON :: AccountAPIStats -> Value # toEncoding :: AccountAPIStats -> Encoding # toJSONList :: [AccountAPIStats] -> Value # toEncodingList :: [AccountAPIStats] -> Encoding # omitField :: AccountAPIStats -> Bool #
Show AccountAPIStats
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> AccountAPIStats -> ShowS # show :: AccountAPIStats -> String # showList :: [AccountAPIStats] -> ShowS #
Eq AccountAPIStats
Instance details Defined in JetStream.Types Methods (==) :: AccountAPIStats -> AccountAPIStats -> Bool # (/=) :: AccountAPIStats -> AccountAPIStats -> Bool #

accountAPILevel :: AccountAPIStats -> Int #

accountAPITotal :: AccountAPIStats -> Integer #

accountAPIErrors :: AccountAPIStats -> Integer #

accountAPIInflight :: AccountAPIStats -> Maybe Integer #

data AccountInfo #

Instances

Instances details

FromJSON AccountInfo
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser AccountInfo # parseJSONList :: Value -> Parser [AccountInfo] # omittedField :: Maybe AccountInfo #
ToJSON AccountInfo
Instance details Defined in JetStream.Types Methods toJSON :: AccountInfo -> Value # toEncoding :: AccountInfo -> Encoding # toJSONList :: [AccountInfo] -> Value # toEncodingList :: [AccountInfo] -> Encoding # omitField :: AccountInfo -> Bool #
Show AccountInfo
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> AccountInfo -> ShowS # show :: AccountInfo -> String # showList :: [AccountInfo] -> ShowS #
Eq AccountInfo
Instance details Defined in JetStream.Types Methods (==) :: AccountInfo -> AccountInfo -> Bool # (/=) :: AccountInfo -> AccountInfo -> Bool #

accountInfoTier :: AccountInfo -> AccountTier #

accountInfoDomain :: AccountInfo -> Maybe ByteString #

accountInfoAPI :: AccountInfo -> AccountAPIStats #

accountInfoTiers :: AccountInfo -> [(ByteString, AccountTier)] #

data AccountLimits #

Instances

Instances details

FromJSON AccountLimits
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser AccountLimits # parseJSONList :: Value -> Parser [AccountLimits] # omittedField :: Maybe AccountLimits #
ToJSON AccountLimits
Instance details Defined in JetStream.Types Methods toJSON :: AccountLimits -> Value # toEncoding :: AccountLimits -> Encoding # toJSONList :: [AccountLimits] -> Value # toEncodingList :: [AccountLimits] -> Encoding # omitField :: AccountLimits -> Bool #
Show AccountLimits
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> AccountLimits -> ShowS # show :: AccountLimits -> String # showList :: [AccountLimits] -> ShowS #
Eq AccountLimits
Instance details Defined in JetStream.Types Methods (==) :: AccountLimits -> AccountLimits -> Bool # (/=) :: AccountLimits -> AccountLimits -> Bool #

accountLimitsMaxMemory :: AccountLimits -> Integer #

accountLimitsMaxStorage :: AccountLimits -> Integer #

accountLimitsMaxStreams :: AccountLimits -> Int #

accountLimitsMaxConsumers :: AccountLimits -> Int #

accountLimitsMaxAckPending :: AccountLimits -> Int #

accountLimitsMemoryMaxStreamBytes :: AccountLimits -> Integer #

accountLimitsStorageMaxStreamBytes :: AccountLimits -> Integer #

accountLimitsMaxBytesRequired :: AccountLimits -> Bool #

data AccountTier #

Instances

Instances details

FromJSON AccountTier
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser AccountTier # parseJSONList :: Value -> Parser [AccountTier] # omittedField :: Maybe AccountTier #
ToJSON AccountTier
Instance details Defined in JetStream.Types Methods toJSON :: AccountTier -> Value # toEncoding :: AccountTier -> Encoding # toJSONList :: [AccountTier] -> Value # toEncodingList :: [AccountTier] -> Encoding # omitField :: AccountTier -> Bool #
Show AccountTier
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> AccountTier -> ShowS # show :: AccountTier -> String # showList :: [AccountTier] -> ShowS #
Eq AccountTier
Instance details Defined in JetStream.Types Methods (==) :: AccountTier -> AccountTier -> Bool # (/=) :: AccountTier -> AccountTier -> Bool #

accountTierMemory :: AccountTier -> Integer #

accountTierStorage :: AccountTier -> Integer #

accountTierReservedMemory :: AccountTier -> Integer #

accountTierReservedStorage :: AccountTier -> Integer #

accountTierStreams :: AccountTier -> Int #

accountTierConsumers :: AccountTier -> Int #

accountTierLimits :: AccountTier -> AccountLimits #

data JetStreamApiError #

Instances

Instances details

FromJSON JetStreamApiError
Instance details Defined in JetStream.Error Methods parseJSON :: Value -> Parser JetStreamApiError # parseJSONList :: Value -> Parser [JetStreamApiError] # omittedField :: Maybe JetStreamApiError #
ToJSON JetStreamApiError
Instance details Defined in JetStream.Error Methods toJSON :: JetStreamApiError -> Value # toEncoding :: JetStreamApiError -> Encoding # toJSONList :: [JetStreamApiError] -> Value # toEncodingList :: [JetStreamApiError] -> Encoding # omitField :: JetStreamApiError -> Bool #
Show JetStreamApiError
Instance details Defined in JetStream.Error Methods showsPrec :: Int -> JetStreamApiError -> ShowS # show :: JetStreamApiError -> String # showList :: [JetStreamApiError] -> ShowS #
Eq JetStreamApiError
Instance details Defined in JetStream.Error Methods (==) :: JetStreamApiError -> JetStreamApiError -> Bool # (/=) :: JetStreamApiError -> JetStreamApiError -> Bool #

apiErrorCode :: JetStreamApiError -> Int #

apiErrorCodeDetail :: JetStreamApiError -> Int #

apiErrorDescription :: JetStreamApiError -> ByteString #

data JetStreamError #

Constructors

JetStreamApiFailure JetStreamApiError
JetStreamStatusError Int (Maybe ByteString)
JetStreamDecodeError String
JetStreamTimeout
JetStreamNoReply
JetStreamNatsError NatsError

Instances

Instances details

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

type StreamName = ByteString #

type ConsumerName = ByteString #

type Subject = ByteString #

type Payload = ByteString #

data Consumer #

Instances

Instances details

Show Consumer
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> Consumer -> ShowS # show :: Consumer -> String # showList :: [Consumer] -> ShowS #
Eq Consumer
Instance details Defined in JetStream.Consumer.Types Methods (==) :: Consumer -> Consumer -> Bool # (/=) :: Consumer -> Consumer -> Bool #
Ord Consumer
Instance details Defined in JetStream.Consumer.Types Methods compare :: Consumer -> Consumer -> Ordering # (<) :: Consumer -> Consumer -> Bool # (<=) :: Consumer -> Consumer -> Bool # (>) :: Consumer -> Consumer -> Bool # (>=) :: Consumer -> Consumer -> Bool # max :: Consumer -> Consumer -> Consumer # min :: Consumer -> Consumer -> Consumer #

data ConsumerAPI #

data ConsumerAction #

Constructors

ConsumerCreate
ConsumerCreateOrUpdate
ConsumerUpdate

Instances

Instances details

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

data ConsumerConfig #

Instances

Instances details

FromJSON ConsumerConfig
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser ConsumerConfig # parseJSONList :: Value -> Parser [ConsumerConfig] # omittedField :: Maybe ConsumerConfig #
ToJSON ConsumerConfig
Instance details Defined in JetStream.Consumer.Types Methods toJSON :: ConsumerConfig -> Value # toEncoding :: ConsumerConfig -> Encoding # toJSONList :: [ConsumerConfig] -> Value # toEncodingList :: [ConsumerConfig] -> Encoding # omitField :: ConsumerConfig -> Bool #
Show ConsumerConfig
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> ConsumerConfig -> ShowS # show :: ConsumerConfig -> String # showList :: [ConsumerConfig] -> ShowS #
Eq ConsumerConfig
Instance details Defined in JetStream.Consumer.Types Methods (==) :: ConsumerConfig -> ConsumerConfig -> Bool # (/=) :: ConsumerConfig -> ConsumerConfig -> Bool #

type ConsumerConfigOption = CallOption ConsumerConfigRequest #

data ConsumerFilter #

Constructors

ConsumerFilterSubject Subject
ConsumerFilterSubjects [Subject]

Instances

Instances details

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

data ConsumerInfo #

Instances

Instances details

FromJSON ConsumerInfo
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser ConsumerInfo # parseJSONList :: Value -> Parser [ConsumerInfo] # omittedField :: Maybe ConsumerInfo #
ToJSON ConsumerInfo
Instance details Defined in JetStream.Consumer.Types Methods toJSON :: ConsumerInfo -> Value # toEncoding :: ConsumerInfo -> Encoding # toJSONList :: [ConsumerInfo] -> Value # toEncodingList :: [ConsumerInfo] -> Encoding # omitField :: ConsumerInfo -> Bool #
Show ConsumerInfo
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> ConsumerInfo -> ShowS # show :: ConsumerInfo -> String # showList :: [ConsumerInfo] -> ShowS #
Eq ConsumerInfo
Instance details Defined in JetStream.Consumer.Types Methods (==) :: ConsumerInfo -> ConsumerInfo -> Bool # (/=) :: ConsumerInfo -> ConsumerInfo -> Bool #

data ConsumerKind #

Constructors

PullConsumer
PushConsumer Subject

Instances

Instances details

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

type ConsumerListOption = CallOption ConsumerListRequest #

data ConsumerListResponse #

Instances

Instances details

FromJSON ConsumerListResponse
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser ConsumerListResponse # parseJSONList :: Value -> Parser [ConsumerListResponse] # omittedField :: Maybe ConsumerListResponse #
Show ConsumerListResponse
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> ConsumerListResponse -> ShowS # show :: ConsumerListResponse -> String # showList :: [ConsumerListResponse] -> ShowS #
Eq ConsumerListResponse
Instance details Defined in JetStream.Consumer.Types Methods (==) :: ConsumerListResponse -> ConsumerListResponse -> Bool # (/=) :: ConsumerListResponse -> ConsumerListResponse -> Bool #

data ConsumerNamesResponse #

Instances

Instances details

FromJSON ConsumerNamesResponse
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser ConsumerNamesResponse # parseJSONList :: Value -> Parser [ConsumerNamesResponse] # omittedField :: Maybe ConsumerNamesResponse #
Show ConsumerNamesResponse
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> ConsumerNamesResponse -> ShowS # show :: ConsumerNamesResponse -> String # showList :: [ConsumerNamesResponse] -> ShowS #
Eq ConsumerNamesResponse
Instance details Defined in JetStream.Consumer.Types Methods (==) :: ConsumerNamesResponse -> ConsumerNamesResponse -> Bool # (/=) :: ConsumerNamesResponse -> ConsumerNamesResponse -> Bool #

data ConsumerPauseResponse #

Instances

Instances details

FromJSON ConsumerPauseResponse
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser ConsumerPauseResponse # parseJSONList :: Value -> Parser [ConsumerPauseResponse] # omittedField :: Maybe ConsumerPauseResponse #
Show ConsumerPauseResponse
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> ConsumerPauseResponse -> ShowS # show :: ConsumerPauseResponse -> String # showList :: [ConsumerPauseResponse] -> ShowS #
Eq ConsumerPauseResponse
Instance details Defined in JetStream.Consumer.Types Methods (==) :: ConsumerPauseResponse -> ConsumerPauseResponse -> Bool # (/=) :: ConsumerPauseResponse -> ConsumerPauseResponse -> Bool #

type ConsumerResetOption = CallOption ConsumerResetRequest #

data ConsumerResetResponse #

Instances

Instances details

FromJSON ConsumerResetResponse
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser ConsumerResetResponse # parseJSONList :: Value -> Parser [ConsumerResetResponse] # omittedField :: Maybe ConsumerResetResponse #
Show ConsumerResetResponse
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> ConsumerResetResponse -> ShowS # show :: ConsumerResetResponse -> String # showList :: [ConsumerResetResponse] -> ShowS #
Eq ConsumerResetResponse
Instance details Defined in JetStream.Consumer.Types Methods (==) :: ConsumerResetResponse -> ConsumerResetResponse -> Bool # (/=) :: ConsumerResetResponse -> ConsumerResetResponse -> Bool #

data ConsumerSequenceInfo #

Instances

Instances details

FromJSON ConsumerSequenceInfo
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser ConsumerSequenceInfo # parseJSONList :: Value -> Parser [ConsumerSequenceInfo] # omittedField :: Maybe ConsumerSequenceInfo #
ToJSON ConsumerSequenceInfo
Instance details Defined in JetStream.Consumer.Types Methods toJSON :: ConsumerSequenceInfo -> Value # toEncoding :: ConsumerSequenceInfo -> Encoding # toJSONList :: [ConsumerSequenceInfo] -> Value # toEncodingList :: [ConsumerSequenceInfo] -> Encoding # omitField :: ConsumerSequenceInfo -> Bool #
Show ConsumerSequenceInfo
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> ConsumerSequenceInfo -> ShowS # show :: ConsumerSequenceInfo -> String # showList :: [ConsumerSequenceInfo] -> ShowS #
Eq ConsumerSequenceInfo
Instance details Defined in JetStream.Consumer.Types Methods (==) :: ConsumerSequenceInfo -> ConsumerSequenceInfo -> Bool # (/=) :: ConsumerSequenceInfo -> ConsumerSequenceInfo -> Bool #

data ConsumerTarget #

Constructors

EphemeralConsumer
NamedConsumer ConsumerName
DurableConsumer ConsumerName

Instances

Instances details

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

data DeleteConsumerResponse #

Instances

Instances details

FromJSON DeleteConsumerResponse
Instance details Defined in JetStream.Consumer.Types Methods parseJSON :: Value -> Parser DeleteConsumerResponse # parseJSONList :: Value -> Parser [DeleteConsumerResponse] # omittedField :: Maybe DeleteConsumerResponse #
Show DeleteConsumerResponse
Instance details Defined in JetStream.Consumer.Types Methods showsPrec :: Int -> DeleteConsumerResponse -> ShowS # show :: DeleteConsumerResponse -> String # showList :: [DeleteConsumerResponse] -> ShowS #
Eq DeleteConsumerResponse
Instance details Defined in JetStream.Consumer.Types Methods (==) :: DeleteConsumerResponse -> DeleteConsumerResponse -> Bool # (/=) :: DeleteConsumerResponse -> DeleteConsumerResponse -> Bool #

withConsumerAckPolicy :: AckPolicy -> ConsumerConfigOption #

withConsumerAckWait :: NominalDiffTime -> ConsumerConfigOption #

withConsumerDeliverGroup :: Subject -> ConsumerConfigOption #

withConsumerDeliverPolicy :: DeliverPolicy -> ConsumerConfigOption #

withConsumerDescription :: ByteString -> ConsumerConfigOption #

withConsumerFilter :: ConsumerFilter -> ConsumerConfigOption #

withConsumerHeadersOnly :: Bool -> ConsumerConfigOption #

withConsumerIdleHeartbeat :: NominalDiffTime -> ConsumerConfigOption #

withConsumerInactiveThreshold :: NominalDiffTime -> ConsumerConfigOption #

withConsumerListOffset :: Int -> ConsumerListOption #

withConsumerMaxAckPending :: Int -> ConsumerConfigOption #

withConsumerMaxDeliver :: Int -> ConsumerConfigOption #

withConsumerMaxWaiting :: Int -> ConsumerConfigOption #

withConsumerMemoryStorage :: Bool -> ConsumerConfigOption #

withConsumerReplayPolicy :: ReplayPolicy -> ConsumerConfigOption #

withConsumerReplicas :: Int -> ConsumerConfigOption #

withConsumerResetSequence :: Sequence -> ConsumerResetOption #

data AckPolicy #

Constructors

AckNone
AckAll
AckExplicit
AckPolicyUnknown Text

Instances

Instances details

FromJSON AckPolicy
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser AckPolicy # parseJSONList :: Value -> Parser [AckPolicy] # omittedField :: Maybe AckPolicy #
ToJSON AckPolicy
Instance details Defined in JetStream.Types Methods toJSON :: AckPolicy -> Value # toEncoding :: AckPolicy -> Encoding # toJSONList :: [AckPolicy] -> Value # toEncodingList :: [AckPolicy] -> Encoding # omitField :: AckPolicy -> Bool #
Show AckPolicy
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> AckPolicy -> ShowS # show :: AckPolicy -> String # showList :: [AckPolicy] -> ShowS #
Eq AckPolicy
Instance details Defined in JetStream.Types Methods (==) :: AckPolicy -> AckPolicy -> Bool # (/=) :: AckPolicy -> AckPolicy -> Bool #

data DeliverPolicy #

Constructors

DeliverAll
DeliverLast
DeliverNew
DeliverByStartSequence Sequence
DeliverByStartTime UTCTime
DeliverLastPerSubject
DeliverPolicyUnknown Text

Instances

Instances details

FromJSON DeliverPolicy
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser DeliverPolicy # parseJSONList :: Value -> Parser [DeliverPolicy] # omittedField :: Maybe DeliverPolicy #
ToJSON DeliverPolicy
Instance details Defined in JetStream.Types Methods toJSON :: DeliverPolicy -> Value # toEncoding :: DeliverPolicy -> Encoding # toJSONList :: [DeliverPolicy] -> Value # toEncodingList :: [DeliverPolicy] -> Encoding # omitField :: DeliverPolicy -> Bool #
Show DeliverPolicy
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> DeliverPolicy -> ShowS # show :: DeliverPolicy -> String # showList :: [DeliverPolicy] -> ShowS #
Eq DeliverPolicy
Instance details Defined in JetStream.Types Methods (==) :: DeliverPolicy -> DeliverPolicy -> Bool # (/=) :: DeliverPolicy -> DeliverPolicy -> Bool #

data ReplayPolicy #

Constructors

ReplayInstant
ReplayOriginal
ReplayPolicyUnknown Text

Instances

Instances details

FromJSON ReplayPolicy
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser ReplayPolicy # parseJSONList :: Value -> Parser [ReplayPolicy] # omittedField :: Maybe ReplayPolicy #
ToJSON ReplayPolicy
Instance details Defined in JetStream.Types Methods toJSON :: ReplayPolicy -> Value # toEncoding :: ReplayPolicy -> Encoding # toJSONList :: [ReplayPolicy] -> Value # toEncodingList :: [ReplayPolicy] -> Encoding # omitField :: ReplayPolicy -> Bool #
Show ReplayPolicy
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> ReplayPolicy -> ShowS # show :: ReplayPolicy -> String # showList :: [ReplayPolicy] -> ShowS #
Eq ReplayPolicy
Instance details Defined in JetStream.Types Methods (==) :: ReplayPolicy -> ReplayPolicy -> Bool # (/=) :: ReplayPolicy -> ReplayPolicy -> Bool #

getConsumerInfo :: ConsumerAPI -> Consumer -> [JetStreamRequestOption] -> IO (Either JetStreamError ConsumerInfo) #

lookupConsumer :: ConsumerAPI -> StreamName -> ConsumerName -> [JetStreamRequestOption] -> IO (Either JetStreamError Consumer) #

putConsumerHandle :: ConsumerAPI -> StreamName -> ConsumerAction -> ConsumerTarget -> ConsumerKind -> [ConsumerConfigOption] -> [JetStreamRequestOption] -> IO (Either JetStreamError Consumer) #

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)] #

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 #

type FetchOption = CallOption PullRequest #

data MessageAPI #

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 OrderedConsumer #

type OrderedConsumerOption = CallOption OrderedConsumerConfig #

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 #

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 #

type PushConsumeOption = CallOption PushConsumeConfig #

data PushSubscription #

messageMetadata :: Message -> Maybe MessageMetadata #

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 #

type PublishOption = PublishConfig -> PublishConfig #

data PublishAPI #

withHeaders :: [(ByteString, ByteString)] -> PublishOption #

data PublishAck #

Instances

Instances details

FromJSON PublishAck
Instance details Defined in JetStream.Publish.Types Methods parseJSON :: Value -> Parser PublishAck # parseJSONList :: Value -> Parser [PublishAck] # omittedField :: Maybe PublishAck #
Show PublishAck
Instance details Defined in JetStream.Publish.Types Methods showsPrec :: Int -> PublishAck -> ShowS # show :: PublishAck -> String # showList :: [PublishAck] -> ShowS #
Eq PublishAck
Instance details Defined in JetStream.Publish.Types Methods (==) :: PublishAck -> PublishAck -> Bool # (/=) :: PublishAck -> PublishAck -> Bool #

data PublishExpectation #

Constructors

ExpectedLastSequence Sequence
ExpectedLastSubjectSequence Sequence
ExpectedLastMsgId ByteString

Instances

Instances details

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

withExpectedStream :: StreamName -> PublishOption #

withMsgId :: ByteString -> PublishOption #

withPublishExpectation :: PublishExpectation -> PublishOption #

data StreamAPI #

data Stream #

Instances

Instances details

Show Stream
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> Stream -> ShowS # show :: Stream -> String # showList :: [Stream] -> ShowS #
Eq Stream
Instance details Defined in JetStream.Stream.Types Methods (==) :: Stream -> Stream -> Bool # (/=) :: Stream -> Stream -> Bool #
Ord Stream
Instance details Defined in JetStream.Stream.Types Methods compare :: Stream -> Stream -> Ordering # (<) :: Stream -> Stream -> Bool # (<=) :: Stream -> Stream -> Bool # (>) :: Stream -> Stream -> Bool # (>=) :: Stream -> Stream -> Bool # max :: Stream -> Stream -> Stream # min :: Stream -> Stream -> Stream #

data DiscardPolicy #

Constructors

DiscardOld
DiscardNew
DiscardPolicyUnknown Text

Instances

Instances details

FromJSON DiscardPolicy
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser DiscardPolicy # parseJSONList :: Value -> Parser [DiscardPolicy] # omittedField :: Maybe DiscardPolicy #
ToJSON DiscardPolicy
Instance details Defined in JetStream.Types Methods toJSON :: DiscardPolicy -> Value # toEncoding :: DiscardPolicy -> Encoding # toJSONList :: [DiscardPolicy] -> Value # toEncodingList :: [DiscardPolicy] -> Encoding # omitField :: DiscardPolicy -> Bool #
Show DiscardPolicy
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> DiscardPolicy -> ShowS # show :: DiscardPolicy -> String # showList :: [DiscardPolicy] -> ShowS #
Eq DiscardPolicy
Instance details Defined in JetStream.Types Methods (==) :: DiscardPolicy -> DiscardPolicy -> Bool # (/=) :: DiscardPolicy -> DiscardPolicy -> Bool #

data RetentionPolicy #

Constructors

LimitsPolicy
InterestPolicy
WorkQueuePolicy
RetentionPolicyUnknown Text

Instances

Instances details

FromJSON RetentionPolicy
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser RetentionPolicy # parseJSONList :: Value -> Parser [RetentionPolicy] # omittedField :: Maybe RetentionPolicy #
ToJSON RetentionPolicy
Instance details Defined in JetStream.Types Methods toJSON :: RetentionPolicy -> Value # toEncoding :: RetentionPolicy -> Encoding # toJSONList :: [RetentionPolicy] -> Value # toEncodingList :: [RetentionPolicy] -> Encoding # omitField :: RetentionPolicy -> Bool #
Show RetentionPolicy
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> RetentionPolicy -> ShowS # show :: RetentionPolicy -> String # showList :: [RetentionPolicy] -> ShowS #
Eq RetentionPolicy
Instance details Defined in JetStream.Types Methods (==) :: RetentionPolicy -> RetentionPolicy -> Bool # (/=) :: RetentionPolicy -> RetentionPolicy -> Bool #

data StorageType #

Constructors

FileStorage
MemoryStorage
StorageTypeUnknown Text

Instances

Instances details

FromJSON StorageType
Instance details Defined in JetStream.Types Methods parseJSON :: Value -> Parser StorageType # parseJSONList :: Value -> Parser [StorageType] # omittedField :: Maybe StorageType #
ToJSON StorageType
Instance details Defined in JetStream.Types Methods toJSON :: StorageType -> Value # toEncoding :: StorageType -> Encoding # toJSONList :: [StorageType] -> Value # toEncodingList :: [StorageType] -> Encoding # omitField :: StorageType -> Bool #
Show StorageType
Instance details Defined in JetStream.Types Methods showsPrec :: Int -> StorageType -> ShowS # show :: StorageType -> String # showList :: [StorageType] -> ShowS #
Eq StorageType
Instance details Defined in JetStream.Types Methods (==) :: StorageType -> StorageType -> Bool # (/=) :: StorageType -> StorageType -> Bool #

data DeleteStreamMessageResponse #

Instances

Instances details

FromJSON DeleteStreamMessageResponse
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser DeleteStreamMessageResponse # parseJSONList :: Value -> Parser [DeleteStreamMessageResponse] # omittedField :: Maybe DeleteStreamMessageResponse #
ToJSON DeleteStreamMessageResponse
Instance details Defined in JetStream.Stream.Types Methods toJSON :: DeleteStreamMessageResponse -> Value # toEncoding :: DeleteStreamMessageResponse -> Encoding # toJSONList :: [DeleteStreamMessageResponse] -> Value # toEncodingList :: [DeleteStreamMessageResponse] -> Encoding # omitField :: DeleteStreamMessageResponse -> Bool #
Show DeleteStreamMessageResponse
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> DeleteStreamMessageResponse -> ShowS # show :: DeleteStreamMessageResponse -> String # showList :: [DeleteStreamMessageResponse] -> ShowS #
Eq DeleteStreamMessageResponse
Instance details Defined in JetStream.Stream.Types Methods (==) :: DeleteStreamMessageResponse -> DeleteStreamMessageResponse -> Bool # (/=) :: DeleteStreamMessageResponse -> DeleteStreamMessageResponse -> Bool #

data DeleteStreamResponse #

Instances

Instances details

FromJSON DeleteStreamResponse
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser DeleteStreamResponse # parseJSONList :: Value -> Parser [DeleteStreamResponse] # omittedField :: Maybe DeleteStreamResponse #
ToJSON DeleteStreamResponse
Instance details Defined in JetStream.Stream.Types Methods toJSON :: DeleteStreamResponse -> Value # toEncoding :: DeleteStreamResponse -> Encoding # toJSONList :: [DeleteStreamResponse] -> Value # toEncodingList :: [DeleteStreamResponse] -> Encoding # omitField :: DeleteStreamResponse -> Bool #
Show DeleteStreamResponse
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> DeleteStreamResponse -> ShowS # show :: DeleteStreamResponse -> String # showList :: [DeleteStreamResponse] -> ShowS #
Eq DeleteStreamResponse
Instance details Defined in JetStream.Stream.Types Methods (==) :: DeleteStreamResponse -> DeleteStreamResponse -> Bool # (/=) :: DeleteStreamResponse -> DeleteStreamResponse -> Bool #

data PurgeStreamResponse #

Instances

Instances details

FromJSON PurgeStreamResponse
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser PurgeStreamResponse # parseJSONList :: Value -> Parser [PurgeStreamResponse] # omittedField :: Maybe PurgeStreamResponse #
ToJSON PurgeStreamResponse
Instance details Defined in JetStream.Stream.Types Methods toJSON :: PurgeStreamResponse -> Value # toEncoding :: PurgeStreamResponse -> Encoding # toJSONList :: [PurgeStreamResponse] -> Value # toEncodingList :: [PurgeStreamResponse] -> Encoding # omitField :: PurgeStreamResponse -> Bool #
Show PurgeStreamResponse
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> PurgeStreamResponse -> ShowS # show :: PurgeStreamResponse -> String # showList :: [PurgeStreamResponse] -> ShowS #
Eq PurgeStreamResponse
Instance details Defined in JetStream.Stream.Types Methods (==) :: PurgeStreamResponse -> PurgeStreamResponse -> Bool # (/=) :: PurgeStreamResponse -> PurgeStreamResponse -> Bool #

data StreamCluster #

Instances

Instances details

FromJSON StreamCluster
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamCluster # parseJSONList :: Value -> Parser [StreamCluster] # omittedField :: Maybe StreamCluster #
ToJSON StreamCluster
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamCluster -> Value # toEncoding :: StreamCluster -> Encoding # toJSONList :: [StreamCluster] -> Value # toEncodingList :: [StreamCluster] -> Encoding # omitField :: StreamCluster -> Bool #
Show StreamCluster
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamCluster -> ShowS # show :: StreamCluster -> String # showList :: [StreamCluster] -> ShowS #
Eq StreamCluster
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamCluster -> StreamCluster -> Bool # (/=) :: StreamCluster -> StreamCluster -> Bool #

data StreamConfig #

Instances

Instances details

FromJSON StreamConfig
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamConfig # parseJSONList :: Value -> Parser [StreamConfig] # omittedField :: Maybe StreamConfig #
ToJSON StreamConfig
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamConfig -> Value # toEncoding :: StreamConfig -> Encoding # toJSONList :: [StreamConfig] -> Value # toEncodingList :: [StreamConfig] -> Encoding # omitField :: StreamConfig -> Bool #
Show StreamConfig
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamConfig -> ShowS # show :: StreamConfig -> String # showList :: [StreamConfig] -> ShowS #
Eq StreamConfig
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamConfig -> StreamConfig -> Bool # (/=) :: StreamConfig -> StreamConfig -> Bool #

data StreamInfo #

Instances

Instances details

FromJSON StreamInfo
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamInfo # parseJSONList :: Value -> Parser [StreamInfo] # omittedField :: Maybe StreamInfo #
ToJSON StreamInfo
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamInfo -> Value # toEncoding :: StreamInfo -> Encoding # toJSONList :: [StreamInfo] -> Value # toEncodingList :: [StreamInfo] -> Encoding # omitField :: StreamInfo -> Bool #
Show StreamInfo
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamInfo -> ShowS # show :: StreamInfo -> String # showList :: [StreamInfo] -> ShowS #
Eq StreamInfo
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamInfo -> StreamInfo -> Bool # (/=) :: StreamInfo -> StreamInfo -> Bool #

data StreamListResponse #

Instances

Instances details

FromJSON StreamListResponse
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamListResponse # parseJSONList :: Value -> Parser [StreamListResponse] # omittedField :: Maybe StreamListResponse #
ToJSON StreamListResponse
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamListResponse -> Value # toEncoding :: StreamListResponse -> Encoding # toJSONList :: [StreamListResponse] -> Value # toEncodingList :: [StreamListResponse] -> Encoding # omitField :: StreamListResponse -> Bool #
Show StreamListResponse
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamListResponse -> ShowS # show :: StreamListResponse -> String # showList :: [StreamListResponse] -> ShowS #
Eq StreamListResponse
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamListResponse -> StreamListResponse -> Bool # (/=) :: StreamListResponse -> StreamListResponse -> Bool #

data StreamMessage #

Instances

Instances details

FromJSON StreamMessage
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamMessage # parseJSONList :: Value -> Parser [StreamMessage] # omittedField :: Maybe StreamMessage #
ToJSON StreamMessage
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamMessage -> Value # toEncoding :: StreamMessage -> Encoding # toJSONList :: [StreamMessage] -> Value # toEncodingList :: [StreamMessage] -> Encoding # omitField :: StreamMessage -> Bool #
Show StreamMessage
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamMessage -> ShowS # show :: StreamMessage -> String # showList :: [StreamMessage] -> ShowS #
Eq StreamMessage
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamMessage -> StreamMessage -> Bool # (/=) :: StreamMessage -> StreamMessage -> Bool #

data StreamMessageDeleteMode #

Constructors

DeleteMessage
SecureDeleteMessage

Instances

Instances details

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

data StreamMessageSelector #

Constructors

StreamMessageBySequence Sequence
LastStreamMessageForSubject Subject
NextStreamMessageForSubject Subject

Instances

Instances details

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

data StreamNamesResponse #

Instances

Instances details

FromJSON StreamNamesResponse
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamNamesResponse # parseJSONList :: Value -> Parser [StreamNamesResponse] # omittedField :: Maybe StreamNamesResponse #
ToJSON StreamNamesResponse
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamNamesResponse -> Value # toEncoding :: StreamNamesResponse -> Encoding # toJSONList :: [StreamNamesResponse] -> Value # toEncodingList :: [StreamNamesResponse] -> Encoding # omitField :: StreamNamesResponse -> Bool #
Show StreamNamesResponse
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamNamesResponse -> ShowS # show :: StreamNamesResponse -> String # showList :: [StreamNamesResponse] -> ShowS #
Eq StreamNamesResponse
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamNamesResponse -> StreamNamesResponse -> Bool # (/=) :: StreamNamesResponse -> StreamNamesResponse -> Bool #

data StreamPeer #

Instances

Instances details

FromJSON StreamPeer
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamPeer # parseJSONList :: Value -> Parser [StreamPeer] # omittedField :: Maybe StreamPeer #
ToJSON StreamPeer
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamPeer -> Value # toEncoding :: StreamPeer -> Encoding # toJSONList :: [StreamPeer] -> Value # toEncodingList :: [StreamPeer] -> Encoding # omitField :: StreamPeer -> Bool #
Show StreamPeer
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamPeer -> ShowS # show :: StreamPeer -> String # showList :: [StreamPeer] -> ShowS #
Eq StreamPeer
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamPeer -> StreamPeer -> Bool # (/=) :: StreamPeer -> StreamPeer -> Bool #

data StreamSourceInfo #

Instances

Instances details

FromJSON StreamSourceInfo
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamSourceInfo # parseJSONList :: Value -> Parser [StreamSourceInfo] # omittedField :: Maybe StreamSourceInfo #
ToJSON StreamSourceInfo
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamSourceInfo -> Value # toEncoding :: StreamSourceInfo -> Encoding # toJSONList :: [StreamSourceInfo] -> Value # toEncodingList :: [StreamSourceInfo] -> Encoding # omitField :: StreamSourceInfo -> Bool #
Show StreamSourceInfo
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamSourceInfo -> ShowS # show :: StreamSourceInfo -> String # showList :: [StreamSourceInfo] -> ShowS #
Eq StreamSourceInfo
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamSourceInfo -> StreamSourceInfo -> Bool # (/=) :: StreamSourceInfo -> StreamSourceInfo -> Bool #

data StreamState #

Instances

Instances details

FromJSON StreamState
Instance details Defined in JetStream.Stream.Types Methods parseJSON :: Value -> Parser StreamState # parseJSONList :: Value -> Parser [StreamState] # omittedField :: Maybe StreamState #
ToJSON StreamState
Instance details Defined in JetStream.Stream.Types Methods toJSON :: StreamState -> Value # toEncoding :: StreamState -> Encoding # toJSONList :: [StreamState] -> Value # toEncodingList :: [StreamState] -> Encoding # omitField :: StreamState -> Bool #
Show StreamState
Instance details Defined in JetStream.Stream.Types Methods showsPrec :: Int -> StreamState -> ShowS # show :: StreamState -> String # showList :: [StreamState] -> ShowS #
Eq StreamState
Instance details Defined in JetStream.Stream.Types Methods (==) :: StreamState -> StreamState -> Bool # (/=) :: StreamState -> StreamState -> Bool #