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

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

Network.Nakadi.Internal.Http

Description

Internal module containing HTTP client relevant code.

Synopsis

Documentation

type StreamConnectCallback m = Response () -> m () Source #

Config

type HttpErrorCallback m = Request -> HttpException -> RetryStatus -> Bool -> m () Source #

Type synonym for user-provided callbacks which are used for HTTP Errror propagation.

data Config m where Source #

Instances

HasNakadiRequestTemplate (Config m) Request 
HasNakadiStreamConnectCallback (Config m) (Maybe (StreamConnectCallback m)) 
HasNakadiRetryPolicy (Config m) (RetryPolicyM IO) 
HasNakadiManager (Config m) (Maybe Manager) 

Methods

manager :: Lens' (Config m) (Maybe Manager)

HasNakadiLogFunc (Config m) (Maybe (LogFunc m)) 

Methods

logFunc :: Lens' (Config m) (Maybe (LogFunc m))

HasNakadiHttpErrorCallback (Config m) (Maybe (HttpErrorCallback m)) 
HasNakadiHttp (Config m) (HttpBackend m) 

Methods

http :: Lens' (Config m) (HttpBackend m)

HasNakadiFlowId (Config m) (Maybe FlowId) 

Methods

flowId :: Lens' (Config m) (Maybe FlowId)

HasNakadiDeserializationFailureCallback (Config m) (Maybe (ByteString -> Text -> m ())) 
HasNakadiConsumeParameters (Config m) (Maybe ConsumeParameters) 
HasNakadiRequestModifier (Config m) (Request -> m Request) 
HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))) 
HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString)) 

data ConsumeParameters Source #

ConsumeParameters

Instances

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

data HttpBackend b Source #

Instances

HasNakadiHttp (Config m) (HttpBackend m) 

Methods

http :: Lens' (Config m) (HttpBackend m)

HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))) 
HasNakadiHttpResponseClose (HttpBackend b) (Response () -> b ()) 

Methods

httpResponseClose :: Lens' (HttpBackend b) (Response () -> b ())

HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString)) 

type LogFunc m = LogSource -> LogLevel -> LogStr -> m () Source #

Type of a logger callback provided to nakadi-client for logging purposes.

type LogFuncIO = LogFunc IO Source #

LogFunc specialized to IO.

data Problem Source #

Type for RFC7807 Problem objects.

Instances

Eq Problem Source # 

Methods

(==) :: Problem -> Problem -> Bool #

(/=) :: Problem -> Problem -> Bool #

Show Problem Source # 
Generic Problem Source # 

Associated Types

type Rep Problem :: * -> * #

Methods

from :: Problem -> Rep Problem x #

to :: Rep Problem x -> Problem #

ToJSON Problem Source # 
FromJSON Problem Source # 
type Rep Problem Source # 

newtype CursorOffset Source #

Type for cursor offsets.

Constructors

CursorOffset 

Fields

Instances

Eq CursorOffset Source # 
Ord CursorOffset Source # 
Show CursorOffset Source # 
IsString CursorOffset Source # 
Generic CursorOffset Source # 

Associated Types

type Rep CursorOffset :: * -> * #

Hashable CursorOffset Source # 
ToJSON CursorOffset Source # 
FromJSON CursorOffset Source # 
HasNakadiOffset Cursor CursorOffset 
HasNakadiOldestAvailableOffset Partition CursorOffset 
HasNakadiNewestAvailableOffset Partition CursorOffset 
type Rep CursorOffset Source # 
type Rep CursorOffset = D1 * (MetaData "CursorOffset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "CursorOffset" PrefixI True) (S1 * (MetaSel (Just Symbol "unCursorOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

newtype EventTypeName Source #

Type for event type names.

Constructors

EventTypeName 

Fields

Instances

Eq EventTypeName Source # 
Ord EventTypeName Source # 
Show EventTypeName Source # 
IsString EventTypeName Source # 
Generic EventTypeName Source # 

Associated Types

type Rep EventTypeName :: * -> * #

Hashable EventTypeName Source # 
ToJSON EventTypeName Source # 
FromJSON EventTypeName Source # 
HasNakadiEventType EventMetadataEnriched EventTypeName 
HasNakadiName EventType EventTypeName 
HasNakadiEventTypes Subscription [EventTypeName] 
type Rep EventTypeName Source # 
type Rep EventTypeName = D1 * (MetaData "EventTypeName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "EventTypeName" PrefixI True) (S1 * (MetaSel (Just Symbol "unEventTypeName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

newtype PartitionName Source #

Type for partition names.

Constructors

PartitionName 

Fields

Instances

Eq PartitionName Source # 
Ord PartitionName Source # 
Show PartitionName Source # 
IsString PartitionName Source # 
Generic PartitionName Source # 

Associated Types

type Rep PartitionName :: * -> * #

Hashable PartitionName Source # 
ToJSON PartitionName Source # 
FromJSON PartitionName Source # 
HasNakadiPartition Cursor PartitionName 
HasNakadiPartition Partition PartitionName 
HasNakadiPartition EventMetadata (Maybe PartitionName) 
HasNakadiPartition EventMetadataEnriched (Maybe PartitionName) 
type Rep PartitionName Source # 
type Rep PartitionName = D1 * (MetaData "PartitionName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "PartitionName" PrefixI True) (S1 * (MetaSel (Just Symbol "unPartitionName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data Cursor Source #

Type for cursors.

Constructors

Cursor 

Instances

Eq Cursor Source # 

Methods

(==) :: Cursor -> Cursor -> Bool #

(/=) :: Cursor -> Cursor -> Bool #

Ord Cursor Source # 
Show Cursor Source # 
Generic Cursor Source # 

Associated Types

type Rep Cursor :: * -> * #

Methods

from :: Cursor -> Rep Cursor x #

to :: Rep Cursor x -> Cursor #

Hashable Cursor Source # 

Methods

hashWithSalt :: Int -> Cursor -> Int #

hash :: Cursor -> Int #

ToJSON Cursor Source # 
FromJSON Cursor Source # 
HasNakadiPartition Cursor PartitionName 
HasNakadiOffset Cursor CursorOffset 
HasNakadiInitialCursor CursorDistanceQuery Cursor 
HasNakadiFinalCursor CursorDistanceQuery Cursor 
HasNakadiItems CursorCommit [Cursor] 
HasNakadiCursor (EventStreamBatch a) Cursor 
type Rep Cursor Source # 
type Rep Cursor = D1 * (MetaData "Cursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "Cursor" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PartitionName)) (S1 * (MetaSel (Just Symbol "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * CursorOffset))))

newtype ApplicationName Source #

Type for application names.

Constructors

ApplicationName 

Instances

Eq ApplicationName Source # 
Ord ApplicationName Source # 
Show ApplicationName Source # 
IsString ApplicationName Source # 
Generic ApplicationName Source # 
Hashable ApplicationName Source # 
ToJSON ApplicationName Source # 
FromJSON ApplicationName Source # 
HasNakadiOwningApplication Subscription ApplicationName 
HasNakadiOwningApplication EventType (Maybe ApplicationName) 
type Rep ApplicationName Source # 
type Rep ApplicationName = D1 * (MetaData "ApplicationName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "ApplicationName" PrefixI True) (S1 * (MetaSel (Just Symbol "unApplicationName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data SubscriptionCursor Source #

Type fo rsubscription cursors.

Constructors

SubscriptionCursor 

Fields

Instances

Eq SubscriptionCursor Source # 
Ord SubscriptionCursor Source # 
Show SubscriptionCursor Source # 
Generic SubscriptionCursor Source # 
ToJSON SubscriptionCursor Source # 
FromJSON SubscriptionCursor Source # 
HasNakadiSubscriptionCursor SubscriptionCursor 
HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor] 
HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor 
type Rep SubscriptionCursor Source # 
type Rep SubscriptionCursor = D1 * (MetaData "SubscriptionCursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "SubscriptionCursor" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PartitionName)) (S1 * (MetaSel (Just Symbol "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * CursorOffset))) ((:*:) * (S1 * (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName)) (S1 * (MetaSel (Just Symbol "_cursorToken") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)))))

data SubscriptionCursorWithoutToken Source #

Type for subscription cursors without token.

Constructors

SubscriptionCursorWithoutToken 

Fields

Instances

Eq SubscriptionCursorWithoutToken Source # 
Ord SubscriptionCursorWithoutToken Source # 
Show SubscriptionCursorWithoutToken Source # 
Generic SubscriptionCursorWithoutToken Source # 
Hashable SubscriptionCursorWithoutToken Source # 
ToJSON SubscriptionCursorWithoutToken Source # 
FromJSON SubscriptionCursorWithoutToken Source # 
HasNakadiInitialCursors Subscription (Maybe [SubscriptionCursorWithoutToken]) 
type Rep SubscriptionCursorWithoutToken Source # 
type Rep SubscriptionCursorWithoutToken = D1 * (MetaData "SubscriptionCursorWithoutToken" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "SubscriptionCursorWithoutToken" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PartitionName)) ((:*:) * (S1 * (MetaSel (Just Symbol "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * CursorOffset)) (S1 * (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName)))))

newtype SubscriptionCursorCommit Source #

Type for commit object for subscription cursor committing.

Constructors

SubscriptionCursorCommit 

Fields

newtype CursorCommit Source #

Type for commit objects for cursor committing.

Constructors

CursorCommit 

Fields

newtype SubscriptionId Source #

Type for subscription IDs.

Constructors

SubscriptionId 

Fields

Instances

Eq SubscriptionId Source # 
Ord SubscriptionId Source # 
Show SubscriptionId Source # 
Generic SubscriptionId Source # 

Associated Types

type Rep SubscriptionId :: * -> * #

Hashable SubscriptionId Source # 
ToJSON SubscriptionId Source # 
FromJSON SubscriptionId Source # 
HasNakadiSubscriptionId SubscriptionEventStream SubscriptionId 
HasNakadiId SubscriptionId UUID 
HasNakadiId Subscription (Maybe SubscriptionId) 
type Rep SubscriptionId Source # 
type Rep SubscriptionId = D1 * (MetaData "SubscriptionId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "SubscriptionId" PrefixI True) (S1 * (MetaSel (Just Symbol "unSubscriptionId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * UUID)))

newtype StreamId Source #

Type for stream IDs.

Constructors

StreamId 

Fields

newtype Timestamp Source #

Type for timestamps.

Constructors

Timestamp 

Fields

Instances

Eq Timestamp Source # 
Ord Timestamp Source # 
Show Timestamp Source # 
Generic Timestamp Source # 

Associated Types

type Rep Timestamp :: * -> * #

Hashable Timestamp Source # 
ToJSON Timestamp Source # 
FromJSON Timestamp Source # 
HasNakadiOccurredAt EventMetadata Timestamp 
HasNakadiOccurredAt EventMetadataEnriched Timestamp 
HasNakadiReceivedAt EventMetadataEnriched Timestamp 
HasNakadiUTCTime Timestamp UTCTime 
HasNakadiCreatedAt Subscription (Maybe Timestamp) 
HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp) 
type Rep Timestamp Source # 
type Rep Timestamp = D1 * (MetaData "Timestamp" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "Timestamp" PrefixI True) (S1 * (MetaSel (Just Symbol "unTimestamp") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * UTCTime)))

newtype FlowId Source #

A Flow ID.

Constructors

FlowId 

Fields

Instances

Eq FlowId Source # 

Methods

(==) :: FlowId -> FlowId -> Bool #

(/=) :: FlowId -> FlowId -> Bool #

Ord FlowId Source # 
Show FlowId Source # 
IsString FlowId Source # 

Methods

fromString :: String -> FlowId #

Generic FlowId Source # 

Associated Types

type Rep FlowId :: * -> * #

Methods

from :: FlowId -> Rep FlowId x #

to :: Rep FlowId x -> FlowId #

ToJSON FlowId Source # 
FromJSON FlowId Source # 
HasNakadiFlowId EventMetadataEnriched (Maybe FlowId) 
HasNakadiFlowId (Config m) (Maybe FlowId) 

Methods

flowId :: Lens' (Config m) (Maybe FlowId)

type Rep FlowId Source # 
type Rep FlowId = D1 * (MetaData "FlowId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "FlowId" PrefixI True) (S1 * (MetaSel (Just Symbol "unFlowId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

newtype EventId Source #

ID of an Event

Constructors

EventId 

Fields

Instances

Eq EventId Source # 

Methods

(==) :: EventId -> EventId -> Bool #

(/=) :: EventId -> EventId -> Bool #

Ord EventId Source # 
Show EventId Source # 
Generic EventId Source # 

Associated Types

type Rep EventId :: * -> * #

Methods

from :: EventId -> Rep EventId x #

to :: Rep EventId x -> EventId #

Hashable EventId Source # 

Methods

hashWithSalt :: Int -> EventId -> Int #

hash :: EventId -> Int #

ToJSON EventId Source # 
FromJSON EventId Source # 
HasNakadiEid EventMetadata EventId 
HasNakadiEid EventMetadataEnriched EventId 
HasNakadiId EventId UUID 

Methods

id :: Lens' EventId UUID

HasNakadiParentEids EventMetadata (Maybe [EventId]) 
HasNakadiParentEids EventMetadataEnriched (Maybe [EventId]) 
type Rep EventId Source # 
type Rep EventId = D1 * (MetaData "EventId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "EventId" PrefixI True) (S1 * (MetaSel (Just Symbol "unEventId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * UUID)))

data Partition Source #

Partition Data

Constructors

Partition 

Fields

data CursorDistanceQuery Source #

Type for cursor-distance queries. Represents the request to compute the distance between initial cursor and final cursor.

Constructors

CursorDistanceQuery 

Fields

Instances

Eq CursorDistanceQuery Source # 
Ord CursorDistanceQuery Source # 
Show CursorDistanceQuery Source # 
Generic CursorDistanceQuery Source # 
Hashable CursorDistanceQuery Source # 
ToJSON CursorDistanceQuery Source # 
FromJSON CursorDistanceQuery Source # 
HasNakadiInitialCursor CursorDistanceQuery Cursor 
HasNakadiFinalCursor CursorDistanceQuery Cursor 
type Rep CursorDistanceQuery Source # 
type Rep CursorDistanceQuery = D1 * (MetaData "CursorDistanceQuery" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "CursorDistanceQuery" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_initialCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Cursor)) (S1 * (MetaSel (Just Symbol "_finalCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Cursor))))

newtype CursorDistanceResult Source #

Type for results of cursor-distance-queries.

Constructors

CursorDistanceResult 

Fields

Instances

Eq CursorDistanceResult Source # 
Ord CursorDistanceResult Source # 
Show CursorDistanceResult Source # 
Generic CursorDistanceResult Source # 
Hashable CursorDistanceResult Source # 
ToJSON CursorDistanceResult Source # 
FromJSON CursorDistanceResult Source # 
HasNakadiDistance CursorDistanceResult Int64 
type Rep CursorDistanceResult Source # 
type Rep CursorDistanceResult = D1 * (MetaData "CursorDistanceResult" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "CursorDistanceResult" PrefixI True) (S1 * (MetaSel (Just Symbol "_distance") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int64)))

data SubscriptionPosition Source #

Type for subscription positions.

Instances

Eq SubscriptionPosition Source # 
Ord SubscriptionPosition Source # 
Show SubscriptionPosition Source # 
Generic SubscriptionPosition Source # 
Hashable SubscriptionPosition Source # 
ToJSON SubscriptionPosition Source # 
FromJSON SubscriptionPosition Source # 
HasNakadiReadFrom Subscription (Maybe SubscriptionPosition) 
type Rep SubscriptionPosition Source # 
type Rep SubscriptionPosition = D1 * (MetaData "SubscriptionPosition" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) ((:+:) * (C1 * (MetaCons "SubscriptionPositionBegin" PrefixI False) (U1 *)) ((:+:) * (C1 * (MetaCons "SubscriptionPositionEnd" PrefixI False) (U1 *)) (C1 * (MetaCons "SubscriptionPositionCursors" PrefixI False) (U1 *))))

data Subscription Source #

Type for a Subscription.

Instances

Eq Subscription Source # 
Ord Subscription Source # 
Show Subscription Source # 
Generic Subscription Source # 

Associated Types

type Rep Subscription :: * -> * #

Hashable Subscription Source # 
ToJSON Subscription Source # 
FromJSON Subscription Source # 
HasNakadiOwningApplication Subscription ApplicationName 
HasNakadiCreatedAt Subscription (Maybe Timestamp) 
HasNakadiItems SubscriptionsListResponse [Subscription] 
HasNakadiReadFrom Subscription (Maybe SubscriptionPosition) 
HasNakadiInitialCursors Subscription (Maybe [SubscriptionCursorWithoutToken]) 
HasNakadiId Subscription (Maybe SubscriptionId) 
HasNakadiEventTypes Subscription [EventTypeName] 
HasNakadiConsumerGroup Subscription (Maybe Text) 
type Rep Subscription Source # 

data PublishingStatus Source #

Type for publishing status.

Instances

Eq PublishingStatus Source # 
Ord PublishingStatus Source # 
Show PublishingStatus Source # 
Generic PublishingStatus Source # 
Hashable PublishingStatus Source # 
ToJSON PublishingStatus Source # 
FromJSON PublishingStatus Source # 
type Rep PublishingStatus Source # 
type Rep PublishingStatus = D1 * (MetaData "PublishingStatus" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) ((:+:) * (C1 * (MetaCons "PublishingStatusSubmitted" PrefixI False) (U1 *)) ((:+:) * (C1 * (MetaCons "PublishingStatusFailed" PrefixI False) (U1 *)) (C1 * (MetaCons "PublishingStatusAborted" PrefixI False) (U1 *))))

data Step Source #

Step

Instances

Eq Step Source # 

Methods

(==) :: Step -> Step -> Bool #

(/=) :: Step -> Step -> Bool #

Ord Step Source # 

Methods

compare :: Step -> Step -> Ordering #

(<) :: Step -> Step -> Bool #

(<=) :: Step -> Step -> Bool #

(>) :: Step -> Step -> Bool #

(>=) :: Step -> Step -> Bool #

max :: Step -> Step -> Step #

min :: Step -> Step -> Step #

Show Step Source # 

Methods

showsPrec :: Int -> Step -> ShowS #

show :: Step -> String #

showList :: [Step] -> ShowS #

Generic Step Source # 

Associated Types

type Rep Step :: * -> * #

Methods

from :: Step -> Rep Step x #

to :: Rep Step x -> Step #

Hashable Step Source # 

Methods

hashWithSalt :: Int -> Step -> Int #

hash :: Step -> Int #

ToJSON Step Source # 
FromJSON Step Source # 
type Rep Step Source # 
type Rep Step = D1 * (MetaData "Step" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) ((:+:) * ((:+:) * (C1 * (MetaCons "StepNone" PrefixI False) (U1 *)) (C1 * (MetaCons "StepValidating" PrefixI False) (U1 *))) ((:+:) * (C1 * (MetaCons "StepPartitioning" PrefixI False) (U1 *)) ((:+:) * (C1 * (MetaCons "StepEnriching" PrefixI False) (U1 *)) (C1 * (MetaCons "StepPublishing" PrefixI False) (U1 *)))))

data BatchItemResponse Source #

In case of failures during batch publishing, Nakadi returns detailed information about which events failed to be published. This per-event information is a batch item response.

Instances

Eq BatchItemResponse Source # 
Ord BatchItemResponse Source # 
Show BatchItemResponse Source # 
Generic BatchItemResponse Source # 
Hashable BatchItemResponse Source # 
ToJSON BatchItemResponse Source # 
FromJSON BatchItemResponse Source # 
type Rep BatchItemResponse Source # 
type Rep BatchItemResponse = D1 * (MetaData "BatchItemResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "BatchItemResponse" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe EventId))) (S1 * (MetaSel (Just Symbol "_publishingStatus") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PublishingStatus))) ((:*:) * (S1 * (MetaSel (Just Symbol "_step") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe Step))) (S1 * (MetaSel (Just Symbol "_detail") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe Text))))))

data SchemaType Source #

SchemaType

Constructors

SchemaTypeJson 

Instances

Eq SchemaType Source # 
Ord SchemaType Source # 
Show SchemaType Source # 
Generic SchemaType Source # 

Associated Types

type Rep SchemaType :: * -> * #

Hashable SchemaType Source # 
ToJSON SchemaType Source # 
FromJSON SchemaType Source # 
HasNakadiSchemaType EventTypeSchema SchemaType 
type Rep SchemaType Source # 
type Rep SchemaType = D1 * (MetaData "SchemaType" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "SchemaTypeJson" PrefixI False) (U1 *))

newtype SchemaVersion Source #

Type for the version of a schema.

Constructors

SchemaVersion 

Instances

Eq SchemaVersion Source # 
Ord SchemaVersion Source # 
Show SchemaVersion Source # 
IsString SchemaVersion Source # 
Generic SchemaVersion Source # 

Associated Types

type Rep SchemaVersion :: * -> * #

Hashable SchemaVersion Source # 
ToJSON SchemaVersion Source # 
FromJSON SchemaVersion Source # 
HasNakadiVersion EventMetadataEnriched SchemaVersion 
HasNakadiVersion EventTypeSchema (Maybe SchemaVersion) 
type Rep SchemaVersion Source # 
type Rep SchemaVersion = D1 * (MetaData "SchemaVersion" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "SchemaVersion" PrefixI True) (S1 * (MetaSel (Just Symbol "unSchemaVersion") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data EventTypeSchema Source #

Type for the schema of an event type.

Instances

Eq EventTypeSchema Source # 
Ord EventTypeSchema Source # 
Show EventTypeSchema Source # 
Generic EventTypeSchema Source # 
Hashable EventTypeSchema Source # 
ToJSON EventTypeSchema Source # 
FromJSON EventTypeSchema Source # 
HasNakadiSchemaType EventTypeSchema SchemaType 
HasNakadiSchema EventTypeSchema Text 
HasNakadiSchema EventType EventTypeSchema 
HasNakadiVersion EventTypeSchema (Maybe SchemaVersion) 
HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp) 
HasNakadiItems EventTypeSchemasResponse [EventTypeSchema] 
type Rep EventTypeSchema Source # 
type Rep EventTypeSchema = D1 * (MetaData "EventTypeSchema" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EventTypeSchema" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_version") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe SchemaVersion))) (S1 * (MetaSel (Just Symbol "_createdAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe Timestamp)))) ((:*:) * (S1 * (MetaSel (Just Symbol "_schemaType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * SchemaType)) (S1 * (MetaSel (Just Symbol "_schema") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)))))

newtype PaginationLink Source #

PaginationLink

Constructors

PaginationLink 

Fields

data PaginationLinks Source #

PaginationLinks

data EventTypeSchemasResponse Source #

EventTypeSchemasResponse

Instances

Eq EventTypeSchemasResponse Source # 
Ord EventTypeSchemasResponse Source # 
Show EventTypeSchemasResponse Source # 
Generic EventTypeSchemasResponse Source # 
Hashable EventTypeSchemasResponse Source # 
ToJSON EventTypeSchemasResponse Source # 
FromJSON EventTypeSchemasResponse Source # 
HasNakadiLinks EventTypeSchemasResponse PaginationLinks 
HasNakadiItems EventTypeSchemasResponse [EventTypeSchema] 
type Rep EventTypeSchemasResponse Source # 
type Rep EventTypeSchemasResponse = D1 * (MetaData "EventTypeSchemasResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EventTypeSchemasResponse" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PaginationLinks)) (S1 * (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * [EventTypeSchema]))))

data SubscriptionsListResponse Source #

SubscriptionsListResponse

Instances

Eq SubscriptionsListResponse Source # 
Ord SubscriptionsListResponse Source # 
Show SubscriptionsListResponse Source # 
Generic SubscriptionsListResponse Source # 
Hashable SubscriptionsListResponse Source # 
ToJSON SubscriptionsListResponse Source # 
FromJSON SubscriptionsListResponse Source # 
HasNakadiLinks SubscriptionsListResponse PaginationLinks 
HasNakadiItems SubscriptionsListResponse [Subscription] 
type Rep SubscriptionsListResponse Source # 
type Rep SubscriptionsListResponse = D1 * (MetaData "SubscriptionsListResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "SubscriptionsListResponse" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PaginationLinks)) (S1 * (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * [Subscription]))))

newtype Offset Source #

Type for offset values.

Constructors

Offset 

Fields

Instances

Eq Offset Source # 

Methods

(==) :: Offset -> Offset -> Bool #

(/=) :: Offset -> Offset -> Bool #

Ord Offset Source # 
Show Offset Source # 
Generic Offset Source # 

Associated Types

type Rep Offset :: * -> * #

Methods

from :: Offset -> Rep Offset x #

to :: Rep Offset x -> Offset #

Hashable Offset Source # 

Methods

hashWithSalt :: Int -> Offset -> Int #

hash :: Offset -> Int #

type Rep Offset Source # 
type Rep Offset = D1 * (MetaData "Offset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "Offset" PrefixI True) (S1 * (MetaSel (Just Symbol "unOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int64)))

newtype Limit Source #

Type for limit values.

Constructors

Limit 

Fields

Instances

Eq Limit Source # 

Methods

(==) :: Limit -> Limit -> Bool #

(/=) :: Limit -> Limit -> Bool #

Ord Limit Source # 

Methods

compare :: Limit -> Limit -> Ordering #

(<) :: Limit -> Limit -> Bool #

(<=) :: Limit -> Limit -> Bool #

(>) :: Limit -> Limit -> Bool #

(>=) :: Limit -> Limit -> Bool #

max :: Limit -> Limit -> Limit #

min :: Limit -> Limit -> Limit #

Show Limit Source # 

Methods

showsPrec :: Int -> Limit -> ShowS #

show :: Limit -> String #

showList :: [Limit] -> ShowS #

Generic Limit Source # 

Associated Types

type Rep Limit :: * -> * #

Methods

from :: Limit -> Rep Limit x #

to :: Rep Limit x -> Limit #

Hashable Limit Source # 

Methods

hashWithSalt :: Int -> Limit -> Int #

hash :: Limit -> Int #

type Rep Limit Source # 
type Rep Limit = D1 * (MetaData "Limit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "Limit" PrefixI True) (S1 * (MetaSel (Just Symbol "unLimit") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int64)))

data PartitionStat Source #

Type for per-partition statistics.

Instances

Eq PartitionStat Source # 
Ord PartitionStat Source # 
Show PartitionStat Source # 
Generic PartitionStat Source # 

Associated Types

type Rep PartitionStat :: * -> * #

ToJSON PartitionStat Source # 
FromJSON PartitionStat Source # 
type Rep PartitionStat Source # 
type Rep PartitionStat = D1 * (MetaData "PartitionStat" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "PartitionStat" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PartitionName)) (S1 * (MetaSel (Just Symbol "_state") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PartitionState))) ((:*:) * (S1 * (MetaSel (Just Symbol "_unconsumedEvents") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64)) (S1 * (MetaSel (Just Symbol "_streamId") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * StreamId)))))

data SubscriptionEventTypeStats Source #

Nakadi type SubscriptionEventTypeStats.

Instances

Eq SubscriptionEventTypeStats Source # 
Ord SubscriptionEventTypeStats Source # 
Show SubscriptionEventTypeStats Source # 
Generic SubscriptionEventTypeStats Source # 
ToJSON SubscriptionEventTypeStats Source # 
FromJSON SubscriptionEventTypeStats Source # 
HasNakadiItems SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats] 
type Rep SubscriptionEventTypeStats Source # 
type Rep SubscriptionEventTypeStats = D1 * (MetaData "SubscriptionEventTypeStats" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "SubscriptionEventTypeStats" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName)) (S1 * (MetaSel (Just Symbol "_partitions") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * [PartitionStat]))))

newtype SubscriptionEventTypeStatsResult Source #

SubscriptionEventTypeStatsResult

Instances

Eq SubscriptionEventTypeStatsResult Source # 
Ord SubscriptionEventTypeStatsResult Source # 
Show SubscriptionEventTypeStatsResult Source # 
Generic SubscriptionEventTypeStatsResult Source # 
ToJSON SubscriptionEventTypeStatsResult Source # 
FromJSON SubscriptionEventTypeStatsResult Source # 
HasNakadiItems SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats] 
type Rep SubscriptionEventTypeStatsResult Source # 
type Rep SubscriptionEventTypeStatsResult = D1 * (MetaData "SubscriptionEventTypeStatsResult" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "SubscriptionEventTypeStatsResult" PrefixI True) (S1 * (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [SubscriptionEventTypeStats])))

data EventTypeCategory Source #

Type for the category of an EventType.

Instances

Eq EventTypeCategory Source # 
Ord EventTypeCategory Source # 
Show EventTypeCategory Source # 
Generic EventTypeCategory Source # 
Hashable EventTypeCategory Source # 
ToJSON EventTypeCategory Source # 
FromJSON EventTypeCategory Source # 
HasNakadiCategory EventType (Maybe EventTypeCategory) 
type Rep EventTypeCategory Source # 
type Rep EventTypeCategory = D1 * (MetaData "EventTypeCategory" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) ((:+:) * (C1 * (MetaCons "EventTypeCategoryUndefined" PrefixI False) (U1 *)) ((:+:) * (C1 * (MetaCons "EventTypeCategoryData" PrefixI False) (U1 *)) (C1 * (MetaCons "EventTypeCategoryBusiness" PrefixI False) (U1 *))))

data PartitionStrategy Source #

Type for a partitioning strategy.

Instances

Eq PartitionStrategy Source # 
Ord PartitionStrategy Source # 
Show PartitionStrategy Source # 
IsString PartitionStrategy Source # 
Generic PartitionStrategy Source # 
Hashable PartitionStrategy Source # 
ToJSON PartitionStrategy Source # 
FromJSON PartitionStrategy Source # 
HasNakadiPartitionStrategy EventType (Maybe PartitionStrategy) 
type Rep PartitionStrategy Source # 
type Rep PartitionStrategy = D1 * (MetaData "PartitionStrategy" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) ((:+:) * ((:+:) * (C1 * (MetaCons "PartitionStrategyRandom" PrefixI False) (U1 *)) (C1 * (MetaCons "PartitionStrategyUser" PrefixI False) (U1 *))) ((:+:) * (C1 * (MetaCons "PartitionStrategyHash" PrefixI False) (U1 *)) (C1 * (MetaCons "PartitionStrategyCustom" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)))))

data EnrichmentStrategy Source #

Type for an enrichment stragey.

Instances

Eq EnrichmentStrategy Source # 
Ord EnrichmentStrategy Source # 
Show EnrichmentStrategy Source # 
Generic EnrichmentStrategy Source # 
Hashable EnrichmentStrategy Source # 
ToJSON EnrichmentStrategy Source # 
FromJSON EnrichmentStrategy Source # 
HasNakadiEnrichmentStrategies EventType (Maybe [EnrichmentStrategy]) 
type Rep EnrichmentStrategy Source # 
type Rep EnrichmentStrategy = D1 * (MetaData "EnrichmentStrategy" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EnrichmentStrategyMetadata" PrefixI False) (U1 *))

data CompatibilityMode Source #

Type for an event type compatibility mode.

Instances

Eq CompatibilityMode Source # 
Ord CompatibilityMode Source # 
Show CompatibilityMode Source # 
Generic CompatibilityMode Source # 
Hashable CompatibilityMode Source # 
ToJSON CompatibilityMode Source # 
FromJSON CompatibilityMode Source # 
HasNakadiCompatibilityMode EventType (Maybe CompatibilityMode) 
type Rep CompatibilityMode Source # 
type Rep CompatibilityMode = D1 * (MetaData "CompatibilityMode" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) ((:+:) * (C1 * (MetaCons "CompatibilityModeCompatible" PrefixI False) (U1 *)) ((:+:) * (C1 * (MetaCons "CompatibilityModeForward" PrefixI False) (U1 *)) (C1 * (MetaCons "CompatibilityModeNone" PrefixI False) (U1 *))))

newtype PartitionKeyField Source #

Type for a partitioning key field.

Instances

Eq PartitionKeyField Source # 
Ord PartitionKeyField Source # 
Show PartitionKeyField Source # 
IsString PartitionKeyField Source # 
Generic PartitionKeyField Source # 
Hashable PartitionKeyField Source # 
ToJSON PartitionKeyField Source # 
FromJSON PartitionKeyField Source # 
HasNakadiPartitionKeyFields EventType (Maybe [PartitionKeyField]) 
type Rep PartitionKeyField Source # 
type Rep PartitionKeyField = D1 * (MetaData "PartitionKeyField" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" True) (C1 * (MetaCons "PartitionKeyField" PrefixI True) (S1 * (MetaSel (Just Symbol "unPartitionKeyField") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data EventTypeStatistics Source #

Type for event type statistics.

Instances

Eq EventTypeStatistics Source # 
Ord EventTypeStatistics Source # 
Show EventTypeStatistics Source # 
Generic EventTypeStatistics Source # 
Hashable EventTypeStatistics Source # 
ToJSON EventTypeStatistics Source # 
FromJSON EventTypeStatistics Source # 
HasNakadiDefaultStatistic EventType (Maybe EventTypeStatistics) 
type Rep EventTypeStatistics Source # 
type Rep EventTypeStatistics = D1 * (MetaData "EventTypeStatistics" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EventTypeStatistics" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_messagesPerMinute") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64)) (S1 * (MetaSel (Just Symbol "_messageSize") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64))) ((:*:) * (S1 * (MetaSel (Just Symbol "_readParallelism") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64)) (S1 * (MetaSel (Just Symbol "_writeParallelism") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64)))))

data EventTypeOptions Source #

Type for event type options.

Constructors

EventTypeOptions 

Instances

Eq EventTypeOptions Source # 
Ord EventTypeOptions Source # 
Show EventTypeOptions Source # 
Generic EventTypeOptions Source # 
Hashable EventTypeOptions Source # 
ToJSON EventTypeOptions Source # 
FromJSON EventTypeOptions Source # 
HasNakadiOptions EventType (Maybe EventTypeOptions) 
type Rep EventTypeOptions Source # 
type Rep EventTypeOptions = D1 * (MetaData "EventTypeOptions" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EventTypeOptions" PrefixI True) (S1 * (MetaSel (Just Symbol "_retentionTime") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64)))

data EventType Source #

EventType

Instances

Eq EventType Source # 
Ord EventType Source # 
Show EventType Source # 
Generic EventType Source # 

Associated Types

type Rep EventType :: * -> * #

Hashable EventType Source # 
ToJSON EventType Source # 
FromJSON EventType Source # 
HasNakadiSchema EventType EventTypeSchema 
HasNakadiName EventType EventTypeName 
HasNakadiPartitionStrategy EventType (Maybe PartitionStrategy) 
HasNakadiPartitionKeyFields EventType (Maybe [PartitionKeyField]) 
HasNakadiOwningApplication EventType (Maybe ApplicationName) 
HasNakadiOptions EventType (Maybe EventTypeOptions) 
HasNakadiEnrichmentStrategies EventType (Maybe [EnrichmentStrategy]) 
HasNakadiDefaultStatistic EventType (Maybe EventTypeStatistics) 
HasNakadiCompatibilityMode EventType (Maybe CompatibilityMode) 
HasNakadiCategory EventType (Maybe EventTypeCategory) 
type Rep EventType Source # 
type Rep EventType = D1 * (MetaData "EventType" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EventType" PrefixI True) ((:*:) * ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_name") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName)) (S1 * (MetaSel (Just Symbol "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe ApplicationName)))) ((:*:) * (S1 * (MetaSel (Just Symbol "_category") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe EventTypeCategory))) ((:*:) * (S1 * (MetaSel (Just Symbol "_enrichmentStrategies") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [EnrichmentStrategy]))) (S1 * (MetaSel (Just Symbol "_partitionStrategy") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PartitionStrategy)))))) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_compatibilityMode") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe CompatibilityMode))) (S1 * (MetaSel (Just Symbol "_schema") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeSchema))) ((:*:) * (S1 * (MetaSel (Just Symbol "_partitionKeyFields") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [PartitionKeyField]))) ((:*:) * (S1 * (MetaSel (Just Symbol "_defaultStatistic") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe EventTypeStatistics))) (S1 * (MetaSel (Just Symbol "_options") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe EventTypeOptions))))))))

data EventMetadata Source #

Type of published event metadata values.

Instances

Eq EventMetadata Source # 
Show EventMetadata Source # 
Generic EventMetadata Source # 

Associated Types

type Rep EventMetadata :: * -> * #

ToJSON EventMetadata Source # 
FromJSON EventMetadata Source # 
HasNakadiOccurredAt EventMetadata Timestamp 
HasNakadiEid EventMetadata EventId 
HasNakadiPartition EventMetadata (Maybe PartitionName) 
HasNakadiParentEids EventMetadata (Maybe [EventId]) 
HasNakadiMetadata (DataChangeEvent a) EventMetadata 
type Rep EventMetadata Source # 
type Rep EventMetadata = D1 * (MetaData "EventMetadata" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EventMetadata" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventId)) (S1 * (MetaSel (Just Symbol "_occurredAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Timestamp))) ((:*:) * (S1 * (MetaSel (Just Symbol "_parentEids") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [EventId]))) (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PartitionName))))))

data EventMetadataEnriched Source #

Type of event metadata enriched by Nakadi

Instances

Eq EventMetadataEnriched Source # 
Show EventMetadataEnriched Source # 
Generic EventMetadataEnriched Source # 
ToJSON EventMetadataEnriched Source # 
FromJSON EventMetadataEnriched Source # 
HasNakadiOccurredAt EventMetadataEnriched Timestamp 
HasNakadiEid EventMetadataEnriched EventId 
HasNakadiVersion EventMetadataEnriched SchemaVersion 
HasNakadiReceivedAt EventMetadataEnriched Timestamp 
HasNakadiEventType EventMetadataEnriched EventTypeName 
HasNakadiFlowId EventMetadataEnriched (Maybe FlowId) 
HasNakadiPartition EventMetadataEnriched (Maybe PartitionName) 
HasNakadiParentEids EventMetadataEnriched (Maybe [EventId]) 
HasNakadiMetadata (DataChangeEventEnriched a) EventMetadataEnriched 
type Rep EventMetadataEnriched Source # 

data EventStreamBatch a Source #

EventStreamBatch

Constructors

EventStreamBatch 

Fields

Instances

Show a => Show (EventStreamBatch a) Source # 
Generic (EventStreamBatch a) Source # 

Associated Types

type Rep (EventStreamBatch a) :: * -> * #

ToJSON a => ToJSON (EventStreamBatch a) Source # 
FromJSON a => FromJSON (EventStreamBatch a) Source # 
HasNakadiCursor (EventStreamBatch a) Cursor 
HasNakadiEvents (EventStreamBatch a) (Maybe (Vector a)) 
type Rep (EventStreamBatch a) Source # 
type Rep (EventStreamBatch a) = D1 * (MetaData "EventStreamBatch" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "EventStreamBatch" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_cursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Cursor)) (S1 * (MetaSel (Just Symbol "_events") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe (Vector a))))))

data SubscriptionEventStreamBatch a Source #

SubscriptionEventStreamBatch

Constructors

SubscriptionEventStreamBatch 

Fields

Instances

Show a => Show (SubscriptionEventStreamBatch a) Source # 
Generic (SubscriptionEventStreamBatch a) Source # 
ToJSON a => ToJSON (SubscriptionEventStreamBatch a) Source # 
FromJSON a => FromJSON (SubscriptionEventStreamBatch a) Source # 
HasNakadiSubscriptionCursor (SubscriptionEventStreamBatch a) 
HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor 
HasNakadiEvents (SubscriptionEventStreamBatch a) (Maybe (Vector a)) 
type Rep (SubscriptionEventStreamBatch a) Source # 
type Rep (SubscriptionEventStreamBatch a) = D1 * (MetaData "SubscriptionEventStreamBatch" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "SubscriptionEventStreamBatch" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_cursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * SubscriptionCursor)) (S1 * (MetaSel (Just Symbol "_events") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe (Vector a))))))

data DataChangeEvent a Source #

DataChangeEvent

Instances

Eq a => Eq (DataChangeEvent a) Source # 
Show a => Show (DataChangeEvent a) Source # 
Generic (DataChangeEvent a) Source # 

Associated Types

type Rep (DataChangeEvent a) :: * -> * #

ToJSON a => ToJSON (DataChangeEvent a) Source # 
FromJSON a => FromJSON (DataChangeEvent a) Source # 
HasNakadiPayload (DataChangeEvent a) a 

Methods

payload :: Lens' (DataChangeEvent a) a

HasNakadiMetadata (DataChangeEvent a) EventMetadata 
HasNakadiDataType (DataChangeEvent a) Text 
HasNakadiDataOp (DataChangeEvent a) DataOp 
type Rep (DataChangeEvent a) Source # 
type Rep (DataChangeEvent a) = D1 * (MetaData "DataChangeEvent" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "DataChangeEvent" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * a)) (S1 * (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventMetadata))) ((:*:) * (S1 * (MetaSel (Just Symbol "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * DataOp)))))

data DataChangeEventEnriched a Source #

A DataChangeEvent enriched by Nakadi

Instances

Eq a => Eq (DataChangeEventEnriched a) Source # 
Show a => Show (DataChangeEventEnriched a) Source # 
Generic (DataChangeEventEnriched a) Source # 
ToJSON a => ToJSON (DataChangeEventEnriched a) Source # 
FromJSON a => FromJSON (DataChangeEventEnriched a) Source # 
HasNakadiPayload (DataChangeEventEnriched a) a 
HasNakadiMetadata (DataChangeEventEnriched a) EventMetadataEnriched 
HasNakadiDataType (DataChangeEventEnriched a) Text 
HasNakadiDataOp (DataChangeEventEnriched a) DataOp 
type Rep (DataChangeEventEnriched a) Source # 
type Rep (DataChangeEventEnriched a) = D1 * (MetaData "DataChangeEventEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.5.0.3-FliWKIVjIrpBm3vSGSpVnv" False) (C1 * (MetaCons "DataChangeEventEnriched" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * a)) (S1 * (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventMetadataEnriched))) ((:*:) * (S1 * (MetaSel (Just Symbol "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * DataOp)))))

makeFieldRenamer :: [(String, String)] -> String -> String Source #

Construct a field renamer function from a field renamer map.

parseUUID :: String -> (UUID -> a) -> Value -> Parser a Source #

parseInteger :: (Integral i, Bounded i) => String -> (i -> a) -> Value -> Parser a Source #

class (Monad b, Monad m) => MonadNakadiBase b m where Source #

Methods

nakadiLiftBase :: b a -> m a Source #

nakadiLiftBase :: (MonadNakadiBase b n, MonadTrans t, m ~ t n) => b a -> m a Source #

Instances

MonadNakadiBase IO IO Source # 

Methods

nakadiLiftBase :: IO a -> IO a Source #

MonadNakadiBase b m => MonadNakadiBase b (ResourceT m) Source # 

Methods

nakadiLiftBase :: b a -> ResourceT m a Source #

MonadNakadiBase b m => MonadNakadiBase b (NoLoggingT m) Source # 

Methods

nakadiLiftBase :: b a -> NoLoggingT m a Source #

MonadNakadiBase b m => MonadNakadiBase b (LoggingT m) Source # 

Methods

nakadiLiftBase :: b a -> LoggingT m a Source #

MonadNakadiBase b m => MonadNakadiBase b (StateT s m) Source # 

Methods

nakadiLiftBase :: b a -> StateT s m a Source #

MonadNakadiBase b m => MonadNakadiBase b (StateT s m) Source # 

Methods

nakadiLiftBase :: b a -> StateT s m a Source #

(MonadNakadiBase b m, Monoid w) => MonadNakadiBase b (WriterT w m) Source # 

Methods

nakadiLiftBase :: b a -> WriterT w m a Source #

(MonadNakadiBase b m, Monoid w) => MonadNakadiBase b (WriterT w m) Source # 

Methods

nakadiLiftBase :: b a -> WriterT w m a Source #

MonadNakadiBase b m => MonadNakadiBase b (NakadiT b m) Source #

MonadNakadiBase

Methods

nakadiLiftBase :: b a -> NakadiT b m a Source #

MonadNakadiBase b m => MonadNakadiBase b (ReaderT * r m) Source # 

Methods

nakadiLiftBase :: b a -> ReaderT * r m a Source #

Monad m => MonadNakadiBase (LoggingT (ReaderT * r m)) (LoggingT (ReaderT * r m)) Source # 

Methods

nakadiLiftBase :: LoggingT (ReaderT * r m) a -> LoggingT (ReaderT * r m) a Source #

Monad m => MonadNakadiBase (NakadiBaseT m) (NakadiBaseT m) Source # 
Monad m => MonadNakadiBase (ReaderT * r m) (ReaderT * r m) Source # 

Methods

nakadiLiftBase :: ReaderT * r m a -> ReaderT * r m a Source #

newtype NakadiBaseT m a Source #

Constructors

NakadiBaseT 

Fields

Instances

MonadTrans NakadiBaseT Source # 

Methods

lift :: Monad m => m a -> NakadiBaseT m a #

MonadReader r m => MonadReader r (NakadiBaseT m) Source # 

Methods

ask :: NakadiBaseT m r #

local :: (r -> r) -> NakadiBaseT m a -> NakadiBaseT m a #

reader :: (r -> a) -> NakadiBaseT m a #

MonadState s m => MonadState s (NakadiBaseT m) Source # 

Methods

get :: NakadiBaseT m s #

put :: s -> NakadiBaseT m () #

state :: (s -> (a, s)) -> NakadiBaseT m a #

MonadBase b m => MonadBase b (NakadiBaseT m) Source # 

Methods

liftBase :: b α -> NakadiBaseT m α #

MonadWriter w m => MonadWriter w (NakadiBaseT m) Source # 

Methods

writer :: (a, w) -> NakadiBaseT m a #

tell :: w -> NakadiBaseT m () #

listen :: NakadiBaseT m a -> NakadiBaseT m (a, w) #

pass :: NakadiBaseT m (a, w -> w) -> NakadiBaseT m a #

Monad m => Monad (NakadiBaseT m) Source # 

Methods

(>>=) :: NakadiBaseT m a -> (a -> NakadiBaseT m b) -> NakadiBaseT m b #

(>>) :: NakadiBaseT m a -> NakadiBaseT m b -> NakadiBaseT m b #

return :: a -> NakadiBaseT m a #

fail :: String -> NakadiBaseT m a #

Functor m => Functor (NakadiBaseT m) Source # 

Methods

fmap :: (a -> b) -> NakadiBaseT m a -> NakadiBaseT m b #

(<$) :: a -> NakadiBaseT m b -> NakadiBaseT m a #

Applicative m => Applicative (NakadiBaseT m) Source # 

Methods

pure :: a -> NakadiBaseT m a #

(<*>) :: NakadiBaseT m (a -> b) -> NakadiBaseT m a -> NakadiBaseT m b #

liftA2 :: (a -> b -> c) -> NakadiBaseT m a -> NakadiBaseT m b -> NakadiBaseT m c #

(*>) :: NakadiBaseT m a -> NakadiBaseT m b -> NakadiBaseT m b #

(<*) :: NakadiBaseT m a -> NakadiBaseT m b -> NakadiBaseT m a #

MonadIO m => MonadIO (NakadiBaseT m) Source # 

Methods

liftIO :: IO a -> NakadiBaseT m a #

MonadThrow m => MonadThrow (NakadiBaseT m) Source # 

Methods

throwM :: Exception e => e -> NakadiBaseT m a #

MonadCatch m => MonadCatch (NakadiBaseT m) Source # 

Methods

catch :: Exception e => NakadiBaseT m a -> (e -> NakadiBaseT m a) -> NakadiBaseT m a #

MonadMask m => MonadMask (NakadiBaseT m) Source # 

Methods

mask :: ((forall a. NakadiBaseT m a -> NakadiBaseT m a) -> NakadiBaseT m b) -> NakadiBaseT m b #

uninterruptibleMask :: ((forall a. NakadiBaseT m a -> NakadiBaseT m a) -> NakadiBaseT m b) -> NakadiBaseT m b #

MonadLogger m => MonadLogger (NakadiBaseT m) Source # 

Methods

monadLoggerLog :: ToLogStr msg => Loc -> LogSource -> LogLevel -> msg -> NakadiBaseT m () #

Monad m => MonadNakadiBase (NakadiBaseT m) (NakadiBaseT m) Source # 

class HasNakadiConfig b r | r -> b where Source #

Minimal complete definition

nakadiConfig

Methods

nakadiConfig :: r -> Config b Source #

class (MonadNakadiBase b m, MonadThrow b, MonadMask b, MonadThrow m, MonadCatch m) => MonadNakadi b m | m -> b where Source #

The MonadNakadi typeclass is implemented by monads in which Nakadi can be called. The first parameter (b) denotes the `base monad`. This is the monad in which the core actions are run. This includes executing (non-streaming) HTTP requests and running user-provided callbacks. The typeclass provides methods for * retrieving the Nakadi configuration * locally changing the Nakadi configuration * extracting specific Nakadi configuration values * lifting actions from the The MonadNakadi typeclass is modelled closely after MonadReader.

Methods

nakadiAsk :: m (Config b) Source #

nakadiAsk :: (MonadNakadi b n, MonadTrans t, m ~ t n) => m (Config b) Source #

Instances

newtype NakadiT b m a Source #

The NakadiT type is just a specialized ReaderT monad.

Constructors

NakadiT 

Fields

Instances

(Monad b, MonadReader r m) => MonadReader r (NakadiT b m) Source #

MonadReader

Methods

ask :: NakadiT b m r #

local :: (r -> r) -> NakadiT b m a -> NakadiT b m a #

reader :: (r -> a) -> NakadiT b m a #

(Monad b, MonadState s m) => MonadState s (NakadiT b m) Source #

MonadState

Methods

get :: NakadiT b m s #

put :: s -> NakadiT b m () #

state :: (s -> (a, s)) -> NakadiT b m a #

(Monad m, MonadBase b' m) => MonadBase b' (NakadiT b m) Source #

MonadBase

Methods

liftBase :: b' α -> NakadiT b m α #

MonadBaseControl b' m => MonadBaseControl b' (NakadiT b m) Source #

MonadBaseControl

Associated Types

type StM (NakadiT b m :: * -> *) a :: * #

Methods

liftBaseWith :: (RunInBase (NakadiT b m) b' -> b' a) -> NakadiT b m a #

restoreM :: StM (NakadiT b m) a -> NakadiT b m a #

MonadNakadiBase b m => MonadNakadiBase b (NakadiT b m) Source #

MonadNakadiBase

Methods

nakadiLiftBase :: b a -> NakadiT b m a Source #

(MonadCatch m, MonadMask b, MonadNakadiBase b (NakadiT b m)) => MonadNakadi b (NakadiT b m) Source #

NakadiT

Methods

nakadiAsk :: NakadiT b m (Config b) Source #

MonadTrans (NakadiT b) Source #

MonadTrans

Methods

lift :: Monad m => m a -> NakadiT b m a #

MonadTransControl (NakadiT b) Source #

MonadTransControl

Associated Types

type StT (NakadiT b :: (* -> *) -> * -> *) a :: * #

Methods

liftWith :: Monad m => (Run (NakadiT b) -> m a) -> NakadiT b m a #

restoreT :: Monad m => m (StT (NakadiT b) a) -> NakadiT b m a #

Monad m => Monad (NakadiT b m) Source #

Monad

Methods

(>>=) :: NakadiT b m a -> (a -> NakadiT b m b) -> NakadiT b m b #

(>>) :: NakadiT b m a -> NakadiT b m b -> NakadiT b m b #

return :: a -> NakadiT b m a #

fail :: String -> NakadiT b m a #

Functor m => Functor (NakadiT b m) Source #

Functor for NakadiT.

Methods

fmap :: (a -> b) -> NakadiT b m a -> NakadiT b m b #

(<$) :: a -> NakadiT b m b -> NakadiT b m a #

Applicative m => Applicative (NakadiT b m) Source #

Applicative for NakadiT.

Methods

pure :: a -> NakadiT b m a #

(<*>) :: NakadiT b m (a -> b) -> NakadiT b m a -> NakadiT b m b #

liftA2 :: (a -> b -> c) -> NakadiT b m a -> NakadiT b m b -> NakadiT b m c #

(*>) :: NakadiT b m a -> NakadiT b m b -> NakadiT b m b #

(<*) :: NakadiT b m a -> NakadiT b m b -> NakadiT b m a #

(Monad b, MonadIO m) => MonadIO (NakadiT b m) Source #

MonadIO

Methods

liftIO :: IO a -> NakadiT b m a #

(Monad b, MonadThrow m) => MonadThrow (NakadiT b m) Source #

MonadThrow

Methods

throwM :: Exception e => e -> NakadiT b m a #

(Monad b, MonadUnliftIO m) => MonadUnliftIO (NakadiT b m) Source #

MonadUnliftIO

Methods

askUnliftIO :: NakadiT b m (UnliftIO (NakadiT b m)) #

withRunInIO :: ((forall a. NakadiT b m a -> IO a) -> IO b) -> NakadiT b m b #

(Monad b, MonadCatch m) => MonadCatch (NakadiT b m) Source #

MonadCatch

Methods

catch :: Exception e => NakadiT b m a -> (e -> NakadiT b m a) -> NakadiT b m a #

(Monad b, MonadMask m) => MonadMask (NakadiT b m) Source #

MonadMask

Methods

mask :: ((forall a. NakadiT b m a -> NakadiT b m a) -> NakadiT b m b) -> NakadiT b m b #

uninterruptibleMask :: ((forall a. NakadiT b m a -> NakadiT b m a) -> NakadiT b m b) -> NakadiT b m b #

MonadLogger m => MonadLogger (NakadiT b m) Source #

MonadLogger

Methods

monadLoggerLog :: ToLogStr msg => Loc -> LogSource -> LogLevel -> msg -> NakadiT b m () #

(Monad b, MonadLoggerIO m) => MonadLoggerIO (NakadiT b m) Source #

MonadLoggerIO

Methods

askLoggerIO :: NakadiT b m (Loc -> LogSource -> LogLevel -> LogStr -> IO ()) #

type StT (NakadiT b) a Source # 
type StT (NakadiT b) a = a
type StM (NakadiT b m) a Source # 
type StM (NakadiT b m) a = ComposeSt (NakadiT b) m a

runNakadiT :: Config b -> NakadiT b m a -> m a Source #

httpJsonBodyStream :: forall b m r. (MonadNakadi b m, MonadMask m) => Status -> [(Status, ByteString -> m NakadiException)] -> (Request -> Request) -> (Response (ConduitM () ByteString m ()) -> m r) -> m r Source #

httpBuildRequest Source #

Arguments

:: MonadNakadi b m 
=> (Request -> Request)

Pure request modifier

-> m Request

Resulting request to execute

conduitDecode Source #

Arguments

:: (FromJSON a, MonadNakadi b m) 
=> Config b

Configuration, containing the deserialization-failure-callback.

-> ConduitM ByteString a m ()

Conduit deserializing bytestrings into custom values

If no deserializationFailureCallback is set in the provided configuration (which is the default), a DeserializationFailureCallback exception will be thrown. Otherwise, simply run the callback.