Database.Franz.Client.Reconnect

Documentation

data Pool

poolLogFunc :: Pool -> String -> IO ()

poolRetryPolicy :: Pool -> RetryPolicyM IO

withPool

Arguments

:: RetryPolicyM IO

-> (String -> IO ())

diagnostic output

-> FranzPath

-> (Pool -> IO a)

-> IO a

withReconnection :: Pool -> (Connection -> IO a) -> IO a

Run an action which takes a Connection, reconnecting whenever it throws an exception.

data Reconnect

Constructors

ReconnectByTimeout

ReconnectByError

ReconnectInQuery !Query !Reconnect

Instances

Eq Reconnect

Defined in Database.Franz.Client.Reconnect

Methods

(==) :: Reconnect -> Reconnect -> Bool

(/=) :: Reconnect -> Reconnect -> Bool

Show Reconnect

Defined in Database.Franz.Client.Reconnect

Methods

showsPrec :: Int -> Reconnect -> ShowS

show :: Reconnect -> String

showList :: [Reconnect] -> ShowS

Exception Reconnect

Defined in Database.Franz.Client.Reconnect

Methods

toException :: Reconnect -> SomeException

fromException :: SomeException -> Maybe Reconnect

displayException :: Reconnect -> String

atomicallyReconnecting

Arguments

:: Int

timeout in microseconds

-> STM a

-> IO a

Run an STM action, throwing Reconnect when it exceeds the given timeout.

fetchWithPool :: Pool -> Query -> (STM Response -> IO r) -> IO r

A wrapper of fetch which calls withReconnection internally