Copyright	(c) Moritz Clasmeier 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

data Config m
type ConfigIO = Config IO
type StreamConnectCallback m = Response () -> m ()
data HttpBackend b = HttpBackend {
- _httpLbs :: Config b -> Request -> Maybe Manager -> b (Response ByteString)
- _httpResponseOpen :: Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))
- _httpResponseClose :: Response () -> b ()
}

Documentation

data Config m Source #

Instances

HasNakadiWorker (Config m) WorkerConfig
Instance details Defined in Network.Nakadi.Internal.Lenses Methods worker :: Lens' (Config m) WorkerConfig
HasNakadiRequestTemplate (Config m) Request
Instance details Defined in Network.Nakadi.Internal.Lenses Methods requestTemplate :: Lens' (Config m) Request
HasNakadiCommitStrategy (Config m) CommitStrategy
Instance details Defined in Network.Nakadi.Internal.Lenses Methods commitStrategy :: Lens' (Config m) CommitStrategy
HasNakadiSubscriptionStats (Config m) (Maybe SubscriptionStatsConf)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionStats :: Lens' (Config m) (Maybe SubscriptionStatsConf)
HasNakadiStreamTimeout (Config m) (Maybe Int32)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods streamTimeout :: Lens' (Config m) (Maybe Int32)
HasNakadiStreamLimit (Config m) (Maybe Int32)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods streamLimit :: Lens' (Config m) (Maybe Int32)
HasNakadiStreamKeepAliveLimit (Config m) (Maybe Int32)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods streamKeepAliveLimit :: Lens' (Config m) (Maybe Int32)
HasNakadiStreamConnectCallback (Config m) (Maybe (StreamConnectCallback m))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods streamConnectCallback :: Lens' (Config m) (Maybe (StreamConnectCallback m))
HasNakadiRetryPolicy (Config m) (RetryPolicyM IO)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods retryPolicy :: Lens' (Config m) (RetryPolicyM IO)
HasNakadiMaxUncommittedEvents (Config m) (Maybe Int32)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods maxUncommittedEvents :: Lens' (Config m) (Maybe Int32)
HasNakadiManager (Config m) (Maybe Manager)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods manager :: Lens' (Config m) (Maybe Manager)
HasNakadiLogFunc (Config m) (Maybe (LogFunc m))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods logFunc :: Lens' (Config m) (Maybe (LogFunc m))
HasNakadiHttpErrorCallback (Config m) (Maybe (HttpErrorCallback m))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpErrorCallback :: Lens' (Config m) (Maybe (HttpErrorCallback m))
HasNakadiHttp (Config m) (HttpBackend m)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods http :: Lens' (Config m) (HttpBackend m)
HasNakadiFlowId (Config m) (Maybe FlowId)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods flowId :: Lens' (Config m) (Maybe FlowId)
HasNakadiDeserializationFailureCallback (Config m) (Maybe (ByteString -> Text -> m ()))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods deserializationFailureCallback :: Lens' (Config m) (Maybe (ByteString -> Text -> m ()))
HasNakadiBatchLimit (Config m) (Maybe Int32)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods batchLimit :: Lens' (Config m) (Maybe Int32)
HasNakadiBatchFlushTimeout (Config m) (Maybe Int32)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods batchFlushTimeout :: Lens' (Config m) (Maybe Int32)
HasNakadiRequestModifier (Config m) (Request -> m Request)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods requestModifier :: Lens' (Config m) (Request -> m Request)
HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
Instance details Defined in Network.Nakadi.Internal.Lenses 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))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpLbs :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))

type ConfigIO = Config IO Source #

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)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods http :: Lens' (Config m) (HttpBackend m)
HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpResponseOpen :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
HasNakadiHttpResponseClose (HttpBackend b) (Response () -> b ())
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpResponseClose :: Lens' (HttpBackend b) (Response () -> b ())
HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpLbs :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))