Safe Haskell	None
Language	Haskell2010

JetStream.API

Description

Capability record for the JetStream client surface.

Synopsis

data JetStream = JetStream {
- streams :: StreamAPI
- consumers :: ConsumerAPI
- publisher :: PublishAPI
- messages :: MessageAPI
}
data JetStreamApiError = JetStreamApiError {
- apiErrorCode :: Maybe Int
- apiErrorCodeDetail :: Maybe Int
- apiErrorDescription :: Maybe ByteString
}
data JetStreamError
- = JetStreamApiFailure JetStreamApiError
- | JetStreamStatusError Int (Maybe ByteString)
- | JetStreamDecodeError String
- | JetStreamTimeout
- | JetStreamNoReply
type StreamName = ByteString
type ConsumerName = ByteString
type Subject = ByteString
type Payload = ByteString
data ConsumerAPI = ConsumerAPI {
- createConsumer :: StreamName -> ConsumerConfig -> IO (Either JetStreamError ConsumerInfo)
- createDurableConsumer :: StreamName -> ConsumerName -> ConsumerConfig -> IO (Either JetStreamError ConsumerInfo)
- consumerInfo :: StreamName -> ConsumerName -> IO (Either JetStreamError ConsumerInfo)
- deleteConsumer :: StreamName -> ConsumerName -> IO (Either JetStreamError DeleteConsumerResponse)
- listConsumers :: StreamName -> ConsumerListRequest -> IO (Either JetStreamError ConsumerListResponse)
- consumerNames :: StreamName -> ConsumerNamesRequest -> IO (Either JetStreamError ConsumerNamesResponse)
}
data ConsumerConfig = ConsumerConfig {
- consumerConfigDurableName :: Maybe ConsumerName
- consumerConfigName :: Maybe ConsumerName
- consumerConfigDescription :: Maybe ByteString
- consumerConfigDeliverPolicy :: Maybe DeliverPolicy
- consumerConfigAckPolicy :: Maybe AckPolicy
- consumerConfigReplayPolicy :: Maybe ReplayPolicy
- consumerConfigFilterSubject :: Maybe Subject
- consumerConfigFilterSubjects :: Maybe [Subject]
- consumerConfigAckWait :: Maybe NominalDiffTime
- consumerConfigMaxDeliver :: Maybe Int
- consumerConfigMaxAckPending :: Maybe Int
- consumerConfigInactiveThreshold :: Maybe NominalDiffTime
}
data ConsumerInfo = ConsumerInfo {
- consumerInfoType :: Maybe ByteString
- consumerInfoStreamName :: Maybe StreamName
- consumerInfoName :: Maybe ConsumerName
- consumerInfoCreated :: Maybe UTCTime
- consumerInfoConfig :: Maybe ConsumerConfig
- consumerInfoDelivered :: Maybe ConsumerSequenceInfo
- consumerInfoAckFloor :: Maybe ConsumerSequenceInfo
- consumerInfoNumAckPending :: Maybe Int
- consumerInfoNumRedelivered :: Maybe Int
- consumerInfoNumWaiting :: Maybe Int
- consumerInfoNumPending :: Maybe Integer
}
newtype ConsumerListRequest = ConsumerListRequest {
- consumerListRequestOffset :: Maybe Int
}
data ConsumerListResponse = ConsumerListResponse {
- consumerListTotal :: Maybe Int
- consumerListOffset :: Maybe Int
- consumerListLimit :: Maybe Int
- consumerListConsumers :: Maybe [ConsumerInfo]
}
newtype ConsumerNamesRequest = ConsumerNamesRequest {
- consumerNamesRequestOffset :: Maybe Int
}
data ConsumerNamesResponse = ConsumerNamesResponse {
- consumerNamesTotal :: Maybe Int
- consumerNamesOffset :: Maybe Int
- consumerNamesLimit :: Maybe Int
- consumerNamesConsumers :: Maybe [ConsumerName]
}
data ConsumerSequenceInfo = ConsumerSequenceInfo {
- consumerSequenceConsumer :: Maybe Integer
- consumerSequenceStream :: Maybe Integer
- consumerSequenceLast :: Maybe UTCTime
}
newtype DeleteConsumerResponse = DeleteConsumerResponse {
- deleteConsumerSuccess :: Maybe Bool
}
defaultConsumerListRequest :: ConsumerListRequest
defaultConsumerNamesRequest :: ConsumerNamesRequest
emptyConsumerConfig :: ConsumerConfig
data AckPolicy
- = AckNone
- | AckAll
- | AckExplicit
data DeliverPolicy
- = DeliverAll
- | DeliverLast
- | DeliverNew
- | DeliverByStartSequence Int
- | DeliverByStartTime UTCTime
- | DeliverLastPerSubject
data ReplayPolicy
- = ReplayInstant
- | ReplayOriginal
data AckVerb
- = Ack
- | Nak
- | InProgress
- | Term
data Message = Message {
- messageSubject :: Subject
- messagePayload :: Maybe Payload
- messageHeaders :: Maybe Headers
- messageReplyTo :: Maybe Subject
- messageStatus :: Maybe PullStatus
}
data MessageAPI = MessageAPI {
- fetch :: StreamName -> ConsumerName -> PullRequest -> IO PullResponse
- ack :: Message -> IO (Either JetStreamError ())
- nak :: Message -> IO (Either JetStreamError ())
- inProgress :: Message -> IO (Either JetStreamError ())
- term :: Message -> IO (Either JetStreamError ())
}
data PullStatus
- = PullNoMessages (Maybe ByteString)
- | PullRequestTimeout (Maybe ByteString)
- | PullStatusError ByteString (Maybe ByteString)
data PullRequest = PullRequest {
- pullRequestBatch :: Int
- pullRequestTimeoutMicros :: Int
- pullRequestNoWait :: Bool
}
data PullResponse = PullResponse {
- pullResponseMessages :: [Message]
- pullResponseStatus :: Maybe PullStatus
}
ackPayload :: AckVerb -> Payload
classifyStatusHeaders :: Maybe Headers -> Maybe PullStatus
defaultPullRequest :: PullRequest
descriptionHeader :: Headers -> Maybe ByteString
inProgressPayload :: Payload
isStatusMessage :: Message -> Bool
nakPayload :: Payload
pullRequestPayload :: Int -> PullRequest -> Payload
statusHeader :: Headers -> Maybe ByteString
termPayload :: Payload
type Headers = [(ByteString, ByteString)]
newtype PublishAPI = PublishAPI {
- publish :: Subject -> Payload -> [PublishOption] -> IO (Either JetStreamError PublishAck)
}
data PublishAck = PublishAck {
- publishAckStream :: StreamName
- publishAckSequence :: Word64
- publishAckDuplicate :: Maybe Bool
- publishAckDomain :: Maybe ByteString
}
type PublishOption = PublishConfig -> PublishConfig
withExpectedLastMsgId :: ByteString -> PublishOption
withExpectedLastSequence :: Word64 -> PublishOption
withExpectedLastSubjectSequence :: Word64 -> PublishOption
withExpectedStream :: StreamName -> PublishOption
withHeaders :: [(ByteString, ByteString)] -> PublishOption
withMsgId :: ByteString -> PublishOption
data StreamAPI = StreamAPI {
- create :: StreamConfig -> IO (Either JetStreamError StreamInfo)
- update :: StreamConfig -> IO (Either JetStreamError StreamInfo)
- info :: StreamName -> IO (Either JetStreamError StreamInfo)
- delete :: StreamName -> IO (Either JetStreamError DeleteStreamResponse)
- purge :: StreamName -> PurgeStreamRequest -> IO (Either JetStreamError PurgeStreamResponse)
- list :: StreamListRequest -> IO (Either JetStreamError StreamListResponse)
- names :: StreamNamesRequest -> IO (Either JetStreamError StreamNamesResponse)
}
newtype DeleteStreamResponse = DeleteStreamResponse {
- deleteStreamSuccess :: Maybe Bool
}
data PurgeStreamRequest = PurgeStreamRequest {
- purgeStreamSubject :: Maybe Subject
- purgeStreamSequence :: Maybe Integer
- purgeStreamKeep :: Maybe Integer
}
data PurgeStreamResponse = PurgeStreamResponse {
- purgeStreamSuccess :: Maybe Bool
- purgeStreamPurged :: Maybe Integer
}
data StreamAlternate = StreamAlternate {
- streamAlternateName :: Maybe StreamName
- streamAlternateDomain :: Maybe ByteString
- streamAlternateCluster :: Maybe ByteString
}
data StreamCluster = StreamCluster {
- streamClusterName :: Maybe ByteString
- streamClusterLeader :: Maybe ByteString
- streamClusterReplicas :: Maybe [StreamPeer]
}
data StreamConfig = StreamConfig {
- streamConfigName :: StreamName
- streamConfigSubjects :: [Subject]
- streamConfigRetention :: Maybe RetentionPolicy
- streamConfigStorage :: Maybe StorageType
- streamConfigDiscard :: Maybe DiscardPolicy
- streamConfigMaxMessages :: Maybe Integer
- streamConfigMaxBytes :: Maybe Integer
- streamConfigMaxAge :: Maybe NominalDiffTime
- streamConfigReplicas :: Maybe Int
- streamConfigDuplicateWindow :: Maybe NominalDiffTime
- streamConfigAllowDirect :: Maybe Bool
}
data StreamInfo = StreamInfo {
- streamInfoType :: Maybe ByteString
- streamInfoConfig :: Maybe StreamConfig
- streamInfoCreated :: Maybe UTCTime
- streamInfoState :: Maybe StreamState
- streamInfoCluster :: Maybe StreamCluster
- streamInfoMirror :: Maybe StreamSourceInfo
- streamInfoSources :: Maybe [StreamSourceInfo]
- streamInfoAlternates :: Maybe [StreamAlternate]
}
data StreamListRequest = StreamListRequest {
- streamListRequestOffset :: Maybe Int
- streamListRequestSubject :: Maybe Subject
}
data StreamListResponse = StreamListResponse {
- streamListTotal :: Maybe Int
- streamListOffset :: Maybe Int
- streamListLimit :: Maybe Int
- streamListStreams :: Maybe [StreamInfo]
}
data StreamNamesRequest = StreamNamesRequest {
- streamNamesRequestOffset :: Maybe Int
- streamNamesRequestSubject :: Maybe Subject
}
data StreamNamesResponse = StreamNamesResponse {
- streamNamesTotal :: Maybe Int
- streamNamesOffset :: Maybe Int
- streamNamesLimit :: Maybe Int
- streamNamesStreams :: Maybe [StreamName]
}
data StreamPeer = StreamPeer {
- streamPeerName :: Maybe ByteString
- streamPeerCurrent :: Maybe Bool
- streamPeerOffline :: Maybe Bool
- streamPeerActive :: Maybe NominalDiffTime
- streamPeerLag :: Maybe Integer
}
data StreamSourceInfo = StreamSourceInfo {
- streamSourceInfoName :: Maybe StreamName
- streamSourceInfoFilterSubject :: Maybe Subject
- streamSourceInfoLag :: Maybe Integer
- streamSourceInfoActive :: Maybe NominalDiffTime
- streamSourceInfoError :: Maybe Value
}
data StreamState = StreamState {
- streamStateMessages :: Maybe Integer
- streamStateBytes :: Maybe Integer
- streamStateFirstSequence :: Maybe Integer
- streamStateFirstTime :: Maybe UTCTime
- streamStateLastSequence :: Maybe Integer
- streamStateLastTime :: Maybe UTCTime
- streamStateConsumerCount :: Maybe Int
- streamStateDeleted :: Maybe [Integer]
- streamStateNumDeleted :: Maybe Integer
- streamStateNumSubjects :: Maybe Integer
}
defaultPurgeStreamRequest :: PurgeStreamRequest
defaultStreamListRequest :: StreamListRequest
defaultStreamNamesRequest :: StreamNamesRequest
durationToNanoseconds :: NominalDiffTime -> Integer
nanosecondsToDuration :: Integer -> NominalDiffTime
data DiscardPolicy
- = DiscardOld
- | DiscardNew
data StorageType
- = FileStorage
- | MemoryStorage
data RetentionPolicy
- = LimitsPolicy
- | InterestPolicy
- | WorkQueuePolicy

Documentation

data JetStream Source #

JetStream capabilities for streams, consumers, publishing, and pull message workflows.

Constructors

JetStream
Fields streams :: StreamAPI Manage streams and inspect stream state. consumers :: ConsumerAPI Manage stream consumers. publisher :: PublishAPI Publish messages to JetStream subjects. messages :: MessageAPI Fetch and acknowledge pull-consumer messages.

data JetStreamApiError #

Constructors

JetStreamApiError
Fields apiErrorCode :: Maybe Int apiErrorCodeDetail :: Maybe Int apiErrorDescription :: Maybe ByteString

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 #

data JetStreamError #

Constructors

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

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

Constructors

ConsumerAPI

Fields

createConsumer :: StreamName -> ConsumerConfig -> IO (Either JetStreamError ConsumerInfo)
createDurableConsumer :: StreamName -> ConsumerName -> ConsumerConfig -> IO (Either JetStreamError ConsumerInfo)
consumerInfo :: StreamName -> ConsumerName -> IO (Either JetStreamError ConsumerInfo)
deleteConsumer :: StreamName -> ConsumerName -> IO (Either JetStreamError DeleteConsumerResponse)
listConsumers :: StreamName -> ConsumerListRequest -> IO (Either JetStreamError ConsumerListResponse)
consumerNames :: StreamName -> ConsumerNamesRequest -> IO (Either JetStreamError ConsumerNamesResponse)

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 #

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 #

newtype ConsumerListRequest #

Constructors

ConsumerListRequest
Fields consumerListRequestOffset :: Maybe Int

Instances

Instances details

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

data ConsumerListResponse #

Constructors

ConsumerListResponse
Fields consumerListTotal :: Maybe Int consumerListOffset :: Maybe Int consumerListLimit :: Maybe Int consumerListConsumers :: Maybe [ConsumerInfo]

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 #

newtype ConsumerNamesRequest #

Constructors

ConsumerNamesRequest
Fields consumerNamesRequestOffset :: Maybe Int

Instances

Instances details

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

data ConsumerNamesResponse #

Constructors

ConsumerNamesResponse
Fields consumerNamesTotal :: Maybe Int consumerNamesOffset :: Maybe Int consumerNamesLimit :: Maybe Int consumerNamesConsumers :: Maybe [ConsumerName]

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

Constructors

ConsumerSequenceInfo
Fields consumerSequenceConsumer :: Maybe Integer consumerSequenceStream :: Maybe Integer consumerSequenceLast :: Maybe UTCTime

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 #

newtype DeleteConsumerResponse #

Constructors

DeleteConsumerResponse
Fields deleteConsumerSuccess :: Maybe Bool

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 #

defaultConsumerListRequest :: ConsumerListRequest #

defaultConsumerNamesRequest :: ConsumerNamesRequest #

emptyConsumerConfig :: ConsumerConfig #

data AckPolicy #

Constructors

AckNone
AckAll
AckExplicit

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 Int
DeliverByStartTime UTCTime
DeliverLastPerSubject

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

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 #

data AckVerb #

Constructors

Ack
Nak
InProgress
Term

Instances

Instances details

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

data Message #

Constructors

Message
Fields messageSubject :: Subject messagePayload :: Maybe Payload messageHeaders :: Maybe Headers messageReplyTo :: Maybe Subject messageStatus :: Maybe PullStatus

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 #

data MessageAPI #

Constructors

MessageAPI
Fields fetch :: StreamName -> ConsumerName -> PullRequest -> IO PullResponse ack :: Message -> IO (Either JetStreamError ()) nak :: Message -> IO (Either JetStreamError ()) inProgress :: Message -> IO (Either JetStreamError ()) term :: Message -> IO (Either JetStreamError ())

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

Constructors

PullRequest
Fields pullRequestBatch :: Int pullRequestTimeoutMicros :: Int pullRequestNoWait :: Bool

Instances

Instances details

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

data PullResponse #

Constructors

PullResponse
Fields pullResponseMessages :: [Message] pullResponseStatus :: Maybe PullStatus

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 #

ackPayload :: AckVerb -> Payload #

classifyStatusHeaders :: Maybe Headers -> Maybe PullStatus #

defaultPullRequest :: PullRequest #

descriptionHeader :: Headers -> Maybe ByteString #

inProgressPayload :: Payload #

isStatusMessage :: Message -> Bool #

nakPayload :: Payload #

pullRequestPayload :: Int -> PullRequest -> Payload #

statusHeader :: Headers -> Maybe ByteString #

termPayload :: Payload #

type Headers = [(ByteString, ByteString)] #

newtype PublishAPI #

Constructors

PublishAPI
Fields publish :: Subject -> Payload -> [PublishOption] -> IO (Either JetStreamError PublishAck)

data PublishAck #

Constructors

PublishAck
Fields publishAckStream :: StreamName publishAckSequence :: Word64 publishAckDuplicate :: Maybe Bool publishAckDomain :: Maybe ByteString

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 #

type PublishOption = PublishConfig -> PublishConfig #

withExpectedLastMsgId :: ByteString -> PublishOption #

withExpectedLastSequence :: Word64 -> PublishOption #

withExpectedLastSubjectSequence :: Word64 -> PublishOption #

withExpectedStream :: StreamName -> PublishOption #

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

withMsgId :: ByteString -> PublishOption #

data StreamAPI #

Constructors

StreamAPI

Fields

create :: StreamConfig -> IO (Either JetStreamError StreamInfo)
update :: StreamConfig -> IO (Either JetStreamError StreamInfo)
info :: StreamName -> IO (Either JetStreamError StreamInfo)
delete :: StreamName -> IO (Either JetStreamError DeleteStreamResponse)
purge :: StreamName -> PurgeStreamRequest -> IO (Either JetStreamError PurgeStreamResponse)
list :: StreamListRequest -> IO (Either JetStreamError StreamListResponse)
names :: StreamNamesRequest -> IO (Either JetStreamError StreamNamesResponse)

newtype DeleteStreamResponse #

Constructors

DeleteStreamResponse
Fields deleteStreamSuccess :: Maybe Bool

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

Constructors

PurgeStreamRequest
Fields purgeStreamSubject :: Maybe Subject purgeStreamSequence :: Maybe Integer purgeStreamKeep :: Maybe Integer

Instances

Instances details

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

data PurgeStreamResponse #

Constructors

PurgeStreamResponse
Fields purgeStreamSuccess :: Maybe Bool purgeStreamPurged :: Maybe Integer

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

Constructors

StreamAlternate
Fields streamAlternateName :: Maybe StreamName streamAlternateDomain :: Maybe ByteString streamAlternateCluster :: Maybe ByteString

Instances

Instances details

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

data StreamCluster #

Constructors

StreamCluster
Fields streamClusterName :: Maybe ByteString streamClusterLeader :: Maybe ByteString streamClusterReplicas :: Maybe [StreamPeer]

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 #

Constructors

StreamInfo
Fields streamInfoType :: Maybe ByteString streamInfoConfig :: Maybe StreamConfig streamInfoCreated :: Maybe UTCTime streamInfoState :: Maybe StreamState streamInfoCluster :: Maybe StreamCluster streamInfoMirror :: Maybe StreamSourceInfo streamInfoSources :: Maybe [StreamSourceInfo] streamInfoAlternates :: Maybe [StreamAlternate]

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

Constructors

StreamListRequest
Fields streamListRequestOffset :: Maybe Int streamListRequestSubject :: Maybe Subject

Instances

Instances details

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

data StreamListResponse #

Constructors

StreamListResponse
Fields streamListTotal :: Maybe Int streamListOffset :: Maybe Int streamListLimit :: Maybe Int streamListStreams :: Maybe [StreamInfo]

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

Constructors

StreamNamesRequest
Fields streamNamesRequestOffset :: Maybe Int streamNamesRequestSubject :: Maybe Subject

Instances

Instances details

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

data StreamNamesResponse #

Constructors

StreamNamesResponse
Fields streamNamesTotal :: Maybe Int streamNamesOffset :: Maybe Int streamNamesLimit :: Maybe Int streamNamesStreams :: Maybe [StreamName]

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 #

Constructors

StreamPeer
Fields streamPeerName :: Maybe ByteString streamPeerCurrent :: Maybe Bool streamPeerOffline :: Maybe Bool streamPeerActive :: Maybe NominalDiffTime streamPeerLag :: Maybe Integer

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 #

Constructors

StreamSourceInfo
Fields streamSourceInfoName :: Maybe StreamName streamSourceInfoFilterSubject :: Maybe Subject streamSourceInfoLag :: Maybe Integer streamSourceInfoActive :: Maybe NominalDiffTime streamSourceInfoError :: Maybe Value

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 #

Constructors

StreamState
Fields streamStateMessages :: Maybe Integer streamStateBytes :: Maybe Integer streamStateFirstSequence :: Maybe Integer streamStateFirstTime :: Maybe UTCTime streamStateLastSequence :: Maybe Integer streamStateLastTime :: Maybe UTCTime streamStateConsumerCount :: Maybe Int streamStateDeleted :: Maybe [Integer] streamStateNumDeleted :: Maybe Integer streamStateNumSubjects :: Maybe Integer

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 #

defaultPurgeStreamRequest :: PurgeStreamRequest #

defaultStreamListRequest :: StreamListRequest #

defaultStreamNamesRequest :: StreamNamesRequest #

durationToNanoseconds :: NominalDiffTime -> Integer #

nanosecondsToDuration :: Integer -> NominalDiffTime #

data DiscardPolicy #

Constructors

DiscardOld
DiscardNew

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

Constructors

FileStorage
MemoryStorage

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

Constructors

LimitsPolicy
InterestPolicy
WorkQueuePolicy

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 #