natskell
Safe HaskellNone
LanguageHaskell2010

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 #

management :: JetStream -> ManagementAPI #

keyValues :: JetStream -> KeyValueAPI #

data JetStreamRequestOption #

withRequestTimeout :: NominalDiffTime -> JetStreamRequestOption #

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 #

module JetStream.API.Consumer

module JetStream.API.KeyValue

module JetStream.API.Management

module JetStream.API.Message

module JetStream.API.Publish

module JetStream.API.Stream