Copyright	(c) Moritz Schulte 2017 2018
License	BSD3
Maintainer	mtesseract@silverratio.net
Stability	experimental
Portability	POSIX
Safe Haskell	None
Language	Haskell2010

Network.Nakadi.Types.Config

Description

This module provides the Nakadi Config Types.

Synopsis

Documentation

data Config m Source #

Instances

HasNakadiRequestTemplate (Config m) Request
Methods requestTemplate :: Lens' (Config m) Request
HasNakadiStreamConnectCallback (Config m) (Maybe (StreamConnectCallback m))
Methods streamConnectCallback :: Lens' (Config m) (Maybe (StreamConnectCallback m))
HasNakadiRetryPolicy (Config m) (RetryPolicyM IO)
Methods retryPolicy :: Lens' (Config m) (RetryPolicyM IO)
HasNakadiManager (Config m) (Maybe Manager)
Methods manager :: Lens' (Config m) (Maybe Manager)
HasNakadiLogFunc (Config m) (Maybe (LogFunc m))
Methods logFunc :: Lens' (Config m) (Maybe (LogFunc m))
HasNakadiHttpErrorCallback (Config m) (Maybe (HttpErrorCallback m))
Methods httpErrorCallback :: Lens' (Config m) (Maybe (HttpErrorCallback m))
HasNakadiHttp (Config m) (HttpBackend m)
Methods http :: Lens' (Config m) (HttpBackend m)
HasNakadiFlowId (Config m) (Maybe FlowId)
Methods flowId :: Lens' (Config m) (Maybe FlowId)
HasNakadiDeserializationFailureCallback (Config m) (Maybe (ByteString -> Text -> m ()))
Methods deserializationFailureCallback :: Lens' (Config m) (Maybe (ByteString -> Text -> m ()))
HasNakadiConsumeParameters (Config m) (Maybe ConsumeParameters)
Methods consumeParameters :: Lens' (Config m) (Maybe ConsumeParameters)
HasNakadiRequestModifier (Config m) (Request -> m Request)
Methods requestModifier :: Lens' (Config m) (Request -> m Request)
HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
Methods httpResponseOpen :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))
Methods httpLbs :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))

type ConfigIO = Config IO Source #

data ConsumeParameters Source #

ConsumeParameters

Instances

Eq ConsumeParameters Source #
Methods (==) :: ConsumeParameters -> ConsumeParameters -> Bool # (/=) :: ConsumeParameters -> ConsumeParameters -> Bool #
Ord ConsumeParameters Source #
Methods compare :: ConsumeParameters -> ConsumeParameters -> Ordering # (<) :: ConsumeParameters -> ConsumeParameters -> Bool # (<=) :: ConsumeParameters -> ConsumeParameters -> Bool # (>) :: ConsumeParameters -> ConsumeParameters -> Bool # (>=) :: ConsumeParameters -> ConsumeParameters -> Bool # max :: ConsumeParameters -> ConsumeParameters -> ConsumeParameters # min :: ConsumeParameters -> ConsumeParameters -> ConsumeParameters #
Show ConsumeParameters Source #
Methods showsPrec :: Int -> ConsumeParameters -> ShowS # show :: ConsumeParameters -> String # showList :: [ConsumeParameters] -> ShowS #
HasNakadiStreamTimeout ConsumeParameters (Maybe Int32)
Methods streamTimeout :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiStreamLimit ConsumeParameters (Maybe Int32)
Methods streamLimit :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiStreamKeepAliveLimit ConsumeParameters (Maybe Int32)
Methods streamKeepAliveLimit :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiMaxUncommittedEvents ConsumeParameters (Maybe Int32)
Methods maxUncommittedEvents :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiBatchLimit ConsumeParameters (Maybe Int32)
Methods batchLimit :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiBatchFlushTimeout ConsumeParameters (Maybe Int32)
Methods batchFlushTimeout :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiConsumeParameters (Config m) (Maybe ConsumeParameters)
Methods consumeParameters :: Lens' (Config m) (Maybe ConsumeParameters)

type StreamConnectCallback m = Response () -> m () Source #

Config

data HttpBackend b Source #

Constructors

HttpBackend
Fields _httpLbs :: Config b -> Request -> Maybe Manager -> b (Response ByteString) _httpResponseOpen :: Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())) _httpResponseClose :: Response () -> b ()

Instances

HasNakadiHttp (Config m) (HttpBackend m)
Methods http :: Lens' (Config m) (HttpBackend m)
HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
Methods httpResponseOpen :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
HasNakadiHttpResponseClose (HttpBackend b) (Response () -> b ())
Methods httpResponseClose :: Lens' (HttpBackend b) (Response () -> b ())
HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))
Methods httpLbs :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))