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
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)
HasNakadiDeserializationFailureCallback Config (Maybe (ByteString -> IO ()))
Methods deserializationFailureCallback :: Lens' Config (Maybe (ByteString -> IO ()))
HasNakadiRequestModifier Config (Request -> IO Request)
Methods requestModifier :: Lens' Config (Request -> IO Request)

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