Network.Nakadi.Types.Service

This module provides the Nakadi Service Types.

Documentation

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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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 EventMetadataEnriched EventTypeName

Methods

eventType :: Lens' EventMetadataEnriched 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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 EventMetadata (Maybe PartitionName)

Methods

partition :: Lens' EventMetadata (Maybe PartitionName)

HasNakadiPartition EventMetadataEnriched (Maybe PartitionName)

Methods

partition :: Lens' EventMetadataEnriched (Maybe PartitionName)

type Rep PartitionName

type Rep PartitionName = D1 * (MetaData "PartitionName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" True) (C1 * (MetaCons "ApplicationName" PrefixI True) (S1 * (MetaSel (Just Symbol "unApplicationName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

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.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "SubscriptionsListResponse" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PaginationLinks)) (S1 * (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * [Subscription]))))

data SubscriptionCursor

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.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "SubscriptionCursor" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PartitionName)) (S1 * (MetaSel (Just Symbol "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * CursorOffset))) ((:*:) * (S1 * (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName)) (S1 * (MetaSel (Just Symbol "_cursorToken") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)))))

newtype FlowId

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 EventMetadataEnriched (Maybe FlowId)

Methods

flowId :: Lens' EventMetadataEnriched (Maybe FlowId)

type Rep FlowId

type Rep FlowId = D1 * (MetaData "FlowId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.1.0-GRLY78MOS1rKNuRVGUE6JH" True) (C1 * (MetaCons "FlowId" PrefixI True) (S1 * (MetaSel (Just Symbol "unFlowId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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 EventMetadata Timestamp

Methods

occurredAt :: Lens' EventMetadata Timestamp

HasNakadiOccurredAt EventMetadataEnriched Timestamp

Methods

occurredAt :: Lens' EventMetadataEnriched Timestamp

HasNakadiReceivedAt EventMetadataEnriched Timestamp

Methods

receivedAt :: Lens' EventMetadataEnriched 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.1.0-GRLY78MOS1rKNuRVGUE6JH" True) (C1 * (MetaCons "Timestamp" PrefixI True) (S1 * (MetaSel (Just Symbol "unTimestamp") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * UTCTime)))

data EventStreamBatch a

EventStreamBatch

Constructors

EventStreamBatch

Fields

• _cursor :: Cursor

  Cursor for this batch

• _events :: Maybe (Vector 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 a))

Methods

events :: Lens' (EventStreamBatch a) (Maybe (Vector a))

type Rep (EventStreamBatch a)

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

data SubscriptionEventStreamBatch a

SubscriptionEventStreamBatch

Constructors

SubscriptionEventStreamBatch

Fields

• _cursor :: SubscriptionCursor

  cursor for this subscription batch

• _events :: Maybe (Vector 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 a))

Methods

events :: Lens' (SubscriptionEventStreamBatch a) (Maybe (Vector a))

type Rep (SubscriptionEventStreamBatch a)

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

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 EventMetadata EventId

Methods

eid :: Lens' EventMetadata EventId

HasNakadiEid EventMetadataEnriched EventId

Methods

eid :: Lens' EventMetadataEnriched EventId

HasNakadiId EventId UUID

Methods

id :: Lens' EventId UUID

HasNakadiParentEids EventMetadata (Maybe [EventId])

Methods

parentEids :: Lens' EventMetadata (Maybe [EventId])

HasNakadiParentEids EventMetadataEnriched (Maybe [EventId])

Methods

parentEids :: Lens' EventMetadataEnriched (Maybe [EventId])

type Rep EventId

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

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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "SchemaTypeJson" PrefixI False) (U1 *))

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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "EventTypeSchemasResponse" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * PaginationLinks)) (S1 * (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * [EventTypeSchema]))))

newtype SchemaVersion

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 EventMetadataEnriched SchemaVersion

Methods

version :: Lens' EventMetadataEnriched 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.1.0-GRLY78MOS1rKNuRVGUE6JH" True) (C1 * (MetaCons "SchemaVersion" PrefixI True) (S1 * (MetaSel (Just Symbol "unSchemaVersion") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" True) (C1 * (MetaCons "PartitionKeyField" PrefixI True) (S1 * (MetaSel (Just Symbol "unPartitionKeyField") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Text)))

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.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "EventType" PrefixI True) ((:*:) * ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_name") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName)) (S1 * (MetaSel (Just Symbol "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe ApplicationName)))) ((:*:) * (S1 * (MetaSel (Just Symbol "_category") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe EventTypeCategory))) ((:*:) * (S1 * (MetaSel (Just Symbol "_enrichmentStrategies") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [EnrichmentStrategy]))) (S1 * (MetaSel (Just Symbol "_partitionStrategy") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PartitionStrategy)))))) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_compatibilityMode") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe CompatibilityMode))) (S1 * (MetaSel (Just Symbol "_schema") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeSchema))) ((:*:) * (S1 * (MetaSel (Just Symbol "_partitionKeyFields") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [PartitionKeyField]))) ((:*:) * (S1 * (MetaSel (Just Symbol "_defaultStatistic") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe EventTypeStatistics))) (S1 * (MetaSel (Just Symbol "_options") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe EventTypeOptions))))))))

data DataChangeEvent a

DataChangeEvent

Constructors

DataChangeEvent

Fields

• _payload :: a
• _metadata :: EventMetadata
• _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.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "DataChangeEvent" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * a)) (S1 * (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventMetadata))) ((:*:) * (S1 * (MetaSel (Just Symbol "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * DataOp)))))

data DataChangeEventEnriched a

A DataChangeEvent enriched by Nakadi

Constructors

DataChangeEventEnriched

Fields

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

Instances

Eq a => Eq (DataChangeEventEnriched a)

Methods

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

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

Show a => Show (DataChangeEventEnriched a)

Methods

showsPrec :: Int -> DataChangeEventEnriched a -> ShowS

show :: DataChangeEventEnriched a -> String

showList :: [DataChangeEventEnriched a] -> ShowS

Generic (DataChangeEventEnriched a)

Associated Types

type Rep (DataChangeEventEnriched a) :: * -> *

Methods

from :: DataChangeEventEnriched a -> Rep (DataChangeEventEnriched a) x

to :: Rep (DataChangeEventEnriched a) x -> DataChangeEventEnriched a

ToJSON a => ToJSON (DataChangeEventEnriched a)

Methods

toJSON :: DataChangeEventEnriched a -> Value

toEncoding :: DataChangeEventEnriched a -> Encoding

toJSONList :: [DataChangeEventEnriched a] -> Value

toEncodingList :: [DataChangeEventEnriched a] -> Encoding

FromJSON a => FromJSON (DataChangeEventEnriched a)

Methods

parseJSON :: Value -> Parser (DataChangeEventEnriched a)

parseJSONList :: Value -> Parser [DataChangeEventEnriched a]

type Rep (DataChangeEventEnriched a)

type Rep (DataChangeEventEnriched a) = D1 * (MetaData "DataChangeEventEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "DataChangeEventEnriched" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * a)) (S1 * (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventMetadataEnriched))) ((:*:) * (S1 * (MetaSel (Just Symbol "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Text)) (S1 * (MetaSel (Just Symbol "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * DataOp)))))

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 EventMetadata

Type of published event metadata values.

Constructors

EventMetadata

Fields

• _eid :: EventId
• _occurredAt :: Timestamp
• _parentEids :: Maybe [EventId]
• _partition :: Maybe PartitionName

Instances

Eq EventMetadata

Methods

(==) :: EventMetadata -> EventMetadata -> Bool

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

Show EventMetadata

Methods

showsPrec :: Int -> EventMetadata -> ShowS

show :: EventMetadata -> String

showList :: [EventMetadata] -> ShowS

Generic EventMetadata

Associated Types

type Rep EventMetadata :: * -> *

Methods

from :: EventMetadata -> Rep EventMetadata x

to :: Rep EventMetadata x -> EventMetadata

ToJSON EventMetadata

Methods

toJSON :: EventMetadata -> Value

toEncoding :: EventMetadata -> Encoding

toJSONList :: [EventMetadata] -> Value

toEncodingList :: [EventMetadata] -> Encoding

FromJSON EventMetadata

Methods

parseJSON :: Value -> Parser EventMetadata

parseJSONList :: Value -> Parser [EventMetadata]

HasNakadiOccurredAt EventMetadata Timestamp

Methods

occurredAt :: Lens' EventMetadata Timestamp

HasNakadiEid EventMetadata EventId

Methods

eid :: Lens' EventMetadata EventId

HasNakadiPartition EventMetadata (Maybe PartitionName)

Methods

partition :: Lens' EventMetadata (Maybe PartitionName)

HasNakadiParentEids EventMetadata (Maybe [EventId])

Methods

parentEids :: Lens' EventMetadata (Maybe [EventId])

type Rep EventMetadata

type Rep EventMetadata = D1 * (MetaData "EventMetadata" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "EventMetadata" PrefixI True) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventId)) (S1 * (MetaSel (Just Symbol "_occurredAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Timestamp))) ((:*:) * (S1 * (MetaSel (Just Symbol "_parentEids") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [EventId]))) (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PartitionName))))))

data EventMetadataEnriched

Type of event metadata enriched by Nakadi

Constructors

EventMetadataEnriched

Fields

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

Instances

Eq EventMetadataEnriched

Methods

(==) :: EventMetadataEnriched -> EventMetadataEnriched -> Bool

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

Show EventMetadataEnriched

Methods

showsPrec :: Int -> EventMetadataEnriched -> ShowS

show :: EventMetadataEnriched -> String

showList :: [EventMetadataEnriched] -> ShowS

Generic EventMetadataEnriched

Associated Types

type Rep EventMetadataEnriched :: * -> *

Methods

from :: EventMetadataEnriched -> Rep EventMetadataEnriched x

to :: Rep EventMetadataEnriched x -> EventMetadataEnriched

ToJSON EventMetadataEnriched

Methods

toJSON :: EventMetadataEnriched -> Value

toEncoding :: EventMetadataEnriched -> Encoding

toJSONList :: [EventMetadataEnriched] -> Value

toEncodingList :: [EventMetadataEnriched] -> Encoding

FromJSON EventMetadataEnriched

Methods

parseJSON :: Value -> Parser EventMetadataEnriched

parseJSONList :: Value -> Parser [EventMetadataEnriched]

HasNakadiOccurredAt EventMetadataEnriched Timestamp

Methods

occurredAt :: Lens' EventMetadataEnriched Timestamp

HasNakadiEid EventMetadataEnriched EventId

Methods

eid :: Lens' EventMetadataEnriched EventId

HasNakadiVersion EventMetadataEnriched SchemaVersion

Methods

version :: Lens' EventMetadataEnriched SchemaVersion

HasNakadiReceivedAt EventMetadataEnriched Timestamp

Methods

receivedAt :: Lens' EventMetadataEnriched Timestamp

HasNakadiEventType EventMetadataEnriched EventTypeName

Methods

eventType :: Lens' EventMetadataEnriched EventTypeName

HasNakadiPartition EventMetadataEnriched (Maybe PartitionName)

Methods

partition :: Lens' EventMetadataEnriched (Maybe PartitionName)

HasNakadiParentEids EventMetadataEnriched (Maybe [EventId])

Methods

parentEids :: Lens' EventMetadataEnriched (Maybe [EventId])

HasNakadiFlowId EventMetadataEnriched (Maybe FlowId)

Methods

flowId :: Lens' EventMetadataEnriched (Maybe FlowId)

type Rep EventMetadataEnriched

type Rep EventMetadataEnriched = D1 * (MetaData "EventMetadataEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.4.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "EventMetadataEnriched" PrefixI True) ((:*:) * ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventId)) (S1 * (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * EventTypeName))) ((:*:) * (S1 * (MetaSel (Just Symbol "_occurredAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Timestamp)) (S1 * (MetaSel (Just Symbol "_receivedAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Timestamp)))) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "_version") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * SchemaVersion)) (S1 * (MetaSel (Just Symbol "_parentEids") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe [EventId])))) ((:*:) * (S1 * (MetaSel (Just Symbol "_flowId") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe FlowId))) (S1 * (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * (Maybe PartitionName)))))))

data EventTypeStatistics

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.1.0-GRLY78MOS1rKNuRVGUE6JH" 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.1.0-GRLY78MOS1rKNuRVGUE6JH" False) (C1 * (MetaCons "EventTypeOptions" PrefixI True) (S1 * (MetaSel (Just Symbol "_retentionTime") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 * Int64)))