Network.Nakadi.Types.Service

This module provides the Nakadi Service Types.

Documentation

newtype CursorOffset

Type for cursor offsets.

Constructors

CursorOffset Text

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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 Text

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]

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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "EventTypeName" PrefixI True) (S1 (MetaSel (Just Symbol "unEventTypeName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype PartitionName

Type for partition names.

Constructors

PartitionName Text

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

type Rep PartitionName

type Rep PartitionName = D1 (MetaData "PartitionName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 PartitionName 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 a0) Cursor

Methods

cursor :: Lens' (EventStreamBatch a0) Cursor

type Rep Cursor

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

newtype ApplicationName

Type for application names.

Constructors

ApplicationName 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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "ApplicationName" PrefixI True) (S1 (MetaSel (Just Symbol "unApplicationName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SubscriptionsListResponse

SubscriptionsListResponse

Constructors

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

data SubscriptionCursor

Type fo rsubscription cursors.

Constructors

SubscriptionCursor PartitionName CursorOffset EventTypeName Text

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

Methods

cursor :: Lens' (SubscriptionEventStreamBatch a0) SubscriptionCursor

type Rep SubscriptionCursor

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

newtype FlowId

A Flow ID.

Constructors

FlowId Text

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]

type Rep FlowId

type Rep FlowId = D1 (MetaData "FlowId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 PartitionName CursorOffset EventTypeName

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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "SubscriptionCursorWithoutToken" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 PartitionName)) ((:*:) (S1 (MetaSel (Just Symbol "_offset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 CursorOffset)) (S1 (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 EventTypeName)))))

newtype SubscriptionCursorCommit

Type for commit object for subscription cursor committing.

Constructors

SubscriptionCursorCommit [SubscriptionCursor]

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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 [Cursor]

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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "CursorCommit" PrefixI True) (S1 (MetaSel (Just Symbol "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Cursor])))

newtype SubscriptionId

Type for subscription IDs.

Constructors

SubscriptionId 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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "SubscriptionId" PrefixI True) (S1 (MetaSel (Just Symbol "unSubscriptionId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UUID)))

newtype StreamId

Type for stream IDs.

Constructors

StreamId Text

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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "StreamId" PrefixI True) (S1 (MetaSel (Just Symbol "unStreamId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SubscriptionEventStream

SubscriptionEventStream

Constructors

SubscriptionEventStream StreamId 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 UTCTime

Instances

Eq Timestamp

Methods

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

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

Ord Timestamp

Methods

compare :: Timestamp -> Timestamp -> Ordering

(<) :: Timestamp -> Timestamp -> Bool

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

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

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

max :: Timestamp -> Timestamp -> Timestamp

min :: Timestamp -> Timestamp -> Timestamp

Show Timestamp

Methods

showsPrec :: Int -> Timestamp -> ShowS

show :: Timestamp -> String

showList :: [Timestamp] -> ShowS

Generic Timestamp

Associated Types

type Rep Timestamp :: * -> *

Methods

from :: Timestamp -> Rep Timestamp x

to :: Rep Timestamp x -> Timestamp

Hashable Timestamp

Methods

hashWithSalt :: Int -> Timestamp -> Int

hash :: Timestamp -> Int

ToJSON Timestamp

Methods

toJSON :: Timestamp -> Value

toEncoding :: Timestamp -> Encoding

toJSONList :: [Timestamp] -> Value

toEncodingList :: [Timestamp] -> Encoding

FromJSON Timestamp

Methods

parseJSON :: Value -> Parser Timestamp

parseJSONList :: Value -> Parser [Timestamp]

HasNakadiOccurredAt Metadata Timestamp

Methods

occurredAt :: Lens' Metadata Timestamp

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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "Timestamp" PrefixI True) (S1 (MetaSel (Just Symbol "unTimestamp") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UTCTime)))

data Metadata

Metadata

Constructors

Metadata Text Timestamp [Text] (Maybe Text)

Instances

Eq Metadata

Methods

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

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

Show Metadata

Methods

showsPrec :: Int -> Metadata -> ShowS

show :: Metadata -> String

showList :: [Metadata] -> ShowS

Generic Metadata

Associated Types

type Rep Metadata :: * -> *

Methods

from :: Metadata -> Rep Metadata x

to :: Rep Metadata x -> Metadata

ToJSON Metadata

Methods

toJSON :: Metadata -> Value

toEncoding :: Metadata -> Encoding

toJSONList :: [Metadata] -> Value

toEncodingList :: [Metadata] -> Encoding

FromJSON Metadata

Methods

parseJSON :: Value -> Parser Metadata

parseJSONList :: Value -> Parser [Metadata]

HasNakadiOccurredAt Metadata Timestamp

Methods

occurredAt :: Lens' Metadata Timestamp

HasNakadiEid Metadata Text

Methods

eid :: Lens' Metadata Text

HasNakadiPartition Metadata (Maybe Text)

Methods

partition :: Lens' Metadata (Maybe Text)

HasNakadiParentEids Metadata [Text]

Methods

parentEids :: Lens' Metadata [Text]

HasNakadiMetadata (Event a0) Metadata

Methods

metadata :: Lens' (Event a0) Metadata

type Rep Metadata

type Rep Metadata = D1 (MetaData "Metadata" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "Metadata" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_occurredAt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Timestamp))) ((:*:) (S1 (MetaSel (Just Symbol "_parentEids") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Text])) (S1 (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Text))))))

data Event a

Event

Constructors

Event a Metadata

Instances

Eq a => Eq (Event a)

Methods

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

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

Show a => Show (Event a)

Methods

showsPrec :: Int -> Event a -> ShowS

show :: Event a -> String

showList :: [Event a] -> ShowS

Generic (Event a)

Associated Types

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

Methods

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

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

ToJSON a0 => ToJSON (Event a0)

Methods

toJSON :: Event a0 -> Value

toEncoding :: Event a0 -> Encoding

toJSONList :: [Event a0] -> Value

toEncodingList :: [Event a0] -> Encoding

FromJSON a0 => FromJSON (Event a0)

Methods

parseJSON :: Value -> Parser (Event a0)

parseJSONList :: Value -> Parser [Event a0]

HasNakadiPayload (Event a0) a0

Methods

payload :: Lens' (Event a0) a0

HasNakadiMetadata (Event a0) Metadata

Methods

metadata :: Lens' (Event a0) Metadata

HasNakadiEvents (EventStreamBatch a0) (Maybe (Vector (Event a0)))

Methods

events :: Lens' (EventStreamBatch a0) (Maybe (Vector (Event a0)))

HasNakadiEvents (SubscriptionEventStreamBatch a0) (Maybe (Vector (Event a0)))

Methods

events :: Lens' (SubscriptionEventStreamBatch a0) (Maybe (Vector (Event a0)))

type Rep (Event a)

type Rep (Event a) = D1 (MetaData "Event" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "Event" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 a)) (S1 (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Metadata))))

data EventStreamBatch a

EventStreamBatch

Constructors

EventStreamBatch Cursor (Maybe (Vector (Event a)))

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 a0 => ToJSON (EventStreamBatch a0)

Methods

toJSON :: EventStreamBatch a0 -> Value

toEncoding :: EventStreamBatch a0 -> Encoding

toJSONList :: [EventStreamBatch a0] -> Value

toEncodingList :: [EventStreamBatch a0] -> Encoding

FromJSON a0 => FromJSON (EventStreamBatch a0)

Methods

parseJSON :: Value -> Parser (EventStreamBatch a0)

parseJSONList :: Value -> Parser [EventStreamBatch a0]

HasNakadiCursor (EventStreamBatch a0) Cursor

Methods

cursor :: Lens' (EventStreamBatch a0) Cursor

HasNakadiEvents (EventStreamBatch a0) (Maybe (Vector (Event a0)))

Methods

events :: Lens' (EventStreamBatch a0) (Maybe (Vector (Event a0)))

type Rep (EventStreamBatch a)

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

data SubscriptionEventStreamBatch a

SubscriptionEventStreamBatch

Constructors

SubscriptionEventStreamBatch SubscriptionCursor (Maybe (Vector (Event a)))

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 a0 => ToJSON (SubscriptionEventStreamBatch a0)

Methods

toJSON :: SubscriptionEventStreamBatch a0 -> Value

toEncoding :: SubscriptionEventStreamBatch a0 -> Encoding

toJSONList :: [SubscriptionEventStreamBatch a0] -> Value

toEncodingList :: [SubscriptionEventStreamBatch a0] -> Encoding

FromJSON a0 => FromJSON (SubscriptionEventStreamBatch a0)

Methods

parseJSON :: Value -> Parser (SubscriptionEventStreamBatch a0)

parseJSONList :: Value -> Parser [SubscriptionEventStreamBatch a0]

HasNakadiSubscriptionCursor (SubscriptionEventStreamBatch a)

Methods

subscriptionCursor :: Getter (SubscriptionEventStreamBatch a) SubscriptionCursor

HasNakadiCursor (SubscriptionEventStreamBatch a0) SubscriptionCursor

Methods

cursor :: Lens' (SubscriptionEventStreamBatch a0) SubscriptionCursor

HasNakadiEvents (SubscriptionEventStreamBatch a0) (Maybe (Vector (Event a0)))

Methods

events :: Lens' (SubscriptionEventStreamBatch a0) (Maybe (Vector (Event a0)))

type Rep (SubscriptionEventStreamBatch a)

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

newtype EventId

ID of an Event

Constructors

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

HasNakadiId EventId UUID

Methods

id :: Lens' EventId UUID

type Rep EventId

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

data Partition

Partition Data

Constructors

Partition CursorOffset CursorOffset PartitionName (Maybe Int64)

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 PartitionName CursorOffset Int64

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 Cursor 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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "CursorDistanceQuery" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_initialCursor") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Cursor)) (S1 (MetaSel (Just Symbol "_finalCursor") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Cursor))))

newtype CursorDistanceResult

Type for results of cursor-distance-queries.

Constructors

CursorDistanceResult 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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 (Maybe SubscriptionId) ApplicationName [EventTypeName] (Maybe Text) (Maybe Timestamp) (Maybe SubscriptionPosition) (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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "Subscription" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_id") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe SubscriptionId))) ((:*:) (S1 (MetaSel (Just Symbol "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ApplicationName)) (S1 (MetaSel (Just Symbol "_eventTypes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [EventTypeName])))) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_consumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Text))) (S1 (MetaSel (Just Symbol "_createdAt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Timestamp)))) ((:*:) (S1 (MetaSel (Just Symbol "_readFrom") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe SubscriptionPosition))) (S1 (MetaSel (Just Symbol "_initialCursors") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 (Maybe EventId) PublishingStatus (Maybe Step) (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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "BatchItemResponse" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe EventId))) (S1 (MetaSel (Just Symbol "_publishingStatus") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 PublishingStatus))) ((:*:) (S1 (MetaSel (Just Symbol "_step") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Step))) (S1 (MetaSel (Just Symbol "_detail") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Text))))))

newtype StreamKeepAliveLimit

StreamKeepAliveLimit

Constructors

StreamKeepAliveLimit 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 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 SubscriptionCursor 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]

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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "SchemaTypeJson" PrefixI False) U1)

data EventTypeSchema

Type for the schema of an event type.

Constructors

EventTypeSchema (Maybe SchemaVersion) (Maybe Timestamp) SchemaType 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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "EventTypeSchema" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_version") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe SchemaVersion))) (S1 (MetaSel (Just Symbol "_createdAt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Timestamp)))) ((:*:) (S1 (MetaSel (Just Symbol "_schemaType") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SchemaType)) (S1 (MetaSel (Just Symbol "_schema") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))))

newtype PaginationLink

PaginationLink

Constructors

PaginationLink 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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "PaginationLink" PrefixI True) (S1 (MetaSel (Just Symbol "_href") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data PaginationLinks

PaginationLinks

Constructors

PaginationLinks (Maybe PaginationLink) (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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "PaginationLinks" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_prev") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe PaginationLink))) (S1 (MetaSel (Just Symbol "_next") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe PaginationLink)))))

data EventTypeSchemasResponse

EventTypeSchemasResponse

Constructors

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

newtype SchemaVersion

Type for the version of a schema.

Constructors

SchemaVersion 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 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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "SchemaVersion" PrefixI True) (S1 (MetaSel (Just Symbol "unSchemaVersion") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype Offset

Type for offset values.

Constructors

Offset Int64

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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "Offset" PrefixI True) (S1 (MetaSel (Just Symbol "unOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

newtype Limit

Type for limit values.

Constructors

Limit Int64

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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 PartitionName PartitionState Int64 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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "PartitionStat" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_partition") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 PartitionName)) (S1 (MetaSel (Just Symbol "_state") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 PartitionState))) ((:*:) (S1 (MetaSel (Just Symbol "_unconsumedEvents") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)) (S1 (MetaSel (Just Symbol "_streamId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 StreamId)))))

data SubscriptionEventTypeStats

Nakadi type SubscriptionEventTypeStats.

Constructors

SubscriptionEventTypeStats EventTypeName [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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "SubscriptionEventTypeStats" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 EventTypeName)) (S1 (MetaSel (Just Symbol "_partitions") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [PartitionStat]))))

newtype SubscriptionEventTypeStatsResult

SubscriptionEventTypeStatsResult

Constructors

SubscriptionEventTypeStatsResult [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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 DecidedLazy) (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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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.2.0.1-5yLFsgfwCKJDJaD007lc44" 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 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.2.0.1-5yLFsgfwCKJDJaD007lc44" True) (C1 (MetaCons "PartitionKeyField" PrefixI True) (S1 (MetaSel (Just Symbol "unPartitionKeyField") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data EventType

EventType

Constructors

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

data DataChangeEvent a

DataChangeEvent

Constructors

DataChangeEvent a Metadata Text 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 a0 => ToJSON (DataChangeEvent a0)

Methods

toJSON :: DataChangeEvent a0 -> Value

toEncoding :: DataChangeEvent a0 -> Encoding

toJSONList :: [DataChangeEvent a0] -> Value

toEncodingList :: [DataChangeEvent a0] -> Encoding

FromJSON a0 => FromJSON (DataChangeEvent a0)

Methods

parseJSON :: Value -> Parser (DataChangeEvent a0)

parseJSONList :: Value -> Parser [DataChangeEvent a0]

type Rep (DataChangeEvent a)

type Rep (DataChangeEvent a) = D1 (MetaData "DataChangeEvent" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "DataChangeEvent" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 a)) (S1 (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Metadata))) ((:*:) (S1 (MetaSel (Just Symbol "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)) (S1 (MetaSel (Just Symbol "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (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 EventEnriched a

Type of enriched event.

Constructors

EventEnriched a MetadataEnriched

Instances

Eq a => Eq (EventEnriched a)

Methods

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

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

Show a => Show (EventEnriched a)

Methods

showsPrec :: Int -> EventEnriched a -> ShowS

show :: EventEnriched a -> String

showList :: [EventEnriched a] -> ShowS

Generic (EventEnriched a)

Associated Types

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

Methods

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

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

ToJSON a0 => ToJSON (EventEnriched a0)

Methods

toJSON :: EventEnriched a0 -> Value

toEncoding :: EventEnriched a0 -> Encoding

toJSONList :: [EventEnriched a0] -> Value

toEncodingList :: [EventEnriched a0] -> Encoding

FromJSON a0 => FromJSON (EventEnriched a0)

Methods

parseJSON :: Value -> Parser (EventEnriched a0)

parseJSONList :: Value -> Parser [EventEnriched a0]

type Rep (EventEnriched a)

type Rep (EventEnriched a) = D1 (MetaData "EventEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "EventEnriched" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "_payload") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 a)) (S1 (MetaSel (Just Symbol "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 MetadataEnriched))))

data MetadataEnriched

Type of enriched metadata values.

Constructors

MetadataEnriched Text EventTypeName Timestamp Timestamp SchemaVersion [Text]

Instances

Eq MetadataEnriched

Methods

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

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

Show MetadataEnriched

Methods

showsPrec :: Int -> MetadataEnriched -> ShowS

show :: MetadataEnriched -> String

showList :: [MetadataEnriched] -> ShowS

Generic MetadataEnriched

Associated Types

type Rep MetadataEnriched :: * -> *

Methods

from :: MetadataEnriched -> Rep MetadataEnriched x

to :: Rep MetadataEnriched x -> MetadataEnriched

ToJSON MetadataEnriched

Methods

toJSON :: MetadataEnriched -> Value

toEncoding :: MetadataEnriched -> Encoding

toJSONList :: [MetadataEnriched] -> Value

toEncodingList :: [MetadataEnriched] -> Encoding

FromJSON MetadataEnriched

Methods

parseJSON :: Value -> Parser MetadataEnriched

parseJSONList :: Value -> Parser [MetadataEnriched]

type Rep MetadataEnriched

type Rep MetadataEnriched = D1 (MetaData "MetadataEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "MetadataEnriched" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_eid") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)) ((:*:) (S1 (MetaSel (Just Symbol "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 EventTypeName)) (S1 (MetaSel (Just Symbol "_occurredAt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Timestamp)))) ((:*:) (S1 (MetaSel (Just Symbol "_receivedAt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Timestamp)) ((:*:) (S1 (MetaSel (Just Symbol "_version") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SchemaVersion)) (S1 (MetaSel (Just Symbol "_parentEids") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Text]))))))

data EventTypeStatistics

Type for event type statistics.

Constructors

EventTypeStatistics Int64 Int64 Int64 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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "EventTypeStatistics" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "_messagesPerMinute") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)) (S1 (MetaSel (Just Symbol "_messageSize") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64))) ((:*:) (S1 (MetaSel (Just Symbol "_readParallelism") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)) (S1 (MetaSel (Just Symbol "_writeParallelism") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))))

data EventTypeOptions

Type for event type options.

Constructors

EventTypeOptions 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.2.0.1-5yLFsgfwCKJDJaD007lc44" False) (C1 (MetaCons "EventTypeOptions" PrefixI True) (S1 (MetaSel (Just Symbol "_retentionTime") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))