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

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

Network.Nakadi.Types.Service

Description

This module provides the Nakadi Service Types.

Synopsis

Documentation

newtype CursorOffset Source #

Type for cursor offsets.

Constructors

CursorOffset 

Fields

Instances
Eq CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorOffset :: * -> * #

Hashable CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOffset Cursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOffset SubscriptionCursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOldestAvailableOffset Partition CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiNewestAvailableOffset Partition CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorOffset = D1 (MetaData "CursorOffset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "CursorOffset" PrefixI True) (S1 (MetaSel (Just "unCursorOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype EventTypeName Source #

Type for event type names.

Constructors

EventTypeName 

Fields

Instances
Eq EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventTypeName :: * -> * #

Hashable EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiEventType SubscriptionCursor EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventType EventMetadataEnriched EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiName EventType EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes SubscriptionRequest [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes Subscription [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartitionIndexMap (WorkerRegistry a) PartitionIndexMap 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventTypeName = D1 (MetaData "EventTypeName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "EventTypeName" PrefixI True) (S1 (MetaSel (Just "unEventTypeName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype PartitionName Source #

Type for partition names.

Constructors

PartitionName 

Fields

Instances
Eq PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep PartitionName :: * -> * #

Hashable PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiPartition Cursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition SubscriptionCursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition Partition PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition PartitionStat PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition EventMetadata (Maybe PartitionName) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition EventMetadataEnriched (Maybe PartitionName) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartitionIndexMap (WorkerRegistry a) PartitionIndexMap 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PartitionName = D1 (MetaData "PartitionName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "PartitionName" PrefixI True) (S1 (MetaSel (Just "unPartitionName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype PartitionCompactionKey Source #

Type for partition compaction keys.

Constructors

PartitionCompactionKey 

Fields

Instances
Eq PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep PartitionCompactionKey :: * -> * #

Hashable PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiPartitionCompactionKey EventMetadata (Maybe PartitionCompactionKey) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartitionCompactionKey EventMetadataEnriched (Maybe PartitionCompactionKey) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PartitionCompactionKey = D1 (MetaData "PartitionCompactionKey" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "PartitionCompactionKey" PrefixI True) (S1 (MetaSel (Just "unPartitionCompactionKey") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data Cursor Source #

Type for cursors.

Constructors

Cursor 
Instances
Eq Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

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

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

Ord Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Cursor :: * -> * #

Methods

from :: Cursor -> Rep Cursor x #

to :: Rep Cursor x -> Cursor #

Hashable Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> Cursor -> Int #

hash :: Cursor -> Int #

ToJSON Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiPartition Cursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOffset Cursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiInitialCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiFinalCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems CursorCommit [Cursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Cursor = D1 (MetaData "Cursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "Cursor" PrefixI True) (S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :*: S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset)))

newtype ApplicationName Source #

Type for application names.

Constructors

ApplicationName 
Instances
Eq ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep ApplicationName :: * -> * #

Hashable ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOwningApplication SubscriptionRequest ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOwningApplication Subscription ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOwningApplication EventType (Maybe ApplicationName) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep ApplicationName = D1 (MetaData "ApplicationName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "ApplicationName" PrefixI True) (S1 (MetaSel (Just "unApplicationName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SubscriptionsListResponse Source #

SubscriptionsListResponse

Instances
Eq SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionsListResponse :: * -> * #

Hashable SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiLinks SubscriptionsListResponse PaginationLinks 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems SubscriptionsListResponse [Subscription] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionsListResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionsListResponse = D1 (MetaData "SubscriptionsListResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionsListResponse" PrefixI True) (S1 (MetaSel (Just "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PaginationLinks) :*: S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [Subscription])))

data SubscriptionCursor Source #

Type fo rsubscription cursors.

Constructors

SubscriptionCursor 

Fields

Instances
Eq SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionCursor :: * -> * #

ToJSON SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSubscriptionCursor SubscriptionCursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition SubscriptionCursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOffset SubscriptionCursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCursor SubscriptionCursorWithCounter SubscriptionCursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventType SubscriptionCursor EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCursorToken SubscriptionCursor Text 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursor = D1 (MetaData "SubscriptionCursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionCursor" PrefixI True) ((S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :*: S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset)) :*: (S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName) :*: S1 (MetaSel (Just "_cursorToken") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text))))

newtype FlowId Source #

A Flow ID.

Constructors

FlowId 

Fields

Instances
Eq FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

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

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

Ord FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

fromString :: String -> FlowId #

Generic FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep FlowId :: * -> * #

Methods

from :: FlowId -> Rep FlowId x #

to :: Rep FlowId x -> FlowId #

ToJSON FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiFlowId EventMetadataEnriched (Maybe FlowId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiFlowId (Config m) (Maybe FlowId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

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

type Rep FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep FlowId = D1 (MetaData "FlowId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "FlowId" PrefixI True) (S1 (MetaSel (Just "unFlowId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SubscriptionCursorWithoutToken Source #

Type for subscription cursors without token.

Constructors

SubscriptionCursorWithoutToken 

Fields

Instances
Eq SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionCursorWithoutToken :: * -> * #

Hashable SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursorWithoutToken = D1 (MetaData "SubscriptionCursorWithoutToken" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionCursorWithoutToken" PrefixI True) (S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :*: (S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset) :*: S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName))))

newtype SubscriptionCursorCommit Source #

Type for commit object for subscription cursor committing.

Constructors

SubscriptionCursorCommit 

Fields

Instances
Show SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionCursorCommit :: * -> * #

ToJSON SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursorCommit = D1 (MetaData "SubscriptionCursorCommit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "SubscriptionCursorCommit" PrefixI True) (S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [SubscriptionCursor])))

newtype CursorCommit Source #

Type for commit objects for cursor committing.

Constructors

CursorCommit 

Fields

Instances
Show CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorCommit :: * -> * #

ToJSON CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiItems CursorCommit [Cursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorCommit = D1 (MetaData "CursorCommit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "CursorCommit" PrefixI True) (S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Cursor])))

newtype SubscriptionId Source #

Type for subscription IDs.

Constructors

SubscriptionId 

Fields

Instances
Eq SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionId :: * -> * #

Hashable SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSubscriptionId SubscriptionEventStream SubscriptionId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId SubscriptionId UUID 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId Subscription SubscriptionId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionId = D1 (MetaData "SubscriptionId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "SubscriptionId" PrefixI True) (S1 (MetaSel (Just "unSubscriptionId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UUID)))

newtype StreamId Source #

Type for stream IDs.

Constructors

StreamId 

Fields

Instances
Eq StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep StreamId :: * -> * #

Methods

from :: StreamId -> Rep StreamId x #

to :: Rep StreamId x -> StreamId #

ToJSON StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiStreamId SubscriptionEventStream StreamId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId StreamId Text 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

id :: Lens' StreamId Text

HasNakadiStreamId PartitionStat (Maybe StreamId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep StreamId = D1 (MetaData "StreamId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "StreamId" PrefixI True) (S1 (MetaSel (Just "unStreamId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype Timestamp Source #

Type for timestamps.

Constructors

Timestamp 

Fields

Instances
Eq Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Timestamp :: * -> * #

Hashable Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOccurredAt EventMetadata Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOccurredAt EventMetadataEnriched Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiReceivedAt EventMetadataEnriched Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCreatedAt Subscription Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiUTCTime Timestamp UTCTime 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Timestamp = D1 (MetaData "Timestamp" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "Timestamp" PrefixI True) (S1 (MetaSel (Just "unTimestamp") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UTCTime)))

data SubscriptionEventStreamBatch a Source #

SubscriptionEventStreamBatch

Constructors

SubscriptionEventStreamBatch 

Fields

Instances
Show a => Show (SubscriptionEventStreamBatch a) Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic (SubscriptionEventStreamBatch a) Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

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

ToJSON a => ToJSON (SubscriptionEventStreamBatch a) Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON a => FromJSON (SubscriptionEventStreamBatch a) Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSubscriptionCursor (SubscriptionEventStreamBatch a) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEvents (SubscriptionEventStreamBatch a) (Maybe (Vector a)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiQueue (Worker a) (TBQueue (SubscriptionEventStreamBatch a)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep (SubscriptionEventStreamBatch a) Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep (SubscriptionEventStreamBatch a) = D1 (MetaData "SubscriptionEventStreamBatch" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionEventStreamBatch" PrefixI True) (S1 (MetaSel (Just "_cursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 SubscriptionCursor) :*: S1 (MetaSel (Just "_events") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe (Vector a)))))

newtype EventId Source #

ID of an Event

Constructors

EventId 

Fields

Instances
Eq EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

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

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

Ord EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventId :: * -> * #

Methods

from :: EventId -> Rep EventId x #

to :: Rep EventId x -> EventId #

Hashable EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> EventId -> Int #

hash :: EventId -> Int #

ToJSON EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiEid EventMetadata EventId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEid EventMetadataEnriched EventId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId EventId UUID 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

id :: Lens' EventId UUID

HasNakadiParentEids EventMetadata (Maybe [EventId]) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiParentEids EventMetadataEnriched (Maybe [EventId]) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventId = D1 (MetaData "EventId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "EventId" PrefixI True) (S1 (MetaSel (Just "unEventId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UUID)))

data Partition Source #

Partition Data

Constructors

Partition 

Fields

data ShiftedCursor Source #

Type for shift-cursor queries.

Constructors

ShiftedCursor 

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 # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorDistanceQuery :: * -> * #

Hashable CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiInitialCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiFinalCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorDistanceQuery = D1 (MetaData "CursorDistanceQuery" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "CursorDistanceQuery" PrefixI True) (S1 (MetaSel (Just "_initialCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Cursor) :*: S1 (MetaSel (Just "_finalCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Cursor)))

newtype CursorDistanceResult Source #

Type for results of cursor-distance-queries.

Constructors

CursorDistanceResult 

Fields

Instances
Eq CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorDistanceResult :: * -> * #

Hashable CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiDistance CursorDistanceResult Int64 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorDistanceResult = D1 (MetaData "CursorDistanceResult" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "CursorDistanceResult" PrefixI True) (S1 (MetaSel (Just "_distance") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

data SubscriptionPosition Source #

Type modelling a subscription position.

Instances
Eq SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionPosition :: * -> * #

Hashable SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSubscriptionPosition Subscription SubscriptionPosition 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionPosition SubscriptionRequest (Maybe SubscriptionPosition) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionPosition = D1 (MetaData "SubscriptionPosition" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionPositionBegin" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "SubscriptionPositionEnd" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "SubscriptionPositionCursors" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [SubscriptionCursorWithoutToken]))))

data Subscription Source #

Type for a Subscription which has already been created.

When a subscription object is retrieved from Nakadi the following fields are regarded as mandatory:

  • id
  • owning_application
  • event_types
  • consumer_group
  • created_at
  • read_from
  • depending on read_from also cursors.
Instances
Eq Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Subscription :: * -> * #

Hashable Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiCreatedAt Subscription Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOwningApplication Subscription ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionPosition Subscription SubscriptionPosition 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId Subscription SubscriptionId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiConsumerGroup Subscription ConsumerGroup 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems SubscriptionsListResponse [Subscription] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes Subscription [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

data SubscriptionRequest Source #

Type for a Subscription which is to be created.

When a subscription is to be created the following fields are regarded as mandatory in the subscription object:

  • owning_application
  • event_types

The remaining fields are regarded as optional:

  • consumer_group
  • read_from
  • depending on read_from the field cursors might have to be present as well.
Instances
Eq SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionRequest :: * -> * #

Hashable SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOwningApplication SubscriptionRequest ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionPosition SubscriptionRequest (Maybe SubscriptionPosition) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes SubscriptionRequest [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiConsumerGroup SubscriptionRequest (Maybe ConsumerGroup) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionRequest = D1 (MetaData "SubscriptionRequest" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionRequest" PrefixI True) ((S1 (MetaSel (Just "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 ApplicationName) :*: S1 (MetaSel (Just "_eventTypes") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [EventTypeName])) :*: (S1 (MetaSel (Just "_consumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe ConsumerGroup)) :*: S1 (MetaSel (Just "_subscriptionPosition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe SubscriptionPosition)))))

newtype ConsumerGroup Source #

This type models the value describing the use case of a subscription. In general this is an additional identifier used to differ subscriptions having the same owning application and event types.

Constructors

ConsumerGroup 
Instances
Eq ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep ConsumerGroup :: * -> * #

Hashable ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiConsumerGroup Subscription ConsumerGroup 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiConsumerGroup SubscriptionRequest (Maybe ConsumerGroup) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep ConsumerGroup = D1 (MetaData "ConsumerGroup" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "ConsumerGroup" PrefixI True) (S1 (MetaSel (Just "unConsumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data PublishingStatus Source #

Type for publishing status.

Instances
Eq PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep PublishingStatus :: * -> * #

Hashable PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PublishingStatus = D1 (MetaData "PublishingStatus" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" 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 # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

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

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

Ord Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

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 # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

showsPrec :: Int -> Step -> ShowS #

show :: Step -> String #

showList :: [Step] -> ShowS #

Generic Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Step :: * -> * #

Methods

from :: Step -> Rep Step x #

to :: Rep Step x -> Step #

Hashable Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> Step -> Int #

hash :: Step -> Int #

ToJSON Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Step = D1 (MetaData "Step" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" 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 # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep BatchItemResponse :: * -> * #

Hashable BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep BatchItemResponse = D1 (MetaData "BatchItemResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "BatchItemResponse" PrefixI True) ((S1 (MetaSel (Just "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe EventId)) :*: S1 (MetaSel (Just "_publishingStatus") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PublishingStatus)) :*: (S1 (MetaSel (Just "_step") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Step)) :*: S1 (MetaSel (Just "_detail") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Text)))))

newtype StreamKeepAliveLimit Source #

StreamKeepAliveLimit

Instances
Eq StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

newtype BatchFlushTimeout Source #

BatchFlushTimeout

data CursorCommitResultType Source #

CursorCommitResultType

Instances
Eq CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

data CursorCommitResult Source #

CursorCommitResult

Instances
Eq CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

newtype CursorCommitResults Source #

Instances
Eq CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

data SchemaType Source #

SchemaType

Constructors

SchemaTypeJson 
Instances
Eq SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SchemaType :: * -> * #

Hashable SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSchemaType EventTypeSchema SchemaType 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SchemaType = D1 (MetaData "SchemaType" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SchemaTypeJson" PrefixI False) (U1 :: * -> *))

data EventTypeSchema Source #

Type for the schema of an event type.

Instances
Eq EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventTypeSchema :: * -> * #

Hashable EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSchemaType EventTypeSchema SchemaType 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSchema EventTypeSchema Text 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSchema EventType EventTypeSchema 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiVersion EventTypeSchema (Maybe SchemaVersion) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems EventTypeSchemasResponse [EventTypeSchema] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventTypeSchema = D1 (MetaData "EventTypeSchema" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "EventTypeSchema" PrefixI True) ((S1 (MetaSel (Just "_version") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe SchemaVersion)) :*: S1 (MetaSel (Just "_createdAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Timestamp))) :*: (S1 (MetaSel (Just "_schemaType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 SchemaType) :*: S1 (MetaSel (Just "_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 # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord EventTypeSchemasResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventTypeSchemasResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventTypeSchemasResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventTypeSchemasResponse :: * -> * #

Hashable EventTypeSchemasResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON EventTypeSchemasResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventTypeSchemasResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiLinks EventTypeSchemasResponse PaginationLinks 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems EventTypeSchemasResponse [EventTypeSchema] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventTypeSchemasResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventTypeSchemasResponse = D1 (MetaData "EventTypeSchemasResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "EventTypeSchemasResponse" PrefixI True) (S1 (MetaSel (Just "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PaginationLinks) :*: S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [EventTypeSchema])))

newtype SchemaVersion Source #

Type for the version of a schema.

Constructors

SchemaVersion 
Instances
Eq SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SchemaVersion :: * -> * #

Hashable SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiVersion EventMetadataEnriched SchemaVersion 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiVersion EventTypeSchema (Maybe SchemaVersion) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SchemaVersion = D1 (MetaData "SchemaVersion" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "SchemaVersion" PrefixI True) (S1 (MetaSel (Just "unSchemaVersion") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype Offset Source #

Type for offset values.

Constructors

Offset 

Fields

Instances
Eq Offset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

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

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

Ord Offset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show Offset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic Offset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Offset :: * -> * #

Methods

from :: Offset -> Rep Offset x #

to :: Rep Offset x -> Offset #

Hashable Offset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> Offset -> Int #

hash :: Offset -> Int #

type Rep Offset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Offset = D1 (MetaData "Offset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "Offset" PrefixI True) (S1 (MetaSel (Just "unOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

newtype Limit Source #

Type for limit values.

Constructors

Limit 

Fields

Instances
Eq Limit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

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

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

Ord Limit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

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 # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

showsPrec :: Int -> Limit -> ShowS #

show :: Limit -> String #

showList :: [Limit] -> ShowS #

Generic Limit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Limit :: * -> * #

Methods

from :: Limit -> Rep Limit x #

to :: Rep Limit x -> Limit #

Hashable Limit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> Limit -> Int #

hash :: Limit -> Int #

type Rep Limit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Limit = D1 (MetaData "Limit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "Limit" PrefixI True) (S1 (MetaSel (Just "unLimit") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

data PartitionState Source #

Type for partition states.

Instances
Eq PartitionState Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PartitionState Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PartitionState Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON PartitionState Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PartitionState Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiState PartitionStat PartitionState 
Instance details

Defined in Network.Nakadi.Internal.Lenses

data PartitionStat Source #

Type for per-partition statistics.

Instances
Eq PartitionStat Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PartitionStat Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PartitionStat Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic PartitionStat Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep PartitionStat :: * -> * #

ToJSON PartitionStat Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PartitionStat Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiPartition PartitionStat PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiState PartitionStat PartitionState 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiUnconsumedEvents PartitionStat (Maybe Int64) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiStreamId PartitionStat (Maybe StreamId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiConsumerLagSeconds PartitionStat (Maybe Int64) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep PartitionStat Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

data SubscriptionEventTypeStats Source #

Nakadi type SubscriptionEventTypeStats.

Instances
Eq SubscriptionEventTypeStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionEventTypeStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionEventTypeStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionEventTypeStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionEventTypeStats :: * -> * #

ToJSON SubscriptionEventTypeStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionEventTypeStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiItems SubscriptionStats [SubscriptionEventTypeStats] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionEventTypeStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionEventTypeStats = D1 (MetaData "SubscriptionEventTypeStats" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionEventTypeStats" PrefixI True) (S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName) :*: S1 (MetaSel (Just "_partitions") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [PartitionStat])))

newtype SubscriptionStats Source #

Type modelling per-subscription statistics. Objects of this type are returned by requests to subscriptionsSUBSCRIPTION-ID/stats.

Instances
Eq SubscriptionStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionStats :: * -> * #

ToJSON SubscriptionStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiItems SubscriptionStats [SubscriptionEventTypeStats] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionStats Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionStats = D1 (MetaData "SubscriptionStats" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "SubscriptionStats" PrefixI True) (S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [SubscriptionEventTypeStats])))

data EventTypeCategory Source #

Instances
Eq EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventTypeCategory :: * -> * #

Hashable EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiCategory EventType (Maybe EventTypeCategory) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventTypeCategory Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventTypeCategory = D1 (MetaData "EventTypeCategory" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "EventTypeCategoryUndefined" PrefixI False) (U1 :: * -> *) :+: (