Network.Nakadi.Internal.Http

Internal module containing HTTP client relevant code.

Documentation

module Network.HTTP.Simple

module Network.HTTP.Types.Status

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

Config

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

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

data Config

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

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

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

Methods

(==) :: ConsumeParameters -> ConsumeParameters -> Bool

(/=) :: ConsumeParameters -> ConsumeParameters -> Bool

Ord ConsumeParameters

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

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

Constructors

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

Instances

Show NakadiException

Methods

showsPrec :: Int -> NakadiException -> ShowS

show :: NakadiException -> String

showList :: [NakadiException] -> ShowS

Exception NakadiException

Methods

toException :: NakadiException -> SomeException

fromException :: SomeException -> Maybe NakadiException

displayException :: NakadiException -> String

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

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

data Problem

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

Methods

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

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

Show Problem

Methods

showsPrec :: Int -> Problem -> ShowS

show :: Problem -> String

showList :: [Problem] -> ShowS

Generic Problem

Associated Types

type Rep Problem :: * -> *

Methods

from :: Problem -> Rep Problem x

to :: Rep Problem x -> Problem

ToJSON Problem

Methods

toJSON :: Problem -> Value

toEncoding :: Problem -> Encoding

toJSONList :: [Problem] -> Value

toEncodingList :: [Problem] -> Encoding

FromJSON Problem

Methods

parseJSON :: Value -> Parser Problem

parseJSONList :: Value -> Parser [Problem]

type Rep Problem

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

Type for cursor offsets.

Constructors

CursorOffset

Fields

• unCursorOffset :: Text

  Opaque Cursor Offset, do not parse this

Instances

Eq CursorOffset

Methods

(==) :: CursorOffset -> CursorOffset -> Bool

(/=) :: CursorOffset -> CursorOffset -> Bool

Ord CursorOffset

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

Methods

showsPrec :: Int -> CursorOffset -> ShowS

show :: CursorOffset -> String

showList :: [CursorOffset] -> ShowS

IsString CursorOffset

Methods

fromString :: String -> CursorOffset

Generic CursorOffset

Associated Types

type Rep CursorOffset :: * -> *

Methods

from :: CursorOffset -> Rep CursorOffset x

to :: Rep CursorOffset x -> CursorOffset

Hashable CursorOffset

Methods

hashWithSalt :: Int -> CursorOffset -> Int

hash :: CursorOffset -> Int

ToJSON CursorOffset

Methods

toJSON :: CursorOffset -> Value

toEncoding :: CursorOffset -> Encoding

toJSONList :: [CursorOffset] -> Value

toEncodingList :: [CursorOffset] -> Encoding

FromJSON CursorOffset

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

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

Type for event type names.

Constructors

EventTypeName

Fields

• unEventTypeName :: Text

  Wrapped Event Type Name

Instances

Eq EventTypeName

Methods

(==) :: EventTypeName -> EventTypeName -> Bool

(/=) :: EventTypeName -> EventTypeName -> Bool

Ord EventTypeName

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

Methods

showsPrec :: Int -> EventTypeName -> ShowS

show :: EventTypeName -> String

showList :: [EventTypeName] -> ShowS

IsString EventTypeName

Methods

fromString :: String -> EventTypeName

Generic EventTypeName

Associated Types

type Rep EventTypeName :: * -> *

Methods

from :: EventTypeName -> Rep EventTypeName x

to :: Rep EventTypeName x -> EventTypeName

Hashable EventTypeName

Methods

hashWithSalt :: Int -> EventTypeName -> Int

hash :: EventTypeName -> Int

ToJSON EventTypeName

Methods

toJSON :: EventTypeName -> Value

toEncoding :: EventTypeName -> Encoding

toJSONList :: [EventTypeName] -> Value

toEncodingList :: [EventTypeName] -> Encoding

FromJSON EventTypeName

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

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

Type for partition names.

Constructors

PartitionName

Fields

• unPartitionName :: Text

  Wrapped Partition Name

Instances

Eq PartitionName

Methods

(==) :: PartitionName -> PartitionName -> Bool

(/=) :: PartitionName -> PartitionName -> Bool

Ord PartitionName

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

Methods

showsPrec :: Int -> PartitionName -> ShowS

show :: PartitionName -> String

showList :: [PartitionName] -> ShowS

IsString PartitionName

Methods

fromString :: String -> PartitionName

Generic PartitionName

Associated Types

type Rep PartitionName :: * -> *

Methods

from :: PartitionName -> Rep PartitionName x

to :: Rep PartitionName x -> PartitionName

Hashable PartitionName

Methods

hashWithSalt :: Int -> PartitionName -> Int

hash :: PartitionName -> Int

ToJSON PartitionName

Methods

toJSON :: PartitionName -> Value

toEncoding :: PartitionName -> Encoding

toJSONList :: [PartitionName] -> Value

toEncodingList :: [PartitionName] -> Encoding

FromJSON PartitionName

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

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

Type for cursor tokens.

Constructors

CursorToken Text

Instances

Eq CursorToken

Methods

(==) :: CursorToken -> CursorToken -> Bool

(/=) :: CursorToken -> CursorToken -> Bool

Ord CursorToken

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

Methods

showsPrec :: Int -> CursorToken -> ShowS

show :: CursorToken -> String

showList :: [CursorToken] -> ShowS

IsString CursorToken

Methods

fromString :: String -> CursorToken

ToJSON CursorToken

Methods

toJSON :: CursorToken -> Value

toEncoding :: CursorToken -> Encoding

toJSONList :: [CursorToken] -> Value

toEncodingList :: [CursorToken] -> Encoding

FromJSON CursorToken

Methods

parseJSON :: Value -> Parser CursorToken

parseJSONList :: Value -> Parser [CursorToken]

data Cursor

Type for cursors.

Constructors

Cursor

Fields

• _partition :: PartitionName
• _offset :: CursorOffset

Instances

Eq Cursor

Methods

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

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

Ord Cursor

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

Methods

showsPrec :: Int -> Cursor -> ShowS

show :: Cursor -> String

showList :: [Cursor] -> ShowS

Generic Cursor

Associated Types

type Rep Cursor :: * -> *

Methods

from :: Cursor -> Rep Cursor x

to :: Rep Cursor x -> Cursor

Hashable Cursor

Methods

hashWithSalt :: Int -> Cursor -> Int

hash :: Cursor -> Int

ToJSON Cursor

Methods

toJSON :: Cursor -> Value

toEncoding :: Cursor -> Encoding

toJSONList :: [Cursor] -> Value

toEncodingList :: [Cursor] -> Encoding

FromJSON Cursor

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

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

Type for application names.

Constructors

ApplicationName

Fields

• unApplicationName :: Text

Instances

Eq ApplicationName

Methods

(==) :: ApplicationName -> ApplicationName -> Bool

(/=) :: ApplicationName -> ApplicationName -> Bool

Ord ApplicationName

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

Methods

showsPrec :: Int -> ApplicationName -> ShowS

show :: ApplicationName -> String

showList :: [ApplicationName] -> ShowS

IsString ApplicationName

Methods

fromString :: String -> ApplicationName

Generic ApplicationName

Associated Types

type Rep ApplicationName :: * -> *

Methods

from :: ApplicationName -> Rep ApplicationName x

to :: Rep ApplicationName x -> ApplicationName

Hashable ApplicationName

Methods

hashWithSalt :: Int -> ApplicationName -> Int

hash :: ApplicationName -> Int

ToJSON ApplicationName

Methods

toJSON :: ApplicationName -> Value

toEncoding :: ApplicationName -> Encoding

toJSONList :: [ApplicationName] -> Value

toEncodingList :: [ApplicationName] -> Encoding

FromJSON ApplicationName

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

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

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

Methods

(==) :: SubscriptionCursor -> SubscriptionCursor -> Bool

(/=) :: SubscriptionCursor -> SubscriptionCursor -> Bool

Ord SubscriptionCursor

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

Methods

showsPrec :: Int -> SubscriptionCursor -> ShowS

show :: SubscriptionCursor -> String

showList :: [SubscriptionCursor] -> ShowS

Generic SubscriptionCursor

Associated Types

type Rep SubscriptionCursor :: * -> *

Methods

from :: SubscriptionCursor -> Rep SubscriptionCursor x

to :: Rep SubscriptionCursor x -> SubscriptionCursor

ToJSON SubscriptionCursor

Methods

toJSON :: SubscriptionCursor -> Value

toEncoding :: SubscriptionCursor -> Encoding

toJSONList :: [SubscriptionCursor] -> Value

toEncodingList :: [SubscriptionCursor] -> Encoding

FromJSON SubscriptionCursor

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

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

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

Methods

(==) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool

(/=) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool

Ord SubscriptionCursorWithoutToken

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

Methods

showsPrec :: Int -> SubscriptionCursorWithoutToken -> ShowS

show :: SubscriptionCursorWithoutToken -> String

showList :: [SubscriptionCursorWithoutToken] -> ShowS

Generic SubscriptionCursorWithoutToken

Associated Types

type Rep SubscriptionCursorWithoutToken :: * -> *

Methods

from :: SubscriptionCursorWithoutToken -> Rep SubscriptionCursorWithoutToken x

to :: Rep SubscriptionCursorWithoutToken x -> SubscriptionCursorWithoutToken

Hashable SubscriptionCursorWithoutToken

Methods

hashWithSalt :: Int -> SubscriptionCursorWithoutToken -> Int

hash :: SubscriptionCursorWithoutToken -> Int

ToJSON SubscriptionCursorWithoutToken

Methods

toJSON :: SubscriptionCursorWithoutToken -> Value

toEncoding :: SubscriptionCursorWithoutToken -> Encoding

toJSONList :: [SubscriptionCursorWithoutToken] -> Value

toEncodingList :: [SubscriptionCursorWithoutToken] -> Encoding

FromJSON SubscriptionCursorWithoutToken

Methods

parseJSON :: Value -> Parser SubscriptionCursorWithoutToken

parseJSONList :: Value -> Parser [SubscriptionCursorWithoutToken]

HasNakadiInitialCursors Subscription (Maybe [SubscriptionCursorWithoutToken])

Methods

initialCursors :: Lens' Subscription (Maybe [SubscriptionCursorWithoutToken])

type Rep SubscriptionCursorWithoutToken

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

Type for commit object for subscription cursor committing.

Constructors

SubscriptionCursorCommit

Fields

• _items :: [SubscriptionCursor]

  List of cursors to commit

Instances

Show SubscriptionCursorCommit

Methods

showsPrec :: Int -> SubscriptionCursorCommit -> ShowS

show :: SubscriptionCursorCommit -> String

showList :: [SubscriptionCursorCommit] -> ShowS

Generic SubscriptionCursorCommit

Associated Types

type Rep SubscriptionCursorCommit :: * -> *

Methods

from :: SubscriptionCursorCommit -> Rep SubscriptionCursorCommit x

to :: Rep SubscriptionCursorCommit x -> SubscriptionCursorCommit

ToJSON SubscriptionCursorCommit

Methods

toJSON :: SubscriptionCursorCommit -> Value

toEncoding :: SubscriptionCursorCommit -> Encoding

toJSONList :: [SubscriptionCursorCommit] -> Value

toEncodingList :: [SubscriptionCursorCommit] -> Encoding

FromJSON SubscriptionCursorCommit

Methods

parseJSON :: Value -> Parser SubscriptionCursorCommit

parseJSONList :: Value -> Parser [SubscriptionCursorCommit]

HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor]

Methods

items :: Lens' SubscriptionCursorCommit [SubscriptionCursor]

type Rep SubscriptionCursorCommit

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

Type for commit objects for cursor committing.

Constructors

CursorCommit

Fields

• _items :: [Cursor]

  List of cursors to commit

Instances

Show CursorCommit

Methods

showsPrec :: Int -> CursorCommit -> ShowS

show :: CursorCommit -> String

showList :: [CursorCommit] -> ShowS

Generic CursorCommit

Associated Types

type Rep CursorCommit :: * -> *

Methods

from :: CursorCommit -> Rep CursorCommit x

to :: Rep CursorCommit x -> CursorCommit

ToJSON CursorCommit

Methods

toJSON :: CursorCommit -> Value

toEncoding :: CursorCommit -> Encoding

toJSONList :: [CursorCommit] -> Value

toEncodingList :: [CursorCommit] -> Encoding

FromJSON CursorCommit

Methods

parseJSON :: Value -> Parser CursorCommit

parseJSONList :: Value -> Parser [CursorCommit]

HasNakadiItems CursorCommit [Cursor]

Methods

items :: Lens' CursorCommit [Cursor]

type Rep CursorCommit

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

Type for subscription IDs.

Constructors

SubscriptionId

Fields

• unSubscriptionId :: UUID

  Wrapped UUID

Instances

Eq SubscriptionId

Methods

(==) :: SubscriptionId -> SubscriptionId -> Bool

(/=) :: SubscriptionId -> SubscriptionId -> Bool

Ord SubscriptionId

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

Methods

showsPrec :: Int -> SubscriptionId -> ShowS

show :: SubscriptionId -> String

showList :: [SubscriptionId] -> ShowS

Generic SubscriptionId

Associated Types

type Rep SubscriptionId :: * -> *

Methods

from :: SubscriptionId -> Rep SubscriptionId x

to :: Rep SubscriptionId x -> SubscriptionId

Hashable SubscriptionId

Methods

hashWithSalt :: Int -> SubscriptionId -> Int

hash :: SubscriptionId -> Int

ToJSON SubscriptionId

Methods

toJSON :: SubscriptionId -> Value

toEncoding :: SubscriptionId -> Encoding

toJSONList :: [SubscriptionId] -> Value

toEncodingList :: [SubscriptionId] -> Encoding

FromJSON SubscriptionId

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

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

Type for stream IDs.

Constructors

StreamId

Fields

• unStreamId :: Text

  Wrapped Stream ID

Instances

Eq StreamId

Methods

(==) :: StreamId -> StreamId -> Bool

(/=) :: StreamId -> StreamId -> Bool

Ord StreamId

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

Methods

showsPrec :: Int -> StreamId -> ShowS

show :: StreamId -> String

showList :: [StreamId] -> ShowS

Generic StreamId

Associated Types

type Rep StreamId :: * -> *

Methods

from :: StreamId -> Rep StreamId x

to :: Rep StreamId x -> StreamId

ToJSON StreamId

Methods

toJSON :: StreamId -> Value

toEncoding :: StreamId -> Encoding

toJSONList :: [StreamId] -> Value

toEncodingList :: [StreamId] -> Encoding

FromJSON StreamId

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

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

SubscriptionEventStream

Constructors

SubscriptionEventStream

Fields

• _streamId :: StreamId
• _subscriptionId :: SubscriptionId

Instances

Show SubscriptionEventStream

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

Type for timestamps.

Constructors

Timestamp

Fields

• unTimestamp :: UTCTime

  Wrapped UTC Timestamp

Instances

Eq Timestamp

Methods

(==) :: Timestamp -> Timestamp -> Bool

(/=) :: Timestamp -> Timestamp -> Bool

Ord Timestamp

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

Methods

showsPrec :: Int -> Timestamp -> ShowS

show :: Timestamp -> String

showList :: [Timestamp] -> ShowS

Generic Timestamp

Associated Types

type Rep Timestamp :: * -> *

Methods

from :: Timestamp -> Rep Timestamp x

to :: Rep Timestamp x -> Timestamp

Hashable Timestamp

Methods

hashWithSalt :: Int -> Timestamp -> Int

hash :: Timestamp -> Int

ToJSON Timestamp

Methods

toJSON :: Timestamp -> Value

toEncoding :: Timestamp -> Encoding

toJSONList :: [Timestamp] -> Value

toEncodingList :: [Timestamp] -> Encoding

FromJSON Timestamp

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

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

A Flow ID.

Constructors

FlowId

Fields

• unFlowId :: Text

  Wrapped Flow ID

Instances

Eq FlowId

Methods

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

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

Ord FlowId

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

Methods

showsPrec :: Int -> FlowId -> ShowS

show :: FlowId -> String

showList :: [FlowId] -> ShowS

Generic FlowId

Associated Types

type Rep FlowId :: * -> *

Methods

from :: FlowId -> Rep FlowId x

to :: Rep FlowId x -> FlowId

ToJSON FlowId

Methods

toJSON :: FlowId -> Value

toEncoding :: FlowId -> Encoding

toJSONList :: [FlowId] -> Value

toEncodingList :: [FlowId] -> Encoding

FromJSON FlowId

Methods

parseJSON :: Value -> Parser FlowId

parseJSONList :: Value -> Parser [FlowId]

HasNakadiFlowId MetadataEnriched (Maybe FlowId)

Methods

flowId :: Lens' MetadataEnriched (Maybe FlowId)

type Rep FlowId

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

ID of an Event

Constructors

EventId

Fields

• unEventId :: UUID

  Wrapped UUID

Instances

Eq EventId

Methods

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

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

Ord EventId

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

Methods

showsPrec :: Int -> EventId -> ShowS

show :: EventId -> String

showList :: [EventId] -> ShowS

Generic EventId

Associated Types

type Rep EventId :: * -> *

Methods

from :: EventId -> Rep EventId x

to :: Rep EventId x -> EventId

Hashable EventId

Methods

hashWithSalt :: Int -> EventId -> Int

hash :: EventId -> Int

ToJSON EventId

Methods

toJSON :: EventId -> Value

toEncoding :: EventId -> Encoding

toJSONList :: [EventId] -> Value

toEncodingList :: [EventId] -> Encoding

FromJSON EventId

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

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

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

Methods

(==) :: Metadata -> Metadata -> Bool

(/=) :: Metadata -> Metadata -> Bool

Show Metadata

Methods

showsPrec :: Int -> Metadata -> ShowS

show :: Metadata -> String

showList :: [Metadata] -> ShowS

Generic Metadata

Associated Types

type Rep Metadata :: * -> *

Methods

from :: Metadata -> Rep Metadata x

to :: Rep Metadata x -> Metadata

ToJSON Metadata

Methods

toJSON :: Metadata -> Value

toEncoding :: Metadata -> Encoding

toJSONList :: [Metadata] -> Value

toEncodingList :: [Metadata] -> Encoding

FromJSON Metadata

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

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

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)

Methods

(==) :: Event a -> Event a -> Bool

(/=) :: Event a -> Event a -> Bool

Show a => Show (Event a)

Methods

showsPrec :: Int -> Event a -> ShowS

show :: Event a -> String

showList :: [Event a] -> ShowS

Generic (Event a)

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)

Methods

toJSON :: Event a -> Value

toEncoding :: Event a -> Encoding

toJSONList :: [Event a] -> Value

toEncodingList :: [Event a] -> Encoding

FromJSON a => FromJSON (Event a)

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)

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

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

Methods

showsPrec :: Int -> Partition -> ShowS

show :: Partition -> String

showList :: [Partition] -> ShowS

ToJSON Partition

Methods

toJSON :: Partition -> Value

toEncoding :: Partition -> Encoding

toJSONList :: [Partition] -> Value

toEncodingList :: [Partition] -> Encoding

FromJSON Partition

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

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

Methods

(==) :: ShiftedCursor -> ShiftedCursor -> Bool

(/=) :: ShiftedCursor -> ShiftedCursor -> Bool

Ord ShiftedCursor

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

Methods

showsPrec :: Int -> ShiftedCursor -> ShowS

show :: ShiftedCursor -> String

showList :: [ShiftedCursor] -> ShowS

ToJSON ShiftedCursor

Methods

toJSON :: ShiftedCursor -> Value

toEncoding :: ShiftedCursor -> Encoding

toJSONList :: [ShiftedCursor] -> Value

toEncodingList :: [ShiftedCursor] -> Encoding

FromJSON ShiftedCursor

Methods

parseJSON :: Value -> Parser ShiftedCursor

parseJSONList :: Value -> Parser [ShiftedCursor]

data CursorDistanceQuery

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

Methods

(==) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool

(/=) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool

Ord CursorDistanceQuery

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

Methods

showsPrec :: Int -> CursorDistanceQuery -> ShowS

show :: CursorDistanceQuery -> String

showList :: [CursorDistanceQuery] -> ShowS

Generic CursorDistanceQuery

Associated Types

type Rep CursorDistanceQuery :: * -> *

Methods

from :: CursorDistanceQuery -> Rep CursorDistanceQuery x

to :: Rep CursorDistanceQuery x -> CursorDistanceQuery

Hashable CursorDistanceQuery

Methods

hashWithSalt :: Int -> CursorDistanceQuery -> Int

hash :: CursorDistanceQuery -> Int

ToJSON CursorDistanceQuery

Methods

toJSON :: CursorDistanceQuery -> Value

toEncoding :: CursorDistanceQuery -> Encoding

toJSONList :: [CursorDistanceQuery] -> Value

toEncodingList :: [CursorDistanceQuery] -> Encoding

FromJSON CursorDistanceQuery

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

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

Type for results of cursor-distance-queries.

Constructors

CursorDistanceResult

Fields

• _distance :: Int64

Instances

Eq CursorDistanceResult

Methods

(==) :: CursorDistanceResult -> CursorDistanceResult -> Bool

(/=) :: CursorDistanceResult -> CursorDistanceResult -> Bool

Ord CursorDistanceResult

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

Methods

showsPrec :: Int -> CursorDistanceResult -> ShowS

show :: CursorDistanceResult -> String

showList :: [CursorDistanceResult] -> ShowS

Generic CursorDistanceResult

Associated Types

type Rep CursorDistanceResult :: * -> *

Methods

from :: CursorDistanceResult -> Rep CursorDistanceResult x

to :: Rep CursorDistanceResult x -> CursorDistanceResult

Hashable CursorDistanceResult

Methods

hashWithSalt :: Int -> CursorDistanceResult -> Int

hash :: CursorDistanceResult -> Int

ToJSON CursorDistanceResult

Methods

toJSON :: CursorDistanceResult -> Value

toEncoding :: CursorDistanceResult -> Encoding

toJSONList :: [CursorDistanceResult] -> Value

toEncodingList :: [CursorDistanceResult] -> Encoding

FromJSON CursorDistanceResult

Methods

parseJSON :: Value -> Parser CursorDistanceResult

parseJSONList :: Value -> Parser [CursorDistanceResult]

HasNakadiDistance CursorDistanceResult Int64

Methods

distance :: Lens' CursorDistanceResult Int64

type Rep CursorDistanceResult

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

Type for subscription positions.

Constructors

SubscriptionPositionBegin

SubscriptionPositionEnd

SubscriptionPositionCursors

Instances

Eq SubscriptionPosition

Methods

(==) :: SubscriptionPosition -> SubscriptionPosition -> Bool

(/=) :: SubscriptionPosition -> SubscriptionPosition -> Bool

Ord SubscriptionPosition

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

Methods

showsPrec :: Int -> SubscriptionPosition -> ShowS

show :: SubscriptionPosition -> String

showList :: [SubscriptionPosition] -> ShowS

Generic SubscriptionPosition

Associated Types

type Rep SubscriptionPosition :: * -> *

Methods

from :: SubscriptionPosition -> Rep SubscriptionPosition x

to :: Rep SubscriptionPosition x -> SubscriptionPosition

Hashable SubscriptionPosition

Methods

hashWithSalt :: Int -> SubscriptionPosition -> Int

hash :: SubscriptionPosition -> Int

ToJSON SubscriptionPosition

Methods

toJSON :: SubscriptionPosition -> Value

toEncoding :: SubscriptionPosition -> Encoding

toJSONList :: [SubscriptionPosition] -> Value

toEncodingList :: [SubscriptionPosition] -> Encoding

FromJSON SubscriptionPosition

Methods

parseJSON :: Value -> Parser SubscriptionPosition

parseJSONList :: Value -> Parser [SubscriptionPosition]

HasNakadiReadFrom Subscription (Maybe SubscriptionPosition)

Methods

readFrom :: Lens' Subscription (Maybe SubscriptionPosition)

type Rep SubscriptionPosition

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

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

Methods

(==) :: Subscription -> Subscription -> Bool

(/=) :: Subscription -> Subscription -> Bool

Ord Subscription

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

Methods

showsPrec :: Int -> Subscription -> ShowS

show :: Subscription -> String

showList :: [Subscription] -> ShowS

Generic Subscription

Associated Types

type Rep Subscription :: * -> *

Methods

from :: Subscription -> Rep Subscription x

to :: Rep Subscription x -> Subscription

Hashable Subscription

Methods

hashWithSalt :: Int -> Subscription -> Int

hash :: Subscription -> Int

ToJSON Subscription

Methods

toJSON :: Subscription -> Value

toEncoding :: Subscription -> Encoding

toJSONList :: [Subscription] -> Value

toEncodingList :: [Subscription] -> Encoding

FromJSON Subscription

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

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

Type for publishing status.

Constructors

PublishingStatusSubmitted

PublishingStatusFailed

PublishingStatusAborted

Instances

Eq PublishingStatus

Methods

(==) :: PublishingStatus -> PublishingStatus -> Bool

(/=) :: PublishingStatus -> PublishingStatus -> Bool

Ord PublishingStatus

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

Methods

showsPrec :: Int -> PublishingStatus -> ShowS

show :: PublishingStatus -> String

showList :: [PublishingStatus] -> ShowS

Generic PublishingStatus

Associated Types

type Rep PublishingStatus :: * -> *

Methods

from :: PublishingStatus -> Rep PublishingStatus x

to :: Rep PublishingStatus x -> PublishingStatus

Hashable PublishingStatus

Methods

hashWithSalt :: Int -> PublishingStatus -> Int

hash :: PublishingStatus -> Int

ToJSON PublishingStatus

Methods

toJSON :: PublishingStatus -> Value

toEncoding :: PublishingStatus -> Encoding

toJSONList :: [PublishingStatus] -> Value

toEncodingList :: [PublishingStatus] -> Encoding

FromJSON PublishingStatus

Methods

parseJSON :: Value -> Parser PublishingStatus

parseJSONList :: Value -> Parser [PublishingStatus]

type Rep PublishingStatus

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

Step

Constructors

StepNone

StepValidating

StepPartitioning

StepEnriching

StepPublishing

Instances

Eq Step

Methods

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

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

Ord Step

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

Methods

showsPrec :: Int -> Step -> ShowS

show :: Step -> String

showList :: [Step] -> ShowS

Generic Step

Associated Types

type Rep Step :: * -> *

Methods

from :: Step -> Rep Step x

to :: Rep Step x -> Step

Hashable Step

Methods

hashWithSalt :: Int -> Step -> Int

hash :: Step -> Int

ToJSON Step

Methods

toJSON :: Step -> Value

toEncoding :: Step -> Encoding

toJSONList :: [Step] -> Value

toEncodingList :: [Step] -> Encoding

FromJSON Step

Methods

parseJSON :: Value -> Parser Step

parseJSONList :: Value -> Parser [Step]

type Rep Step

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

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

Methods

(==) :: BatchItemResponse -> BatchItemResponse -> Bool

(/=) :: BatchItemResponse -> BatchItemResponse -> Bool

Ord BatchItemResponse

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

Methods

showsPrec :: Int -> BatchItemResponse -> ShowS

show :: BatchItemResponse -> String

showList :: [BatchItemResponse] -> ShowS

Generic BatchItemResponse

Associated Types

type Rep BatchItemResponse :: * -> *

Methods

from :: BatchItemResponse -> Rep BatchItemResponse x

to :: Rep BatchItemResponse x -> BatchItemResponse

Hashable BatchItemResponse

Methods

hashWithSalt :: Int -> BatchItemResponse -> Int

hash :: BatchItemResponse -> Int

ToJSON BatchItemResponse

Methods

toJSON :: BatchItemResponse -> Value

toEncoding :: BatchItemResponse -> Encoding

toJSONList :: [BatchItemResponse] -> Value

toEncodingList :: [BatchItemResponse] -> Encoding

FromJSON BatchItemResponse

Methods

parseJSON :: Value -> Parser BatchItemResponse

parseJSONList :: Value -> Parser [BatchItemResponse]

type Rep BatchItemResponse

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

StreamKeepAliveLimit

Constructors

StreamKeepAliveLimit

Fields

• unStreamKeepAliveLimit :: Int32

Instances

Eq StreamKeepAliveLimit

Methods

(==) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool

(/=) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool

Ord StreamKeepAliveLimit

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

Methods

showsPrec :: Int -> StreamKeepAliveLimit -> ShowS

show :: StreamKeepAliveLimit -> String

showList :: [StreamKeepAliveLimit] -> ShowS

ToJSON StreamKeepAliveLimit

Methods

toJSON :: StreamKeepAliveLimit -> Value

toEncoding :: StreamKeepAliveLimit -> Encoding

toJSONList :: [StreamKeepAliveLimit] -> Value

toEncodingList :: [StreamKeepAliveLimit] -> Encoding

FromJSON StreamKeepAliveLimit

Methods

parseJSON :: Value -> Parser StreamKeepAliveLimit

parseJSONList :: Value -> Parser [StreamKeepAliveLimit]

newtype BatchFlushTimeout

BatchFlushTimeout

Constructors

BatchFlushTimeout

Fields

• unBatchFlushTimeout :: Int32

Instances

Eq BatchFlushTimeout

Methods

(==) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool

(/=) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool

Ord BatchFlushTimeout

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

Methods

showsPrec :: Int -> BatchFlushTimeout -> ShowS

show :: BatchFlushTimeout -> String

showList :: [BatchFlushTimeout] -> ShowS

ToJSON BatchFlushTimeout

Methods

toJSON :: BatchFlushTimeout -> Value

toEncoding :: BatchFlushTimeout -> Encoding

toJSONList :: [BatchFlushTimeout] -> Value

toEncodingList :: [BatchFlushTimeout] -> Encoding

FromJSON BatchFlushTimeout

Methods

parseJSON :: Value -> Parser BatchFlushTimeout

parseJSONList :: Value -> Parser [BatchFlushTimeout]

data CursorCommitResultType

CursorCommitResultType

Constructors

CursorCommitResultCommitted

CursorCommitResultOutdated

Instances

Eq CursorCommitResultType

Methods

(==) :: CursorCommitResultType -> CursorCommitResultType -> Bool

(/=) :: CursorCommitResultType -> CursorCommitResultType -> Bool

Ord CursorCommitResultType

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

Methods

showsPrec :: Int -> CursorCommitResultType -> ShowS

show :: CursorCommitResultType -> String

showList :: [CursorCommitResultType] -> ShowS

ToJSON CursorCommitResultType

Methods

toJSON :: CursorCommitResultType -> Value

toEncoding :: CursorCommitResultType -> Encoding

toJSONList :: [CursorCommitResultType] -> Value

toEncodingList :: [CursorCommitResultType] -> Encoding

FromJSON CursorCommitResultType

Methods

parseJSON :: Value -> Parser CursorCommitResultType

parseJSONList :: Value -> Parser [CursorCommitResultType]

data CursorCommitResult

CursorCommitResult

Constructors

CursorCommitResult

Fields

• _cursor :: SubscriptionCursor
• _result :: CursorCommitResultType

Instances

Eq CursorCommitResult

Methods

(==) :: CursorCommitResult -> CursorCommitResult -> Bool

(/=) :: CursorCommitResult -> CursorCommitResult -> Bool

Ord CursorCommitResult

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

Methods

showsPrec :: Int -> CursorCommitResult -> ShowS

show :: CursorCommitResult -> String

showList :: [CursorCommitResult] -> ShowS

ToJSON CursorCommitResult

Methods

toJSON :: CursorCommitResult -> Value

toEncoding :: CursorCommitResult -> Encoding

toJSONList :: [CursorCommitResult] -> Value

toEncodingList :: [CursorCommitResult] -> Encoding

FromJSON CursorCommitResult

Methods

parseJSON :: Value -> Parser CursorCommitResult

parseJSONList :: Value -> Parser [CursorCommitResult]

newtype CursorCommitResults

Constructors

CursorCommitResults

Fields

• _items :: [CursorCommitResult]

Instances

Eq CursorCommitResults

Methods

(==) :: CursorCommitResults -> CursorCommitResults -> Bool

(/=) :: CursorCommitResults -> CursorCommitResults -> Bool

Ord CursorCommitResults

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

Methods

showsPrec :: Int -> CursorCommitResults -> ShowS

show :: CursorCommitResults -> String

showList :: [CursorCommitResults] -> ShowS

ToJSON CursorCommitResults

Methods

toJSON :: CursorCommitResults -> Value

toEncoding :: CursorCommitResults -> Encoding

toJSONList :: [CursorCommitResults] -> Value

toEncodingList :: [CursorCommitResults] -> Encoding

FromJSON CursorCommitResults

Methods

parseJSON :: Value -> Parser CursorCommitResults

parseJSONList :: Value -> Parser [CursorCommitResults]

data SchemaType

SchemaType

Constructors

SchemaTypeJson

Instances

Eq SchemaType

Methods

(==) :: SchemaType -> SchemaType -> Bool

(/=) :: SchemaType -> SchemaType -> Bool

Ord SchemaType

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

Methods

showsPrec :: Int -> SchemaType -> ShowS

show :: SchemaType -> String

showList :: [SchemaType] -> ShowS

Generic SchemaType

Associated Types

type Rep SchemaType :: * -> *

Methods

from :: SchemaType -> Rep SchemaType x

to :: Rep SchemaType x -> SchemaType

Hashable SchemaType

Methods

hashWithSalt :: Int -> SchemaType -> Int

hash :: SchemaType -> Int

ToJSON SchemaType

Methods

toJSON :: SchemaType -> Value

toEncoding :: SchemaType -> Encoding

toJSONList :: [SchemaType] -> Value

toEncodingList :: [SchemaType] -> Encoding

FromJSON SchemaType

Methods

parseJSON :: Value -> Parser SchemaType

parseJSONList :: Value -> Parser [SchemaType]

HasNakadiSchemaType EventTypeSchema SchemaType

Methods

schemaType :: Lens' EventTypeSchema SchemaType

type Rep SchemaType

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

Type for the version of a schema.

Constructors

SchemaVersion

Fields

• unSchemaVersion :: Text

Instances

Eq SchemaVersion

Methods

(==) :: SchemaVersion -> SchemaVersion -> Bool

(/=) :: SchemaVersion -> SchemaVersion -> Bool

Ord SchemaVersion

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

Methods

showsPrec :: Int -> SchemaVersion -> ShowS

show :: SchemaVersion -> String

showList :: [SchemaVersion] -> ShowS

IsString SchemaVersion

Methods

fromString :: String -> SchemaVersion

Generic SchemaVersion

Associated Types

type Rep SchemaVersion :: * -> *

Methods

from :: SchemaVersion -> Rep SchemaVersion x

to :: Rep SchemaVersion x -> SchemaVersion

Hashable SchemaVersion

Methods

hashWithSalt :: Int -> SchemaVersion -> Int

hash :: SchemaVersion -> Int

ToJSON SchemaVersion

Methods

toJSON :: SchemaVersion -> Value

toEncoding :: SchemaVersion -> Encoding

toJSONList :: [SchemaVersion] -> Value

toEncodingList :: [SchemaVersion] -> Encoding

FromJSON SchemaVersion

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

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

Type for the schema of an event type.

Constructors

EventTypeSchema

Fields

• _version :: Maybe SchemaVersion
• _createdAt :: Maybe Timestamp
• _schemaType :: SchemaType
• _schema :: Text

Instances

Eq EventTypeSchema

Methods

(==) :: EventTypeSchema -> EventTypeSchema -> Bool

(/=) :: EventTypeSchema -> EventTypeSchema -> Bool

Ord EventTypeSchema

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

Methods

showsPrec :: Int -> EventTypeSchema -> ShowS

show :: EventTypeSchema -> String

showList :: [EventTypeSchema] -> ShowS

Generic EventTypeSchema

Associated Types

type Rep EventTypeSchema :: * -> *

Methods

from :: EventTypeSchema -> Rep EventTypeSchema x

to :: Rep EventTypeSchema x -> EventTypeSchema

Hashable EventTypeSchema

Methods

hashWithSalt :: Int -> EventTypeSchema -> Int

hash :: EventTypeSchema -> Int

ToJSON EventTypeSchema

Methods

toJSON :: EventTypeSchema -> Value

toEncoding :: EventTypeSchema -> Encoding

toJSONList :: [EventTypeSchema] -> Value

toEncodingList :: [EventTypeSchema] -> Encoding

FromJSON EventTypeSchema

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

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

PaginationLink

Constructors

PaginationLink

Fields

• _href :: Text

Instances

Eq PaginationLink

Methods

(==) :: PaginationLink -> PaginationLink -> Bool

(/=) :: PaginationLink -> PaginationLink -> Bool

Ord PaginationLink

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

Methods

showsPrec :: Int -> PaginationLink -> ShowS

show :: PaginationLink -> String

showList :: [PaginationLink] -> ShowS

Generic PaginationLink

Associated Types

type Rep PaginationLink :: * -> *

Methods

from :: PaginationLink -> Rep PaginationLink x

to :: Rep PaginationLink x -> PaginationLink

Hashable PaginationLink

Methods

hashWithSalt :: Int -> PaginationLink -> Int

hash :: PaginationLink -> Int

ToJSON PaginationLink

Methods

toJSON :: PaginationLink -> Value

toEncoding :: PaginationLink -> Encoding

toJSONList :: [PaginationLink] -> Value

toEncodingList :: [PaginationLink] -> Encoding

FromJSON PaginationLink

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

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

PaginationLinks

Constructors

PaginationLinks

Fields

• _prev :: Maybe PaginationLink
• _next :: Maybe PaginationLink

Instances

Eq PaginationLinks

Methods

(==) :: PaginationLinks -> PaginationLinks -> Bool

(/=) :: PaginationLinks -> PaginationLinks -> Bool

Ord PaginationLinks

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

Methods

showsPrec :: Int -> PaginationLinks -> ShowS

show :: PaginationLinks -> String

showList :: [PaginationLinks] -> ShowS

Generic PaginationLinks

Associated Types

type Rep PaginationLinks :: * -> *

Methods

from :: PaginationLinks -> Rep PaginationLinks x

to :: Rep PaginationLinks x -> PaginationLinks

Hashable PaginationLinks

Methods

hashWithSalt :: Int -> PaginationLinks -> Int

hash :: PaginationLinks -> Int

ToJSON PaginationLinks

Methods

toJSON :: PaginationLinks -> Value

toEncoding :: PaginationLinks -> Encoding

toJSONList :: [PaginationLinks] -> Value

toEncodingList :: [PaginationLinks] -> Encoding

FromJSON PaginationLinks

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

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

EventTypeSchemasResponse

Constructors

EventTypeSchemasResponse

Fields

• _links :: PaginationLinks
• _items :: [EventTypeSchema]

Instances

Eq EventTypeSchemasResponse

Methods

(==) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool

(/=) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool

Ord EventTypeSchemasResponse

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

Methods

showsPrec :: Int -> EventTypeSchemasResponse -> ShowS

show :: EventTypeSchemasResponse -> String

showList :: [EventTypeSchemasResponse] -> ShowS

Generic EventTypeSchemasResponse

Associated Types

type Rep EventTypeSchemasResponse :: * -> *

Methods

from :: EventTypeSchemasResponse -> Rep EventTypeSchemasResponse x

to :: Rep EventTypeSchemasResponse x -> EventTypeSchemasResponse

Hashable EventTypeSchemasResponse

Methods

hashWithSalt :: Int -> EventTypeSchemasResponse -> Int

hash :: EventTypeSchemasResponse -> Int

ToJSON EventTypeSchemasResponse

Methods

toJSON :: EventTypeSchemasResponse -> Value

toEncoding :: EventTypeSchemasResponse -> Encoding

toJSONList :: [EventTypeSchemasResponse] -> Value

toEncodingList :: [EventTypeSchemasResponse] -> Encoding

FromJSON EventTypeSchemasResponse

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

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

SubscriptionsListResponse

Constructors

SubscriptionsListResponse

Fields

• _links :: PaginationLinks
• _items :: [Subscription]

Instances

Eq SubscriptionsListResponse

Methods

(==) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool

(/=) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool

Ord SubscriptionsListResponse

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

Methods

showsPrec :: Int -> SubscriptionsListResponse -> ShowS

show :: SubscriptionsListResponse -> String

showList :: [SubscriptionsListResponse] -> ShowS

Generic SubscriptionsListResponse

Associated Types

type Rep SubscriptionsListResponse :: * -> *

Methods

from :: SubscriptionsListResponse -> Rep SubscriptionsListResponse x

to :: Rep SubscriptionsListResponse x -> SubscriptionsListResponse

Hashable SubscriptionsListResponse

Methods

hashWithSalt :: Int -> SubscriptionsListResponse -> Int

hash :: SubscriptionsListResponse -> Int

ToJSON SubscriptionsListResponse

Methods

toJSON :: SubscriptionsListResponse -> Value

toEncoding :: SubscriptionsListResponse -> Encoding

toJSONList :: [SubscriptionsListResponse] -> Value

toEncodingList :: [SubscriptionsListResponse] -> Encoding

FromJSON SubscriptionsListResponse

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

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

Type for offset values.

Constructors

Offset

Fields

• unOffset :: Int64

  Wrapped offset value

Instances

Eq Offset

Methods

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

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

Ord Offset

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

Methods

showsPrec :: Int -> Offset -> ShowS

show :: Offset -> String

showList :: [Offset] -> ShowS

Generic Offset

Associated Types

type Rep Offset :: * -> *

Methods

from :: Offset -> Rep Offset x

to :: Rep Offset x -> Offset

Hashable Offset

Methods

hashWithSalt :: Int -> Offset -> Int

hash :: Offset -> Int

type Rep Offset

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

Type for limit values.

Constructors

Limit

Fields

• unLimit :: Int64

  Wrapped limit value.

Instances

Eq Limit

Methods

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

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

Ord Limit

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

Methods

showsPrec :: Int -> Limit -> ShowS

show :: Limit -> String

showList :: [Limit] -> ShowS

Generic Limit

Associated Types

type Rep Limit :: * -> *

Methods

from :: Limit -> Rep Limit x

to :: Rep Limit x -> Limit

Hashable Limit

Methods

hashWithSalt :: Int -> Limit -> Int

hash :: Limit -> Int

type Rep Limit

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

Type for partition states.

Constructors

PartitionStateUnassigned

PartitionStateReassigning

PartitionStateAssigned

Instances

Eq PartitionState

Methods

(==) :: PartitionState -> PartitionState -> Bool

(/=) :: PartitionState -> PartitionState -> Bool

Ord PartitionState

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

Methods

showsPrec :: Int -> PartitionState -> ShowS

show :: PartitionState -> String

showList :: [PartitionState] -> ShowS

ToJSON PartitionState

Methods

toJSON :: PartitionState -> Value

toEncoding :: PartitionState -> Encoding

toJSONList :: [PartitionState] -> Value

toEncodingList :: [PartitionState] -> Encoding

FromJSON PartitionState

Methods

parseJSON :: Value -> Parser PartitionState

parseJSONList :: Value -> Parser [PartitionState]

data PartitionStat

Type for per-partition statistics.

Constructors

PartitionStat

Fields

• _partition :: PartitionName
• _state :: PartitionState
• _unconsumedEvents :: Int64
• _streamId :: StreamId

Instances

Eq PartitionStat

Methods

(==) :: PartitionStat -> PartitionStat -> Bool

(/=) :: PartitionStat -> PartitionStat -> Bool

Ord PartitionStat

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

Methods

showsPrec :: Int -> PartitionStat -> ShowS

show :: PartitionStat -> String

showList :: [PartitionStat] -> ShowS

Generic PartitionStat

Associated Types

type Rep PartitionStat :: * -> *

Methods

from :: PartitionStat -> Rep PartitionStat x

to :: Rep PartitionStat x -> PartitionStat

ToJSON PartitionStat

Methods

toJSON :: PartitionStat -> Value

toEncoding :: PartitionStat -> Encoding

toJSONList :: [PartitionStat] -> Value

toEncodingList :: [PartitionStat] -> Encoding

FromJSON PartitionStat

Methods

parseJSON :: Value -> Parser PartitionStat

parseJSONList :: Value -> Parser [PartitionStat]

type Rep PartitionStat

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

Nakadi type SubscriptionEventTypeStats.

Constructors

SubscriptionEventTypeStats

Fields

• _eventType :: EventTypeName
• _partitions :: [PartitionStat]

Instances

Eq SubscriptionEventTypeStats

Methods

(==) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool

(/=) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool

Ord SubscriptionEventTypeStats

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

Methods

showsPrec :: Int -> SubscriptionEventTypeStats -> ShowS

show :: SubscriptionEventTypeStats -> String

showList :: [SubscriptionEventTypeStats] -> ShowS

Generic SubscriptionEventTypeStats

Associated Types

type Rep SubscriptionEventTypeStats :: * -> *

Methods

from :: SubscriptionEventTypeStats -> Rep SubscriptionEventTypeStats x

to :: Rep SubscriptionEventTypeStats x -> SubscriptionEventTypeStats

ToJSON SubscriptionEventTypeStats

Methods

toJSON :: SubscriptionEventTypeStats -> Value

toEncoding :: SubscriptionEventTypeStats -> Encoding

toJSONList :: [SubscriptionEventTypeStats] -> Value

toEncodingList :: [SubscriptionEventTypeStats] -> Encoding

FromJSON SubscriptionEventTypeStats

Methods

parseJSON :: Value -> Parser SubscriptionEventTypeStats

parseJSONList :: Value -> Parser [SubscriptionEventTypeStats]

HasNakadiItems SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]

Methods

items :: Lens' SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]

type Rep SubscriptionEventTypeStats

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

SubscriptionEventTypeStatsResult

Constructors

SubscriptionEventTypeStatsResult

Fields

• _items :: [SubscriptionEventTypeStats]

Instances

Eq SubscriptionEventTypeStatsResult

Methods

(==) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool

(/=) :: SubscriptionEventTypeStatsResult -> SubscriptionEventTypeStatsResult -> Bool

Ord SubscriptionEventTypeStatsResult

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

Methods

showsPrec :: Int -> SubscriptionEventTypeStatsResult -> ShowS

show :: SubscriptionEventTypeStatsResult -> String

showList :: [SubscriptionEventTypeStatsResult] -> ShowS

Generic SubscriptionEventTypeStatsResult

Associated Types

type Rep SubscriptionEventTypeStatsResult :: * -> *

Methods

from :: SubscriptionEventTypeStatsResult -> Rep SubscriptionEventTypeStatsResult x

to :: Rep SubscriptionEventTypeStatsResult x -> SubscriptionEventTypeStatsResult

ToJSON SubscriptionEventTypeStatsResult

Methods

toJSON :: SubscriptionEventTypeStatsResult -> Value

toEncoding :: SubscriptionEventTypeStatsResult -> Encoding

toJSONList :: [SubscriptionEventTypeStatsResult] -> Value

toEncodingList :: [SubscriptionEventTypeStatsResult] -> Encoding

FromJSON SubscriptionEventTypeStatsResult

Methods

parseJSON :: Value -> Parser SubscriptionEventTypeStatsResult

parseJSONList :: Value -> Parser [SubscriptionEventTypeStatsResult]

HasNakadiItems SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]

Methods

items :: Lens' SubscriptionEventTypeStatsResult [SubscriptionEventTypeStats]

type Rep SubscriptionEventTypeStatsResult

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

Type for the category of an EventType.

Constructors

EventTypeCategoryUndefined

EventTypeCategoryData

EventTypeCategoryBusiness

Instances

Eq EventTypeCategory

Methods

(==) :: EventTypeCategory -> EventTypeCategory -> Bool

(/=) :: EventTypeCategory -> EventTypeCategory -> Bool

Ord EventTypeCategory

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

Methods

showsPrec :: Int -> EventTypeCategory -> ShowS

show :: EventTypeCategory -> String

showList :: [EventTypeCategory] -> ShowS

Generic EventTypeCategory

Associated Types

type Rep EventTypeCategory :: * -> *

Methods

from :: EventTypeCategory -> Rep EventTypeCategory x

to :: Rep EventTypeCategory x -> EventTypeCategory

Hashable EventTypeCategory

Methods

hashWithSalt :: Int -> EventTypeCategory -> Int

hash :: EventTypeCategory -> Int

ToJSON EventTypeCategory

Methods

toJSON :: EventTypeCategory -> Value

toEncoding :: EventTypeCategory -> Encoding

toJSONList :: [EventTypeCategory] -> Value

toEncodingList :: [EventTypeCategory] -> Encoding

FromJSON EventTypeCategory

Methods

parseJSON :: Value -> Parser EventTypeCategory

parseJSONList :: Value -> Parser [EventTypeCategory]

HasNakadiCategory EventType (Maybe EventTypeCategory)

Methods

category :: Lens' EventType (Maybe EventTypeCategory)

type Rep EventTypeCategory

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

Type for a partitioning strategy.

Constructors

PartitionStrategyRandom

PartitionStrategyUser

PartitionStrategyHash

PartitionStrategyCustom Text

Instances

Eq PartitionStrategy

Methods

(==) :: PartitionStrategy -> PartitionStrategy -> Bool

(/=) :: PartitionStrategy -> PartitionStrategy -> Bool

Ord PartitionStrategy

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

Methods

showsPrec :: Int -> PartitionStrategy -> ShowS

show :: PartitionStrategy -> String

showList :: [PartitionStrategy] -> ShowS

IsString PartitionStrategy

Methods

fromString :: String -> PartitionStrategy

Generic PartitionStrategy

Associated Types

type Rep PartitionStrategy :: * -> *

Methods

from :: PartitionStrategy -> Rep PartitionStrategy x

to :: Rep PartitionStrategy x -> PartitionStrategy

Hashable PartitionStrategy

Methods

hashWithSalt :: Int -> PartitionStrategy -> Int

hash :: PartitionStrategy -> Int

ToJSON PartitionStrategy

Methods

toJSON :: PartitionStrategy -> Value

toEncoding :: PartitionStrategy -> Encoding

toJSONList :: [PartitionStrategy] -> Value

toEncodingList :: [PartitionStrategy] -> Encoding

FromJSON PartitionStrategy

Methods

parseJSON :: Value -> Parser PartitionStrategy

parseJSONList :: Value -> Parser [PartitionStrategy]

HasNakadiPartitionStrategy EventType (Maybe PartitionStrategy)

Methods

partitionStrategy :: Lens' EventType (Maybe PartitionStrategy)

type Rep PartitionStrategy

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

Type for an enrichment stragey.

Constructors

EnrichmentStrategyMetadata

Instances

Eq EnrichmentStrategy

Methods

(==) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool

(/=) :: EnrichmentStrategy -> EnrichmentStrategy -> Bool

Ord EnrichmentStrategy

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

Methods

showsPrec :: Int -> EnrichmentStrategy -> ShowS

show :: EnrichmentStrategy -> String

showList :: [EnrichmentStrategy] -> ShowS

Generic EnrichmentStrategy

Associated Types

type Rep EnrichmentStrategy :: * -> *

Methods

from :: EnrichmentStrategy -> Rep EnrichmentStrategy x

to :: Rep EnrichmentStrategy x -> EnrichmentStrategy

Hashable EnrichmentStrategy

Methods

hashWithSalt :: Int -> EnrichmentStrategy -> Int

hash :: EnrichmentStrategy -> Int

ToJSON EnrichmentStrategy

Methods

toJSON :: EnrichmentStrategy -> Value

toEncoding :: EnrichmentStrategy -> Encoding

toJSONList :: [EnrichmentStrategy] -> Value

toEncodingList :: [EnrichmentStrategy] -> Encoding

FromJSON EnrichmentStrategy

Methods

parseJSON :: Value -> Parser EnrichmentStrategy

parseJSONList :: Value -> Parser [EnrichmentStrategy]

HasNakadiEnrichmentStrategies EventType (Maybe [EnrichmentStrategy])

Methods

enrichmentStrategies :: Lens' EventType (Maybe [EnrichmentStrategy])

type Rep EnrichmentStrategy

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

Type for an event type compatibility mode.

Constructors

CompatibilityModeCompatible

CompatibilityModeForward

CompatibilityModeNone

Instances

Eq CompatibilityMode

Methods

(==) :: CompatibilityMode -> CompatibilityMode -> Bool

(/=) :: CompatibilityMode -> CompatibilityMode -> Bool

Ord CompatibilityMode

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

Methods

showsPrec :: Int -> CompatibilityMode -> ShowS

show :: CompatibilityMode -> String

showList :: [CompatibilityMode] -> ShowS

Generic CompatibilityMode

Associated Types

type Rep CompatibilityMode :: * -> *

Methods

from :: CompatibilityMode -> Rep CompatibilityMode x

to :: Rep CompatibilityMode x -> CompatibilityMode

Hashable CompatibilityMode

Methods

hashWithSalt :: Int -> CompatibilityMode -> Int

hash :: CompatibilityMode -> Int

ToJSON CompatibilityMode

Methods

toJSON :: CompatibilityMode -> Value

toEncoding :: CompatibilityMode -> Encoding

toJSONList :: [CompatibilityMode] -> Value

toEncodingList :: [CompatibilityMode] -> Encoding

FromJSON CompatibilityMode

Methods

parseJSON :: Value -> Parser CompatibilityMode

parseJSONList :: Value -> Parser [CompatibilityMode]

HasNakadiCompatibilityMode EventType (Maybe CompatibilityMode)

Methods

compatibilityMode :: Lens' EventType (Maybe CompatibilityMode)

type Rep CompatibilityMode

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

Type for a partitioning key field.

Constructors

PartitionKeyField

Fields

• unPartitionKeyField :: Text

Instances

Eq PartitionKeyField

Methods

(==) :: PartitionKeyField -> PartitionKeyField -> Bool

(/=) :: PartitionKeyField -> PartitionKeyField -> Bool

Ord PartitionKeyField

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

Methods

showsPrec :: Int -> PartitionKeyField -> ShowS

show :: PartitionKeyField -> String

showList :: [PartitionKeyField] -> ShowS

IsString PartitionKeyField

Methods

fromString :: String -> PartitionKeyField

Generic PartitionKeyField

Associated Types

type Rep PartitionKeyField :: * -> *

Methods

from :: PartitionKeyField -> Rep PartitionKeyField x

to :: Rep PartitionKeyField x -> PartitionKeyField

Hashable PartitionKeyField

Methods

hashWithSalt :: Int -> PartitionKeyField -> Int

hash :: PartitionKeyField -> Int

ToJSON PartitionKeyField

Methods

toJSON :: PartitionKeyField -> Value

toEncoding :: PartitionKeyField -> Encoding

toJSONList :: [PartitionKeyField] -> Value

toEncodingList :: [PartitionKeyField] -> Encoding

FromJSON PartitionKeyField

Methods

parseJSON :: Value -> Parser PartitionKeyField

parseJSONList :: Value -> Parser [PartitionKeyField]

HasNakadiPartitionKeyFields EventType (Maybe [PartitionKeyField])

Methods

partitionKeyFields :: Lens' EventType (Maybe [PartitionKeyField])

type Rep PartitionKeyField

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

Type for event type statistics.

Constructors

EventTypeStatistics

Fields

• _messagesPerMinute :: Int64
• _messageSize :: Int64
• _readParallelism :: Int64
• _writeParallelism :: Int64

Instances

Eq EventTypeStatistics

Methods

(==) :: EventTypeStatistics -> EventTypeStatistics -> Bool

(/=) :: EventTypeStatistics -> EventTypeStatistics -> Bool

Ord EventTypeStatistics

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

Methods

showsPrec :: Int -> EventTypeStatistics -> ShowS

show :: EventTypeStatistics -> String

showList :: [EventTypeStatistics] -> ShowS

Generic EventTypeStatistics

Associated Types

type Rep EventTypeStatistics :: * -> *

Methods

from :: EventTypeStatistics -> Rep EventTypeStatistics x

to :: Rep EventTypeStatistics x -> EventTypeStatistics

Hashable EventTypeStatistics

Methods

hashWithSalt :: Int -> EventTypeStatistics -> Int

hash :: EventTypeStatistics -> Int

ToJSON EventTypeStatistics

Methods

toJSON :: EventTypeStatistics -> Value

toEncoding :: EventTypeStatistics -> Encoding

toJSONList :: [EventTypeStatistics] -> Value

toEncodingList :: [EventTypeStatistics] -> Encoding

FromJSON EventTypeStatistics

Methods

parseJSON :: Value -> Parser EventTypeStatistics

parseJSONList :: Value -> Parser [EventTypeStatistics]

HasNakadiDefaultStatistic EventType (Maybe EventTypeStatistics)

Methods

defaultStatistic :: Lens' EventType (Maybe EventTypeStatistics)

type Rep EventTypeStatistics

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

Type for event type options.

Constructors

EventTypeOptions

Fields

• _retentionTime :: Int64

Instances

Eq EventTypeOptions

Methods

(==) :: EventTypeOptions -> EventTypeOptions -> Bool

(/=) :: EventTypeOptions -> EventTypeOptions -> Bool

Ord EventTypeOptions

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

Methods

showsPrec :: Int -> EventTypeOptions -> ShowS

show :: EventTypeOptions -> String

showList :: [EventTypeOptions] -> ShowS

Generic EventTypeOptions

Associated Types

type Rep EventTypeOptions :: * -> *

Methods

from :: EventTypeOptions -> Rep EventTypeOptions x

to :: Rep EventTypeOptions x -> EventTypeOptions

Hashable EventTypeOptions

Methods

hashWithSalt :: Int -> EventTypeOptions -> Int

hash :: EventTypeOptions -> Int

ToJSON EventTypeOptions

Methods

toJSON :: EventTypeOptions -> Value

toEncoding :: EventTypeOptions -> Encoding

toJSONList :: [EventTypeOptions] -> Value

toEncodingList :: [EventTypeOptions] -> Encoding

FromJSON EventTypeOptions

Methods

parseJSON :: Value -> Parser EventTypeOptions

parseJSONList :: Value -> Parser [EventTypeOptions]

HasNakadiOptions EventType (Maybe EventTypeOptions)

Methods

options :: Lens' EventType (Maybe EventTypeOptions)

type Rep EventTypeOptions

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

EventType

Constructors

EventType

Fields

• _name :: EventTypeName
• _owningApplication :: Maybe ApplicationName
• _category :: Maybe EventTypeCategory
• _enrichmentStrategies :: Maybe [EnrichmentStrategy]
• _partitionStrategy :: Maybe PartitionStrategy
• _compatibilityMode :: Maybe CompatibilityMode
• _schema :: EventTypeSchema
• _partitionKeyFields :: Maybe [PartitionKeyField]
• _defaultStatistic :: Maybe EventTypeStatistics
• _options :: Maybe EventTypeOptions

Instances

Eq EventType

Methods

(==) :: EventType -> EventType -> Bool

(/=) :: EventType -> EventType -> Bool

Ord EventType

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

Methods

showsPrec :: Int -> EventType -> ShowS

show :: EventType -> String

showList :: [EventType] -> ShowS

Generic EventType

Associated Types

type Rep EventType :: * -> *

Methods

from :: EventType -> Rep EventType x

to :: Rep EventType x -> EventType

Hashable EventType

Methods

hashWithSalt :: Int -> EventType -> Int

hash :: EventType -> Int

ToJSON EventType

Methods

toJSON :: EventType -> Value

toEncoding :: EventType -> Encoding

toJSONList :: [EventType] -> Value

toEncodingList :: [EventType] -> Encoding

FromJSON EventType

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

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

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

Methods

(==) :: MetadataEnriched -> MetadataEnriched -> Bool

(/=) :: MetadataEnriched -> MetadataEnriched -> Bool

Show MetadataEnriched

Methods

showsPrec :: Int -> MetadataEnriched -> ShowS

show :: MetadataEnriched -> String

showList :: [MetadataEnriched] -> ShowS

Generic MetadataEnriched

Associated Types

type Rep MetadataEnriched :: * -> *

Methods

from :: MetadataEnriched -> Rep MetadataEnriched x

to :: Rep MetadataEnriched x -> MetadataEnriched

ToJSON MetadataEnriched

Methods

toJSON :: MetadataEnriched -> Value

toEncoding :: MetadataEnriched -> Encoding

toJSONList :: [MetadataEnriched] -> Value

toEncodingList :: [MetadataEnriched] -> Encoding

FromJSON MetadataEnriched

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

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

Type of enriched event.

Constructors

EventEnriched

Fields

• _payload :: a
• _metadata :: MetadataEnriched

Instances

Eq a => Eq (EventEnriched a)

Methods

(==) :: EventEnriched a -> EventEnriched a -> Bool

(/=) :: EventEnriched a -> EventEnriched a -> Bool

Show a => Show (EventEnriched a)

Methods

showsPrec :: Int -> EventEnriched a -> ShowS

show :: EventEnriched a -> String

showList :: [EventEnriched a] -> ShowS

Generic (EventEnriched a)

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)

Methods

toJSON :: EventEnriched a -> Value

toEncoding :: EventEnriched a -> Encoding

toJSONList :: [EventEnriched a] -> Value

toEncodingList :: [EventEnriched a] -> Encoding

FromJSON a => FromJSON (EventEnriched a)

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)

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

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)

Methods

showsPrec :: Int -> EventStreamBatch a -> ShowS

show :: EventStreamBatch a -> String

showList :: [EventStreamBatch a] -> ShowS

Generic (EventStreamBatch a)

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)

Methods

toJSON :: EventStreamBatch a -> Value

toEncoding :: EventStreamBatch a -> Encoding

toJSONList :: [EventStreamBatch a] -> Value

toEncodingList :: [EventStreamBatch a] -> Encoding

FromJSON a => FromJSON (EventStreamBatch a)

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)

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

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)

Methods

showsPrec :: Int -> SubscriptionEventStreamBatch a -> ShowS

show :: SubscriptionEventStreamBatch a -> String

showList :: [SubscriptionEventStreamBatch a] -> ShowS

Generic (SubscriptionEventStreamBatch a)

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)

Methods

toJSON :: SubscriptionEventStreamBatch a -> Value

toEncoding :: SubscriptionEventStreamBatch a -> Encoding

toJSONList :: [SubscriptionEventStreamBatch a] -> Value

toEncodingList :: [SubscriptionEventStreamBatch a] -> Encoding

FromJSON a => FromJSON (SubscriptionEventStreamBatch a)

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)

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

Type for "data_op" as contained in the DataChangeEvent.

Constructors

DataOpCreation

DataOpUpdate

DataOpDeletion

DataOpSnapshot

Instances

Eq DataOp

Methods

(==) :: DataOp -> DataOp -> Bool

(/=) :: DataOp -> DataOp -> Bool

Ord DataOp

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

Methods

showsPrec :: Int -> DataOp -> ShowS

show :: DataOp -> String

showList :: [DataOp] -> ShowS

ToJSON DataOp

Methods

toJSON :: DataOp -> Value

toEncoding :: DataOp -> Encoding

toJSONList :: [DataOp] -> Value

toEncodingList :: [DataOp] -> Encoding

FromJSON DataOp

Methods

parseJSON :: Value -> Parser DataOp

parseJSONList :: Value -> Parser [DataOp]

data DataChangeEvent a

DataChangeEvent

Constructors

DataChangeEvent

Fields

• _payload :: a
• _metadata :: Metadata
• _dataType :: Text
• _dataOp :: DataOp

Instances

Eq a => Eq (DataChangeEvent a)

Methods

(==) :: DataChangeEvent a -> DataChangeEvent a -> Bool

(/=) :: DataChangeEvent a -> DataChangeEvent a -> Bool

Show a => Show (DataChangeEvent a)

Methods

showsPrec :: Int -> DataChangeEvent a -> ShowS

show :: DataChangeEvent a -> String

showList :: [DataChangeEvent a] -> ShowS

Generic (DataChangeEvent a)

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)

Methods

toJSON :: DataChangeEvent a -> Value

toEncoding :: DataChangeEvent a -> Encoding

toJSONList :: [DataChangeEvent a] -> Value

toEncodingList :: [DataChangeEvent a] -> Encoding

FromJSON a => FromJSON (DataChangeEvent a)

Methods

parseJSON :: Value -> Parser (DataChangeEvent a)

parseJSONList :: Value -> Parser [DataChangeEvent a]

type Rep (DataChangeEvent a)

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

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

Construct a field renamer function from a field renamer map.

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

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

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

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)

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

Minimal complete definition

nakadiConfig

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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