Copyright	(c) Moritz Schulte 2017
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 Source #

Instances

HasNakadiRequestTemplate Config Request
Methods requestTemplate :: Lens' Config Request
HasNakadiManager Config Manager
Methods manager :: Lens' Config Manager
HasNakadiHttp Config HttpBackend
Methods http :: Lens' Config HttpBackend
HasNakadiConsumeParameters Config ConsumeParameters
Methods consumeParameters :: Lens' Config ConsumeParameters
HasNakadiCtxConfig SubscriptionEventStreamContext Config
Methods ctxConfig :: Lens' SubscriptionEventStreamContext Config
HasNakadiStreamConnectCallback Config (Maybe StreamConnectCallback)
Methods streamConnectCallback :: Lens' Config (Maybe StreamConnectCallback)
HasNakadiRetryPolicy Config (RetryPolicyM IO)
Methods retryPolicy :: Lens' Config (RetryPolicyM IO)
HasNakadiLogFunc Config (Maybe LogFunc)
Methods logFunc :: Lens' Config (Maybe LogFunc)
HasNakadiHttpErrorCallback Config (Maybe HttpErrorCallback)
Methods httpErrorCallback :: Lens' Config (Maybe HttpErrorCallback)
HasNakadiDeserializationFailureCallback Config (Maybe (ByteString -> Text -> IO ()))
Methods deserializationFailureCallback :: Lens' Config (Maybe (ByteString -> Text -> IO ()))
HasNakadiRequestModifier Config (Request -> IO Request)
Methods requestModifier :: Lens' 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.

Constructors

HttpBackend
Fields _httpLbs :: Request -> IO (Response ByteString) _responseOpen :: Request -> Manager -> IO (Response BodyReader) _responseClose :: Response BodyReader -> IO ()

Instances

HasNakadiHttp Config HttpBackend
Methods http :: Lens' Config HttpBackend
HasNakadiResponseOpen HttpBackend (Request -> Manager -> IO (Response BodyReader))
Methods responseOpen :: Lens' HttpBackend (Request -> Manager -> IO (Response BodyReader))
HasNakadiResponseClose HttpBackend (Response BodyReader -> IO ())
Methods responseClose :: Lens' HttpBackend (Response BodyReader -> IO ())
HasNakadiHttpLbs HttpBackend (Request -> IO (Response ByteString))
Methods httpLbs :: Lens' HttpBackend (Request -> IO (Response ByteString))

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 #
HasNakadiConsumeParameters Config ConsumeParameters
Methods consumeParameters :: Lens' Config ConsumeParameters
HasNakadiFlowId ConsumeParameters (Maybe Text)
Methods flowId :: Lens' ConsumeParameters (Maybe Text)
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)

type StreamConnectCallback = Maybe LogFunc -> Response () -> IO () Source #

Config