Safe Haskell	None
Language	Haskell2010

JetStream.API.Stream

Description

JetStream stream management contract.

Documentation

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 #

withCompression :: StreamCompression -> StreamConfigOption #

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

Constructors

NoCompression
S2Compression
StreamCompressionUnknown Text

Instances

Instances details

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

type StreamConfigOption = CallOption StreamConfigRequest #

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 #

withAllowDirect :: Bool -> StreamConfigOption #

withAllowRollup :: Bool -> StreamConfigOption #

withDenyDelete :: Bool -> StreamConfigOption #

withDescription :: ByteString -> StreamConfigOption #

withDiscard :: DiscardPolicy -> StreamConfigOption #

withDuplicateWindow :: NominalDiffTime -> StreamConfigOption #

withMaxAge :: NominalDiffTime -> StreamConfigOption #

withMaxBytes :: Integer -> StreamConfigOption #

withMaxConsumers :: Int -> StreamConfigOption #

withMaxMessageSize :: Int32 -> StreamConfigOption #

withMaxMessages :: Integer -> StreamConfigOption #

withMaxMessagesPerSubject :: Integer -> StreamConfigOption #

withReplicas :: Int -> StreamConfigOption #

withRetention :: RetentionPolicy -> StreamConfigOption #

withStorage :: StorageType -> StreamConfigOption #

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

Constructors

StreamMessageBySequence Word64
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 #

type PurgeStreamOption = CallOption PurgeStreamRequest #

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 #

type StreamListOption = CallOption StreamListRequest #

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

withPurgeKeep :: Integer -> PurgeStreamOption #

withPurgeSequence :: Word64 -> PurgeStreamOption #

withPurgeSubject :: Subject -> PurgeStreamOption #

withStreamListOffset :: Int -> StreamListOption #

withStreamListSubject :: Subject -> StreamListOption #

createStream :: StreamAPI -> StreamName -> [Subject] -> [StreamConfigOption] -> [JetStreamRequestOption] -> IO (Either JetStreamError Stream) #

getStreamInfo :: StreamAPI -> Stream -> [JetStreamRequestOption] -> IO (Either JetStreamError StreamInfo) #

lookupStream :: StreamAPI -> StreamName -> [JetStreamRequestOption] -> IO (Either JetStreamError Stream) #