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 Source #
Methods requestTemplate :: Lens' Config Request Source #
HasNakadiManager Config Manager Source #
Methods manager :: Lens' Config Manager Source #
HasNakadiConsumeParameters Config ConsumeParameters Source #
Methods consumeParameters :: Lens' Config ConsumeParameters Source #
HasNakadiCtxConfig SubscriptionEventStreamContext Config Source #
Methods ctxConfig :: Lens' SubscriptionEventStreamContext Config Source #
HasNakadiStreamConnectCallback Config (Maybe StreamConnectCallback) Source #
Methods streamConnectCallback :: Lens' Config (Maybe StreamConnectCallback) Source #
HasNakadiRetryPolicy Config (RetryPolicyM IO) Source #
Methods retryPolicy :: Lens' Config (RetryPolicyM IO) Source #
HasNakadiLogFunc Config (Maybe LogFunc) Source #
Methods logFunc :: Lens' Config (Maybe LogFunc) Source #
HasNakadiDeserializationFailureCallback Config (Maybe (ByteString -> IO ())) Source #
Methods deserializationFailureCallback :: Lens' Config (Maybe (ByteString -> IO ())) Source #
HasNakadiRequestModifier Config (Request -> IO Request) Source #
Methods requestModifier :: Lens' Config (Request -> IO Request) 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 #
HasNakadiConsumeParameters Config ConsumeParameters Source #
Methods consumeParameters :: Lens' Config ConsumeParameters Source #
HasNakadiStreamTimeout ConsumeParameters (Maybe Int32) Source #
Methods streamTimeout :: Lens' ConsumeParameters (Maybe Int32) Source #
HasNakadiStreamLimit ConsumeParameters (Maybe Int32) Source #
Methods streamLimit :: Lens' ConsumeParameters (Maybe Int32) Source #
HasNakadiStreamKeepAliveLimit ConsumeParameters (Maybe Int32) Source #
Methods streamKeepAliveLimit :: Lens' ConsumeParameters (Maybe Int32) Source #
HasNakadiMaxUncommittedEvents ConsumeParameters (Maybe Int32) Source #
Methods maxUncommittedEvents :: Lens' ConsumeParameters (Maybe Int32) Source #
HasNakadiFlowId ConsumeParameters (Maybe Text) Source #
Methods flowId :: Lens' ConsumeParameters (Maybe Text) Source #
HasNakadiBatchLimit ConsumeParameters (Maybe Int32) Source #
Methods batchLimit :: Lens' ConsumeParameters (Maybe Int32) Source #
HasNakadiBatchFlushTimeout ConsumeParameters (Maybe Int32) Source #
Methods batchFlushTimeout :: Lens' ConsumeParameters (Maybe Int32) Source #

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

Config