Copyright	(c) Moritz Schulte 2017
License	BSD3
Maintainer	mtesseract@silverratio.net
Stability	experimental
Portability	POSIX
Safe Haskell	None
Language	Haskell2010

Network.Nakadi.Types.Service

Description

This module provides the Nakadi Service Types.

Synopsis

Documentation

newtype CursorOffset Source #

Type for cursor offsets.

Constructors

CursorOffset
Fields unCursorOffset :: Text Opaque Cursor Offset, do not parse this

Instances

Eq CursorOffset Source #
Methods (==) :: CursorOffset -> CursorOffset -> Bool # (/=) :: CursorOffset -> CursorOffset -> Bool #
Ord CursorOffset Source #
Methods compare :: CursorOffset -> CursorOffset -> Ordering # (<) :: CursorOffset -> CursorOffset -> Bool # (<=) :: CursorOffset -> CursorOffset -> Bool # (>) :: CursorOffset -> CursorOffset -> Bool # (>=) :: CursorOffset -> CursorOffset -> Bool # max :: CursorOffset -> CursorOffset -> CursorOffset # min :: CursorOffset -> CursorOffset -> CursorOffset #
Show CursorOffset Source #
Methods showsPrec :: Int -> CursorOffset -> ShowS # show :: CursorOffset -> String # showList :: [CursorOffset] -> ShowS #
IsString CursorOffset Source #
Methods fromString :: String -> CursorOffset #
Generic CursorOffset Source #
Associated Types type Rep CursorOffset :: * -> * # Methods from :: CursorOffset -> Rep CursorOffset x # to :: Rep CursorOffset x -> CursorOffset #
Hashable CursorOffset Source #
Methods hashWithSalt :: Int -> CursorOffset -> Int # hash :: CursorOffset -> Int #
ToJSON CursorOffset Source #
Methods toJSON :: CursorOffset -> Value # toEncoding :: CursorOffset -> Encoding # toJSONList :: [CursorOffset] -> Value # toEncodingList :: [CursorOffset] -> Encoding #
FromJSON CursorOffset Source #
Methods parseJSON :: Value -> Parser CursorOffset # parseJSONList :: Value -> Parser [CursorOffset] #
HasNakadiOffset Cursor CursorOffset
Methods offset :: Lens' Cursor CursorOffset
HasNakadiOldestAvailableOffset Partition CursorOffset
Methods oldestAvailableOffset :: Lens' Partition CursorOffset
HasNakadiNewestAvailableOffset Partition CursorOffset
Methods newestAvailableOffset :: Lens' Partition CursorOffset
type Rep CursorOffset Source #
type Rep CursorOffset = D1 * (MetaData "CursorOffset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 unEventTypeName :: Text Wrapped Event Type Name

Instances

Eq EventTypeName Source #
Methods (==) :: EventTypeName -> EventTypeName -> Bool # (/=) :: EventTypeName -> EventTypeName -> Bool #
Ord EventTypeName Source #
Methods compare :: EventTypeName -> EventTypeName -> Ordering # (<) :: EventTypeName -> EventTypeName -> Bool # (<=) :: EventTypeName -> EventTypeName -> Bool # (>) :: EventTypeName -> EventTypeName -> Bool # (>=) :: EventTypeName -> EventTypeName -> Bool # max :: EventTypeName -> EventTypeName -> EventTypeName # min :: EventTypeName -> EventTypeName -> EventTypeName #
Show EventTypeName Source #
Methods showsPrec :: Int -> EventTypeName -> ShowS # show :: EventTypeName -> String # showList :: [EventTypeName] -> ShowS #
IsString EventTypeName Source #
Methods fromString :: String -> EventTypeName #
Generic EventTypeName Source #
Associated Types type Rep EventTypeName :: * -> * # Methods from :: EventTypeName -> Rep EventTypeName x # to :: Rep EventTypeName x -> EventTypeName #
Hashable EventTypeName Source #
Methods hashWithSalt :: Int -> EventTypeName -> Int # hash :: EventTypeName -> Int #
ToJSON EventTypeName Source #
Methods toJSON :: EventTypeName -> Value # toEncoding :: EventTypeName -> Encoding # toJSONList :: [EventTypeName] -> Value # toEncodingList :: [EventTypeName] -> Encoding #
FromJSON EventTypeName Source #
Methods parseJSON :: Value -> Parser EventTypeName # parseJSONList :: Value -> Parser [EventTypeName] #
HasNakadiEventType MetadataEnriched EventTypeName
Methods eventType :: Lens' MetadataEnriched EventTypeName
HasNakadiName EventType EventTypeName
Methods name :: Lens' EventType EventTypeName
HasNakadiEventTypes Subscription [EventTypeName]
Methods eventTypes :: Lens' Subscription [EventTypeName]
type Rep EventTypeName Source #
type Rep EventTypeName = D1 * (MetaData "EventTypeName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 unPartitionName :: Text Wrapped Partition Name

Instances

Eq PartitionName Source #
Methods (==) :: PartitionName -> PartitionName -> Bool # (/=) :: PartitionName -> PartitionName -> Bool #
Ord PartitionName Source #
Methods compare :: PartitionName -> PartitionName -> Ordering # (<) :: PartitionName -> PartitionName -> Bool # (<=) :: PartitionName -> PartitionName -> Bool # (>) :: PartitionName -> PartitionName -> Bool # (>=) :: PartitionName -> PartitionName -> Bool # max :: PartitionName -> PartitionName -> PartitionName # min :: PartitionName -> PartitionName -> PartitionName #
Show PartitionName Source #
Methods showsPrec :: Int -> PartitionName -> ShowS # show :: PartitionName -> String # showList :: [PartitionName] -> ShowS #
IsString PartitionName Source #
Methods fromString :: String -> PartitionName #
Generic PartitionName Source #
Associated Types type Rep PartitionName :: * -> * # Methods from :: PartitionName -> Rep PartitionName x # to :: Rep PartitionName x -> PartitionName #
Hashable PartitionName Source #
Methods hashWithSalt :: Int -> PartitionName -> Int # hash :: PartitionName -> Int #
ToJSON PartitionName Source #
Methods toJSON :: PartitionName -> Value # toEncoding :: PartitionName -> Encoding # toJSONList :: [PartitionName] -> Value # toEncodingList :: [PartitionName] -> Encoding #
FromJSON PartitionName Source #
Methods parseJSON :: Value -> Parser PartitionName # parseJSONList :: Value -> Parser [PartitionName] #
HasNakadiPartition Cursor PartitionName
Methods partition :: Lens' Cursor PartitionName
HasNakadiPartition Partition PartitionName
Methods partition :: Lens' Partition PartitionName
HasNakadiPartition Metadata (Maybe PartitionName)
Methods partition :: Lens' Metadata (Maybe PartitionName)
HasNakadiPartition MetadataEnriched (Maybe PartitionName)
Methods partition :: Lens' MetadataEnriched (Maybe PartitionName)
type Rep PartitionName Source #
type Rep PartitionName = D1 * (MetaData "PartitionName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "PartitionName" PrefixI True) (S1 * (MetaSel (Just Symbol "unPartitionName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

newtype CursorToken Source #

Type for cursor tokens.

Constructors

CursorToken Text

Instances

Eq CursorToken Source #
Methods (==) :: CursorToken -> CursorToken -> Bool # (/=) :: CursorToken -> CursorToken -> Bool #
Ord CursorToken Source #
Methods compare :: CursorToken -> CursorToken -> Ordering # (<) :: CursorToken -> CursorToken -> Bool # (<=) :: CursorToken -> CursorToken -> Bool # (>) :: CursorToken -> CursorToken -> Bool # (>=) :: CursorToken -> CursorToken -> Bool # max :: CursorToken -> CursorToken -> CursorToken # min :: CursorToken -> CursorToken -> CursorToken #
Show CursorToken Source #
Methods showsPrec :: Int -> CursorToken -> ShowS # show :: CursorToken -> String # showList :: [CursorToken] -> ShowS #
IsString CursorToken Source #
Methods fromString :: String -> CursorToken #
ToJSON CursorToken Source #
Methods toJSON :: CursorToken -> Value # toEncoding :: CursorToken -> Encoding # toJSONList :: [CursorToken] -> Value # toEncodingList :: [CursorToken] -> Encoding #
FromJSON CursorToken Source #
Methods parseJSON :: Value -> Parser CursorToken # parseJSONList :: Value -> Parser [CursorToken] #

data Cursor Source #

Type for cursors.

Constructors

Cursor
Fields _partition :: PartitionName _offset :: CursorOffset

Instances

Eq Cursor Source #
Methods (==) :: Cursor -> Cursor -> Bool # (/=) :: Cursor -> Cursor -> Bool #
Ord Cursor Source #
Methods compare :: Cursor -> Cursor -> Ordering # (<) :: Cursor -> Cursor -> Bool # (<=) :: Cursor -> Cursor -> Bool # (>) :: Cursor -> Cursor -> Bool # (>=) :: Cursor -> Cursor -> Bool # max :: Cursor -> Cursor -> Cursor # min :: Cursor -> Cursor -> Cursor #
Show Cursor Source #
Methods showsPrec :: Int -> Cursor -> ShowS # show :: Cursor -> String # showList :: [Cursor] -> ShowS #
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 #
Methods toJSON :: Cursor -> Value # toEncoding :: Cursor -> Encoding # toJSONList :: [Cursor] -> Value # toEncodingList :: [Cursor] -> Encoding #
FromJSON Cursor Source #
Methods parseJSON :: Value -> Parser Cursor # parseJSONList :: Value -> Parser [Cursor] #
HasNakadiPartition Cursor PartitionName
Methods partition :: Lens' Cursor PartitionName
HasNakadiOffset Cursor CursorOffset
Methods offset :: Lens' Cursor CursorOffset
HasNakadiInitialCursor CursorDistanceQuery Cursor
Methods initialCursor :: Lens' CursorDistanceQuery Cursor
HasNakadiFinalCursor CursorDistanceQuery Cursor
Methods finalCursor :: Lens' CursorDistanceQuery Cursor
HasNakadiItems CursorCommit [Cursor]
Methods items :: Lens' CursorCommit [Cursor]
HasNakadiCursor (EventStreamBatch a) Cursor
Methods cursor :: Lens' (EventStreamBatch a) Cursor
type Rep Cursor Source #
type Rep Cursor = D1 * (MetaData "Cursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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
Fields unApplicationName :: Text

Instances

Eq ApplicationName Source #
Methods (==) :: ApplicationName -> ApplicationName -> Bool # (/=) :: ApplicationName -> ApplicationName -> Bool #
Ord ApplicationName Source #
Methods compare :: ApplicationName -> ApplicationName -> Ordering # (<) :: ApplicationName -> ApplicationName -> Bool # (<=) :: ApplicationName -> ApplicationName -> Bool # (>) :: ApplicationName -> ApplicationName -> Bool # (>=) :: ApplicationName -> ApplicationName -> Bool # max :: ApplicationName -> ApplicationName -> ApplicationName # min :: ApplicationName -> ApplicationName -> ApplicationName #
Show ApplicationName Source #
Methods showsPrec :: Int -> ApplicationName -> ShowS # show :: ApplicationName -> String # showList :: [ApplicationName] -> ShowS #
IsString ApplicationName Source #
Methods fromString :: String -> ApplicationName #
Generic ApplicationName Source #
Associated Types type Rep ApplicationName :: * -> * # Methods from :: ApplicationName -> Rep ApplicationName x # to :: Rep ApplicationName x -> ApplicationName #
Hashable ApplicationName Source #
Methods hashWithSalt :: Int -> ApplicationName -> Int # hash :: ApplicationName -> Int #
ToJSON ApplicationName Source #
Methods toJSON :: ApplicationName -> Value # toEncoding :: ApplicationName -> Encoding # toJSONList :: [ApplicationName] -> Value # toEncodingList :: [ApplicationName] -> Encoding #
FromJSON ApplicationName Source #
Methods parseJSON :: Value -> Parser ApplicationName # parseJSONList :: Value -> Parser [ApplicationName] #
HasNakadiOwningApplication Subscription ApplicationName
Methods owningApplication :: Lens' Subscription ApplicationName
HasNakadiOwningApplication EventType (Maybe ApplicationName)
Methods owningApplication :: Lens' EventType (Maybe ApplicationName)
type Rep ApplicationName Source #
type Rep ApplicationName = D1 * (MetaData "ApplicationName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "ApplicationName" PrefixI True) (S1 * (MetaSel (Just Symbol "unApplicationName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data SubscriptionsListResponse Source #

SubscriptionsListResponse

Constructors

SubscriptionsListResponse
Fields _links :: PaginationLinks _items :: [Subscription]

Instances

Eq SubscriptionsListResponse Source #
Methods (==) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (/=) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool #
Ord SubscriptionsListResponse Source #
Methods compare :: SubscriptionsListResponse -> SubscriptionsListResponse -> Ordering # (<) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (<=) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (>) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (>=) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # max :: SubscriptionsListResponse -> SubscriptionsListResponse -> SubscriptionsListResponse # min :: SubscriptionsListResponse -> SubscriptionsListResponse -> SubscriptionsListResponse #
Show SubscriptionsListResponse Source #
Methods showsPrec :: Int -> SubscriptionsListResponse -> ShowS # show :: SubscriptionsListResponse -> String # showList :: [SubscriptionsListResponse] -> ShowS #
Generic SubscriptionsListResponse Source #
Associated Types type Rep SubscriptionsListResponse :: * -> * # Methods from :: SubscriptionsListResponse -> Rep SubscriptionsListResponse x # to :: Rep SubscriptionsListResponse x -> SubscriptionsListResponse #
Hashable SubscriptionsListResponse Source #
Methods hashWithSalt :: Int -> SubscriptionsListResponse -> Int # hash :: SubscriptionsListResponse -> Int #
ToJSON SubscriptionsListResponse Source #
Methods toJSON :: SubscriptionsListResponse -> Value # toEncoding :: SubscriptionsListResponse -> Encoding # toJSONList :: [SubscriptionsListResponse] -> Value # toEncodingList :: [SubscriptionsListResponse] -> Encoding #
FromJSON SubscriptionsListResponse Source #
Methods parseJSON :: Value -> Parser SubscriptionsListResponse # parseJSONList :: Value -> Parser [SubscriptionsListResponse] #
HasNakadiLinks SubscriptionsListResponse PaginationLinks
Methods links :: Lens' SubscriptionsListResponse PaginationLinks
HasNakadiItems SubscriptionsListResponse [Subscription]
Methods items :: Lens' SubscriptionsListResponse [Subscription]
type Rep SubscriptionsListResponse Source #
type Rep SubscriptionsListResponse = D1 * (MetaData "SubscriptionsListResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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]))))

data SubscriptionCursor Source #

Type fo rsubscription cursors.

Constructors

SubscriptionCursor
Fields _partition :: PartitionName Partition Name of this cursor _offset :: CursorOffset Offset of this cursor _eventType :: EventTypeName Event Type Name of this cursor _cursorToken :: Text Token of this cursor

Instances

Eq SubscriptionCursor Source #
Methods (==) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (/=) :: SubscriptionCursor -> SubscriptionCursor -> Bool #
Ord SubscriptionCursor Source #
Methods compare :: SubscriptionCursor -> SubscriptionCursor -> Ordering # (<) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (<=) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (>) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (>=) :: SubscriptionCursor -> SubscriptionCursor -> Bool # max :: SubscriptionCursor -> SubscriptionCursor -> SubscriptionCursor # min :: SubscriptionCursor -> SubscriptionCursor -> SubscriptionCursor #
Show SubscriptionCursor Source #
Methods showsPrec :: Int -> SubscriptionCursor -> ShowS # show :: SubscriptionCursor -> String # showList :: [SubscriptionCursor] -> ShowS #
Generic SubscriptionCursor Source #
Associated Types type Rep SubscriptionCursor :: * -> * # Methods from :: SubscriptionCursor -> Rep SubscriptionCursor x # to :: Rep SubscriptionCursor x -> SubscriptionCursor #
ToJSON SubscriptionCursor Source #
Methods toJSON :: SubscriptionCursor -> Value # toEncoding :: SubscriptionCursor -> Encoding # toJSONList :: [SubscriptionCursor] -> Value # toEncodingList :: [SubscriptionCursor] -> Encoding #
FromJSON SubscriptionCursor Source #
Methods parseJSON :: Value -> Parser SubscriptionCursor # parseJSONList :: Value -> Parser [SubscriptionCursor] #
HasNakadiSubscriptionCursor SubscriptionCursor
Methods subscriptionCursor :: Getter SubscriptionCursor SubscriptionCursor
HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor]
Methods items :: Lens' SubscriptionCursorCommit [SubscriptionCursor]
HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor
Methods cursor :: Lens' (SubscriptionEventStreamBatch a) SubscriptionCursor
type Rep SubscriptionCursor Source #
type Rep SubscriptionCursor = D1 * (MetaData "SubscriptionCursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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)))))

newtype FlowId Source #

A Flow ID.

Constructors

FlowId
Fields unFlowId :: Text Wrapped Flow ID

Instances

Eq FlowId Source #
Methods (==) :: FlowId -> FlowId -> Bool # (/=) :: FlowId -> FlowId -> Bool #
Ord FlowId Source #
Methods compare :: FlowId -> FlowId -> Ordering # (<) :: FlowId -> FlowId -> Bool # (<=) :: FlowId -> FlowId -> Bool # (>) :: FlowId -> FlowId -> Bool # (>=) :: FlowId -> FlowId -> Bool # max :: FlowId -> FlowId -> FlowId # min :: FlowId -> FlowId -> FlowId #
Show FlowId Source #
Methods showsPrec :: Int -> FlowId -> ShowS # show :: FlowId -> String # showList :: [FlowId] -> ShowS #
Generic FlowId Source #
Associated Types type Rep FlowId :: * -> * # Methods from :: FlowId -> Rep FlowId x # to :: Rep FlowId x -> FlowId #
ToJSON FlowId Source #
Methods toJSON :: FlowId -> Value # toEncoding :: FlowId -> Encoding # toJSONList :: [FlowId] -> Value # toEncodingList :: [FlowId] -> Encoding #
FromJSON FlowId Source #
Methods parseJSON :: Value -> Parser FlowId # parseJSONList :: Value -> Parser [FlowId] #
HasNakadiFlowId MetadataEnriched (Maybe FlowId)
Methods flowId :: Lens' MetadataEnriched (Maybe FlowId)
type Rep FlowId Source #
type Rep FlowId = D1 * (MetaData "FlowId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "FlowId" PrefixI True) (S1 * (MetaSel (Just Symbol "unFlowId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data SubscriptionCursorWithoutToken Source #

Type for subscription cursors without token.

Constructors

SubscriptionCursorWithoutToken
Fields _partition :: PartitionName Partition Name of this cursor _offset :: CursorOffset Offset of this cursor _eventType :: EventTypeName Event Type Name of this cursor

Instances

Eq SubscriptionCursorWithoutToken Source #
Methods (==) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (/=) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool #
Ord SubscriptionCursorWithoutToken Source #
Methods compare :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Ordering # (<) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (<=) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (>) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (>=) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # max :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken # min :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken #
Show SubscriptionCursorWithoutToken Source #
Methods showsPrec :: Int -> SubscriptionCursorWithoutToken -> ShowS # show :: SubscriptionCursorWithoutToken -> String # showList :: [SubscriptionCursorWithoutToken] -> ShowS #
Generic SubscriptionCursorWithoutToken Source #
Associated Types type Rep SubscriptionCursorWithoutToken :: * -> * # Methods from :: SubscriptionCursorWithoutToken -> Rep SubscriptionCursorWithoutToken x # to :: Rep SubscriptionCursorWithoutToken x -> SubscriptionCursorWithoutToken #
Hashable SubscriptionCursorWithoutToken Source #
Methods hashWithSalt :: Int -> SubscriptionCursorWithoutToken -> Int # hash :: SubscriptionCursorWithoutToken -> Int #
ToJSON SubscriptionCursorWithoutToken Source #
Methods toJSON :: SubscriptionCursorWithoutToken -> Value # toEncoding :: SubscriptionCursorWithoutToken -> Encoding # toJSONList :: [SubscriptionCursorWithoutToken] -> Value # toEncodingList :: [SubscriptionCursorWithoutToken] -> Encoding #
FromJSON SubscriptionCursorWithoutToken Source #
Methods parseJSON :: Value -> Parser SubscriptionCursorWithoutToken # parseJSONList :: Value -> Parser [SubscriptionCursorWithoutToken] #
HasNakadiInitialCursors Subscription (Maybe [SubscriptionCursorWithoutToken])
Methods initialCursors :: Lens' Subscription (Maybe [SubscriptionCursorWithoutToken])
type Rep SubscriptionCursorWithoutToken Source #
type Rep SubscriptionCursorWithoutToken = D1 * (MetaData "SubscriptionCursorWithoutToken" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 _items :: [SubscriptionCursor] List of cursors to commit

Instances

Show SubscriptionCursorCommit Source #
Methods showsPrec :: Int -> SubscriptionCursorCommit -> ShowS # show :: SubscriptionCursorCommit -> String # showList :: [SubscriptionCursorCommit] -> ShowS #
Generic SubscriptionCursorCommit Source #
Associated Types type Rep SubscriptionCursorCommit :: * -> * # Methods from :: SubscriptionCursorCommit -> Rep SubscriptionCursorCommit x # to :: Rep SubscriptionCursorCommit x -> SubscriptionCursorCommit #
ToJSON SubscriptionCursorCommit Source #
Methods toJSON :: SubscriptionCursorCommit -> Value # toEncoding :: SubscriptionCursorCommit -> Encoding # toJSONList :: [SubscriptionCursorCommit] -> Value # toEncodingList :: [SubscriptionCursorCommit] -> Encoding #
FromJSON SubscriptionCursorCommit Source #
Methods parseJSON :: Value -> Parser SubscriptionCursorCommit # parseJSONList :: Value -> Parser [SubscriptionCursorCommit] #
HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor]
Methods items :: Lens' SubscriptionCursorCommit [SubscriptionCursor]
type Rep SubscriptionCursorCommit Source #
type Rep SubscriptionCursorCommit = D1 * (MetaData "SubscriptionCursorCommit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "SubscriptionCursorCommit" PrefixI True) (S1 * (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [SubscriptionCursor])))

newtype CursorCommit Source #

Type for commit objects for cursor committing.

Constructors

CursorCommit
Fields _items :: [Cursor] List of cursors to commit

Instances

Show CursorCommit Source #
Methods showsPrec :: Int -> CursorCommit -> ShowS # show :: CursorCommit -> String # showList :: [CursorCommit] -> ShowS #
Generic CursorCommit Source #
Associated Types type Rep CursorCommit :: * -> * # Methods from :: CursorCommit -> Rep CursorCommit x # to :: Rep CursorCommit x -> CursorCommit #
ToJSON CursorCommit Source #
Methods toJSON :: CursorCommit -> Value # toEncoding :: CursorCommit -> Encoding # toJSONList :: [CursorCommit] -> Value # toEncodingList :: [CursorCommit] -> Encoding #
FromJSON CursorCommit Source #
Methods parseJSON :: Value -> Parser CursorCommit # parseJSONList :: Value -> Parser [CursorCommit] #
HasNakadiItems CursorCommit [Cursor]
Methods items :: Lens' CursorCommit [Cursor]
type Rep CursorCommit Source #
type Rep CursorCommit = D1 * (MetaData "CursorCommit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "CursorCommit" PrefixI True) (S1 * (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [Cursor])))

newtype SubscriptionId Source #

Type for subscription IDs.

Constructors

SubscriptionId
Fields unSubscriptionId :: UUID Wrapped UUID

Instances

Eq SubscriptionId Source #
Methods (==) :: SubscriptionId -> SubscriptionId -> Bool # (/=) :: SubscriptionId -> SubscriptionId -> Bool #
Ord SubscriptionId Source #
Methods compare :: SubscriptionId -> SubscriptionId -> Ordering # (<) :: SubscriptionId -> SubscriptionId -> Bool # (<=) :: SubscriptionId -> SubscriptionId -> Bool # (>) :: SubscriptionId -> SubscriptionId -> Bool # (>=) :: SubscriptionId -> SubscriptionId -> Bool # max :: SubscriptionId -> SubscriptionId -> SubscriptionId # min :: SubscriptionId -> SubscriptionId -> SubscriptionId #
Show SubscriptionId Source #
Methods showsPrec :: Int -> SubscriptionId -> ShowS # show :: SubscriptionId -> String # showList :: [SubscriptionId] -> ShowS #
Generic SubscriptionId Source #
Associated Types type Rep SubscriptionId :: * -> * # Methods from :: SubscriptionId -> Rep SubscriptionId x # to :: Rep SubscriptionId x -> SubscriptionId #
Hashable SubscriptionId Source #
Methods hashWithSalt :: Int -> SubscriptionId -> Int # hash :: SubscriptionId -> Int #
ToJSON SubscriptionId Source #
Methods toJSON :: SubscriptionId -> Value # toEncoding :: SubscriptionId -> Encoding # toJSONList :: [SubscriptionId] -> Value # toEncodingList :: [SubscriptionId] -> Encoding #
FromJSON SubscriptionId Source #
Methods parseJSON :: Value -> Parser SubscriptionId # parseJSONList :: Value -> Parser [SubscriptionId] #
HasNakadiSubscriptionId SubscriptionEventStream SubscriptionId
Methods subscriptionId :: Lens' SubscriptionEventStream SubscriptionId
HasNakadiSubscriptionId SubscriptionEventStreamContext SubscriptionId
Methods subscriptionId :: Lens' SubscriptionEventStreamContext SubscriptionId
HasNakadiId SubscriptionId UUID
Methods id :: Lens' SubscriptionId UUID
HasNakadiId Subscription (Maybe SubscriptionId)
Methods id :: Lens' Subscription (Maybe SubscriptionId)
type Rep SubscriptionId Source #
type Rep SubscriptionId = D1 * (MetaData "SubscriptionId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 unStreamId :: Text Wrapped Stream ID

Instances

Eq StreamId Source #
Methods (==) :: StreamId -> StreamId -> Bool # (/=) :: StreamId -> StreamId -> Bool #
Ord StreamId Source #
Methods compare :: StreamId -> StreamId -> Ordering # (<) :: StreamId -> StreamId -> Bool # (<=) :: StreamId -> StreamId -> Bool # (>) :: StreamId -> StreamId -> Bool # (>=) :: StreamId -> StreamId -> Bool # max :: StreamId -> StreamId -> StreamId # min :: StreamId -> StreamId -> StreamId #
Show StreamId Source #
Methods showsPrec :: Int -> StreamId -> ShowS # show :: StreamId -> String # showList :: [StreamId] -> ShowS #
Generic StreamId Source #
Associated Types type Rep StreamId :: * -> * # Methods from :: StreamId -> Rep StreamId x # to :: Rep StreamId x -> StreamId #
ToJSON StreamId Source #
Methods toJSON :: StreamId -> Value # toEncoding :: StreamId -> Encoding # toJSONList :: [StreamId] -> Value # toEncodingList :: [StreamId] -> Encoding #
FromJSON StreamId Source #
Methods parseJSON :: Value -> Parser StreamId # parseJSONList :: Value -> Parser [StreamId] #
HasNakadiStreamId SubscriptionEventStream StreamId
Methods streamId :: Lens' SubscriptionEventStream StreamId
HasNakadiStreamId SubscriptionEventStreamContext StreamId
Methods streamId :: Lens' SubscriptionEventStreamContext StreamId
HasNakadiId StreamId Text
Methods id :: Lens' StreamId Text
type Rep StreamId Source #
type Rep StreamId = D1 * (MetaData "StreamId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "StreamId" PrefixI True) (S1 * (MetaSel (Just Symbol "unStreamId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data SubscriptionEventStream Source #

SubscriptionEventStream

Constructors

SubscriptionEventStream
Fields _streamId :: StreamId _subscriptionId :: SubscriptionId

Instances

Show SubscriptionEventStream Source #
Methods showsPrec :: Int -> SubscriptionEventStream -> ShowS # show :: SubscriptionEventStream -> String # showList :: [SubscriptionEventStream] -> ShowS #
HasNakadiSubscriptionId SubscriptionEventStream SubscriptionId
Methods subscriptionId :: Lens' SubscriptionEventStream SubscriptionId
HasNakadiStreamId SubscriptionEventStream StreamId
Methods streamId :: Lens' SubscriptionEventStream StreamId

newtype Timestamp Source #

Type for timestamps.

Constructors

Timestamp
Fields unTimestamp :: UTCTime Wrapped UTC Timestamp

Instances

Eq Timestamp Source #
Methods (==) :: Timestamp -> Timestamp -> Bool # (/=) :: Timestamp -> Timestamp -> Bool #
Ord Timestamp Source #
Methods compare :: Timestamp -> Timestamp -> Ordering # (<) :: Timestamp -> Timestamp -> Bool # (<=) :: Timestamp -> Timestamp -> Bool # (>) :: Timestamp -> Timestamp -> Bool # (>=) :: Timestamp -> Timestamp -> Bool # max :: Timestamp -> Timestamp -> Timestamp # min :: Timestamp -> Timestamp -> Timestamp #
Show Timestamp Source #
Methods showsPrec :: Int -> Timestamp -> ShowS # show :: Timestamp -> String # showList :: [Timestamp] -> ShowS #
Generic Timestamp Source #
Associated Types type Rep Timestamp :: * -> * # Methods from :: Timestamp -> Rep Timestamp x # to :: Rep Timestamp x -> Timestamp #
Hashable Timestamp Source #
Methods hashWithSalt :: Int -> Timestamp -> Int # hash :: Timestamp -> Int #
ToJSON Timestamp Source #
Methods toJSON :: Timestamp -> Value # toEncoding :: Timestamp -> Encoding # toJSONList :: [Timestamp] -> Value # toEncodingList :: [Timestamp] -> Encoding #
FromJSON Timestamp Source #
Methods parseJSON :: Value -> Parser Timestamp # parseJSONList :: Value -> Parser [Timestamp] #
HasNakadiOccurredAt Metadata Timestamp
Methods occurredAt :: Lens' Metadata Timestamp
HasNakadiOccurredAt MetadataEnriched Timestamp
Methods occurredAt :: Lens' MetadataEnriched Timestamp
HasNakadiReceivedAt MetadataEnriched Timestamp
Methods receivedAt :: Lens' MetadataEnriched Timestamp
HasNakadiUTCTime Timestamp UTCTime
Methods utcTime :: Lens' Timestamp UTCTime
HasNakadiCreatedAt Subscription (Maybe Timestamp)
Methods createdAt :: Lens' Subscription (Maybe Timestamp)
HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp)
Methods createdAt :: Lens' EventTypeSchema (Maybe Timestamp)
type Rep Timestamp Source #
type Rep Timestamp = D1 * (MetaData "Timestamp" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "Timestamp" PrefixI True) (S1 * (MetaSel (Just Symbol "unTimestamp") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * UTCTime)))

data Metadata Source #

Metadata

Constructors

Metadata
Fields _eid :: EventId Event ID _occurredAt :: Timestamp Occurred-At timestamp _parentEids :: Maybe [EventId] Event IDs of the Events which triggered this event _partition :: Maybe PartitionName Partition on which this Event is stored

Instances

Eq Metadata Source #
Methods (==) :: Metadata -> Metadata -> Bool # (/=) :: Metadata -> Metadata -> Bool #
Show Metadata Source #
Methods showsPrec :: Int -> Metadata -> ShowS # show :: Metadata -> String # showList :: [Metadata] -> ShowS #
Generic Metadata Source #
Associated Types type Rep Metadata :: * -> * # Methods from :: Metadata -> Rep Metadata x # to :: Rep Metadata x -> Metadata #
ToJSON Metadata Source #
Methods toJSON :: Metadata -> Value # toEncoding :: Metadata -> Encoding # toJSONList :: [Metadata] -> Value # toEncodingList :: [Metadata] -> Encoding #
FromJSON Metadata Source #
Methods parseJSON :: Value -> Parser Metadata # parseJSONList :: Value -> Parser [Metadata] #
HasNakadiOccurredAt Metadata Timestamp
Methods occurredAt :: Lens' Metadata Timestamp
HasNakadiEid Metadata EventId
Methods eid :: Lens' Metadata EventId
HasNakadiPartition Metadata (Maybe PartitionName)
Methods partition :: Lens' Metadata (Maybe PartitionName)
HasNakadiParentEids Metadata (Maybe [EventId])
Methods parentEids :: Lens' Metadata (Maybe [EventId])
HasNakadiMetadata (Event a) Metadata
Methods metadata :: Lens' (Event a) Metadata
type Rep Metadata Source #
type Rep Metadata = D1 * (MetaData "Metadata" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "Metadata" 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 Event a Source #

Event

Constructors

Event
Fields _payload :: a Payload of this Event. In the Nakadi API it is called `data`, but it cannot be named `_data`, as this this would cause the lense 'data' to be created, which is a reserved keyword _metadata :: Metadata Meta data for this Event

Instances

Eq a => Eq (Event a) Source #
Methods (==) :: Event a -> Event a -> Bool # (/=) :: Event a -> Event a -> Bool #
Show a => Show (Event a) Source #
Methods showsPrec :: Int -> Event a -> ShowS # show :: Event a -> String # showList :: [Event a] -> ShowS #
Generic (Event a) Source #
Associated Types type Rep (Event a) :: * -> * # Methods from :: Event a -> Rep (Event a) x # to :: Rep (Event a) x -> Event a #
ToJSON a => ToJSON (Event a) Source #
Methods toJSON :: Event a -> Value # toEncoding :: Event a -> Encoding # toJSONList :: [Event a] -> Value # toEncodingList :: [Event a] -> Encoding #
FromJSON a => FromJSON (Event a) Source #
Methods parseJSON :: Value -> Parser (Event a) # parseJSONList :: Value -> Parser [Event a] #
HasNakadiPayload (Event a) a
Methods payload :: Lens' (Event a) a
HasNakadiMetadata (Event a) Metadata
Methods metadata :: Lens' (Event a) Metadata
type Rep (Event a) Source #
type Rep (Event a) = D1 * (MetaData "Event" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "Event" PrefixI True) ((::) (S1 * (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * a)) (S1 * (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Metadata))))

data EventStreamBatch a Source #

EventStreamBatch

Constructors

EventStreamBatch
Fields _cursor :: Cursor Cursor for this batch _events :: Maybe (Vector (EventEnriched a)) Events in this batch

Instances

Show a => Show (EventStreamBatch a) Source #
Methods showsPrec :: Int -> EventStreamBatch a -> ShowS # show :: EventStreamBatch a -> String # showList :: [EventStreamBatch a] -> ShowS #
Generic (EventStreamBatch a) Source #
Associated Types type Rep (EventStreamBatch a) :: * -> * # Methods from :: EventStreamBatch a -> Rep (EventStreamBatch a) x # to :: Rep (EventStreamBatch a) x -> EventStreamBatch a #
ToJSON a => ToJSON (EventStreamBatch a) Source #
Methods toJSON :: EventStreamBatch a -> Value # toEncoding :: EventStreamBatch a -> Encoding # toJSONList :: [EventStreamBatch a] -> Value # toEncodingList :: [EventStreamBatch a] -> Encoding #
FromJSON a => FromJSON (EventStreamBatch a) Source #
Methods parseJSON :: Value -> Parser (EventStreamBatch a) # parseJSONList :: Value -> Parser [EventStreamBatch a] #
HasNakadiCursor (EventStreamBatch a) Cursor
Methods cursor :: Lens' (EventStreamBatch a) Cursor
HasNakadiEvents (EventStreamBatch a) (Maybe (Vector (EventEnriched a)))
Methods events :: Lens' (EventStreamBatch a) (Maybe (Vector (EventEnriched a)))
type Rep (EventStreamBatch a) Source #
type Rep (EventStreamBatch a) = D1 * (MetaData "EventStreamBatch" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 (EventEnriched a)))))))

data SubscriptionEventStreamBatch a Source #

SubscriptionEventStreamBatch

Constructors

SubscriptionEventStreamBatch
Fields _cursor :: SubscriptionCursor cursor for this subscription batch _events :: Maybe (Vector (EventEnriched a)) Events for this subscription batch

Instances

Show a => Show (SubscriptionEventStreamBatch a) Source #
Methods showsPrec :: Int -> SubscriptionEventStreamBatch a -> ShowS # show :: SubscriptionEventStreamBatch a -> String # showList :: [SubscriptionEventStreamBatch a] -> ShowS #
Generic (SubscriptionEventStreamBatch a) Source #
Associated Types type Rep (SubscriptionEventStreamBatch a) :: * -> * # Methods from :: SubscriptionEventStreamBatch a -> Rep (SubscriptionEventStreamBatch a) x # to :: Rep (SubscriptionEventStreamBatch a) x -> SubscriptionEventStreamBatch a #
ToJSON a => ToJSON (SubscriptionEventStreamBatch a) Source #
Methods toJSON :: SubscriptionEventStreamBatch a -> Value # toEncoding :: SubscriptionEventStreamBatch a -> Encoding # toJSONList :: [SubscriptionEventStreamBatch a] -> Value # toEncodingList :: [SubscriptionEventStreamBatch a] -> Encoding #
FromJSON a => FromJSON (SubscriptionEventStreamBatch a) Source #
Methods parseJSON :: Value -> Parser (SubscriptionEventStreamBatch a) # parseJSONList :: Value -> Parser [SubscriptionEventStreamBatch a] #
HasNakadiSubscriptionCursor (SubscriptionEventStreamBatch a)
Methods subscriptionCursor :: Getter (SubscriptionEventStreamBatch a) SubscriptionCursor
HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor
Methods cursor :: Lens' (SubscriptionEventStreamBatch a) SubscriptionCursor
HasNakadiEvents (SubscriptionEventStreamBatch a) (Maybe (Vector (EventEnriched a)))
Methods events :: Lens' (SubscriptionEventStreamBatch a) (Maybe (Vector (EventEnriched a)))
type Rep (SubscriptionEventStreamBatch a) Source #
type Rep (SubscriptionEventStreamBatch a) = D1 * (MetaData "SubscriptionEventStreamBatch" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 (EventEnriched a)))))))

newtype EventId Source #

ID of an Event

Constructors

EventId
Fields unEventId :: UUID Wrapped UUID

Instances

Eq EventId Source #
Methods (==) :: EventId -> EventId -> Bool # (/=) :: EventId -> EventId -> Bool #
Ord EventId Source #
Methods compare :: EventId -> EventId -> Ordering # (<) :: EventId -> EventId -> Bool # (<=) :: EventId -> EventId -> Bool # (>) :: EventId -> EventId -> Bool # (>=) :: EventId -> EventId -> Bool # max :: EventId -> EventId -> EventId # min :: EventId -> EventId -> EventId #
Show EventId Source #
Methods showsPrec :: Int -> EventId -> ShowS # show :: EventId -> String # showList :: [EventId] -> ShowS #
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 #
Methods toJSON :: EventId -> Value # toEncoding :: EventId -> Encoding # toJSONList :: [EventId] -> Value # toEncodingList :: [EventId] -> Encoding #
FromJSON EventId Source #
Methods parseJSON :: Value -> Parser EventId # parseJSONList :: Value -> Parser [EventId] #
HasNakadiEid Metadata EventId
Methods eid :: Lens' Metadata EventId
HasNakadiEid MetadataEnriched EventId
Methods eid :: Lens' MetadataEnriched EventId
HasNakadiId EventId UUID
Methods id :: Lens' EventId UUID
HasNakadiParentEids Metadata (Maybe [EventId])
Methods parentEids :: Lens' Metadata (Maybe [EventId])
HasNakadiParentEids MetadataEnriched (Maybe [EventId])
Methods parentEids :: Lens' MetadataEnriched (Maybe [EventId])
type Rep EventId Source #
type Rep EventId = D1 * (MetaData "EventId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "EventId" PrefixI True) (S1 * (MetaSel (Just Symbol "unEventId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * UUID)))

data Partition Source #

Partition Data

Constructors

Partition
Fields _oldestAvailableOffset :: CursorOffset Oldest available cursor offset for this partition _newestAvailableOffset :: CursorOffset Newest available cursor offset for this partition _partition :: PartitionName Name of the partition _unconsumedEvents :: Maybe Int64 Number of unconsumed Events

Instances

Show Partition Source #
Methods showsPrec :: Int -> Partition -> ShowS # show :: Partition -> String # showList :: [Partition] -> ShowS #
ToJSON Partition Source #
Methods toJSON :: Partition -> Value # toEncoding :: Partition -> Encoding # toJSONList :: [Partition] -> Value # toEncodingList :: [Partition] -> Encoding #
FromJSON Partition Source #
Methods parseJSON :: Value -> Parser Partition # parseJSONList :: Value -> Parser [Partition] #
HasNakadiPartition Partition PartitionName
Methods partition :: Lens' Partition PartitionName
HasNakadiOldestAvailableOffset Partition CursorOffset
Methods oldestAvailableOffset :: Lens' Partition CursorOffset
HasNakadiNewestAvailableOffset Partition CursorOffset
Methods newestAvailableOffset :: Lens' Partition CursorOffset
HasNakadiUnconsumedEvents Partition (Maybe Int64)
Methods unconsumedEvents :: Lens' Partition (Maybe Int64)

data ShiftedCursor Source #

Type for shift-cursor queries.

Constructors

ShiftedCursor
Fields _partition :: PartitionName Partition of the cursor to shift _offset :: CursorOffset Offset of the cursor to shift _shift :: Int64 Shift by this number.

Instances

Eq ShiftedCursor Source #
Methods (==) :: ShiftedCursor -> ShiftedCursor -> Bool # (/=) :: ShiftedCursor -> ShiftedCursor -> Bool #
Ord ShiftedCursor Source #
Methods compare :: ShiftedCursor -> ShiftedCursor -> Ordering # (<) :: ShiftedCursor -> ShiftedCursor -> Bool # (<=) :: ShiftedCursor -> ShiftedCursor -> Bool # (>) :: ShiftedCursor -> ShiftedCursor -> Bool # (>=) :: ShiftedCursor -> ShiftedCursor -> Bool # max :: ShiftedCursor -> ShiftedCursor -> ShiftedCursor # min :: ShiftedCursor -> ShiftedCursor -> ShiftedCursor #
Show ShiftedCursor Source #
Methods showsPrec :: Int -> ShiftedCursor -> ShowS # show :: ShiftedCursor -> String # showList :: [ShiftedCursor] -> ShowS #
ToJSON ShiftedCursor Source #
Methods toJSON :: ShiftedCursor -> Value # toEncoding :: ShiftedCursor -> Encoding # toJSONList :: [ShiftedCursor] -> Value # toEncodingList :: [ShiftedCursor] -> Encoding #
FromJSON ShiftedCursor Source #
Methods parseJSON :: Value -> Parser ShiftedCursor # parseJSONList :: Value -> Parser [ShiftedCursor] #

data CursorDistanceQuery Source #

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

Constructors

CursorDistanceQuery
Fields _initialCursor :: Cursor Initial Cursor _finalCursor :: Cursor Final cursor.

Instances

Eq CursorDistanceQuery Source #
Methods (==) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (/=) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool #
Ord CursorDistanceQuery Source #
Methods compare :: CursorDistanceQuery -> CursorDistanceQuery -> Ordering # (<) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (<=) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (>) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (>=) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # max :: CursorDistanceQuery -> CursorDistanceQuery -> CursorDistanceQuery # min :: CursorDistanceQuery -> CursorDistanceQuery -> CursorDistanceQuery #
Show CursorDistanceQuery Source #
Methods showsPrec :: Int -> CursorDistanceQuery -> ShowS # show :: CursorDistanceQuery -> String # showList :: [CursorDistanceQuery] -> ShowS #
Generic CursorDistanceQuery Source #
Associated Types type Rep CursorDistanceQuery :: * -> * # Methods from :: CursorDistanceQuery -> Rep CursorDistanceQuery x # to :: Rep CursorDistanceQuery x -> CursorDistanceQuery #
Hashable CursorDistanceQuery Source #
Methods hashWithSalt :: Int -> CursorDistanceQuery -> Int # hash :: CursorDistanceQuery -> Int #
ToJSON CursorDistanceQuery Source #
Methods toJSON :: CursorDistanceQuery -> Value # toEncoding :: CursorDistanceQuery -> Encoding # toJSONList :: [CursorDistanceQuery] -> Value # toEncodingList :: [CursorDistanceQuery] -> Encoding #
FromJSON CursorDistanceQuery Source #
Methods parseJSON :: Value -> Parser CursorDistanceQuery # parseJSONList :: Value -> Parser [CursorDistanceQuery] #
HasNakadiInitialCursor CursorDistanceQuery Cursor
Methods initialCursor :: Lens' CursorDistanceQuery Cursor
HasNakadiFinalCursor CursorDistanceQuery Cursor
Methods finalCursor :: Lens' CursorDistanceQuery Cursor
type Rep CursorDistanceQuery Source #
type Rep CursorDistanceQuery = D1 * (MetaData "CursorDistanceQuery" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 _distance :: Int64

Instances

Eq CursorDistanceResult Source #
Methods (==) :: CursorDistanceResult -> CursorDistanceResult -> Bool # (/=) :: CursorDistanceResult -> CursorDistanceResult -> Bool #
Ord CursorDistanceResult Source #
Methods compare :: CursorDistanceResult -> CursorDistanceResult -> Ordering # (<) :: CursorDistanceResult -> CursorDistanceResult -> Bool # (<=) :: CursorDistanceResult -> CursorDistanceResult -> Bool # (>) :: CursorDistanceResult -> CursorDistanceResult -> Bool # (>=) :: CursorDistanceResult -> CursorDistanceResult -> Bool # max :: CursorDistanceResult -> CursorDistanceResult -> CursorDistanceResult # min :: CursorDistanceResult -> CursorDistanceResult -> CursorDistanceResult #
Show CursorDistanceResult Source #
Methods showsPrec :: Int -> CursorDistanceResult -> ShowS # show :: CursorDistanceResult -> String # showList :: [CursorDistanceResult] -> ShowS #
Generic CursorDistanceResult Source #
Associated Types type Rep CursorDistanceResult :: * -> * # Methods from :: CursorDistanceResult -> Rep CursorDistanceResult x # to :: Rep CursorDistanceResult x -> CursorDistanceResult #
Hashable CursorDistanceResult Source #
Methods hashWithSalt :: Int -> CursorDistanceResult -> Int # hash :: CursorDistanceResult -> Int #
ToJSON CursorDistanceResult Source #
Methods toJSON :: CursorDistanceResult -> Value # toEncoding :: CursorDistanceResult -> Encoding # toJSONList :: [CursorDistanceResult] -> Value # toEncodingList :: [CursorDistanceResult] -> Encoding #
FromJSON CursorDistanceResult Source #
Methods parseJSON :: Value -> Parser CursorDistanceResult # parseJSONList :: Value -> Parser [CursorDistanceResult] #
HasNakadiDistance CursorDistanceResult Int64
Methods distance :: Lens' CursorDistanceResult Int64
type Rep CursorDistanceResult Source #
type Rep CursorDistanceResult = D1 * (MetaData "CursorDistanceResult" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "CursorDistanceResult" PrefixI True) (S1 * (MetaSel (Just Symbol "_distance") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int64)))

data SubscriptionPosition Source #

Type for subscription positions.

Constructors

SubscriptionPositionBegin
SubscriptionPositionEnd
SubscriptionPositionCursors

Instances

Eq SubscriptionPosition Source #
Methods (==) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (/=) :: SubscriptionPosition -> SubscriptionPosition -> Bool #
Ord SubscriptionPosition Source #
Methods compare :: SubscriptionPosition -> SubscriptionPosition -> Ordering # (<) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (<=) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (>) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (>=) :: SubscriptionPosition -> SubscriptionPosition -> Bool # max :: SubscriptionPosition -> SubscriptionPosition -> SubscriptionPosition # min :: SubscriptionPosition -> SubscriptionPosition -> SubscriptionPosition #
Show SubscriptionPosition Source #
Methods showsPrec :: Int -> SubscriptionPosition -> ShowS # show :: SubscriptionPosition -> String # showList :: [SubscriptionPosition] -> ShowS #
Generic SubscriptionPosition Source #
Associated Types type Rep SubscriptionPosition :: * -> * # Methods from :: SubscriptionPosition -> Rep SubscriptionPosition x # to :: Rep SubscriptionPosition x -> SubscriptionPosition #
Hashable SubscriptionPosition Source #
Methods hashWithSalt :: Int -> SubscriptionPosition -> Int # hash :: SubscriptionPosition -> Int #
ToJSON SubscriptionPosition Source #
Methods toJSON :: SubscriptionPosition -> Value # toEncoding :: SubscriptionPosition -> Encoding # toJSONList :: [SubscriptionPosition] -> Value # toEncodingList :: [SubscriptionPosition] -> Encoding #
FromJSON SubscriptionPosition Source #
Methods parseJSON :: Value -> Parser SubscriptionPosition # parseJSONList :: Value -> Parser [SubscriptionPosition] #
HasNakadiReadFrom Subscription (Maybe SubscriptionPosition)
Methods readFrom :: Lens' Subscription (Maybe SubscriptionPosition)
type Rep SubscriptionPosition Source #
type Rep SubscriptionPosition = D1 * (MetaData "SubscriptionPosition" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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.

Constructors

Subscription
Fields _id :: Maybe SubscriptionId _owningApplication :: ApplicationName _eventTypes :: [EventTypeName] _consumerGroup :: Maybe Text _createdAt :: Maybe Timestamp _readFrom :: Maybe SubscriptionPosition _initialCursors :: Maybe [SubscriptionCursorWithoutToken]

Instances

Eq Subscription Source #
Methods (==) :: Subscription -> Subscription -> Bool # (/=) :: Subscription -> Subscription -> Bool #
Ord Subscription Source #
Methods compare :: Subscription -> Subscription -> Ordering # (<) :: Subscription -> Subscription -> Bool # (<=) :: Subscription -> Subscription -> Bool # (>) :: Subscription -> Subscription -> Bool # (>=) :: Subscription -> Subscription -> Bool # max :: Subscription -> Subscription -> Subscription # min :: Subscription -> Subscription -> Subscription #
Show Subscription Source #
Methods showsPrec :: Int -> Subscription -> ShowS # show :: Subscription -> String # showList :: [Subscription] -> ShowS #
Generic Subscription Source #
Associated Types type Rep Subscription :: * -> * # Methods from :: Subscription -> Rep Subscription x # to :: Rep Subscription x -> Subscription #
Hashable Subscription Source #
Methods hashWithSalt :: Int -> Subscription -> Int # hash :: Subscription -> Int #
ToJSON Subscription Source #
Methods toJSON :: Subscription -> Value # toEncoding :: Subscription -> Encoding # toJSONList :: [Subscription] -> Value # toEncodingList :: [Subscription] -> Encoding #
FromJSON Subscription Source #
Methods parseJSON :: Value -> Parser Subscription # parseJSONList :: Value -> Parser [Subscription] #
HasNakadiOwningApplication Subscription ApplicationName
Methods owningApplication :: Lens' Subscription ApplicationName
HasNakadiCreatedAt Subscription (Maybe Timestamp)
Methods createdAt :: Lens' Subscription (Maybe Timestamp)
HasNakadiItems SubscriptionsListResponse [Subscription]
Methods items :: Lens' SubscriptionsListResponse [Subscription]
HasNakadiReadFrom Subscription (Maybe SubscriptionPosition)
Methods readFrom :: Lens' Subscription (Maybe SubscriptionPosition)
HasNakadiInitialCursors Subscription (Maybe [SubscriptionCursorWithoutToken])
Methods initialCursors :: Lens' Subscription (Maybe [SubscriptionCursorWithoutToken])
HasNakadiId Subscription (Maybe SubscriptionId)
Methods id :: Lens' Subscription (Maybe SubscriptionId)
HasNakadiEventTypes Subscription [EventTypeName]
Methods eventTypes :: Lens' Subscription [EventTypeName]
HasNakadiConsumerGroup Subscription (Maybe Text)
Methods consumerGroup :: Lens' Subscription (Maybe Text)
type Rep Subscription Source #
type Rep Subscription = D1 * (MetaData "Subscription" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "Subscription" PrefixI True) ((::) ((::) (S1 * (MetaSel (Just Symbol "_id") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe SubscriptionId))) ((::) (S1 * (MetaSel (Just Symbol "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * ApplicationName)) (S1 * (MetaSel (Just Symbol "_eventTypes") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * [EventTypeName])))) ((::) ((::) (S1 * (MetaSel (Just Symbol "_consumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "_createdAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe Timestamp)))) ((::) (S1 * (MetaSel (Just Symbol "_readFrom") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe SubscriptionPosition))) (S1 * (MetaSel (Just Symbol "_initialCursors") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [SubscriptionCursorWithoutToken])))))))

data PublishingStatus Source #

Type for publishing status.

Constructors

PublishingStatusSubmitted
PublishingStatusFailed
PublishingStatusAborted

Instances

Eq PublishingStatus Source #
Methods (==) :: PublishingStatus -> PublishingStatus -> Bool # (/=) :: PublishingStatus -> PublishingStatus -> Bool #
Ord PublishingStatus Source #
Methods compare :: PublishingStatus -> PublishingStatus -> Ordering # (<) :: PublishingStatus -> PublishingStatus -> Bool # (<=) :: PublishingStatus -> PublishingStatus -> Bool # (>) :: PublishingStatus -> PublishingStatus -> Bool # (>=) :: PublishingStatus -> PublishingStatus -> Bool # max :: PublishingStatus -> PublishingStatus -> PublishingStatus # min :: PublishingStatus -> PublishingStatus -> PublishingStatus #
Show PublishingStatus Source #
Methods showsPrec :: Int -> PublishingStatus -> ShowS # show :: PublishingStatus -> String # showList :: [PublishingStatus] -> ShowS #
Generic PublishingStatus Source #
Associated Types type Rep PublishingStatus :: * -> * # Methods from :: PublishingStatus -> Rep PublishingStatus x # to :: Rep PublishingStatus x -> PublishingStatus #
Hashable PublishingStatus Source #
Methods hashWithSalt :: Int -> PublishingStatus -> Int # hash :: PublishingStatus -> Int #
ToJSON PublishingStatus Source #
Methods toJSON :: PublishingStatus -> Value # toEncoding :: PublishingStatus -> Encoding # toJSONList :: [PublishingStatus] -> Value # toEncodingList :: [PublishingStatus] -> Encoding #
FromJSON PublishingStatus Source #
Methods parseJSON :: Value -> Parser PublishingStatus # parseJSONList :: Value -> Parser [PublishingStatus] #
type Rep PublishingStatus Source #
type Rep PublishingStatus = D1 * (MetaData "PublishingStatus" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) ((:+:) * (C1 * (MetaCons "PublishingStatusSubmitted" PrefixI False) (U1 )) ((:+:) (C1 * (MetaCons "PublishingStatusFailed" PrefixI False) (U1 )) (C1 (MetaCons "PublishingStatusAborted" PrefixI False) (U1 *))))

data Step Source #

Step

Constructors

StepNone
StepValidating
StepPartitioning
StepEnriching
StepPublishing

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 #
Methods toJSON :: Step -> Value # toEncoding :: Step -> Encoding # toJSONList :: [Step] -> Value # toEncodingList :: [Step] -> Encoding #
FromJSON Step Source #
Methods parseJSON :: Value -> Parser Step # parseJSONList :: Value -> Parser [Step] #
type Rep Step Source #
type Rep Step = D1 * (MetaData "Step" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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.

Constructors

BatchItemResponse
Fields _eid :: Maybe EventId _publishingStatus :: PublishingStatus _step :: Maybe Step _detail :: Maybe Text

Instances

Eq BatchItemResponse Source #
Methods (==) :: BatchItemResponse -> BatchItemResponse -> Bool # (/=) :: BatchItemResponse -> BatchItemResponse -> Bool #
Ord BatchItemResponse Source #
Methods compare :: BatchItemResponse -> BatchItemResponse -> Ordering # (<) :: BatchItemResponse -> BatchItemResponse -> Bool # (<=) :: BatchItemResponse -> BatchItemResponse -> Bool # (>) :: BatchItemResponse -> BatchItemResponse -> Bool # (>=) :: BatchItemResponse -> BatchItemResponse -> Bool # max :: BatchItemResponse -> BatchItemResponse -> BatchItemResponse # min :: BatchItemResponse -> BatchItemResponse -> BatchItemResponse #
Show BatchItemResponse Source #
Methods showsPrec :: Int -> BatchItemResponse -> ShowS # show :: BatchItemResponse -> String # showList :: [BatchItemResponse] -> ShowS #
Generic BatchItemResponse Source #
Associated Types type Rep BatchItemResponse :: * -> * # Methods from :: BatchItemResponse -> Rep BatchItemResponse x # to :: Rep BatchItemResponse x -> BatchItemResponse #
Hashable BatchItemResponse Source #
Methods hashWithSalt :: Int -> BatchItemResponse -> Int # hash :: BatchItemResponse -> Int #
ToJSON BatchItemResponse Source #
Methods toJSON :: BatchItemResponse -> Value # toEncoding :: BatchItemResponse -> Encoding # toJSONList :: [BatchItemResponse] -> Value # toEncodingList :: [BatchItemResponse] -> Encoding #
FromJSON BatchItemResponse Source #
Methods parseJSON :: Value -> Parser BatchItemResponse # parseJSONList :: Value -> Parser [BatchItemResponse] #
type Rep BatchItemResponse Source #
type Rep BatchItemResponse = D1 * (MetaData "BatchItemResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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))))))

newtype StreamKeepAliveLimit Source #

StreamKeepAliveLimit

Constructors

StreamKeepAliveLimit
Fields unStreamKeepAliveLimit :: Int32

Instances

Eq StreamKeepAliveLimit Source #
Methods (==) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (/=) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool #
Ord StreamKeepAliveLimit Source #
Methods compare :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Ordering # (<) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (<=) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (>) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (>=) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # max :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> StreamKeepAliveLimit # min :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> StreamKeepAliveLimit #
Show StreamKeepAliveLimit Source #
Methods showsPrec :: Int -> StreamKeepAliveLimit -> ShowS # show :: StreamKeepAliveLimit -> String # showList :: [StreamKeepAliveLimit] -> ShowS #
ToJSON StreamKeepAliveLimit Source #
Methods toJSON :: StreamKeepAliveLimit -> Value # toEncoding :: StreamKeepAliveLimit -> Encoding # toJSONList :: [StreamKeepAliveLimit] -> Value # toEncodingList :: [StreamKeepAliveLimit] -> Encoding #
FromJSON StreamKeepAliveLimit Source #
Methods parseJSON :: Value -> Parser StreamKeepAliveLimit # parseJSONList :: Value -> Parser [StreamKeepAliveLimit] #

newtype BatchFlushTimeout Source #

BatchFlushTimeout

Constructors

BatchFlushTimeout
Fields unBatchFlushTimeout :: Int32

Instances

Eq BatchFlushTimeout Source #
Methods (==) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (/=) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool #
Ord BatchFlushTimeout Source #
Methods compare :: BatchFlushTimeout -> BatchFlushTimeout -> Ordering # (<) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (<=) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (>) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (>=) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # max :: BatchFlushTimeout -> BatchFlushTimeout -> BatchFlushTimeout # min :: BatchFlushTimeout -> BatchFlushTimeout -> BatchFlushTimeout #
Show BatchFlushTimeout Source #
Methods showsPrec :: Int -> BatchFlushTimeout -> ShowS # show :: BatchFlushTimeout -> String # showList :: [BatchFlushTimeout] -> ShowS #
ToJSON BatchFlushTimeout Source #
Methods toJSON :: BatchFlushTimeout -> Value # toEncoding :: BatchFlushTimeout -> Encoding # toJSONList :: [BatchFlushTimeout] -> Value # toEncodingList :: [BatchFlushTimeout] -> Encoding #
FromJSON BatchFlushTimeout Source #
Methods parseJSON :: Value -> Parser BatchFlushTimeout # parseJSONList :: Value -> Parser [BatchFlushTimeout] #

data CursorCommitResultType Source #

CursorCommitResultType

Constructors

CursorCommitResultCommitted
CursorCommitResultOutdated

Instances

Eq CursorCommitResultType Source #
Methods (==) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (/=) :: CursorCommitResultType -> CursorCommitResultType -> Bool #
Ord CursorCommitResultType Source #
Methods compare :: CursorCommitResultType -> CursorCommitResultType -> Ordering # (<) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (<=) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (>) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (>=) :: CursorCommitResultType -> CursorCommitResultType -> Bool # max :: CursorCommitResultType -> CursorCommitResultType -> CursorCommitResultType # min :: CursorCommitResultType -> CursorCommitResultType -> CursorCommitResultType #
Show CursorCommitResultType Source #
Methods showsPrec :: Int -> CursorCommitResultType -> ShowS # show :: CursorCommitResultType -> String # showList :: [CursorCommitResultType] -> ShowS #
ToJSON CursorCommitResultType Source #
Methods toJSON :: CursorCommitResultType -> Value # toEncoding :: CursorCommitResultType -> Encoding # toJSONList :: [CursorCommitResultType] -> Value # toEncodingList :: [CursorCommitResultType] -> Encoding #
FromJSON CursorCommitResultType Source #
Methods parseJSON :: Value -> Parser CursorCommitResultType # parseJSONList :: Value -> Parser [CursorCommitResultType] #

data CursorCommitResult Source #

CursorCommitResult

Constructors

CursorCommitResult
Fields _cursor :: SubscriptionCursor _result :: CursorCommitResultType

Instances

Eq CursorCommitResult Source #
Methods (==) :: CursorCommitResult -> CursorCommitResult -> Bool # (/=) :: CursorCommitResult -> CursorCommitResult -> Bool #
Ord CursorCommitResult Source #
Methods compare :: CursorCommitResult -> CursorCommitResult -> Ordering # (<) :: CursorCommitResult -> CursorCommitResult -> Bool # (<=) :: CursorCommitResult -> CursorCommitResult -> Bool # (>) :: CursorCommitResult -> CursorCommitResult -> Bool # (>=) :: CursorCommitResult -> CursorCommitResult -> Bool # max :: CursorCommitResult -> CursorCommitResult -> CursorCommitResult # min :: CursorCommitResult -> CursorCommitResult -> CursorCommitResult #
Show CursorCommitResult Source #
Methods showsPrec :: Int -> CursorCommitResult -> ShowS # show :: CursorCommitResult -> String # showList :: [CursorCommitResult] -> ShowS #
ToJSON CursorCommitResult Source #
Methods toJSON :: CursorCommitResult -> Value # toEncoding :: CursorCommitResult -> Encoding # toJSONList :: [CursorCommitResult] -> Value # toEncodingList :: [CursorCommitResult] -> Encoding #
FromJSON CursorCommitResult Source #
Methods parseJSON :: Value -> Parser CursorCommitResult # parseJSONList :: Value -> Parser [CursorCommitResult] #

newtype CursorCommitResults Source #

Constructors

CursorCommitResults
Fields _items :: [CursorCommitResult]

Instances

Eq CursorCommitResults Source #
Methods (==) :: CursorCommitResults -> CursorCommitResults -> Bool # (/=) :: CursorCommitResults -> CursorCommitResults -> Bool #
Ord CursorCommitResults Source #
Methods compare :: CursorCommitResults -> CursorCommitResults -> Ordering # (<) :: CursorCommitResults -> CursorCommitResults -> Bool # (<=) :: CursorCommitResults -> CursorCommitResults -> Bool # (>) :: CursorCommitResults -> CursorCommitResults -> Bool # (>=) :: CursorCommitResults -> CursorCommitResults -> Bool # max :: CursorCommitResults -> CursorCommitResults -> CursorCommitResults # min :: CursorCommitResults -> CursorCommitResults -> CursorCommitResults #
Show CursorCommitResults Source #
Methods showsPrec :: Int -> CursorCommitResults -> ShowS # show :: CursorCommitResults -> String # showList :: [CursorCommitResults] -> ShowS #
ToJSON CursorCommitResults Source #
Methods toJSON :: CursorCommitResults -> Value # toEncoding :: CursorCommitResults -> Encoding # toJSONList :: [CursorCommitResults] -> Value # toEncodingList :: [CursorCommitResults] -> Encoding #
FromJSON CursorCommitResults Source #
Methods parseJSON :: Value -> Parser CursorCommitResults # parseJSONList :: Value -> Parser [CursorCommitResults] #

data SchemaType Source #

SchemaType

Constructors

SchemaTypeJson

Instances

Eq SchemaType Source #
Methods (==) :: SchemaType -> SchemaType -> Bool # (/=) :: SchemaType -> SchemaType -> Bool #
Ord SchemaType Source #
Methods compare :: SchemaType -> SchemaType -> Ordering # (<) :: SchemaType -> SchemaType -> Bool # (<=) :: SchemaType -> SchemaType -> Bool # (>) :: SchemaType -> SchemaType -> Bool # (>=) :: SchemaType -> SchemaType -> Bool # max :: SchemaType -> SchemaType -> SchemaType # min :: SchemaType -> SchemaType -> SchemaType #
Show SchemaType Source #
Methods showsPrec :: Int -> SchemaType -> ShowS # show :: SchemaType -> String # showList :: [SchemaType] -> ShowS #
Generic SchemaType Source #
Associated Types type Rep SchemaType :: * -> * # Methods from :: SchemaType -> Rep SchemaType x # to :: Rep SchemaType x -> SchemaType #
Hashable SchemaType Source #
Methods hashWithSalt :: Int -> SchemaType -> Int # hash :: SchemaType -> Int #
ToJSON SchemaType Source #
Methods toJSON :: SchemaType -> Value # toEncoding :: SchemaType -> Encoding # toJSONList :: [SchemaType] -> Value # toEncodingList :: [SchemaType] -> Encoding #
FromJSON SchemaType Source #
Methods parseJSON :: Value -> Parser SchemaType # parseJSONList :: Value -> Parser [SchemaType] #
HasNakadiSchemaType EventTypeSchema SchemaType
Methods schemaType :: Lens' EventTypeSchema SchemaType
type Rep SchemaType Source #
type Rep SchemaType = D1 * (MetaData "SchemaType" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "SchemaTypeJson" PrefixI False) (U1 *))

data EventTypeSchema Source #

Type for the schema of an event type.

Constructors

EventTypeSchema
Fields _version :: Maybe SchemaVersion _createdAt :: Maybe Timestamp _schemaType :: SchemaType _schema :: Text

Instances

Eq EventTypeSchema Source #
Methods (==) :: EventTypeSchema -> EventTypeSchema -> Bool # (/=) :: EventTypeSchema -> EventTypeSchema -> Bool #
Ord EventTypeSchema Source #
Methods compare :: EventTypeSchema -> EventTypeSchema -> Ordering # (<) :: EventTypeSchema -> EventTypeSchema -> Bool # (<=) :: EventTypeSchema -> EventTypeSchema -> Bool # (>) :: EventTypeSchema -> EventTypeSchema -> Bool # (>=) :: EventTypeSchema -> EventTypeSchema -> Bool # max :: EventTypeSchema -> EventTypeSchema -> EventTypeSchema # min :: EventTypeSchema -> EventTypeSchema -> EventTypeSchema #
Show EventTypeSchema Source #
Methods showsPrec :: Int -> EventTypeSchema -> ShowS # show :: EventTypeSchema -> String # showList :: [EventTypeSchema] -> ShowS #
Generic EventTypeSchema Source #
Associated Types type Rep EventTypeSchema :: * -> * # Methods from :: EventTypeSchema -> Rep EventTypeSchema x # to :: Rep EventTypeSchema x -> EventTypeSchema #
Hashable EventTypeSchema Source #
Methods hashWithSalt :: Int -> EventTypeSchema -> Int # hash :: EventTypeSchema -> Int #
ToJSON EventTypeSchema Source #
Methods toJSON :: EventTypeSchema -> Value # toEncoding :: EventTypeSchema -> Encoding # toJSONList :: [EventTypeSchema] -> Value # toEncodingList :: [EventTypeSchema] -> Encoding #
FromJSON EventTypeSchema Source #
Methods parseJSON :: Value -> Parser EventTypeSchema # parseJSONList :: Value -> Parser [EventTypeSchema] #
HasNakadiSchemaType EventTypeSchema SchemaType
Methods schemaType :: Lens' EventTypeSchema SchemaType
HasNakadiSchema EventTypeSchema Text
Methods schema :: Lens' EventTypeSchema Text
HasNakadiSchema EventType EventTypeSchema
Methods schema :: Lens' EventType EventTypeSchema
HasNakadiVersion EventTypeSchema (Maybe SchemaVersion)
Methods version :: Lens' EventTypeSchema (Maybe SchemaVersion)
HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp)
Methods createdAt :: Lens' EventTypeSchema (Maybe Timestamp)
HasNakadiItems EventTypeSchemasResponse [EventTypeSchema]
Methods items :: Lens' EventTypeSchemasResponse [EventTypeSchema]
type Rep EventTypeSchema Source #
type Rep EventTypeSchema = D1 * (MetaData "EventTypeSchema" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 _href :: Text

Instances

Eq PaginationLink Source #
Methods (==) :: PaginationLink -> PaginationLink -> Bool # (/=) :: PaginationLink -> PaginationLink -> Bool #
Ord PaginationLink Source #
Methods compare :: PaginationLink -> PaginationLink -> Ordering # (<) :: PaginationLink -> PaginationLink -> Bool # (<=) :: PaginationLink -> PaginationLink -> Bool # (>) :: PaginationLink -> PaginationLink -> Bool # (>=) :: PaginationLink -> PaginationLink -> Bool # max :: PaginationLink -> PaginationLink -> PaginationLink # min :: PaginationLink -> PaginationLink -> PaginationLink #
Show PaginationLink Source #
Methods showsPrec :: Int -> PaginationLink -> ShowS # show :: PaginationLink -> String # showList :: [PaginationLink] -> ShowS #
Generic PaginationLink Source #
Associated Types type Rep PaginationLink :: * -> * # Methods from :: PaginationLink -> Rep PaginationLink x # to :: Rep PaginationLink x -> PaginationLink #
Hashable PaginationLink Source #
Methods hashWithSalt :: Int -> PaginationLink -> Int # hash :: PaginationLink -> Int #
ToJSON PaginationLink Source #
Methods toJSON :: PaginationLink -> Value # toEncoding :: PaginationLink -> Encoding # toJSONList :: [PaginationLink] -> Value # toEncodingList :: [PaginationLink] -> Encoding #
FromJSON PaginationLink Source #
Methods parseJSON :: Value -> Parser PaginationLink # parseJSONList :: Value -> Parser [PaginationLink] #
HasNakadiHref PaginationLink Text
Methods href :: Lens' PaginationLink Text
HasNakadiPrev PaginationLinks (Maybe PaginationLink)
Methods prev :: Lens' PaginationLinks (Maybe PaginationLink)
HasNakadiNext PaginationLinks (Maybe PaginationLink)
Methods next :: Lens' PaginationLinks (Maybe PaginationLink)
type Rep PaginationLink Source #
type Rep PaginationLink = D1 * (MetaData "PaginationLink" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "PaginationLink" PrefixI True) (S1 * (MetaSel (Just Symbol "_href") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data PaginationLinks Source #

PaginationLinks

Constructors

PaginationLinks
Fields _prev :: Maybe PaginationLink _next :: Maybe PaginationLink

Instances

Eq PaginationLinks Source #
Methods (==) :: PaginationLinks -> PaginationLinks -> Bool # (/=) :: PaginationLinks -> PaginationLinks -> Bool #
Ord PaginationLinks Source #
Methods compare :: PaginationLinks -> PaginationLinks -> Ordering # (<) :: PaginationLinks -> PaginationLinks -> Bool # (<=) :: PaginationLinks -> PaginationLinks -> Bool # (>) :: PaginationLinks -> PaginationLinks -> Bool # (>=) :: PaginationLinks -> PaginationLinks -> Bool # max :: PaginationLinks -> PaginationLinks -> PaginationLinks # min :: PaginationLinks -> PaginationLinks -> PaginationLinks #
Show PaginationLinks Source #
Methods showsPrec :: Int -> PaginationLinks -> ShowS # show :: PaginationLinks -> String # showList :: [PaginationLinks] -> ShowS #
Generic PaginationLinks Source #
Associated Types type Rep PaginationLinks :: * -> * # Methods from :: PaginationLinks -> Rep PaginationLinks x # to :: Rep PaginationLinks x -> PaginationLinks #
Hashable PaginationLinks Source #
Methods hashWithSalt :: Int -> PaginationLinks -> Int # hash :: PaginationLinks -> Int #
ToJSON PaginationLinks Source #
Methods toJSON :: PaginationLinks -> Value # toEncoding :: PaginationLinks -> Encoding # toJSONList :: [PaginationLinks] -> Value # toEncodingList :: [PaginationLinks] -> Encoding #
FromJSON PaginationLinks Source #
Methods parseJSON :: Value -> Parser PaginationLinks # parseJSONList :: Value -> Parser [PaginationLinks] #
HasNakadiLinks EventTypeSchemasResponse PaginationLinks
Methods links :: Lens' EventTypeSchemasResponse PaginationLinks
HasNakadiLinks SubscriptionsListResponse PaginationLinks
Methods links :: Lens' SubscriptionsListResponse PaginationLinks
HasNakadiPrev PaginationLinks (Maybe PaginationLink)
Methods prev :: Lens' PaginationLinks (Maybe PaginationLink)
HasNakadiNext PaginationLinks (Maybe PaginationLink)
Methods next :: Lens' PaginationLinks (Maybe PaginationLink)
type Rep PaginationLinks Source #
type Rep PaginationLinks = D1 * (MetaData "PaginationLinks" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "PaginationLinks" PrefixI True) ((::) (S1 * (MetaSel (Just Symbol "_prev") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PaginationLink))) (S1 * (MetaSel (Just Symbol "_next") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PaginationLink)))))

data EventTypeSchemasResponse Source #

EventTypeSchemasResponse

Constructors

EventTypeSchemasResponse
Fields _links :: PaginationLinks _items :: [EventTypeSchema]

Instances

Eq EventTypeSchemasResponse Source #
Methods (==) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (/=) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool #
Ord EventTypeSchemasResponse Source #
Methods compare :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Ordering # (<) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (<=) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (>) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (>=) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # max :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> EventTypeSchemasResponse # min :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> EventTypeSchemasResponse #
Show EventTypeSchemasResponse Source #
Methods showsPrec :: Int -> EventTypeSchemasResponse -> ShowS # show :: EventTypeSchemasResponse -> String # showList :: [EventTypeSchemasResponse] -> ShowS #
Generic EventTypeSchemasResponse Source #
Associated Types type Rep EventTypeSchemasResponse :: * -> * # Methods from :: EventTypeSchemasResponse -> Rep EventTypeSchemasResponse x # to :: Rep EventTypeSchemasResponse x -> EventTypeSchemasResponse #
Hashable EventTypeSchemasResponse Source #
Methods hashWithSalt :: Int -> EventTypeSchemasResponse -> Int # hash :: EventTypeSchemasResponse -> Int #
ToJSON EventTypeSchemasResponse Source #
Methods toJSON :: EventTypeSchemasResponse -> Value # toEncoding :: EventTypeSchemasResponse -> Encoding # toJSONList :: [EventTypeSchemasResponse] -> Value # toEncodingList :: [EventTypeSchemasResponse] -> Encoding #
FromJSON EventTypeSchemasResponse Source #
Methods parseJSON :: Value -> Parser EventTypeSchemasResponse # parseJSONList :: Value -> Parser [EventTypeSchemasResponse] #
HasNakadiLinks EventTypeSchemasResponse PaginationLinks
Methods links :: Lens' EventTypeSchemasResponse PaginationLinks
HasNakadiItems EventTypeSchemasResponse [EventTypeSchema]
Methods items :: Lens' EventTypeSchemasResponse [EventTypeSchema]
type Rep EventTypeSchemasResponse Source #
type Rep EventTypeSchemasResponse = D1 * (MetaData "EventTypeSchemasResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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]))))

newtype SchemaVersion Source #

Type for the version of a schema.

Constructors

SchemaVersion
Fields unSchemaVersion :: Text

Instances

Eq SchemaVersion Source #
Methods (==) :: SchemaVersion -> SchemaVersion -> Bool # (/=) :: SchemaVersion -> SchemaVersion -> Bool #
Ord SchemaVersion Source #
Methods compare :: SchemaVersion -> SchemaVersion -> Ordering # (<) :: SchemaVersion -> SchemaVersion -> Bool # (<=) :: SchemaVersion -> SchemaVersion -> Bool # (>) :: SchemaVersion -> SchemaVersion -> Bool # (>=) :: SchemaVersion -> SchemaVersion -> Bool # max :: SchemaVersion -> SchemaVersion -> SchemaVersion # min :: SchemaVersion -> SchemaVersion -> SchemaVersion #
Show SchemaVersion Source #
Methods showsPrec :: Int -> SchemaVersion -> ShowS # show :: SchemaVersion -> String # showList :: [SchemaVersion] -> ShowS #
IsString SchemaVersion Source #
Methods fromString :: String -> SchemaVersion #
Generic SchemaVersion Source #
Associated Types type Rep SchemaVersion :: * -> * # Methods from :: SchemaVersion -> Rep SchemaVersion x # to :: Rep SchemaVersion x -> SchemaVersion #
Hashable SchemaVersion Source #
Methods hashWithSalt :: Int -> SchemaVersion -> Int # hash :: SchemaVersion -> Int #
ToJSON SchemaVersion Source #
Methods toJSON :: SchemaVersion -> Value # toEncoding :: SchemaVersion -> Encoding # toJSONList :: [SchemaVersion] -> Value # toEncodingList :: [SchemaVersion] -> Encoding #
FromJSON SchemaVersion Source #
Methods parseJSON :: Value -> Parser SchemaVersion # parseJSONList :: Value -> Parser [SchemaVersion] #
HasNakadiVersion MetadataEnriched SchemaVersion
Methods version :: Lens' MetadataEnriched SchemaVersion
HasNakadiVersion EventTypeSchema (Maybe SchemaVersion)
Methods version :: Lens' EventTypeSchema (Maybe SchemaVersion)
type Rep SchemaVersion Source #
type Rep SchemaVersion = D1 * (MetaData "SchemaVersion" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "SchemaVersion" PrefixI True) (S1 * (MetaSel (Just Symbol "unSchemaVersion") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

newtype Offset Source #

Type for offset values.

Constructors

Offset
Fields unOffset :: Int64 Wrapped offset value

Instances

Eq Offset Source #
Methods (==) :: Offset -> Offset -> Bool # (/=) :: Offset -> Offset -> Bool #
Ord Offset Source #
Methods compare :: Offset -> Offset -> Ordering # (<) :: Offset -> Offset -> Bool # (<=) :: Offset -> Offset -> Bool # (>) :: Offset -> Offset -> Bool # (>=) :: Offset -> Offset -> Bool # max :: Offset -> Offset -> Offset # min :: Offset -> Offset -> Offset #
Show Offset Source #
Methods showsPrec :: Int -> Offset -> ShowS # show :: Offset -> String # showList :: [Offset] -> ShowS #
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.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 unLimit :: Int64 Wrapped limit value.

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.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "Limit" PrefixI True) (S1 * (MetaSel (Just Symbol "unLimit") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int64)))

data PartitionState Source #

Type for partition states.

Constructors

PartitionStateUnassigned
PartitionStateReassigning
PartitionStateAssigned

Instances

Eq PartitionState Source #
Methods (==) :: PartitionState -> PartitionState -> Bool # (/=) :: PartitionState -> PartitionState -> Bool #
Ord PartitionState Source #
Methods compare :: PartitionState -> PartitionState -> Ordering # (<) :: PartitionState -> PartitionState -> Bool # (<=) :: PartitionState -> PartitionState -> Bool # (>) :: PartitionState -> PartitionState -> Bool # (>=) :: PartitionState -> PartitionState -> Bool # max :: PartitionState -> PartitionState -> PartitionState # min :: PartitionState -> PartitionState -> PartitionState #
Show PartitionState Source #
Methods showsPrec :: Int -> PartitionState -> ShowS # show :: PartitionState -> String # showList :: [PartitionState] -> ShowS #
ToJSON PartitionState Source #
Methods toJSON :: PartitionState -> Value # toEncoding :: PartitionState -> Encoding # toJSONList :: [PartitionState] -> Value # toEncodingList :: [PartitionState] -> Encoding #
FromJSON PartitionState Source #
Methods parseJSON :: Value -> Parser PartitionState # parseJSONList :: Value -> Parser [PartitionState] #

data PartitionStat Source #

Type for per-partition statistics.

Constructors

PartitionStat
Fields _partition :: PartitionName _state :: PartitionState _unconsumedEvents :: Int64 _streamId :: StreamId

Instances

Eq PartitionStat Source #
Methods (==) :: PartitionStat -> PartitionStat -> Bool # (/=) :: PartitionStat -> PartitionStat -> Bool #
Ord PartitionStat Source #
Methods compare :: PartitionStat -> PartitionStat -> Ordering # (<) :: PartitionStat -> PartitionStat -> Bool # (<=) :: PartitionStat -> PartitionStat -> Bool # (>) :: PartitionStat -> PartitionStat -> Bool # (>=) :: PartitionStat -> PartitionStat -> Bool # max :: PartitionStat -> PartitionStat -> PartitionStat # min :: PartitionStat -> PartitionStat -> PartitionStat #
Show PartitionStat Source #
Methods showsPrec :: Int -> PartitionStat -> ShowS # show :: PartitionStat -> String # showList :: [PartitionStat] -> ShowS #
Generic PartitionStat Source #
Associated Types type Rep PartitionStat :: * -> * # Methods from :: PartitionStat -> Rep PartitionStat x # to :: Rep PartitionStat x -> PartitionStat #
ToJSON PartitionStat Source #
Methods toJSON :: PartitionStat -> Value # toEncoding :: PartitionStat -> Encoding # toJSONList :: [PartitionStat] -> Value # toEncodingList :: [PartitionStat] -> Encoding #
FromJSON PartitionStat Source #
Methods parseJSON :: Value -> Parser PartitionStat # parseJSONList :: Value -> Parser [PartitionStat] #
type Rep PartitionStat Source #
type Rep PartitionStat = D1 * (MetaData "PartitionStat" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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.

Constructors

SubscriptionEventTypeStats
Fields _eventType :: EventTypeName _partitions :: [PartitionStat]

Instances

Eq SubscriptionEventTypeStats Source #
Methods (==) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (/=) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool #
Ord SubscriptionEventTypeStats Source #
Methods compare :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Ordering # (<) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (<=) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (>) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (>=) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # max :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> SubscriptionEventTypeStats # min :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> SubscriptionEventTypeStats #
Show SubscriptionEventTypeStats Source #
Methods showsPrec :: Int -> SubscriptionEventTypeStats -> ShowS # show :: SubscriptionEventTypeStats -> String # showList :: [SubscriptionEventTypeStats] -> ShowS #
Generic SubscriptionEventTypeStats Source #
Associated Types type Rep SubscriptionEventTypeStats :: * -> * # Methods from :: SubscriptionEventTypeStats -> Rep SubscriptionEventTypeStats x # to :: Rep SubscriptionEventTypeStats x -> SubscriptionEventTypeStats #
ToJSON SubscriptionEventTypeStats Source #
Methods toJSON :: SubscriptionEventTypeStats -> Value # toEncoding :: SubscriptionEventTypeStats -> Encoding # toJSONList :: [SubscriptionEventTypeStats] -> Value # toEncodingList :: [SubscriptionEventTypeStats] -> Encoding #
FromJSON SubscriptionEventTypeStats Source #
Methods parseJSON :: Value -> Parser SubscriptionEventTypeStats # parseJSONList :: Value -> Parser [SubscriptionEventTypeStats] #
HasNakadiItems SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]
Methods items :: Lens' SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]
type Rep SubscriptionEventTypeStats Source #
type Rep SubscriptionEventTypeStats = D1 * (MetaData "SubscriptionEventTypeStats" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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

Constructors

SubscriptionEventTypeStatsResult
Fields _items :: [SubscriptionEventTypeStats]

Instances

Eq SubscriptionEventTypeStatsResult Source #
Methods (==) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool # (/=) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool #
Ord SubscriptionEventTypeStatsResult Source #
Methods compare :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Ordering # (<) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool # (<=) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool # (>) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool # (>=) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool # max :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult # min :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult #
Show SubscriptionEventTypeStatsResult Source #
Methods showsPrec :: Int -> SubscriptionEventTypeStatsResult -> ShowS # show :: SubscriptionEventTypeStatsResult -> String # showList :: [SubscriptionEventTypeStatsResult] -> ShowS #
Generic SubscriptionEventTypeStatsResult Source #
Associated Types type Rep SubscriptionEventTypeStatsResult :: * -> * # Methods from :: SubscriptionEventTypeStatsResult -> Rep SubscriptionEventTypeStatsResult x # to :: Rep SubscriptionEventTypeStatsResult x -> SubscriptionEventTypeStatsResult #
ToJSON SubscriptionEventTypeStatsResult Source #
Methods toJSON :: SubscriptionEventTypeStatsResult -> Value # toEncoding :: SubscriptionEventTypeStatsResult -> Encoding # toJSONList :: [SubscriptionEventTypeStatsResult] -> Value # toEncodingList :: [SubscriptionEventTypeStatsResult] -> Encoding #
FromJSON SubscriptionEventTypeStatsResult Source #
Methods parseJSON :: Value -> Parser SubscriptionEventTypeStatsResult # parseJSONList :: Value -> Parser [SubscriptionEventTypeStatsResult] #
HasNakadiItems SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]
Methods items :: Lens' SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]
type Rep SubscriptionEventTypeStatsResult Source #
type Rep SubscriptionEventTypeStatsResult = D1 * (MetaData "SubscriptionEventTypeStatsResult" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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.

Constructors

EventTypeCategoryUndefined
EventTypeCategoryData
EventTypeCategoryBusiness

Instances

Eq EventTypeCategory Source #
Methods (==) :: EventTypeCategory -> EventTypeCategory -> Bool # (/=) :: EventTypeCategory -> EventTypeCategory -> Bool #
Ord EventTypeCategory Source #
Methods compare :: EventTypeCategory -> EventTypeCategory -> Ordering # (<) :: EventTypeCategory -> EventTypeCategory -> Bool # (<=) :: EventTypeCategory -> EventTypeCategory -> Bool # (>) :: EventTypeCategory -> EventTypeCategory -> Bool # (>=) :: EventTypeCategory -> EventTypeCategory -> Bool # max :: EventTypeCategory -> EventTypeCategory -> EventTypeCategory # min :: EventTypeCategory -> EventTypeCategory -> EventTypeCategory #
Show EventTypeCategory Source #
Methods showsPrec :: Int -> EventTypeCategory -> ShowS # show :: EventTypeCategory -> String # showList :: [EventTypeCategory] -> ShowS #
Generic EventTypeCategory Source #
Associated Types type Rep EventTypeCategory :: * -> * # Methods from :: EventTypeCategory -> Rep EventTypeCategory x # to :: Rep EventTypeCategory x -> EventTypeCategory #
Hashable EventTypeCategory Source #
Methods hashWithSalt :: Int -> EventTypeCategory -> Int # hash :: EventTypeCategory -> Int #
ToJSON EventTypeCategory Source #
Methods toJSON :: EventTypeCategory -> Value # toEncoding :: EventTypeCategory -> Encoding # toJSONList :: [EventTypeCategory] -> Value # toEncodingList :: [EventTypeCategory] -> Encoding #
FromJSON EventTypeCategory Source #
Methods parseJSON :: Value -> Parser EventTypeCategory # parseJSONList :: Value -> Parser [EventTypeCategory] #
HasNakadiCategory EventType (Maybe EventTypeCategory)
Methods category :: Lens' EventType (Maybe EventTypeCategory)
type Rep EventTypeCategory Source #
type Rep EventTypeCategory = D1 * (MetaData "EventTypeCategory" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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.

Constructors

PartitionStrategyRandom
PartitionStrategyUser
PartitionStrategyHash
PartitionStrategyCustom Text

Instances

Eq PartitionStrategy Source #
Methods (==) :: PartitionStrategy -> PartitionStrategy -> Bool # (/=) :: PartitionStrategy -> PartitionStrategy -> Bool #
Ord PartitionStrategy Source #
Methods compare :: PartitionStrategy -> PartitionStrategy -> Ordering # (<) :: PartitionStrategy -> PartitionStrategy -> Bool # (<=) :: PartitionStrategy -> PartitionStrategy -> Bool # (>) :: PartitionStrategy -> PartitionStrategy -> Bool # (>=) :: PartitionStrategy -> PartitionStrategy -> Bool # max :: PartitionStrategy -> PartitionStrategy -> PartitionStrategy # min :: PartitionStrategy -> PartitionStrategy -> PartitionStrategy #
Show PartitionStrategy Source #
Methods showsPrec :: Int -> PartitionStrategy -> ShowS # show :: PartitionStrategy -> String # showList :: [PartitionStrategy] -> ShowS #
IsString PartitionStrategy Source #
Methods fromString :: String -> PartitionStrategy #
Generic PartitionStrategy Source #
Associated Types type Rep PartitionStrategy :: * -> * # Methods from :: PartitionStrategy -> Rep PartitionStrategy x # to :: Rep PartitionStrategy x -> PartitionStrategy #
Hashable PartitionStrategy Source #
Methods hashWithSalt :: Int -> PartitionStrategy -> Int # hash :: PartitionStrategy -> Int #
ToJSON PartitionStrategy Source #
Methods toJSON :: PartitionStrategy -> Value # toEncoding :: PartitionStrategy -> Encoding # toJSONList :: [PartitionStrategy] -> Value # toEncodingList :: [PartitionStrategy] -> Encoding #
FromJSON PartitionStrategy Source #
Methods parseJSON :: Value -> Parser PartitionStrategy # parseJSONList :: Value -> Parser [PartitionStrategy] #
HasNakadiPartitionStrategy EventType (Maybe PartitionStrategy)
Methods partitionStrategy :: Lens' EventType (Maybe PartitionStrategy)
type Rep PartitionStrategy Source #
type Rep PartitionStrategy = D1 * (MetaData "PartitionStrategy" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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.

Constructors

EnrichmentStrategyMetadata

Instances

Eq EnrichmentStrategy Source #
Methods (==) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool # (/=) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool #
Ord EnrichmentStrategy Source #
Methods compare :: EnrichmentStrategy -> EnrichmentStrategy -> Ordering # (<) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool # (<=) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool # (>) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool # (>=) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool # max :: EnrichmentStrategy -> EnrichmentStrategy -> EnrichmentStrategy # min :: EnrichmentStrategy -> EnrichmentStrategy -> EnrichmentStrategy #
Show EnrichmentStrategy Source #
Methods showsPrec :: Int -> EnrichmentStrategy -> ShowS # show :: EnrichmentStrategy -> String # showList :: [EnrichmentStrategy] -> ShowS #
Generic EnrichmentStrategy Source #
Associated Types type Rep EnrichmentStrategy :: * -> * # Methods from :: EnrichmentStrategy -> Rep EnrichmentStrategy x # to :: Rep EnrichmentStrategy x -> EnrichmentStrategy #
Hashable EnrichmentStrategy Source #
Methods hashWithSalt :: Int -> EnrichmentStrategy -> Int # hash :: EnrichmentStrategy -> Int #
ToJSON EnrichmentStrategy Source #
Methods toJSON :: EnrichmentStrategy -> Value # toEncoding :: EnrichmentStrategy -> Encoding # toJSONList :: [EnrichmentStrategy] -> Value # toEncodingList :: [EnrichmentStrategy] -> Encoding #
FromJSON EnrichmentStrategy Source #
Methods parseJSON :: Value -> Parser EnrichmentStrategy # parseJSONList :: Value -> Parser [EnrichmentStrategy] #
HasNakadiEnrichmentStrategies EventType (Maybe [EnrichmentStrategy])
Methods enrichmentStrategies :: Lens' EventType (Maybe [EnrichmentStrategy])
type Rep EnrichmentStrategy Source #
type Rep EnrichmentStrategy = D1 * (MetaData "EnrichmentStrategy" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "EnrichmentStrategyMetadata" PrefixI False) (U1 *))

data CompatibilityMode Source #

Type for an event type compatibility mode.

Constructors

CompatibilityModeCompatible
CompatibilityModeForward
CompatibilityModeNone

Instances

Eq CompatibilityMode Source #
Methods (==) :: CompatibilityMode -> CompatibilityMode -> Bool # (/=) :: CompatibilityMode -> CompatibilityMode -> Bool #
Ord CompatibilityMode Source #
Methods compare :: CompatibilityMode -> CompatibilityMode -> Ordering # (<) :: CompatibilityMode -> CompatibilityMode -> Bool # (<=) :: CompatibilityMode -> CompatibilityMode -> Bool # (>) :: CompatibilityMode -> CompatibilityMode -> Bool # (>=) :: CompatibilityMode -> CompatibilityMode -> Bool # max :: CompatibilityMode -> CompatibilityMode -> CompatibilityMode # min :: CompatibilityMode -> CompatibilityMode -> CompatibilityMode #
Show CompatibilityMode Source #
Methods showsPrec :: Int -> CompatibilityMode -> ShowS # show :: CompatibilityMode -> String # showList :: [CompatibilityMode] -> ShowS #
Generic CompatibilityMode Source #
Associated Types type Rep CompatibilityMode :: * -> * # Methods from :: CompatibilityMode -> Rep CompatibilityMode x # to :: Rep CompatibilityMode x -> CompatibilityMode #
Hashable CompatibilityMode Source #
Methods hashWithSalt :: Int -> CompatibilityMode -> Int # hash :: CompatibilityMode -> Int #
ToJSON CompatibilityMode Source #
Methods toJSON :: CompatibilityMode -> Value # toEncoding :: CompatibilityMode -> Encoding # toJSONList :: [CompatibilityMode] -> Value # toEncodingList :: [CompatibilityMode] -> Encoding #
FromJSON CompatibilityMode Source #
Methods parseJSON :: Value -> Parser CompatibilityMode # parseJSONList :: Value -> Parser [CompatibilityMode] #
HasNakadiCompatibilityMode EventType (Maybe CompatibilityMode)
Methods compatibilityMode :: Lens' EventType (Maybe CompatibilityMode)
type Rep CompatibilityMode Source #
type Rep CompatibilityMode = D1 * (MetaData "CompatibilityMode" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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.

Constructors

PartitionKeyField
Fields unPartitionKeyField :: Text

Instances

Eq PartitionKeyField Source #
Methods (==) :: PartitionKeyField -> PartitionKeyField -> Bool # (/=) :: PartitionKeyField -> PartitionKeyField -> Bool #
Ord PartitionKeyField Source #
Methods compare :: PartitionKeyField -> PartitionKeyField -> Ordering # (<) :: PartitionKeyField -> PartitionKeyField -> Bool # (<=) :: PartitionKeyField -> PartitionKeyField -> Bool # (>) :: PartitionKeyField -> PartitionKeyField -> Bool # (>=) :: PartitionKeyField -> PartitionKeyField -> Bool # max :: PartitionKeyField -> PartitionKeyField -> PartitionKeyField # min :: PartitionKeyField -> PartitionKeyField -> PartitionKeyField #
Show PartitionKeyField Source #
Methods showsPrec :: Int -> PartitionKeyField -> ShowS # show :: PartitionKeyField -> String # showList :: [PartitionKeyField] -> ShowS #
IsString PartitionKeyField Source #
Methods fromString :: String -> PartitionKeyField #
Generic PartitionKeyField Source #
Associated Types type Rep PartitionKeyField :: * -> * # Methods from :: PartitionKeyField -> Rep PartitionKeyField x # to :: Rep PartitionKeyField x -> PartitionKeyField #
Hashable PartitionKeyField Source #
Methods hashWithSalt :: Int -> PartitionKeyField -> Int # hash :: PartitionKeyField -> Int #
ToJSON PartitionKeyField Source #
Methods toJSON :: PartitionKeyField -> Value # toEncoding :: PartitionKeyField -> Encoding # toJSONList :: [PartitionKeyField] -> Value # toEncodingList :: [PartitionKeyField] -> Encoding #
FromJSON PartitionKeyField Source #
Methods parseJSON :: Value -> Parser PartitionKeyField # parseJSONList :: Value -> Parser [PartitionKeyField] #
HasNakadiPartitionKeyFields EventType (Maybe [PartitionKeyField])
Methods partitionKeyFields :: Lens' EventType (Maybe [PartitionKeyField])
type Rep PartitionKeyField Source #
type Rep PartitionKeyField = D1 * (MetaData "PartitionKeyField" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" True) (C1 * (MetaCons "PartitionKeyField" PrefixI True) (S1 * (MetaSel (Just Symbol "unPartitionKeyField") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

data EventType Source #

EventType

Constructors

EventType

Instances

Eq EventType Source #
Methods (==) :: EventType -> EventType -> Bool # (/=) :: EventType -> EventType -> Bool #
Ord EventType Source #
Methods compare :: EventType -> EventType -> Ordering # (<) :: EventType -> EventType -> Bool # (<=) :: EventType -> EventType -> Bool # (>) :: EventType -> EventType -> Bool # (>=) :: EventType -> EventType -> Bool # max :: EventType -> EventType -> EventType # min :: EventType -> EventType -> EventType #
Show EventType Source #
Methods showsPrec :: Int -> EventType -> ShowS # show :: EventType -> String # showList :: [EventType] -> ShowS #
Generic EventType Source #
Associated Types type Rep EventType :: * -> * # Methods from :: EventType -> Rep EventType x # to :: Rep EventType x -> EventType #
Hashable EventType Source #
Methods hashWithSalt :: Int -> EventType -> Int # hash :: EventType -> Int #
ToJSON EventType Source #
Methods toJSON :: EventType -> Value # toEncoding :: EventType -> Encoding # toJSONList :: [EventType] -> Value # toEncodingList :: [EventType] -> Encoding #
FromJSON EventType Source #
Methods parseJSON :: Value -> Parser EventType # parseJSONList :: Value -> Parser [EventType] #
HasNakadiSchema EventType EventTypeSchema
Methods schema :: Lens' EventType EventTypeSchema
HasNakadiName EventType EventTypeName
Methods name :: Lens' EventType EventTypeName
HasNakadiPartitionStrategy EventType (Maybe PartitionStrategy)
Methods partitionStrategy :: Lens' EventType (Maybe PartitionStrategy)
HasNakadiPartitionKeyFields EventType (Maybe [PartitionKeyField])
Methods partitionKeyFields :: Lens' EventType (Maybe [PartitionKeyField])
HasNakadiOwningApplication EventType (Maybe ApplicationName)
Methods owningApplication :: Lens' EventType (Maybe ApplicationName)
HasNakadiOptions EventType (Maybe EventTypeOptions)
Methods options :: Lens' EventType (Maybe EventTypeOptions)
HasNakadiEnrichmentStrategies EventType (Maybe [EnrichmentStrategy])
Methods enrichmentStrategies :: Lens' EventType (Maybe [EnrichmentStrategy])
HasNakadiDefaultStatistic EventType (Maybe EventTypeStatistics)
Methods defaultStatistic :: Lens' EventType (Maybe EventTypeStatistics)
HasNakadiCompatibilityMode EventType (Maybe CompatibilityMode)
Methods compatibilityMode :: Lens' EventType (Maybe CompatibilityMode)
HasNakadiCategory EventType (Maybe EventTypeCategory)
Methods category :: Lens' EventType (Maybe EventTypeCategory)
type Rep EventType Source #
type Rep EventType = D1 * (MetaData "EventType" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 DataChangeEvent a Source #

DataChangeEvent

Constructors

DataChangeEvent
Fields _payload :: a _metadata :: Metadata _dataType :: Text _dataOp :: DataOp

Instances

Eq a => Eq (DataChangeEvent a) Source #
Methods (==) :: DataChangeEvent a -> DataChangeEvent a -> Bool # (/=) :: DataChangeEvent a -> DataChangeEvent a -> Bool #
Show a => Show (DataChangeEvent a) Source #
Methods showsPrec :: Int -> DataChangeEvent a -> ShowS # show :: DataChangeEvent a -> String # showList :: [DataChangeEvent a] -> ShowS #
Generic (DataChangeEvent a) Source #
Associated Types type Rep (DataChangeEvent a) :: * -> * # Methods from :: DataChangeEvent a -> Rep (DataChangeEvent a) x # to :: Rep (DataChangeEvent a) x -> DataChangeEvent a #
ToJSON a => ToJSON (DataChangeEvent a) Source #
Methods toJSON :: DataChangeEvent a -> Value # toEncoding :: DataChangeEvent a -> Encoding # toJSONList :: [DataChangeEvent a] -> Value # toEncodingList :: [DataChangeEvent a] -> Encoding #
FromJSON a => FromJSON (DataChangeEvent a) Source #
Methods parseJSON :: Value -> Parser (DataChangeEvent a) # parseJSONList :: Value -> Parser [DataChangeEvent a] #
type Rep (DataChangeEvent a) Source #
type Rep (DataChangeEvent a) = D1 * (MetaData "DataChangeEvent" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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 * Metadata))) ((::) (S1 * (MetaSel (Just Symbol "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * DataOp)))))

data DataOp Source #

Type for "data_op" as contained in the DataChangeEvent.

Constructors

DataOpCreation
DataOpUpdate
DataOpDeletion
DataOpSnapshot

Instances

Eq DataOp Source #
Methods (==) :: DataOp -> DataOp -> Bool # (/=) :: DataOp -> DataOp -> Bool #
Ord DataOp Source #
Methods compare :: DataOp -> DataOp -> Ordering # (<) :: DataOp -> DataOp -> Bool # (<=) :: DataOp -> DataOp -> Bool # (>) :: DataOp -> DataOp -> Bool # (>=) :: DataOp -> DataOp -> Bool # max :: DataOp -> DataOp -> DataOp # min :: DataOp -> DataOp -> DataOp #
Show DataOp Source #
Methods showsPrec :: Int -> DataOp -> ShowS # show :: DataOp -> String # showList :: [DataOp] -> ShowS #
ToJSON DataOp Source #
Methods toJSON :: DataOp -> Value # toEncoding :: DataOp -> Encoding # toJSONList :: [DataOp] -> Value # toEncodingList :: [DataOp] -> Encoding #
FromJSON DataOp Source #
Methods parseJSON :: Value -> Parser DataOp # parseJSONList :: Value -> Parser [DataOp] #

data EventEnriched a Source #

Type of enriched event.

Constructors

EventEnriched
Fields _payload :: a _metadata :: MetadataEnriched

Instances

Eq a => Eq (EventEnriched a) Source #
Methods (==) :: EventEnriched a -> EventEnriched a -> Bool # (/=) :: EventEnriched a -> EventEnriched a -> Bool #
Show a => Show (EventEnriched a) Source #
Methods showsPrec :: Int -> EventEnriched a -> ShowS # show :: EventEnriched a -> String # showList :: [EventEnriched a] -> ShowS #
Generic (EventEnriched a) Source #
Associated Types type Rep (EventEnriched a) :: * -> * # Methods from :: EventEnriched a -> Rep (EventEnriched a) x # to :: Rep (EventEnriched a) x -> EventEnriched a #
ToJSON a => ToJSON (EventEnriched a) Source #
Methods toJSON :: EventEnriched a -> Value # toEncoding :: EventEnriched a -> Encoding # toJSONList :: [EventEnriched a] -> Value # toEncodingList :: [EventEnriched a] -> Encoding #
FromJSON a => FromJSON (EventEnriched a) Source #
Methods parseJSON :: Value -> Parser (EventEnriched a) # parseJSONList :: Value -> Parser [EventEnriched a] #
HasNakadiEvents (EventStreamBatch a) (Maybe (Vector (EventEnriched a)))
Methods events :: Lens' (EventStreamBatch a) (Maybe (Vector (EventEnriched a)))
HasNakadiEvents (SubscriptionEventStreamBatch a) (Maybe (Vector (EventEnriched a)))
Methods events :: Lens' (SubscriptionEventStreamBatch a) (Maybe (Vector (EventEnriched a)))
type Rep (EventEnriched a) Source #
type Rep (EventEnriched a) = D1 * (MetaData "EventEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "EventEnriched" PrefixI True) ((::) (S1 * (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * a)) (S1 * (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * MetadataEnriched))))

data MetadataEnriched Source #

Type of enriched metadata values.

Constructors

MetadataEnriched
Fields _eid :: EventId _eventType :: EventTypeName _occurredAt :: Timestamp _receivedAt :: Timestamp _version :: SchemaVersion _parentEids :: Maybe [EventId] _flowId :: Maybe FlowId _partition :: Maybe PartitionName

Instances

Eq MetadataEnriched Source #
Methods (==) :: MetadataEnriched -> MetadataEnriched -> Bool # (/=) :: MetadataEnriched -> MetadataEnriched -> Bool #
Show MetadataEnriched Source #
Methods showsPrec :: Int -> MetadataEnriched -> ShowS # show :: MetadataEnriched -> String # showList :: [MetadataEnriched] -> ShowS #
Generic MetadataEnriched Source #
Associated Types type Rep MetadataEnriched :: * -> * # Methods from :: MetadataEnriched -> Rep MetadataEnriched x # to :: Rep MetadataEnriched x -> MetadataEnriched #
ToJSON MetadataEnriched Source #
Methods toJSON :: MetadataEnriched -> Value # toEncoding :: MetadataEnriched -> Encoding # toJSONList :: [MetadataEnriched] -> Value # toEncodingList :: [MetadataEnriched] -> Encoding #
FromJSON MetadataEnriched Source #
Methods parseJSON :: Value -> Parser MetadataEnriched # parseJSONList :: Value -> Parser [MetadataEnriched] #
HasNakadiOccurredAt MetadataEnriched Timestamp
Methods occurredAt :: Lens' MetadataEnriched Timestamp
HasNakadiEid MetadataEnriched EventId
Methods eid :: Lens' MetadataEnriched EventId
HasNakadiVersion MetadataEnriched SchemaVersion
Methods version :: Lens' MetadataEnriched SchemaVersion
HasNakadiReceivedAt MetadataEnriched Timestamp
Methods receivedAt :: Lens' MetadataEnriched Timestamp
HasNakadiEventType MetadataEnriched EventTypeName
Methods eventType :: Lens' MetadataEnriched EventTypeName
HasNakadiPartition MetadataEnriched (Maybe PartitionName)
Methods partition :: Lens' MetadataEnriched (Maybe PartitionName)
HasNakadiParentEids MetadataEnriched (Maybe [EventId])
Methods parentEids :: Lens' MetadataEnriched (Maybe [EventId])
HasNakadiFlowId MetadataEnriched (Maybe FlowId)
Methods flowId :: Lens' MetadataEnriched (Maybe FlowId)
type Rep MetadataEnriched Source #
type Rep MetadataEnriched = D1 * (MetaData "MetadataEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "MetadataEnriched" PrefixI True) ((::) ((::) ((::) (S1 * (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventId)) (S1 * (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName))) ((::) (S1 * (MetaSel (Just Symbol "_occurredAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Timestamp)) (S1 * (MetaSel (Just Symbol "_receivedAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Timestamp)))) ((::) ((::) (S1 * (MetaSel (Just Symbol "_version") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * SchemaVersion)) (S1 * (MetaSel (Just Symbol "_parentEids") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [EventId])))) ((::) (S1 * (MetaSel (Just Symbol "_flowId") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe FlowId))) (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PartitionName)))))))

data EventTypeStatistics Source #

Type for event type statistics.

Constructors

EventTypeStatistics
Fields _messagesPerMinute :: Int64 _messageSize :: Int64 _readParallelism :: Int64 _writeParallelism :: Int64

Instances

Eq EventTypeStatistics Source #
Methods (==) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (/=) :: EventTypeStatistics -> EventTypeStatistics -> Bool #
Ord EventTypeStatistics Source #
Methods compare :: EventTypeStatistics -> EventTypeStatistics -> Ordering # (<) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (<=) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (>) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (>=) :: EventTypeStatistics -> EventTypeStatistics -> Bool # max :: EventTypeStatistics -> EventTypeStatistics -> EventTypeStatistics # min :: EventTypeStatistics -> EventTypeStatistics -> EventTypeStatistics #
Show EventTypeStatistics Source #
Methods showsPrec :: Int -> EventTypeStatistics -> ShowS # show :: EventTypeStatistics -> String # showList :: [EventTypeStatistics] -> ShowS #
Generic EventTypeStatistics Source #
Associated Types type Rep EventTypeStatistics :: * -> * # Methods from :: EventTypeStatistics -> Rep EventTypeStatistics x # to :: Rep EventTypeStatistics x -> EventTypeStatistics #
Hashable EventTypeStatistics Source #
Methods hashWithSalt :: Int -> EventTypeStatistics -> Int # hash :: EventTypeStatistics -> Int #
ToJSON EventTypeStatistics Source #
Methods toJSON :: EventTypeStatistics -> Value # toEncoding :: EventTypeStatistics -> Encoding # toJSONList :: [EventTypeStatistics] -> Value # toEncodingList :: [EventTypeStatistics] -> Encoding #
FromJSON EventTypeStatistics Source #
Methods parseJSON :: Value -> Parser EventTypeStatistics # parseJSONList :: Value -> Parser [EventTypeStatistics] #
HasNakadiDefaultStatistic EventType (Maybe EventTypeStatistics)
Methods defaultStatistic :: Lens' EventType (Maybe EventTypeStatistics)
type Rep EventTypeStatistics Source #
type Rep EventTypeStatistics = D1 * (MetaData "EventTypeStatistics" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" 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
Fields _retentionTime :: Int64

Instances

Eq EventTypeOptions Source #
Methods (==) :: EventTypeOptions -> EventTypeOptions -> Bool # (/=) :: EventTypeOptions -> EventTypeOptions -> Bool #
Ord EventTypeOptions Source #
Methods compare :: EventTypeOptions -> EventTypeOptions -> Ordering # (<) :: EventTypeOptions -> EventTypeOptions -> Bool # (<=) :: EventTypeOptions -> EventTypeOptions -> Bool # (>) :: EventTypeOptions -> EventTypeOptions -> Bool # (>=) :: EventTypeOptions -> EventTypeOptions -> Bool # max :: EventTypeOptions -> EventTypeOptions -> EventTypeOptions # min :: EventTypeOptions -> EventTypeOptions -> EventTypeOptions #
Show EventTypeOptions Source #
Methods showsPrec :: Int -> EventTypeOptions -> ShowS # show :: EventTypeOptions -> String # showList :: [EventTypeOptions] -> ShowS #
Generic EventTypeOptions Source #
Associated Types type Rep EventTypeOptions :: * -> * # Methods from :: EventTypeOptions -> Rep EventTypeOptions x # to :: Rep EventTypeOptions x -> EventTypeOptions #
Hashable EventTypeOptions Source #
Methods hashWithSalt :: Int -> EventTypeOptions -> Int # hash :: EventTypeOptions -> Int #
ToJSON EventTypeOptions Source #
Methods toJSON :: EventTypeOptions -> Value # toEncoding :: EventTypeOptions -> Encoding # toJSONList :: [EventTypeOptions] -> Value # toEncodingList :: [EventTypeOptions] -> Encoding #
FromJSON EventTypeOptions Source #
Methods parseJSON :: Value -> Parser EventTypeOptions # parseJSONList :: Value -> Parser [EventTypeOptions] #
HasNakadiOptions EventType (Maybe EventTypeOptions)
Methods options :: Lens' EventType (Maybe EventTypeOptions)
type Rep EventTypeOptions Source #
type Rep EventTypeOptions = D1 * (MetaData "EventTypeOptions" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "EventTypeOptions" PrefixI True) (S1 * (MetaSel (Just Symbol "_retentionTime") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64)))