nakadi-client-0.4.0.0: Client library for the Nakadi Event Broker

Copyright(c) Moritz Schulte 2017
LicenseBSD3
Maintainermtesseract@silverratio.net
Stabilityexperimental
PortabilityPOSIX
Safe HaskellNone
LanguageHaskell2010

Network.Nakadi.Types.Config

Description

This module provides the Nakadi Config Types.

Synopsis

Documentation

data Config Source #

Instances

HasNakadiRequestTemplate Config Request 
HasNakadiManager Config Manager 
HasNakadiHttp Config HttpBackend 
HasNakadiConsumeParameters Config ConsumeParameters 
HasNakadiCtxConfig SubscriptionEventStreamContext Config 
HasNakadiStreamConnectCallback Config (Maybe StreamConnectCallback) 
HasNakadiRetryPolicy Config (RetryPolicyM IO) 
HasNakadiLogFunc Config (Maybe LogFunc) 
HasNakadiHttpErrorCallback Config (Maybe HttpErrorCallback) 
HasNakadiDeserializationFailureCallback Config (Maybe (ByteString -> Text -> IO ())) 
HasNakadiRequestModifier Config (Request -> IO Request) 

data HttpBackend Source #

Type encapsulating the HTTP backend functions used by this package. By default the corresponding functions from the http-client package are used. Useful, for e.g., testing.

Instances

HasNakadiHttp Config HttpBackend 
HasNakadiResponseOpen HttpBackend (Request -> Manager -> IO (Response BodyReader)) 
HasNakadiResponseClose HttpBackend (Response BodyReader -> IO ()) 
HasNakadiHttpLbs HttpBackend (Request -> IO (Response ByteString)) 

data ConsumeParameters Source #

ConsumeParameters

Instances

Eq ConsumeParameters Source # 
Ord ConsumeParameters Source # 
Show ConsumeParameters Source # 
HasNakadiConsumeParameters Config ConsumeParameters 
HasNakadiFlowId ConsumeParameters (Maybe Text) 
HasNakadiStreamTimeout ConsumeParameters (Maybe Int32) 
HasNakadiStreamLimit ConsumeParameters (Maybe Int32) 
HasNakadiStreamKeepAliveLimit ConsumeParameters (Maybe Int32) 
HasNakadiMaxUncommittedEvents ConsumeParameters (Maybe Int32) 
HasNakadiBatchLimit ConsumeParameters (Maybe Int32) 
HasNakadiBatchFlushTimeout ConsumeParameters (Maybe Int32)