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

Network.Nakadi.Internal.Http

Description

Internal module containing HTTP client relevant code.

Synopsis

Documentation

module Network.HTTP.Simple

module Network.HTTP.Types.Status

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

Config

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

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

data Config Source #

Constructors

Config
Fields _requestTemplate :: Request _requestModifier :: Request -> IO Request _manager :: Manager _consumeParameters :: ConsumeParameters _deserializationFailureCallback :: Maybe (ByteString -> Text -> IO ()) _streamConnectCallback :: Maybe StreamConnectCallback _logFunc :: Maybe LogFunc _retryPolicy :: RetryPolicyM IO _http :: HttpBackend _httpErrorCallback :: Maybe HttpErrorCallback

Instances

HasNakadiRequestTemplate Config Request
Methods requestTemplate :: Lens' Config Request
HasNakadiManager Config Manager
Methods manager :: Lens' Config Manager
HasNakadiHttp Config HttpBackend
Methods http :: Lens' Config HttpBackend
HasNakadiConsumeParameters Config ConsumeParameters
Methods consumeParameters :: Lens' Config ConsumeParameters
HasNakadiCtxConfig SubscriptionEventStreamContext Config
Methods ctxConfig :: Lens' SubscriptionEventStreamContext Config
HasNakadiStreamConnectCallback Config (Maybe StreamConnectCallback)
Methods streamConnectCallback :: Lens' Config (Maybe StreamConnectCallback)
HasNakadiRetryPolicy Config (RetryPolicyM IO)
Methods retryPolicy :: Lens' Config (RetryPolicyM IO)
HasNakadiLogFunc Config (Maybe LogFunc)
Methods logFunc :: Lens' Config (Maybe LogFunc)
HasNakadiHttpErrorCallback Config (Maybe HttpErrorCallback)
Methods httpErrorCallback :: Lens' Config (Maybe HttpErrorCallback)
HasNakadiDeserializationFailureCallback Config (Maybe (ByteString -> Text -> IO ()))
Methods deserializationFailureCallback :: Lens' Config (Maybe (ByteString -> Text -> IO ()))
HasNakadiRequestModifier Config (Request -> IO Request)
Methods requestModifier :: Lens' Config (Request -> IO Request)

data HttpBackend Source #

Type encapsulating the HTTP backend functions used by this package. By default the corresponding functions from the http-client package are used. Useful, for e.g., testing.

Constructors

HttpBackend
Fields _httpLbs :: Request -> IO (Response ByteString) _responseOpen :: Request -> Manager -> IO (Response BodyReader) _responseClose :: Response BodyReader -> IO ()

Instances

HasNakadiHttp Config HttpBackend
Methods http :: Lens' Config HttpBackend
HasNakadiResponseOpen HttpBackend (Request -> Manager -> IO (Response BodyReader))
Methods responseOpen :: Lens' HttpBackend (Request -> Manager -> IO (Response BodyReader))
HasNakadiResponseClose HttpBackend (Response BodyReader -> IO ())
Methods responseClose :: Lens' HttpBackend (Response BodyReader -> IO ())
HasNakadiHttpLbs HttpBackend (Request -> IO (Response ByteString))
Methods httpLbs :: Lens' HttpBackend (Request -> IO (Response ByteString))

data ConsumeParameters Source #

ConsumeParameters

Constructors

ConsumeParameters
Fields _maxUncommittedEvents :: Maybe Int32 _batchLimit :: Maybe Int32 _streamLimit :: Maybe Int32 _batchFlushTimeout :: Maybe Int32 _streamTimeout :: Maybe Int32 _streamKeepAliveLimit :: Maybe Int32 _flowId :: Maybe Text

Instances

Eq ConsumeParameters Source #
Methods (==) :: ConsumeParameters -> ConsumeParameters -> Bool # (/=) :: ConsumeParameters -> ConsumeParameters -> Bool #
Ord ConsumeParameters Source #
Methods compare :: ConsumeParameters -> ConsumeParameters -> Ordering # (<) :: ConsumeParameters -> ConsumeParameters -> Bool # (<=) :: ConsumeParameters -> ConsumeParameters -> Bool # (>) :: ConsumeParameters -> ConsumeParameters -> Bool # (>=) :: ConsumeParameters -> ConsumeParameters -> Bool # max :: ConsumeParameters -> ConsumeParameters -> ConsumeParameters # min :: ConsumeParameters -> ConsumeParameters -> ConsumeParameters #
Show ConsumeParameters Source #
Methods showsPrec :: Int -> ConsumeParameters -> ShowS # show :: ConsumeParameters -> String # showList :: [ConsumeParameters] -> ShowS #
HasNakadiConsumeParameters Config ConsumeParameters
Methods consumeParameters :: Lens' Config ConsumeParameters
HasNakadiFlowId ConsumeParameters (Maybe Text)
Methods flowId :: Lens' ConsumeParameters (Maybe Text)
HasNakadiStreamTimeout ConsumeParameters (Maybe Int32)
Methods streamTimeout :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiStreamLimit ConsumeParameters (Maybe Int32)
Methods streamLimit :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiStreamKeepAliveLimit ConsumeParameters (Maybe Int32)
Methods streamKeepAliveLimit :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiMaxUncommittedEvents ConsumeParameters (Maybe Int32)
Methods maxUncommittedEvents :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiBatchLimit ConsumeParameters (Maybe Int32)
Methods batchLimit :: Lens' ConsumeParameters (Maybe Int32)
HasNakadiBatchFlushTimeout ConsumeParameters (Maybe Int32)
Methods batchFlushTimeout :: Lens' ConsumeParameters (Maybe Int32)

data NakadiException Source #

Instances

Show NakadiException Source #
Methods showsPrec :: Int -> NakadiException -> ShowS # show :: NakadiException -> String # showList :: [NakadiException] -> ShowS #
Exception NakadiException Source #
Methods toException :: NakadiException -> SomeException # fromException :: SomeException -> Maybe NakadiException # displayException :: NakadiException -> String #

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

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

data Problem Source #

Type for RFC7807 Problem objects.

Constructors

Problem
Fields problemType :: Text problemTitle :: Text problemStatus :: Int32 problemDetail :: Maybe Text problemInstance :: Maybe Text problemCustom :: Maybe (HashMap Text Value)

Instances

Eq Problem Source #
Methods (==) :: Problem -> Problem -> Bool # (/=) :: Problem -> Problem -> Bool #
Show Problem Source #
Methods showsPrec :: Int -> Problem -> ShowS # show :: Problem -> String # showList :: [Problem] -> ShowS #
Generic Problem Source #
Associated Types type Rep Problem :: * -> * # Methods from :: Problem -> Rep Problem x # to :: Rep Problem x -> Problem #
ToJSON Problem Source #
Methods toJSON :: Problem -> Value # toEncoding :: Problem -> Encoding # toJSONList :: [Problem] -> Value # toEncodingList :: [Problem] -> Encoding #
FromJSON Problem Source #
Methods parseJSON :: Value -> Parser Problem # parseJSONList :: Value -> Parser [Problem] #
type Rep Problem Source #
type Rep Problem = D1 * (MetaData "Problem" "Network.Nakadi.Internal.Types.Problem" "nakadi-client-0.4.0.0-B6Ql0ylSfFaJkyrh8vPSc2" False) (C1 * (MetaCons "Problem" PrefixI True) ((::) ((::) (S1 * (MetaSel (Just Symbol "problemType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)) ((::) (S1 * (MetaSel (Just Symbol "problemTitle") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "problemStatus") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int32)))) ((::) (S1 * (MetaSel (Just Symbol "problemDetail") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe Text))) ((::) (S1 * (MetaSel (Just Symbol "problemInstance") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe Text))) (S1 * (MetaSel (Just Symbol "problemCustom") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe (HashMap Text Value))))))))

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 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)))))

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)))

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)))

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 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 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 *))

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)))

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]))))

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]))))

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 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)))

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 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 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 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)))))))

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 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 SubscriptionEventStreamContext Source #

This context is required in the environment for running a subscription. It is managed by the library, not by the user.

Constructors

SubscriptionEventStreamContext
Fields _streamId :: StreamId _subscriptionId :: SubscriptionId _ctxConfig :: Config

Instances

HasNakadiSubscriptionId SubscriptionEventStreamContext SubscriptionId
Methods subscriptionId :: Lens' SubscriptionEventStreamContext SubscriptionId
HasNakadiStreamId SubscriptionEventStreamContext StreamId
Methods streamId :: Lens' SubscriptionEventStreamContext StreamId
HasNakadiCtxConfig SubscriptionEventStreamContext Config
Methods ctxConfig :: Lens' SubscriptionEventStreamContext Config

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

Construct a field renamer function from a field renamer map.

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

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

type MonadNakadi m = (MonadIO m, MonadCatch m, MonadThrow m, MonadMask m) Source #

Type constraint synonym for encapsulating the monad constraints required by most funtions in this package.

type MonadNakadiEnv r m = (MonadNakadi m, MonadReader r m, HasNakadiConfig r Config) Source #

Type constraint synonym for encapsulating the monad constraints required by most funtions in this package. Reader Monad version, expects a Config to be available in the current reader environment.

class HasNakadiConfig s a Source #

Minimal complete definition

nakadiConfig

httpJsonBody :: (MonadMask m, MonadIO m, FromJSON a) => Config -> Status -> [(Status, ByteString -> m NakadiException)] -> (Request -> Request) -> m a Source #

httpJsonNoBody :: (MonadMask m, MonadIO m) => Config -> Status -> [(Status, ByteString -> m NakadiException)] -> (Request -> Request) -> m () Source #

httpJsonBodyStream :: (MonadMask m, MonadIO m, FromJSON a, MonadBaseControl IO m, MonadResource m) => Config -> Status -> (Response () -> Either Text b) -> [(Status, ByteString -> m NakadiException)] -> (Request -> Request) -> m (b, ConduitM () a (ReaderT r m) ()) Source #

errorClientNotAuthenticated :: MonadThrow m => ByteString -> m NakadiException Source #

errorUnprocessableEntity :: MonadThrow m => ByteString -> m NakadiException Source #

errorAccessForbidden :: MonadThrow m => ByteString -> m NakadiException Source #

errorTooManyRequests :: MonadThrow m => ByteString -> m NakadiException Source #

errorBadRequest :: MonadThrow m => ByteString -> m NakadiException Source #

errorSubscriptionNotFound :: MonadThrow m => ByteString -> m NakadiException Source #

errorCursorAlreadyCommitted :: MonadThrow m => ByteString -> m NakadiException Source #

errorCursorResetInProgress :: MonadThrow m => ByteString -> m NakadiException Source #

errorEventTypeNotFound :: MonadThrow m => ByteString -> m NakadiException Source #

errorSubscriptionExistsAlready :: MonadThrow m => ByteString -> m NakadiException Source #

errorBatchPartiallySubmitted :: MonadThrow m => ByteString -> m NakadiException Source #

errorBatchNotSubmitted :: MonadThrow m => ByteString -> m NakadiException Source #

setRequestQueryParameters :: [(ByteString, ByteString)] -> Request -> Request Source #

BatchPartiallySubmitted [BatchItemResponse]
BatchNotSubmitted [BatchItemResponse]
BatchValidationFailure [BatchItemResponse]
ClientNotAuthenticated Problem
AccessForbidden Problem
UnprocessableEntity Problem
Conflict Problem
DeserializationFailure ByteString
UnexpectedResponse (Response ())
NotFound Problem
TooManyRequests Problem
BadRequest Problem
SubscriptionNotFound Problem
CursorAlreadyCommitted CursorCommitResults
CursorResetInProgress Problem
EventTypeNotFound Problem
SubscriptionExistsAlready Subscription
RequestModificationException SomeException
CursorDistanceNoResult