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

Network.Nakadi.Types.Service

Description

This module provides the Nakadi Service Types.

Synopsis

newtype CursorOffset = CursorOffset {
- unCursorOffset :: Text
}
newtype EventTypeName = EventTypeName {
- unEventTypeName :: Text
}
newtype PartitionName = PartitionName {
- unPartitionName :: Text
}
newtype PartitionCompactionKey = PartitionCompactionKey {
- unPartitionCompactionKey :: Text
}
newtype CursorToken = CursorToken Text
data Cursor = Cursor {
- _partition :: PartitionName
- _offset :: CursorOffset
}
newtype ApplicationName = ApplicationName {
- unApplicationName :: Text
}
data SubscriptionsListResponse = SubscriptionsListResponse {
- _links :: PaginationLinks
- _items :: [Subscription]
}
data SubscriptionCursor = SubscriptionCursor {
- _partition :: PartitionName
- _offset :: CursorOffset
- _eventType :: EventTypeName
- _cursorToken :: Text
}
newtype FlowId = FlowId {
- unFlowId :: Text
}
data SubscriptionCursorWithoutToken = SubscriptionCursorWithoutToken {
- _partition :: PartitionName
- _offset :: CursorOffset
- _eventType :: EventTypeName
}
newtype SubscriptionCursorCommit = SubscriptionCursorCommit {
- _items :: [SubscriptionCursor]
}
newtype CursorCommit = CursorCommit {
- _items :: [Cursor]
}
newtype SubscriptionId = SubscriptionId {
- unSubscriptionId :: UUID
}
newtype StreamId = StreamId {
- unStreamId :: Text
}
data SubscriptionEventStream = SubscriptionEventStream {
- _streamId :: StreamId
- _subscriptionId :: SubscriptionId
}
newtype Timestamp = Timestamp {
- unTimestamp :: UTCTime
}
data SubscriptionEventStreamBatch a = SubscriptionEventStreamBatch {
- _cursor :: SubscriptionCursor
- _events :: Maybe (Vector a)
}
newtype EventId = EventId {
- unEventId :: UUID
}
data Partition = Partition {
- _oldestAvailableOffset :: CursorOffset
- _newestAvailableOffset :: CursorOffset
- _partition :: PartitionName
- _unconsumedEvents :: Maybe Int64
}
data ShiftedCursor = ShiftedCursor {
- _partition :: PartitionName
- _offset :: CursorOffset
- _shift :: Int64
}
data CursorDistanceQuery = CursorDistanceQuery {
- _initialCursor :: Cursor
- _finalCursor :: Cursor
}
newtype CursorDistanceResult = CursorDistanceResult {
- _distance :: Int64
}
data SubscriptionPosition
- = SubscriptionPositionBegin
- | SubscriptionPositionEnd
- | SubscriptionPositionCursors [SubscriptionCursorWithoutToken]
data Subscription = Subscription {
- _id :: SubscriptionId
- _owningApplication :: ApplicationName
- _eventTypes :: [EventTypeName]
- _consumerGroup :: ConsumerGroup
- _createdAt :: Timestamp
- _subscriptionPosition :: SubscriptionPosition
}
data SubscriptionRequest = SubscriptionRequest {
- _owningApplication :: ApplicationName
- _eventTypes :: [EventTypeName]
- _consumerGroup :: Maybe ConsumerGroup
- _subscriptionPosition :: Maybe SubscriptionPosition
}
newtype ConsumerGroup = ConsumerGroup {
- unConsumerGroup :: Text
}
data PublishingStatus
- = PublishingStatusSubmitted
- | PublishingStatusFailed
- | PublishingStatusAborted
data Step
- = StepNone
- | StepValidating
- | StepPartitioning
- | StepEnriching
- | StepPublishing
data BatchItemResponse = BatchItemResponse {
- _eid :: Maybe EventId
- _publishingStatus :: PublishingStatus
- _step :: Maybe Step
- _detail :: Maybe Text
}
newtype StreamKeepAliveLimit = StreamKeepAliveLimit {
- unStreamKeepAliveLimit :: Int32
}
newtype BatchFlushTimeout = BatchFlushTimeout {
- unBatchFlushTimeout :: Int32
}
data CursorCommitResultType
- = CursorCommitResultCommitted
- | CursorCommitResultOutdated
data CursorCommitResult = CursorCommitResult {
- _cursor :: SubscriptionCursor
- _result :: CursorCommitResultType
}
newtype CursorCommitResults = CursorCommitResults {
- _items :: [CursorCommitResult]
}
data SchemaType = SchemaTypeJson
data EventTypeSchema = EventTypeSchema {
- _version :: Maybe SchemaVersion
- _createdAt :: Maybe Timestamp
- _schemaType :: SchemaType
- _schema :: Text
}
newtype PaginationLink = PaginationLink {
- _href :: Text
}
data PaginationLinks = PaginationLinks {
- _prev :: Maybe PaginationLink
- _next :: Maybe PaginationLink
}
data EventTypeSchemasResponse = EventTypeSchemasResponse {
- _links :: PaginationLinks
- _items :: [EventTypeSchema]
}
newtype SchemaVersion = SchemaVersion {
- unSchemaVersion :: Text
}
newtype Offset = Offset {
- unOffset :: Int64
}
newtype Limit = Limit {
- unLimit :: Int64
}
data PartitionState
- = PartitionStateUnassigned
- | PartitionStateReassigning
- | PartitionStateAssigned
data PartitionStat = PartitionStat {
- _partition :: PartitionName
- _state :: PartitionState
- _unconsumedEvents :: Maybe Int64
- _streamId :: Maybe StreamId
- _consumerLagSeconds :: Maybe Int64
}
data SubscriptionEventTypeStats = SubscriptionEventTypeStats {
- _eventType :: EventTypeName
- _partitions :: [PartitionStat]
}
newtype SubscriptionStats = SubscriptionStats {
- _items :: [SubscriptionEventTypeStats]
}
data EventTypeCategory
- = EventTypeCategoryUndefined
- | EventTypeCategoryData
- | EventTypeCategoryBusiness
data PartitionStrategy
- = PartitionStrategyRandom
- | PartitionStrategyUser
- | PartitionStrategyHash
- | PartitionStrategyCustom Text
data EnrichmentStrategy = EnrichmentStrategyMetadata
data CompatibilityMode
- = CompatibilityModeCompatible
- | CompatibilityModeForward
- | CompatibilityModeNone
data CleanupPolicy
- = CleanupPolicyDelete
- | CleanupPolicyCompact
newtype PartitionKeyField = PartitionKeyField {
- unPartitionKeyField :: Text
}
data EventType = EventType {
- _name :: EventTypeName
- _owningApplication :: Maybe ApplicationName
- _category :: Maybe EventTypeCategory
- _enrichmentStrategies :: Maybe [EnrichmentStrategy]
- _partitionStrategy :: Maybe PartitionStrategy
- _compatibilityMode :: Maybe CompatibilityMode
- _schema :: EventTypeSchema
- _partitionKeyFields :: Maybe [PartitionKeyField]
- _cleanupPolicy :: Maybe CleanupPolicy
- _defaultStatistic :: Maybe EventTypeStatistics
- _options :: Maybe EventTypeOptions
}
data DataChangeEvent a = DataChangeEvent {
- _payload :: a
- _metadata :: EventMetadata
- _dataType :: Text
- _dataOp :: DataOp
}
data DataChangeEventEnriched a = DataChangeEventEnriched {
- _payload :: a
- _metadata :: EventMetadataEnriched
- _dataType :: Text
- _dataOp :: DataOp
}
data BusinessEvent a = BusinessEvent {
- _payload :: a
- _metadata :: EventMetadata
}
data BusinessEventEnriched a = BusinessEventEnriched {
- _payload :: a
- _metadata :: EventMetadataEnriched
}
data DataOp
- = DataOpCreation
- | DataOpUpdate
- | DataOpDeletion
- | DataOpSnapshot
data EventMetadata = EventMetadata {
- _eid :: EventId
- _occurredAt :: Timestamp
- _parentEids :: Maybe [EventId]
- _partition :: Maybe PartitionName
- _partitionCompactionKey :: Maybe PartitionCompactionKey
}
data EventMetadataEnriched = EventMetadataEnriched {
- _eid :: EventId
- _eventType :: EventTypeName
- _occurredAt :: Timestamp
- _receivedAt :: Timestamp
- _version :: SchemaVersion
- _parentEids :: Maybe [EventId]
- _flowId :: Maybe FlowId
- _partition :: Maybe PartitionName
- _partitionCompactionKey :: Maybe PartitionCompactionKey
}
data EventTypeStatistics = EventTypeStatistics {
- _messagesPerMinute :: Int64
- _messageSize :: Int64
- _readParallelism :: Int64
- _writeParallelism :: Int64
}
data EventTypeOptions = EventTypeOptions {
- _retentionTime :: Int64
}

Documentation

newtype CursorOffset Source #

Type for cursor offsets.

Constructors

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

Instances

Eq CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: CursorOffset -> CursorOffset -> Bool # (/=) :: CursorOffset -> CursorOffset -> Bool #
Ord CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: CursorOffset -> CursorOffset -> Ordering # (<) :: CursorOffset -> CursorOffset -> Bool # (<=) :: CursorOffset -> CursorOffset -> Bool # (>) :: CursorOffset -> CursorOffset -> Bool # (>=) :: CursorOffset -> CursorOffset -> Bool # max :: CursorOffset -> CursorOffset -> CursorOffset # min :: CursorOffset -> CursorOffset -> CursorOffset #
Show CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> CursorOffset -> ShowS # show :: CursorOffset -> String # showList :: [CursorOffset] -> ShowS #
IsString CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods fromString :: String -> CursorOffset #
Generic CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep CursorOffset :: Type -> Type # Methods from :: CursorOffset -> Rep CursorOffset x # to :: Rep CursorOffset x -> CursorOffset #
Hashable CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> CursorOffset -> Int # hash :: CursorOffset -> Int #
ToJSON CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: CursorOffset -> Value # toEncoding :: CursorOffset -> Encoding # toJSONList :: [CursorOffset] -> Value # toEncodingList :: [CursorOffset] -> Encoding #
FromJSON CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser CursorOffset # parseJSONList :: Value -> Parser [CursorOffset] #
HasNakadiOffset Cursor CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods offset :: Lens' Cursor CursorOffset
HasNakadiOffset SubscriptionCursor CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods offset :: Lens' SubscriptionCursor CursorOffset
HasNakadiOldestAvailableOffset Partition CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods oldestAvailableOffset :: Lens' Partition CursorOffset
HasNakadiNewestAvailableOffset Partition CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods newestAvailableOffset :: Lens' Partition CursorOffset
type Rep CursorOffset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep CursorOffset = D1 (MetaData "CursorOffset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "CursorOffset" PrefixI True) (S1 (MetaSel (Just "unCursorOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype EventTypeName Source #

Type for event type names.

Constructors

EventTypeName
Fields unEventTypeName :: Text Wrapped Event Type Name

Instances

Eq EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventTypeName -> EventTypeName -> Bool # (/=) :: EventTypeName -> EventTypeName -> Bool #
Ord EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: EventTypeName -> EventTypeName -> Ordering # (<) :: EventTypeName -> EventTypeName -> Bool # (<=) :: EventTypeName -> EventTypeName -> Bool # (>) :: EventTypeName -> EventTypeName -> Bool # (>=) :: EventTypeName -> EventTypeName -> Bool # max :: EventTypeName -> EventTypeName -> EventTypeName # min :: EventTypeName -> EventTypeName -> EventTypeName #
Show EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventTypeName -> ShowS # show :: EventTypeName -> String # showList :: [EventTypeName] -> ShowS #
IsString EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods fromString :: String -> EventTypeName #
Generic EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventTypeName :: Type -> Type # Methods from :: EventTypeName -> Rep EventTypeName x # to :: Rep EventTypeName x -> EventTypeName #
Hashable EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> EventTypeName -> Int # hash :: EventTypeName -> Int #
ToJSON EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventTypeName -> Value # toEncoding :: EventTypeName -> Encoding # toJSONList :: [EventTypeName] -> Value # toEncodingList :: [EventTypeName] -> Encoding #
FromJSON EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventTypeName # parseJSONList :: Value -> Parser [EventTypeName] #
HasNakadiEventType SubscriptionCursor EventTypeName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eventType :: Lens' SubscriptionCursor EventTypeName
HasNakadiEventType EventMetadataEnriched EventTypeName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eventType :: Lens' EventMetadataEnriched EventTypeName
HasNakadiName EventType EventTypeName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods name :: Lens' EventType EventTypeName
HasNakadiEventTypes SubscriptionRequest [EventTypeName]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eventTypes :: Lens' SubscriptionRequest [EventTypeName]
HasNakadiEventTypes Subscription [EventTypeName]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eventTypes :: Lens' Subscription [EventTypeName]
HasNakadiPartitionIndexMap (WorkerRegistry a) PartitionIndexMap
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionIndexMap :: Lens' (WorkerRegistry a) PartitionIndexMap
type Rep EventTypeName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventTypeName = D1 (MetaData "EventTypeName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "EventTypeName" PrefixI True) (S1 (MetaSel (Just "unEventTypeName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype PartitionName Source #

Type for partition names.

Constructors

PartitionName
Fields unPartitionName :: Text Wrapped Partition Name

Instances

Eq PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: PartitionName -> PartitionName -> Bool # (/=) :: PartitionName -> PartitionName -> Bool #
Ord PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: PartitionName -> PartitionName -> Ordering # (<) :: PartitionName -> PartitionName -> Bool # (<=) :: PartitionName -> PartitionName -> Bool # (>) :: PartitionName -> PartitionName -> Bool # (>=) :: PartitionName -> PartitionName -> Bool # max :: PartitionName -> PartitionName -> PartitionName # min :: PartitionName -> PartitionName -> PartitionName #
Show PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> PartitionName -> ShowS # show :: PartitionName -> String # showList :: [PartitionName] -> ShowS #
IsString PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods fromString :: String -> PartitionName #
Generic PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep PartitionName :: Type -> Type # Methods from :: PartitionName -> Rep PartitionName x # to :: Rep PartitionName x -> PartitionName #
Hashable PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> PartitionName -> Int # hash :: PartitionName -> Int #
ToJSON PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: PartitionName -> Value # toEncoding :: PartitionName -> Encoding # toJSONList :: [PartitionName] -> Value # toEncodingList :: [PartitionName] -> Encoding #
FromJSON PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser PartitionName # parseJSONList :: Value -> Parser [PartitionName] #
HasNakadiPartition Cursor PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' Cursor PartitionName
HasNakadiPartition SubscriptionCursor PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' SubscriptionCursor PartitionName
HasNakadiPartition Partition PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' Partition PartitionName
HasNakadiPartition PartitionStat PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' PartitionStat PartitionName
HasNakadiPartition EventMetadata (Maybe PartitionName)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' EventMetadata (Maybe PartitionName)
HasNakadiPartition EventMetadataEnriched (Maybe PartitionName)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' EventMetadataEnriched (Maybe PartitionName)
HasNakadiPartitionIndexMap (WorkerRegistry a) PartitionIndexMap
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionIndexMap :: Lens' (WorkerRegistry a) PartitionIndexMap
type Rep PartitionName Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep PartitionName = D1 (MetaData "PartitionName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "PartitionName" PrefixI True) (S1 (MetaSel (Just "unPartitionName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype PartitionCompactionKey Source #

Type for partition compaction keys.

Constructors

PartitionCompactionKey
Fields unPartitionCompactionKey :: Text Wrapped Partition Compaction Key

Instances

Eq PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: PartitionCompactionKey -> PartitionCompactionKey -> Bool # (/=) :: PartitionCompactionKey -> PartitionCompactionKey -> Bool #
Ord PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: PartitionCompactionKey -> PartitionCompactionKey -> Ordering # (<) :: PartitionCompactionKey -> PartitionCompactionKey -> Bool # (<=) :: PartitionCompactionKey -> PartitionCompactionKey -> Bool # (>) :: PartitionCompactionKey -> PartitionCompactionKey -> Bool # (>=) :: PartitionCompactionKey -> PartitionCompactionKey -> Bool # max :: PartitionCompactionKey -> PartitionCompactionKey -> PartitionCompactionKey # min :: PartitionCompactionKey -> PartitionCompactionKey -> PartitionCompactionKey #
Show PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> PartitionCompactionKey -> ShowS # show :: PartitionCompactionKey -> String # showList :: [PartitionCompactionKey] -> ShowS #
IsString PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods fromString :: String -> PartitionCompactionKey #
Generic PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep PartitionCompactionKey :: Type -> Type # Methods from :: PartitionCompactionKey -> Rep PartitionCompactionKey x # to :: Rep PartitionCompactionKey x -> PartitionCompactionKey #
Hashable PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> PartitionCompactionKey -> Int # hash :: PartitionCompactionKey -> Int #
ToJSON PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: PartitionCompactionKey -> Value # toEncoding :: PartitionCompactionKey -> Encoding # toJSONList :: [PartitionCompactionKey] -> Value # toEncodingList :: [PartitionCompactionKey] -> Encoding #
FromJSON PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser PartitionCompactionKey # parseJSONList :: Value -> Parser [PartitionCompactionKey] #
HasNakadiPartitionCompactionKey EventMetadata (Maybe PartitionCompactionKey)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionCompactionKey :: Lens' EventMetadata (Maybe PartitionCompactionKey)
HasNakadiPartitionCompactionKey EventMetadataEnriched (Maybe PartitionCompactionKey)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionCompactionKey :: Lens' EventMetadataEnriched (Maybe PartitionCompactionKey)
type Rep PartitionCompactionKey Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep PartitionCompactionKey = D1 (MetaData "PartitionCompactionKey" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "PartitionCompactionKey" PrefixI True) (S1 (MetaSel (Just "unPartitionCompactionKey") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype CursorToken Source #

Type for cursor tokens.

Constructors

CursorToken Text

Instances

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

data Cursor Source #

Type for cursors.

Constructors

Cursor
Fields _partition :: PartitionName _offset :: CursorOffset

Instances

Eq Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: Cursor -> Cursor -> Bool # (/=) :: Cursor -> Cursor -> Bool #
Ord Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: Cursor -> Cursor -> Ordering # (<) :: Cursor -> Cursor -> Bool # (<=) :: Cursor -> Cursor -> Bool # (>) :: Cursor -> Cursor -> Bool # (>=) :: Cursor -> Cursor -> Bool # max :: Cursor -> Cursor -> Cursor # min :: Cursor -> Cursor -> Cursor #
Show Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> Cursor -> ShowS # show :: Cursor -> String # showList :: [Cursor] -> ShowS #
Generic Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep Cursor :: Type -> Type # Methods from :: Cursor -> Rep Cursor x # to :: Rep Cursor x -> Cursor #
Hashable Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> Cursor -> Int # hash :: Cursor -> Int #
ToJSON Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: Cursor -> Value # toEncoding :: Cursor -> Encoding # toJSONList :: [Cursor] -> Value # toEncodingList :: [Cursor] -> Encoding #
FromJSON Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser Cursor # parseJSONList :: Value -> Parser [Cursor] #
HasNakadiPartition Cursor PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' Cursor PartitionName
HasNakadiOffset Cursor CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods offset :: Lens' Cursor CursorOffset
HasNakadiInitialCursor CursorDistanceQuery Cursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods initialCursor :: Lens' CursorDistanceQuery Cursor
HasNakadiFinalCursor CursorDistanceQuery Cursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods finalCursor :: Lens' CursorDistanceQuery Cursor
HasNakadiItems CursorCommit [Cursor]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods items :: Lens' CursorCommit [Cursor]
type Rep Cursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep Cursor = D1 (MetaData "Cursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "Cursor" PrefixI True) (S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :*: S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset)))

newtype ApplicationName Source #

Type for application names.

Constructors

ApplicationName
Fields unApplicationName :: Text

Instances

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

data SubscriptionsListResponse Source #

SubscriptionsListResponse

Constructors

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

Instances

Eq SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (/=) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool #
Ord SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionsListResponse -> SubscriptionsListResponse -> Ordering # (<) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (<=) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (>) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # (>=) :: SubscriptionsListResponse -> SubscriptionsListResponse -> Bool # max :: SubscriptionsListResponse -> SubscriptionsListResponse -> SubscriptionsListResponse # min :: SubscriptionsListResponse -> SubscriptionsListResponse -> SubscriptionsListResponse #
Show SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionsListResponse -> ShowS # show :: SubscriptionsListResponse -> String # showList :: [SubscriptionsListResponse] -> ShowS #
Generic SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionsListResponse :: Type -> Type # Methods from :: SubscriptionsListResponse -> Rep SubscriptionsListResponse x # to :: Rep SubscriptionsListResponse x -> SubscriptionsListResponse #
Hashable SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> SubscriptionsListResponse -> Int # hash :: SubscriptionsListResponse -> Int #
ToJSON SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionsListResponse -> Value # toEncoding :: SubscriptionsListResponse -> Encoding # toJSONList :: [SubscriptionsListResponse] -> Value # toEncodingList :: [SubscriptionsListResponse] -> Encoding #
FromJSON SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionsListResponse # parseJSONList :: Value -> Parser [SubscriptionsListResponse] #
HasNakadiLinks SubscriptionsListResponse PaginationLinks
Instance details Defined in Network.Nakadi.Internal.Lenses Methods links :: Lens' SubscriptionsListResponse PaginationLinks
HasNakadiItems SubscriptionsListResponse [Subscription]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods items :: Lens' SubscriptionsListResponse [Subscription]
type Rep SubscriptionsListResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionsListResponse = D1 (MetaData "SubscriptionsListResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "SubscriptionsListResponse" PrefixI True) (S1 (MetaSel (Just "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PaginationLinks) :*: S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [Subscription])))

data SubscriptionCursor Source #

Type fo rsubscription cursors.

Constructors

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

Instances

Eq SubscriptionCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (/=) :: SubscriptionCursor -> SubscriptionCursor -> Bool #
Ord SubscriptionCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionCursor -> SubscriptionCursor -> Ordering # (<) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (<=) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (>) :: SubscriptionCursor -> SubscriptionCursor -> Bool # (>=) :: SubscriptionCursor -> SubscriptionCursor -> Bool # max :: SubscriptionCursor -> SubscriptionCursor -> SubscriptionCursor # min :: SubscriptionCursor -> SubscriptionCursor -> SubscriptionCursor #
Show SubscriptionCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionCursor -> ShowS # show :: SubscriptionCursor -> String # showList :: [SubscriptionCursor] -> ShowS #
Generic SubscriptionCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionCursor :: Type -> Type # Methods from :: SubscriptionCursor -> Rep SubscriptionCursor x # to :: Rep SubscriptionCursor x -> SubscriptionCursor #
ToJSON SubscriptionCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionCursor -> Value # toEncoding :: SubscriptionCursor -> Encoding # toJSONList :: [SubscriptionCursor] -> Value # toEncodingList :: [SubscriptionCursor] -> Encoding #
FromJSON SubscriptionCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionCursor # parseJSONList :: Value -> Parser [SubscriptionCursor] #
HasNakadiSubscriptionCursor SubscriptionCursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionCursor :: Getter SubscriptionCursor SubscriptionCursor
HasNakadiPartition SubscriptionCursor PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' SubscriptionCursor PartitionName
HasNakadiOffset SubscriptionCursor CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods offset :: Lens' SubscriptionCursor CursorOffset
HasNakadiCursor SubscriptionCursorWithCounter SubscriptionCursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods cursor :: Lens' SubscriptionCursorWithCounter SubscriptionCursor
HasNakadiEventType SubscriptionCursor EventTypeName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eventType :: Lens' SubscriptionCursor EventTypeName
HasNakadiCursorToken SubscriptionCursor Text
Instance details Defined in Network.Nakadi.Internal.Lenses Methods cursorToken :: Lens' SubscriptionCursor Text
HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods items :: Lens' SubscriptionCursorCommit [SubscriptionCursor]
HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods cursor :: Lens' (SubscriptionEventStreamBatch a) SubscriptionCursor
type Rep SubscriptionCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionCursor = D1 (MetaData "SubscriptionCursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "SubscriptionCursor" PrefixI True) ((S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :: S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset)) :: (S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName) :*: S1 (MetaSel (Just "_cursorToken") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text))))

newtype FlowId Source #

A Flow ID.

Constructors

FlowId
Fields unFlowId :: Text Wrapped Flow ID

Instances

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

data SubscriptionCursorWithoutToken Source #

Type for subscription cursors without token.

Constructors

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

Instances

Eq SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (/=) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool #
Ord SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Ordering # (<) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (<=) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (>) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # (>=) :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> Bool # max :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken # min :: SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken -> SubscriptionCursorWithoutToken #
Show SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionCursorWithoutToken -> ShowS # show :: SubscriptionCursorWithoutToken -> String # showList :: [SubscriptionCursorWithoutToken] -> ShowS #
Generic SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionCursorWithoutToken :: Type -> Type # Methods from :: SubscriptionCursorWithoutToken -> Rep SubscriptionCursorWithoutToken x # to :: Rep SubscriptionCursorWithoutToken x -> SubscriptionCursorWithoutToken #
Hashable SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> SubscriptionCursorWithoutToken -> Int # hash :: SubscriptionCursorWithoutToken -> Int #
ToJSON SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionCursorWithoutToken -> Value # toEncoding :: SubscriptionCursorWithoutToken -> Encoding # toJSONList :: [SubscriptionCursorWithoutToken] -> Value # toEncodingList :: [SubscriptionCursorWithoutToken] -> Encoding #
FromJSON SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionCursorWithoutToken # parseJSONList :: Value -> Parser [SubscriptionCursorWithoutToken] #
type Rep SubscriptionCursorWithoutToken Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionCursorWithoutToken = D1 (MetaData "SubscriptionCursorWithoutToken" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "SubscriptionCursorWithoutToken" PrefixI True) (S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :: (S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset) :: S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName))))

newtype SubscriptionCursorCommit Source #

Type for commit object for subscription cursor committing.

Constructors

SubscriptionCursorCommit
Fields _items :: [SubscriptionCursor] List of cursors to commit

Instances

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

newtype CursorCommit Source #

Type for commit objects for cursor committing.

Constructors

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

Instances

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

newtype SubscriptionId Source #

Type for subscription IDs.

Constructors

SubscriptionId
Fields unSubscriptionId :: UUID Wrapped UUID

Instances

Eq SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionId -> SubscriptionId -> Bool # (/=) :: SubscriptionId -> SubscriptionId -> Bool #
Ord SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionId -> SubscriptionId -> Ordering # (<) :: SubscriptionId -> SubscriptionId -> Bool # (<=) :: SubscriptionId -> SubscriptionId -> Bool # (>) :: SubscriptionId -> SubscriptionId -> Bool # (>=) :: SubscriptionId -> SubscriptionId -> Bool # max :: SubscriptionId -> SubscriptionId -> SubscriptionId # min :: SubscriptionId -> SubscriptionId -> SubscriptionId #
Show SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionId -> ShowS # show :: SubscriptionId -> String # showList :: [SubscriptionId] -> ShowS #
Generic SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionId :: Type -> Type # Methods from :: SubscriptionId -> Rep SubscriptionId x # to :: Rep SubscriptionId x -> SubscriptionId #
Hashable SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> SubscriptionId -> Int # hash :: SubscriptionId -> Int #
ToJSON SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionId -> Value # toEncoding :: SubscriptionId -> Encoding # toJSONList :: [SubscriptionId] -> Value # toEncodingList :: [SubscriptionId] -> Encoding #
FromJSON SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionId # parseJSONList :: Value -> Parser [SubscriptionId] #
HasNakadiSubscriptionId SubscriptionEventStream SubscriptionId
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionId :: Lens' SubscriptionEventStream SubscriptionId
HasNakadiId SubscriptionId UUID
Instance details Defined in Network.Nakadi.Internal.Lenses Methods id :: Lens' SubscriptionId UUID
HasNakadiId Subscription SubscriptionId
Instance details Defined in Network.Nakadi.Internal.Lenses Methods id :: Lens' Subscription SubscriptionId
type Rep SubscriptionId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionId = D1 (MetaData "SubscriptionId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "SubscriptionId" PrefixI True) (S1 (MetaSel (Just "unSubscriptionId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UUID)))

newtype StreamId Source #

Type for stream IDs.

Constructors

StreamId
Fields unStreamId :: Text Wrapped Stream ID

Instances

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

data SubscriptionEventStream Source #

SubscriptionEventStream

Constructors

SubscriptionEventStream
Fields _streamId :: StreamId _subscriptionId :: SubscriptionId

Instances

Show SubscriptionEventStream Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionEventStream -> ShowS # show :: SubscriptionEventStream -> String # showList :: [SubscriptionEventStream] -> ShowS #
HasNakadiStreamId SubscriptionEventStream StreamId
Instance details Defined in Network.Nakadi.Internal.Lenses Methods streamId :: Lens' SubscriptionEventStream StreamId
HasNakadiSubscriptionId SubscriptionEventStream SubscriptionId
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionId :: Lens' SubscriptionEventStream SubscriptionId

newtype Timestamp Source #

Type for timestamps.

Constructors

Timestamp
Fields unTimestamp :: UTCTime Wrapped UTC Timestamp

Instances

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

data SubscriptionEventStreamBatch a Source #

SubscriptionEventStreamBatch

Constructors

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

Instances

Show a => Show (SubscriptionEventStreamBatch a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionEventStreamBatch a -> ShowS # show :: SubscriptionEventStreamBatch a -> String # showList :: [SubscriptionEventStreamBatch a] -> ShowS #
Generic (SubscriptionEventStreamBatch a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep (SubscriptionEventStreamBatch a) :: Type -> Type # Methods from :: SubscriptionEventStreamBatch a -> Rep (SubscriptionEventStreamBatch a) x # to :: Rep (SubscriptionEventStreamBatch a) x -> SubscriptionEventStreamBatch a #
ToJSON a => ToJSON (SubscriptionEventStreamBatch a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionEventStreamBatch a -> Value # toEncoding :: SubscriptionEventStreamBatch a -> Encoding # toJSONList :: [SubscriptionEventStreamBatch a] -> Value # toEncodingList :: [SubscriptionEventStreamBatch a] -> Encoding #
FromJSON a => FromJSON (SubscriptionEventStreamBatch a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser (SubscriptionEventStreamBatch a) # parseJSONList :: Value -> Parser [SubscriptionEventStreamBatch a] #
HasNakadiSubscriptionCursor (SubscriptionEventStreamBatch a)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionCursor :: Getter (SubscriptionEventStreamBatch a) SubscriptionCursor
HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods cursor :: Lens' (SubscriptionEventStreamBatch a) SubscriptionCursor
HasNakadiEvents (SubscriptionEventStreamBatch a) (Maybe (Vector a))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods events :: Lens' (SubscriptionEventStreamBatch a) (Maybe (Vector a))
HasNakadiQueue (Worker a) (TBQueue (SubscriptionEventStreamBatch a))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods queue :: Lens' (Worker a) (TBQueue (SubscriptionEventStreamBatch a))
type Rep (SubscriptionEventStreamBatch a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep (SubscriptionEventStreamBatch a) = D1 (MetaData "SubscriptionEventStreamBatch" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "SubscriptionEventStreamBatch" PrefixI True) (S1 (MetaSel (Just "_cursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 SubscriptionCursor) :*: S1 (MetaSel (Just "_events") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe (Vector a)))))

newtype EventId Source #

ID of an Event

Constructors

EventId
Fields unEventId :: UUID Wrapped UUID

Instances

Eq EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventId -> EventId -> Bool # (/=) :: EventId -> EventId -> Bool #
Ord EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: EventId -> EventId -> Ordering # (<) :: EventId -> EventId -> Bool # (<=) :: EventId -> EventId -> Bool # (>) :: EventId -> EventId -> Bool # (>=) :: EventId -> EventId -> Bool # max :: EventId -> EventId -> EventId # min :: EventId -> EventId -> EventId #
Show EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventId -> ShowS # show :: EventId -> String # showList :: [EventId] -> ShowS #
Generic EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventId :: Type -> Type # Methods from :: EventId -> Rep EventId x # to :: Rep EventId x -> EventId #
Hashable EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> EventId -> Int # hash :: EventId -> Int #
ToJSON EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventId -> Value # toEncoding :: EventId -> Encoding # toJSONList :: [EventId] -> Value # toEncodingList :: [EventId] -> Encoding #
FromJSON EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventId # parseJSONList :: Value -> Parser [EventId] #
HasNakadiEid EventMetadata EventId
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eid :: Lens' EventMetadata EventId
HasNakadiEid EventMetadataEnriched EventId
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eid :: Lens' EventMetadataEnriched EventId
HasNakadiId EventId UUID
Instance details Defined in Network.Nakadi.Internal.Lenses Methods id :: Lens' EventId UUID
HasNakadiParentEids EventMetadata (Maybe [EventId])
Instance details Defined in Network.Nakadi.Internal.Lenses Methods parentEids :: Lens' EventMetadata (Maybe [EventId])
HasNakadiParentEids EventMetadataEnriched (Maybe [EventId])
Instance details Defined in Network.Nakadi.Internal.Lenses Methods parentEids :: Lens' EventMetadataEnriched (Maybe [EventId])
type Rep EventId Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventId = D1 (MetaData "EventId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "EventId" PrefixI True) (S1 (MetaSel (Just "unEventId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UUID)))

data Partition Source #

Partition Data

Constructors

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

Instances

Show Partition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> Partition -> ShowS # show :: Partition -> String # showList :: [Partition] -> ShowS #
ToJSON Partition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: Partition -> Value # toEncoding :: Partition -> Encoding # toJSONList :: [Partition] -> Value # toEncodingList :: [Partition] -> Encoding #
FromJSON Partition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser Partition # parseJSONList :: Value -> Parser [Partition] #
HasNakadiPartition Partition PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' Partition PartitionName
HasNakadiOldestAvailableOffset Partition CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods oldestAvailableOffset :: Lens' Partition CursorOffset
HasNakadiNewestAvailableOffset Partition CursorOffset
Instance details Defined in Network.Nakadi.Internal.Lenses Methods newestAvailableOffset :: Lens' Partition CursorOffset
HasNakadiUnconsumedEvents Partition (Maybe Int64)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods unconsumedEvents :: Lens' Partition (Maybe Int64)

data ShiftedCursor Source #

Type for shift-cursor queries.

Constructors

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

Instances

Eq ShiftedCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: ShiftedCursor -> ShiftedCursor -> Bool # (/=) :: ShiftedCursor -> ShiftedCursor -> Bool #
Ord ShiftedCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: ShiftedCursor -> ShiftedCursor -> Ordering # (<) :: ShiftedCursor -> ShiftedCursor -> Bool # (<=) :: ShiftedCursor -> ShiftedCursor -> Bool # (>) :: ShiftedCursor -> ShiftedCursor -> Bool # (>=) :: ShiftedCursor -> ShiftedCursor -> Bool # max :: ShiftedCursor -> ShiftedCursor -> ShiftedCursor # min :: ShiftedCursor -> ShiftedCursor -> ShiftedCursor #
Show ShiftedCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> ShiftedCursor -> ShowS # show :: ShiftedCursor -> String # showList :: [ShiftedCursor] -> ShowS #
ToJSON ShiftedCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: ShiftedCursor -> Value # toEncoding :: ShiftedCursor -> Encoding # toJSONList :: [ShiftedCursor] -> Value # toEncodingList :: [ShiftedCursor] -> Encoding #
FromJSON ShiftedCursor Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser ShiftedCursor # parseJSONList :: Value -> Parser [ShiftedCursor] #

data CursorDistanceQuery Source #

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

Constructors

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

Instances

Eq CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (/=) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool #
Ord CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: CursorDistanceQuery -> CursorDistanceQuery -> Ordering # (<) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (<=) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (>) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # (>=) :: CursorDistanceQuery -> CursorDistanceQuery -> Bool # max :: CursorDistanceQuery -> CursorDistanceQuery -> CursorDistanceQuery # min :: CursorDistanceQuery -> CursorDistanceQuery -> CursorDistanceQuery #
Show CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> CursorDistanceQuery -> ShowS # show :: CursorDistanceQuery -> String # showList :: [CursorDistanceQuery] -> ShowS #
Generic CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep CursorDistanceQuery :: Type -> Type # Methods from :: CursorDistanceQuery -> Rep CursorDistanceQuery x # to :: Rep CursorDistanceQuery x -> CursorDistanceQuery #
Hashable CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> CursorDistanceQuery -> Int # hash :: CursorDistanceQuery -> Int #
ToJSON CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: CursorDistanceQuery -> Value # toEncoding :: CursorDistanceQuery -> Encoding # toJSONList :: [CursorDistanceQuery] -> Value # toEncodingList :: [CursorDistanceQuery] -> Encoding #
FromJSON CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser CursorDistanceQuery # parseJSONList :: Value -> Parser [CursorDistanceQuery] #
HasNakadiInitialCursor CursorDistanceQuery Cursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods initialCursor :: Lens' CursorDistanceQuery Cursor
HasNakadiFinalCursor CursorDistanceQuery Cursor
Instance details Defined in Network.Nakadi.Internal.Lenses Methods finalCursor :: Lens' CursorDistanceQuery Cursor
type Rep CursorDistanceQuery Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep CursorDistanceQuery = D1 (MetaData "CursorDistanceQuery" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "CursorDistanceQuery" PrefixI True) (S1 (MetaSel (Just "_initialCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Cursor) :*: S1 (MetaSel (Just "_finalCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Cursor)))

newtype CursorDistanceResult Source #

Type for results of cursor-distance-queries.

Constructors

CursorDistanceResult
Fields _distance :: Int64

Instances

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

data SubscriptionPosition Source #

Type modelling a subscription position.

Constructors

SubscriptionPositionBegin
SubscriptionPositionEnd
SubscriptionPositionCursors [SubscriptionCursorWithoutToken]

Instances

Eq SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (/=) :: SubscriptionPosition -> SubscriptionPosition -> Bool #
Ord SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionPosition -> SubscriptionPosition -> Ordering # (<) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (<=) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (>) :: SubscriptionPosition -> SubscriptionPosition -> Bool # (>=) :: SubscriptionPosition -> SubscriptionPosition -> Bool # max :: SubscriptionPosition -> SubscriptionPosition -> SubscriptionPosition # min :: SubscriptionPosition -> SubscriptionPosition -> SubscriptionPosition #
Show SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionPosition -> ShowS # show :: SubscriptionPosition -> String # showList :: [SubscriptionPosition] -> ShowS #
Generic SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionPosition :: Type -> Type # Methods from :: SubscriptionPosition -> Rep SubscriptionPosition x # to :: Rep SubscriptionPosition x -> SubscriptionPosition #
Hashable SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> SubscriptionPosition -> Int # hash :: SubscriptionPosition -> Int #
ToJSON SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionPosition -> Value # toEncoding :: SubscriptionPosition -> Encoding # toJSONList :: [SubscriptionPosition] -> Value # toEncodingList :: [SubscriptionPosition] -> Encoding #
FromJSON SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionPosition # parseJSONList :: Value -> Parser [SubscriptionPosition] #
HasNakadiSubscriptionPosition Subscription SubscriptionPosition
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionPosition :: Lens' Subscription SubscriptionPosition
HasNakadiSubscriptionPosition SubscriptionRequest (Maybe SubscriptionPosition)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionPosition :: Lens' SubscriptionRequest (Maybe SubscriptionPosition)
type Rep SubscriptionPosition Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionPosition = D1 (MetaData "SubscriptionPosition" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "SubscriptionPositionBegin" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "SubscriptionPositionEnd" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "SubscriptionPositionCursors" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [SubscriptionCursorWithoutToken]))))

data Subscription Source #

Type for a Subscription which has already been created.

When a subscription object is retrieved from Nakadi the following fields are regarded as mandatory:

```
id
```
```
owning_application
```
```
event_types
```
```
consumer_group
```
```
created_at
```
```
read_from
```
depending on read_from also cursors.

Constructors

Subscription
Fields _id :: SubscriptionId _owningApplication :: ApplicationName _eventTypes :: [EventTypeName] _consumerGroup :: ConsumerGroup _createdAt :: Timestamp _subscriptionPosition :: SubscriptionPosition

Instances

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

data SubscriptionRequest Source #

Type for a Subscription which is to be created.

When a subscription is to be created the following fields are regarded as mandatory in the subscription object:

```
owning_application
```
```
event_types
```

The remaining fields are regarded as optional:

```
consumer_group
```
```
read_from
```
depending on read_from the field cursors might have to be present as well.

Constructors

SubscriptionRequest
Fields _owningApplication :: ApplicationName _eventTypes :: [EventTypeName] _consumerGroup :: Maybe ConsumerGroup _subscriptionPosition :: Maybe SubscriptionPosition

Instances

Eq SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionRequest -> SubscriptionRequest -> Bool # (/=) :: SubscriptionRequest -> SubscriptionRequest -> Bool #
Ord SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionRequest -> SubscriptionRequest -> Ordering # (<) :: SubscriptionRequest -> SubscriptionRequest -> Bool # (<=) :: SubscriptionRequest -> SubscriptionRequest -> Bool # (>) :: SubscriptionRequest -> SubscriptionRequest -> Bool # (>=) :: SubscriptionRequest -> SubscriptionRequest -> Bool # max :: SubscriptionRequest -> SubscriptionRequest -> SubscriptionRequest # min :: SubscriptionRequest -> SubscriptionRequest -> SubscriptionRequest #
Show SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionRequest -> ShowS # show :: SubscriptionRequest -> String # showList :: [SubscriptionRequest] -> ShowS #
Generic SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionRequest :: Type -> Type # Methods from :: SubscriptionRequest -> Rep SubscriptionRequest x # to :: Rep SubscriptionRequest x -> SubscriptionRequest #
Hashable SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> SubscriptionRequest -> Int # hash :: SubscriptionRequest -> Int #
ToJSON SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionRequest -> Value # toEncoding :: SubscriptionRequest -> Encoding # toJSONList :: [SubscriptionRequest] -> Value # toEncodingList :: [SubscriptionRequest] -> Encoding #
FromJSON SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionRequest # parseJSONList :: Value -> Parser [SubscriptionRequest] #
HasNakadiOwningApplication SubscriptionRequest ApplicationName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods owningApplication :: Lens' SubscriptionRequest ApplicationName
HasNakadiSubscriptionPosition SubscriptionRequest (Maybe SubscriptionPosition)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods subscriptionPosition :: Lens' SubscriptionRequest (Maybe SubscriptionPosition)
HasNakadiEventTypes SubscriptionRequest [EventTypeName]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eventTypes :: Lens' SubscriptionRequest [EventTypeName]
HasNakadiConsumerGroup SubscriptionRequest (Maybe ConsumerGroup)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods consumerGroup :: Lens' SubscriptionRequest (Maybe ConsumerGroup)
type Rep SubscriptionRequest Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionRequest = D1 (MetaData "SubscriptionRequest" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "SubscriptionRequest" PrefixI True) ((S1 (MetaSel (Just "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 ApplicationName) :: S1 (MetaSel (Just "_eventTypes") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [EventTypeName])) :: (S1 (MetaSel (Just "_consumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe ConsumerGroup)) :*: S1 (MetaSel (Just "_subscriptionPosition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe SubscriptionPosition)))))

newtype ConsumerGroup Source #

This type models the value describing the use case of a subscription. In general this is an additional identifier used to differ subscriptions having the same owning application and event types.

Constructors

ConsumerGroup
Fields unConsumerGroup :: Text

Instances

Eq ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: ConsumerGroup -> ConsumerGroup -> Bool # (/=) :: ConsumerGroup -> ConsumerGroup -> Bool #
Ord ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: ConsumerGroup -> ConsumerGroup -> Ordering # (<) :: ConsumerGroup -> ConsumerGroup -> Bool # (<=) :: ConsumerGroup -> ConsumerGroup -> Bool # (>) :: ConsumerGroup -> ConsumerGroup -> Bool # (>=) :: ConsumerGroup -> ConsumerGroup -> Bool # max :: ConsumerGroup -> ConsumerGroup -> ConsumerGroup # min :: ConsumerGroup -> ConsumerGroup -> ConsumerGroup #
Show ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> ConsumerGroup -> ShowS # show :: ConsumerGroup -> String # showList :: [ConsumerGroup] -> ShowS #
IsString ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods fromString :: String -> ConsumerGroup #
Generic ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep ConsumerGroup :: Type -> Type # Methods from :: ConsumerGroup -> Rep ConsumerGroup x # to :: Rep ConsumerGroup x -> ConsumerGroup #
Hashable ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> ConsumerGroup -> Int # hash :: ConsumerGroup -> Int #
ToJSON ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: ConsumerGroup -> Value # toEncoding :: ConsumerGroup -> Encoding # toJSONList :: [ConsumerGroup] -> Value # toEncodingList :: [ConsumerGroup] -> Encoding #
FromJSON ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser ConsumerGroup # parseJSONList :: Value -> Parser [ConsumerGroup] #
HasNakadiConsumerGroup Subscription ConsumerGroup
Instance details Defined in Network.Nakadi.Internal.Lenses Methods consumerGroup :: Lens' Subscription ConsumerGroup
HasNakadiConsumerGroup SubscriptionRequest (Maybe ConsumerGroup)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods consumerGroup :: Lens' SubscriptionRequest (Maybe ConsumerGroup)
type Rep ConsumerGroup Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep ConsumerGroup = D1 (MetaData "ConsumerGroup" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "ConsumerGroup" PrefixI True) (S1 (MetaSel (Just "unConsumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data PublishingStatus Source #

Type for publishing status.

Constructors

PublishingStatusSubmitted
PublishingStatusFailed
PublishingStatusAborted

Instances

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

data Step Source #

Step

Constructors

StepNone
StepValidating
StepPartitioning
StepEnriching
StepPublishing

Instances

Eq Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: Step -> Step -> Bool # (/=) :: Step -> Step -> Bool #
Ord Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: Step -> Step -> Ordering # (<) :: Step -> Step -> Bool # (<=) :: Step -> Step -> Bool # (>) :: Step -> Step -> Bool # (>=) :: Step -> Step -> Bool # max :: Step -> Step -> Step # min :: Step -> Step -> Step #
Show Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> Step -> ShowS # show :: Step -> String # showList :: [Step] -> ShowS #
Generic Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep Step :: Type -> Type # Methods from :: Step -> Rep Step x # to :: Rep Step x -> Step #
Hashable Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> Step -> Int # hash :: Step -> Int #
ToJSON Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: Step -> Value # toEncoding :: Step -> Encoding # toJSONList :: [Step] -> Value # toEncodingList :: [Step] -> Encoding #
FromJSON Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser Step # parseJSONList :: Value -> Parser [Step] #
type Rep Step Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep Step = D1 (MetaData "Step" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) ((C1 (MetaCons "StepNone" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "StepValidating" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "StepPartitioning" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "StepEnriching" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "StepPublishing" PrefixI False) (U1 :: Type -> Type))))

data BatchItemResponse Source #

In case of failures during batch publishing, Nakadi returns detailed information about which events failed to be published. This per-event information is a batch item response.

Constructors

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

Instances

Eq BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: BatchItemResponse -> BatchItemResponse -> Bool # (/=) :: BatchItemResponse -> BatchItemResponse -> Bool #
Ord BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: BatchItemResponse -> BatchItemResponse -> Ordering # (<) :: BatchItemResponse -> BatchItemResponse -> Bool # (<=) :: BatchItemResponse -> BatchItemResponse -> Bool # (>) :: BatchItemResponse -> BatchItemResponse -> Bool # (>=) :: BatchItemResponse -> BatchItemResponse -> Bool # max :: BatchItemResponse -> BatchItemResponse -> BatchItemResponse # min :: BatchItemResponse -> BatchItemResponse -> BatchItemResponse #
Show BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> BatchItemResponse -> ShowS # show :: BatchItemResponse -> String # showList :: [BatchItemResponse] -> ShowS #
Generic BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep BatchItemResponse :: Type -> Type # Methods from :: BatchItemResponse -> Rep BatchItemResponse x # to :: Rep BatchItemResponse x -> BatchItemResponse #
Hashable BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> BatchItemResponse -> Int # hash :: BatchItemResponse -> Int #
ToJSON BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: BatchItemResponse -> Value # toEncoding :: BatchItemResponse -> Encoding # toJSONList :: [BatchItemResponse] -> Value # toEncodingList :: [BatchItemResponse] -> Encoding #
FromJSON BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser BatchItemResponse # parseJSONList :: Value -> Parser [BatchItemResponse] #
type Rep BatchItemResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep BatchItemResponse = D1 (MetaData "BatchItemResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "BatchItemResponse" PrefixI True) ((S1 (MetaSel (Just "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe EventId)) :: S1 (MetaSel (Just "_publishingStatus") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PublishingStatus)) :: (S1 (MetaSel (Just "_step") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Step)) :*: S1 (MetaSel (Just "_detail") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Text)))))

newtype StreamKeepAliveLimit Source #

StreamKeepAliveLimit

Constructors

StreamKeepAliveLimit
Fields unStreamKeepAliveLimit :: Int32

Instances

Eq StreamKeepAliveLimit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (/=) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool #
Ord StreamKeepAliveLimit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Ordering # (<) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (<=) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (>) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # (>=) :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> Bool # max :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> StreamKeepAliveLimit # min :: StreamKeepAliveLimit -> StreamKeepAliveLimit -> StreamKeepAliveLimit #
Show StreamKeepAliveLimit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> StreamKeepAliveLimit -> ShowS # show :: StreamKeepAliveLimit -> String # showList :: [StreamKeepAliveLimit] -> ShowS #
ToJSON StreamKeepAliveLimit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: StreamKeepAliveLimit -> Value # toEncoding :: StreamKeepAliveLimit -> Encoding # toJSONList :: [StreamKeepAliveLimit] -> Value # toEncodingList :: [StreamKeepAliveLimit] -> Encoding #
FromJSON StreamKeepAliveLimit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser StreamKeepAliveLimit # parseJSONList :: Value -> Parser [StreamKeepAliveLimit] #

newtype BatchFlushTimeout Source #

BatchFlushTimeout

Constructors

BatchFlushTimeout
Fields unBatchFlushTimeout :: Int32

Instances

Eq BatchFlushTimeout Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (/=) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool #
Ord BatchFlushTimeout Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: BatchFlushTimeout -> BatchFlushTimeout -> Ordering # (<) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (<=) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (>) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # (>=) :: BatchFlushTimeout -> BatchFlushTimeout -> Bool # max :: BatchFlushTimeout -> BatchFlushTimeout -> BatchFlushTimeout # min :: BatchFlushTimeout -> BatchFlushTimeout -> BatchFlushTimeout #
Show BatchFlushTimeout Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> BatchFlushTimeout -> ShowS # show :: BatchFlushTimeout -> String # showList :: [BatchFlushTimeout] -> ShowS #
ToJSON BatchFlushTimeout Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: BatchFlushTimeout -> Value # toEncoding :: BatchFlushTimeout -> Encoding # toJSONList :: [BatchFlushTimeout] -> Value # toEncodingList :: [BatchFlushTimeout] -> Encoding #
FromJSON BatchFlushTimeout Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser BatchFlushTimeout # parseJSONList :: Value -> Parser [BatchFlushTimeout] #

data CursorCommitResultType Source #

CursorCommitResultType

Constructors

CursorCommitResultCommitted
CursorCommitResultOutdated

Instances

Eq CursorCommitResultType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (/=) :: CursorCommitResultType -> CursorCommitResultType -> Bool #
Ord CursorCommitResultType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: CursorCommitResultType -> CursorCommitResultType -> Ordering # (<) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (<=) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (>) :: CursorCommitResultType -> CursorCommitResultType -> Bool # (>=) :: CursorCommitResultType -> CursorCommitResultType -> Bool # max :: CursorCommitResultType -> CursorCommitResultType -> CursorCommitResultType # min :: CursorCommitResultType -> CursorCommitResultType -> CursorCommitResultType #
Show CursorCommitResultType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> CursorCommitResultType -> ShowS # show :: CursorCommitResultType -> String # showList :: [CursorCommitResultType] -> ShowS #
ToJSON CursorCommitResultType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: CursorCommitResultType -> Value # toEncoding :: CursorCommitResultType -> Encoding # toJSONList :: [CursorCommitResultType] -> Value # toEncodingList :: [CursorCommitResultType] -> Encoding #
FromJSON CursorCommitResultType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser CursorCommitResultType # parseJSONList :: Value -> Parser [CursorCommitResultType] #

data CursorCommitResult Source #

CursorCommitResult

Constructors

CursorCommitResult
Fields _cursor :: SubscriptionCursor _result :: CursorCommitResultType

Instances

Eq CursorCommitResult Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: CursorCommitResult -> CursorCommitResult -> Bool # (/=) :: CursorCommitResult -> CursorCommitResult -> Bool #
Ord CursorCommitResult Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: CursorCommitResult -> CursorCommitResult -> Ordering # (<) :: CursorCommitResult -> CursorCommitResult -> Bool # (<=) :: CursorCommitResult -> CursorCommitResult -> Bool # (>) :: CursorCommitResult -> CursorCommitResult -> Bool # (>=) :: CursorCommitResult -> CursorCommitResult -> Bool # max :: CursorCommitResult -> CursorCommitResult -> CursorCommitResult # min :: CursorCommitResult -> CursorCommitResult -> CursorCommitResult #
Show CursorCommitResult Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> CursorCommitResult -> ShowS # show :: CursorCommitResult -> String # showList :: [CursorCommitResult] -> ShowS #
ToJSON CursorCommitResult Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: CursorCommitResult -> Value # toEncoding :: CursorCommitResult -> Encoding # toJSONList :: [CursorCommitResult] -> Value # toEncodingList :: [CursorCommitResult] -> Encoding #
FromJSON CursorCommitResult Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser CursorCommitResult # parseJSONList :: Value -> Parser [CursorCommitResult] #

newtype CursorCommitResults Source #

Constructors

CursorCommitResults
Fields _items :: [CursorCommitResult]

Instances

Eq CursorCommitResults Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: CursorCommitResults -> CursorCommitResults -> Bool # (/=) :: CursorCommitResults -> CursorCommitResults -> Bool #
Ord CursorCommitResults Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: CursorCommitResults -> CursorCommitResults -> Ordering # (<) :: CursorCommitResults -> CursorCommitResults -> Bool # (<=) :: CursorCommitResults -> CursorCommitResults -> Bool # (>) :: CursorCommitResults -> CursorCommitResults -> Bool # (>=) :: CursorCommitResults -> CursorCommitResults -> Bool # max :: CursorCommitResults -> CursorCommitResults -> CursorCommitResults # min :: CursorCommitResults -> CursorCommitResults -> CursorCommitResults #
Show CursorCommitResults Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> CursorCommitResults -> ShowS # show :: CursorCommitResults -> String # showList :: [CursorCommitResults] -> ShowS #
ToJSON CursorCommitResults Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: CursorCommitResults -> Value # toEncoding :: CursorCommitResults -> Encoding # toJSONList :: [CursorCommitResults] -> Value # toEncodingList :: [CursorCommitResults] -> Encoding #
FromJSON CursorCommitResults Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser CursorCommitResults # parseJSONList :: Value -> Parser [CursorCommitResults] #

data SchemaType Source #

SchemaType

Constructors

SchemaTypeJson

Instances

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

data EventTypeSchema Source #

Type for the schema of an event type.

Constructors

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

Instances

Eq EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventTypeSchema -> EventTypeSchema -> Bool # (/=) :: EventTypeSchema -> EventTypeSchema -> Bool #
Ord EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: EventTypeSchema -> EventTypeSchema -> Ordering # (<) :: EventTypeSchema -> EventTypeSchema -> Bool # (<=) :: EventTypeSchema -> EventTypeSchema -> Bool # (>) :: EventTypeSchema -> EventTypeSchema -> Bool # (>=) :: EventTypeSchema -> EventTypeSchema -> Bool # max :: EventTypeSchema -> EventTypeSchema -> EventTypeSchema # min :: EventTypeSchema -> EventTypeSchema -> EventTypeSchema #
Show EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventTypeSchema -> ShowS # show :: EventTypeSchema -> String # showList :: [EventTypeSchema] -> ShowS #
Generic EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventTypeSchema :: Type -> Type # Methods from :: EventTypeSchema -> Rep EventTypeSchema x # to :: Rep EventTypeSchema x -> EventTypeSchema #
Hashable EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> EventTypeSchema -> Int # hash :: EventTypeSchema -> Int #
ToJSON EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventTypeSchema -> Value # toEncoding :: EventTypeSchema -> Encoding # toJSONList :: [EventTypeSchema] -> Value # toEncodingList :: [EventTypeSchema] -> Encoding #
FromJSON EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventTypeSchema # parseJSONList :: Value -> Parser [EventTypeSchema] #
HasNakadiSchemaType EventTypeSchema SchemaType
Instance details Defined in Network.Nakadi.Internal.Lenses Methods schemaType :: Lens' EventTypeSchema SchemaType
HasNakadiSchema EventTypeSchema Text
Instance details Defined in Network.Nakadi.Internal.Lenses Methods schema :: Lens' EventTypeSchema Text
HasNakadiSchema EventType EventTypeSchema
Instance details Defined in Network.Nakadi.Internal.Lenses Methods schema :: Lens' EventType EventTypeSchema
HasNakadiVersion EventTypeSchema (Maybe SchemaVersion)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods version :: Lens' EventTypeSchema (Maybe SchemaVersion)
HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods createdAt :: Lens' EventTypeSchema (Maybe Timestamp)
HasNakadiItems EventTypeSchemasResponse [EventTypeSchema]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods items :: Lens' EventTypeSchemasResponse [EventTypeSchema]
type Rep EventTypeSchema Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventTypeSchema = D1 (MetaData "EventTypeSchema" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "EventTypeSchema" PrefixI True) ((S1 (MetaSel (Just "_version") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe SchemaVersion)) :: S1 (MetaSel (Just "_createdAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Timestamp))) :: (S1 (MetaSel (Just "_schemaType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 SchemaType) :*: S1 (MetaSel (Just "_schema") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text))))

newtype PaginationLink Source #

PaginationLink

Constructors

PaginationLink
Fields _href :: Text

Instances

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

data PaginationLinks Source #

PaginationLinks

Constructors

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

Instances

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

data EventTypeSchemasResponse Source #

EventTypeSchemasResponse

Constructors

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

Instances

Eq EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (/=) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool #
Ord EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Ordering # (<) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (<=) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (>) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # (>=) :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> Bool # max :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> EventTypeSchemasResponse # min :: EventTypeSchemasResponse -> EventTypeSchemasResponse -> EventTypeSchemasResponse #
Show EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventTypeSchemasResponse -> ShowS # show :: EventTypeSchemasResponse -> String # showList :: [EventTypeSchemasResponse] -> ShowS #
Generic EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventTypeSchemasResponse :: Type -> Type # Methods from :: EventTypeSchemasResponse -> Rep EventTypeSchemasResponse x # to :: Rep EventTypeSchemasResponse x -> EventTypeSchemasResponse #
Hashable EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> EventTypeSchemasResponse -> Int # hash :: EventTypeSchemasResponse -> Int #
ToJSON EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventTypeSchemasResponse -> Value # toEncoding :: EventTypeSchemasResponse -> Encoding # toJSONList :: [EventTypeSchemasResponse] -> Value # toEncodingList :: [EventTypeSchemasResponse] -> Encoding #
FromJSON EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventTypeSchemasResponse # parseJSONList :: Value -> Parser [EventTypeSchemasResponse] #
HasNakadiLinks EventTypeSchemasResponse PaginationLinks
Instance details Defined in Network.Nakadi.Internal.Lenses Methods links :: Lens' EventTypeSchemasResponse PaginationLinks
HasNakadiItems EventTypeSchemasResponse [EventTypeSchema]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods items :: Lens' EventTypeSchemasResponse [EventTypeSchema]
type Rep EventTypeSchemasResponse Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventTypeSchemasResponse = D1 (MetaData "EventTypeSchemasResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "EventTypeSchemasResponse" PrefixI True) (S1 (MetaSel (Just "_links") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PaginationLinks) :*: S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [EventTypeSchema])))

newtype SchemaVersion Source #

Type for the version of a schema.

Constructors

SchemaVersion
Fields unSchemaVersion :: Text

Instances

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

newtype Offset Source #

Type for offset values.

Constructors

Offset
Fields unOffset :: Int64 Wrapped offset value

Instances

Eq Offset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: Offset -> Offset -> Bool # (/=) :: Offset -> Offset -> Bool #
Ord Offset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: Offset -> Offset -> Ordering # (<) :: Offset -> Offset -> Bool # (<=) :: Offset -> Offset -> Bool # (>) :: Offset -> Offset -> Bool # (>=) :: Offset -> Offset -> Bool # max :: Offset -> Offset -> Offset # min :: Offset -> Offset -> Offset #
Show Offset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> Offset -> ShowS # show :: Offset -> String # showList :: [Offset] -> ShowS #
Generic Offset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep Offset :: Type -> Type # Methods from :: Offset -> Rep Offset x # to :: Rep Offset x -> Offset #
Hashable Offset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> Offset -> Int # hash :: Offset -> Int #
type Rep Offset Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep Offset = D1 (MetaData "Offset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "Offset" PrefixI True) (S1 (MetaSel (Just "unOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

newtype Limit Source #

Type for limit values.

Constructors

Limit
Fields unLimit :: Int64 Wrapped limit value.

Instances

Eq Limit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: Limit -> Limit -> Bool # (/=) :: Limit -> Limit -> Bool #
Ord Limit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: Limit -> Limit -> Ordering # (<) :: Limit -> Limit -> Bool # (<=) :: Limit -> Limit -> Bool # (>) :: Limit -> Limit -> Bool # (>=) :: Limit -> Limit -> Bool # max :: Limit -> Limit -> Limit # min :: Limit -> Limit -> Limit #
Show Limit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> Limit -> ShowS # show :: Limit -> String # showList :: [Limit] -> ShowS #
Generic Limit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep Limit :: Type -> Type # Methods from :: Limit -> Rep Limit x # to :: Rep Limit x -> Limit #
Hashable Limit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> Limit -> Int # hash :: Limit -> Int #
type Rep Limit Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep Limit = D1 (MetaData "Limit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "Limit" PrefixI True) (S1 (MetaSel (Just "unLimit") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

data PartitionState Source #

Type for partition states.

Constructors

PartitionStateUnassigned
PartitionStateReassigning
PartitionStateAssigned

Instances

Eq PartitionState Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: PartitionState -> PartitionState -> Bool # (/=) :: PartitionState -> PartitionState -> Bool #
Ord PartitionState Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: PartitionState -> PartitionState -> Ordering # (<) :: PartitionState -> PartitionState -> Bool # (<=) :: PartitionState -> PartitionState -> Bool # (>) :: PartitionState -> PartitionState -> Bool # (>=) :: PartitionState -> PartitionState -> Bool # max :: PartitionState -> PartitionState -> PartitionState # min :: PartitionState -> PartitionState -> PartitionState #
Show PartitionState Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> PartitionState -> ShowS # show :: PartitionState -> String # showList :: [PartitionState] -> ShowS #
ToJSON PartitionState Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: PartitionState -> Value # toEncoding :: PartitionState -> Encoding # toJSONList :: [PartitionState] -> Value # toEncodingList :: [PartitionState] -> Encoding #
FromJSON PartitionState Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser PartitionState # parseJSONList :: Value -> Parser [PartitionState] #
HasNakadiState PartitionStat PartitionState
Instance details Defined in Network.Nakadi.Internal.Lenses Methods state :: Lens' PartitionStat PartitionState

data PartitionStat Source #

Type for per-partition statistics.

Constructors

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

Instances

Eq PartitionStat Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: PartitionStat -> PartitionStat -> Bool # (/=) :: PartitionStat -> PartitionStat -> Bool #
Ord PartitionStat Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: PartitionStat -> PartitionStat -> Ordering # (<) :: PartitionStat -> PartitionStat -> Bool # (<=) :: PartitionStat -> PartitionStat -> Bool # (>) :: PartitionStat -> PartitionStat -> Bool # (>=) :: PartitionStat -> PartitionStat -> Bool # max :: PartitionStat -> PartitionStat -> PartitionStat # min :: PartitionStat -> PartitionStat -> PartitionStat #
Show PartitionStat Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> PartitionStat -> ShowS # show :: PartitionStat -> String # showList :: [PartitionStat] -> ShowS #
Generic PartitionStat Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep PartitionStat :: Type -> Type # Methods from :: PartitionStat -> Rep PartitionStat x # to :: Rep PartitionStat x -> PartitionStat #
ToJSON PartitionStat Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: PartitionStat -> Value # toEncoding :: PartitionStat -> Encoding # toJSONList :: [PartitionStat] -> Value # toEncodingList :: [PartitionStat] -> Encoding #
FromJSON PartitionStat Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser PartitionStat # parseJSONList :: Value -> Parser [PartitionStat] #
HasNakadiPartition PartitionStat PartitionName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' PartitionStat PartitionName
HasNakadiState PartitionStat PartitionState
Instance details Defined in Network.Nakadi.Internal.Lenses Methods state :: Lens' PartitionStat PartitionState
HasNakadiUnconsumedEvents PartitionStat (Maybe Int64)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods unconsumedEvents :: Lens' PartitionStat (Maybe Int64)
HasNakadiStreamId PartitionStat (Maybe StreamId)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods streamId :: Lens' PartitionStat (Maybe StreamId)
HasNakadiConsumerLagSeconds PartitionStat (Maybe Int64)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods consumerLagSeconds :: Lens' PartitionStat (Maybe Int64)
type Rep PartitionStat Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep PartitionStat = D1 (MetaData "PartitionStat" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "PartitionStat" PrefixI True) ((S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :: S1 (MetaSel (Just "_state") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionState)) :: (S1 (MetaSel (Just "_unconsumedEvents") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Int64)) :: (S1 (MetaSel (Just "_streamId") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe StreamId)) :: S1 (MetaSel (Just "_consumerLagSeconds") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Int64))))))

data SubscriptionEventTypeStats Source #

Nakadi type SubscriptionEventTypeStats.

Constructors

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

Instances

Eq SubscriptionEventTypeStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (/=) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool #
Ord SubscriptionEventTypeStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Ordering # (<) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (<=) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (>) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # (>=) :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> Bool # max :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> SubscriptionEventTypeStats # min :: SubscriptionEventTypeStats -> SubscriptionEventTypeStats -> SubscriptionEventTypeStats #
Show SubscriptionEventTypeStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionEventTypeStats -> ShowS # show :: SubscriptionEventTypeStats -> String # showList :: [SubscriptionEventTypeStats] -> ShowS #
Generic SubscriptionEventTypeStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionEventTypeStats :: Type -> Type # Methods from :: SubscriptionEventTypeStats -> Rep SubscriptionEventTypeStats x # to :: Rep SubscriptionEventTypeStats x -> SubscriptionEventTypeStats #
ToJSON SubscriptionEventTypeStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionEventTypeStats -> Value # toEncoding :: SubscriptionEventTypeStats -> Encoding # toJSONList :: [SubscriptionEventTypeStats] -> Value # toEncodingList :: [SubscriptionEventTypeStats] -> Encoding #
FromJSON SubscriptionEventTypeStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionEventTypeStats # parseJSONList :: Value -> Parser [SubscriptionEventTypeStats] #
HasNakadiItems SubscriptionStats [SubscriptionEventTypeStats]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods items :: Lens' SubscriptionStats [SubscriptionEventTypeStats]
type Rep SubscriptionEventTypeStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionEventTypeStats = D1 (MetaData "SubscriptionEventTypeStats" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "SubscriptionEventTypeStats" PrefixI True) (S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName) :*: S1 (MetaSel (Just "_partitions") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [PartitionStat])))

newtype SubscriptionStats Source #

Type modelling per-subscription statistics. Objects of this type are returned by requests to subscriptionsSUBSCRIPTION-ID/stats.

Constructors

SubscriptionStats
Fields _items :: [SubscriptionEventTypeStats]

Instances

Eq SubscriptionStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: SubscriptionStats -> SubscriptionStats -> Bool # (/=) :: SubscriptionStats -> SubscriptionStats -> Bool #
Ord SubscriptionStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: SubscriptionStats -> SubscriptionStats -> Ordering # (<) :: SubscriptionStats -> SubscriptionStats -> Bool # (<=) :: SubscriptionStats -> SubscriptionStats -> Bool # (>) :: SubscriptionStats -> SubscriptionStats -> Bool # (>=) :: SubscriptionStats -> SubscriptionStats -> Bool # max :: SubscriptionStats -> SubscriptionStats -> SubscriptionStats # min :: SubscriptionStats -> SubscriptionStats -> SubscriptionStats #
Show SubscriptionStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> SubscriptionStats -> ShowS # show :: SubscriptionStats -> String # showList :: [SubscriptionStats] -> ShowS #
Generic SubscriptionStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep SubscriptionStats :: Type -> Type # Methods from :: SubscriptionStats -> Rep SubscriptionStats x # to :: Rep SubscriptionStats x -> SubscriptionStats #
ToJSON SubscriptionStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: SubscriptionStats -> Value # toEncoding :: SubscriptionStats -> Encoding # toJSONList :: [SubscriptionStats] -> Value # toEncodingList :: [SubscriptionStats] -> Encoding #
FromJSON SubscriptionStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser SubscriptionStats # parseJSONList :: Value -> Parser [SubscriptionStats] #
HasNakadiItems SubscriptionStats [SubscriptionEventTypeStats]
Instance details Defined in Network.Nakadi.Internal.Lenses Methods items :: Lens' SubscriptionStats [SubscriptionEventTypeStats]
type Rep SubscriptionStats Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep SubscriptionStats = D1 (MetaData "SubscriptionStats" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" True) (C1 (MetaCons "SubscriptionStats" PrefixI True) (S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [SubscriptionEventTypeStats])))

data EventTypeCategory Source #

Constructors

EventTypeCategoryUndefined
EventTypeCategoryData
EventTypeCategoryBusiness

Instances

Eq EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventTypeCategory -> EventTypeCategory -> Bool # (/=) :: EventTypeCategory -> EventTypeCategory -> Bool #
Ord EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: EventTypeCategory -> EventTypeCategory -> Ordering # (<) :: EventTypeCategory -> EventTypeCategory -> Bool # (<=) :: EventTypeCategory -> EventTypeCategory -> Bool # (>) :: EventTypeCategory -> EventTypeCategory -> Bool # (>=) :: EventTypeCategory -> EventTypeCategory -> Bool # max :: EventTypeCategory -> EventTypeCategory -> EventTypeCategory # min :: EventTypeCategory -> EventTypeCategory -> EventTypeCategory #
Show EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventTypeCategory -> ShowS # show :: EventTypeCategory -> String # showList :: [EventTypeCategory] -> ShowS #
Generic EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventTypeCategory :: Type -> Type # Methods from :: EventTypeCategory -> Rep EventTypeCategory x # to :: Rep EventTypeCategory x -> EventTypeCategory #
Hashable EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> EventTypeCategory -> Int # hash :: EventTypeCategory -> Int #
ToJSON EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventTypeCategory -> Value # toEncoding :: EventTypeCategory -> Encoding # toJSONList :: [EventTypeCategory] -> Value # toEncodingList :: [EventTypeCategory] -> Encoding #
FromJSON EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventTypeCategory # parseJSONList :: Value -> Parser [EventTypeCategory] #
HasNakadiCategory EventType (Maybe EventTypeCategory)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods category :: Lens' EventType (Maybe EventTypeCategory)
type Rep EventTypeCategory Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventTypeCategory = D1 (MetaData "EventTypeCategory" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "EventTypeCategoryUndefined" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "EventTypeCategoryData" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "EventTypeCategoryBusiness" PrefixI False) (U1 :: Type -> Type)))

data PartitionStrategy Source #

Type for a partitioning strategy.

Constructors

PartitionStrategyRandom
PartitionStrategyUser
PartitionStrategyHash
PartitionStrategyCustom Text

Instances

Eq PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: PartitionStrategy -> PartitionStrategy -> Bool # (/=) :: PartitionStrategy -> PartitionStrategy -> Bool #
Ord PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: PartitionStrategy -> PartitionStrategy -> Ordering # (<) :: PartitionStrategy -> PartitionStrategy -> Bool # (<=) :: PartitionStrategy -> PartitionStrategy -> Bool # (>) :: PartitionStrategy -> PartitionStrategy -> Bool # (>=) :: PartitionStrategy -> PartitionStrategy -> Bool # max :: PartitionStrategy -> PartitionStrategy -> PartitionStrategy # min :: PartitionStrategy -> PartitionStrategy -> PartitionStrategy #
Show PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> PartitionStrategy -> ShowS # show :: PartitionStrategy -> String # showList :: [PartitionStrategy] -> ShowS #
IsString PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods fromString :: String -> PartitionStrategy #
Generic PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep PartitionStrategy :: Type -> Type # Methods from :: PartitionStrategy -> Rep PartitionStrategy x # to :: Rep PartitionStrategy x -> PartitionStrategy #
Hashable PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> PartitionStrategy -> Int # hash :: PartitionStrategy -> Int #
ToJSON PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: PartitionStrategy -> Value # toEncoding :: PartitionStrategy -> Encoding # toJSONList :: [PartitionStrategy] -> Value # toEncodingList :: [PartitionStrategy] -> Encoding #
FromJSON PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser PartitionStrategy # parseJSONList :: Value -> Parser [PartitionStrategy] #
HasNakadiPartitionStrategy EventType (Maybe PartitionStrategy)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionStrategy :: Lens' EventType (Maybe PartitionStrategy)
type Rep PartitionStrategy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep PartitionStrategy = D1 (MetaData "PartitionStrategy" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) ((C1 (MetaCons "PartitionStrategyRandom" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "PartitionStrategyUser" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "PartitionStrategyHash" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "PartitionStrategyCustom" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text))))

data EnrichmentStrategy Source #

Type for an enrichment stragey.

Constructors

EnrichmentStrategyMetadata

Instances

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

data CompatibilityMode Source #

Type for an event type compatibility mode.

Constructors

CompatibilityModeCompatible
CompatibilityModeForward
CompatibilityModeNone

Instances

Eq CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: CompatibilityMode -> CompatibilityMode -> Bool # (/=) :: CompatibilityMode -> CompatibilityMode -> Bool #
Ord CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: CompatibilityMode -> CompatibilityMode -> Ordering # (<) :: CompatibilityMode -> CompatibilityMode -> Bool # (<=) :: CompatibilityMode -> CompatibilityMode -> Bool # (>) :: CompatibilityMode -> CompatibilityMode -> Bool # (>=) :: CompatibilityMode -> CompatibilityMode -> Bool # max :: CompatibilityMode -> CompatibilityMode -> CompatibilityMode # min :: CompatibilityMode -> CompatibilityMode -> CompatibilityMode #
Show CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> CompatibilityMode -> ShowS # show :: CompatibilityMode -> String # showList :: [CompatibilityMode] -> ShowS #
Generic CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep CompatibilityMode :: Type -> Type # Methods from :: CompatibilityMode -> Rep CompatibilityMode x # to :: Rep CompatibilityMode x -> CompatibilityMode #
Hashable CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> CompatibilityMode -> Int # hash :: CompatibilityMode -> Int #
ToJSON CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: CompatibilityMode -> Value # toEncoding :: CompatibilityMode -> Encoding # toJSONList :: [CompatibilityMode] -> Value # toEncodingList :: [CompatibilityMode] -> Encoding #
FromJSON CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser CompatibilityMode # parseJSONList :: Value -> Parser [CompatibilityMode] #
HasNakadiCompatibilityMode EventType (Maybe CompatibilityMode)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods compatibilityMode :: Lens' EventType (Maybe CompatibilityMode)
type Rep CompatibilityMode Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep CompatibilityMode = D1 (MetaData "CompatibilityMode" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "CompatibilityModeCompatible" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "CompatibilityModeForward" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "CompatibilityModeNone" PrefixI False) (U1 :: Type -> Type)))

data CleanupPolicy Source #

Type for cleanup policy.

Constructors

CleanupPolicyDelete
CleanupPolicyCompact

Instances

Eq CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: CleanupPolicy -> CleanupPolicy -> Bool # (/=) :: CleanupPolicy -> CleanupPolicy -> Bool #
Ord CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: CleanupPolicy -> CleanupPolicy -> Ordering # (<) :: CleanupPolicy -> CleanupPolicy -> Bool # (<=) :: CleanupPolicy -> CleanupPolicy -> Bool # (>) :: CleanupPolicy -> CleanupPolicy -> Bool # (>=) :: CleanupPolicy -> CleanupPolicy -> Bool # max :: CleanupPolicy -> CleanupPolicy -> CleanupPolicy # min :: CleanupPolicy -> CleanupPolicy -> CleanupPolicy #
Show CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> CleanupPolicy -> ShowS # show :: CleanupPolicy -> String # showList :: [CleanupPolicy] -> ShowS #
Generic CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep CleanupPolicy :: Type -> Type # Methods from :: CleanupPolicy -> Rep CleanupPolicy x # to :: Rep CleanupPolicy x -> CleanupPolicy #
Hashable CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> CleanupPolicy -> Int # hash :: CleanupPolicy -> Int #
ToJSON CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: CleanupPolicy -> Value # toEncoding :: CleanupPolicy -> Encoding # toJSONList :: [CleanupPolicy] -> Value # toEncodingList :: [CleanupPolicy] -> Encoding #
FromJSON CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser CleanupPolicy # parseJSONList :: Value -> Parser [CleanupPolicy] #
HasNakadiCleanupPolicy EventType (Maybe CleanupPolicy)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods cleanupPolicy :: Lens' EventType (Maybe CleanupPolicy)
type Rep CleanupPolicy Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep CleanupPolicy = D1 (MetaData "CleanupPolicy" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "CleanupPolicyDelete" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "CleanupPolicyCompact" PrefixI False) (U1 :: Type -> Type))

newtype PartitionKeyField Source #

Type for a partitioning key field.

Constructors

PartitionKeyField
Fields unPartitionKeyField :: Text

Instances

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

data EventType Source #

EventType

Constructors

EventType

Instances

Eq EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventType -> EventType -> Bool # (/=) :: EventType -> EventType -> Bool #
Ord EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: EventType -> EventType -> Ordering # (<) :: EventType -> EventType -> Bool # (<=) :: EventType -> EventType -> Bool # (>) :: EventType -> EventType -> Bool # (>=) :: EventType -> EventType -> Bool # max :: EventType -> EventType -> EventType # min :: EventType -> EventType -> EventType #
Show EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventType -> ShowS # show :: EventType -> String # showList :: [EventType] -> ShowS #
Generic EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventType :: Type -> Type # Methods from :: EventType -> Rep EventType x # to :: Rep EventType x -> EventType #
Hashable EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> EventType -> Int # hash :: EventType -> Int #
ToJSON EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventType -> Value # toEncoding :: EventType -> Encoding # toJSONList :: [EventType] -> Value # toEncodingList :: [EventType] -> Encoding #
FromJSON EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventType # parseJSONList :: Value -> Parser [EventType] #
HasNakadiSchema EventType EventTypeSchema
Instance details Defined in Network.Nakadi.Internal.Lenses Methods schema :: Lens' EventType EventTypeSchema
HasNakadiName EventType EventTypeName
Instance details Defined in Network.Nakadi.Internal.Lenses Methods name :: Lens' EventType EventTypeName
HasNakadiPartitionStrategy EventType (Maybe PartitionStrategy)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionStrategy :: Lens' EventType (Maybe PartitionStrategy)
HasNakadiPartitionKeyFields EventType (Maybe [PartitionKeyField])
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionKeyFields :: Lens' EventType (Maybe [PartitionKeyField])
HasNakadiOwningApplication EventType (Maybe ApplicationName)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods owningApplication :: Lens' EventType (Maybe ApplicationName)
HasNakadiOptions EventType (Maybe EventTypeOptions)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods options :: Lens' EventType (Maybe EventTypeOptions)
HasNakadiEnrichmentStrategies EventType (Maybe [EnrichmentStrategy])
Instance details Defined in Network.Nakadi.Internal.Lenses Methods enrichmentStrategies :: Lens' EventType (Maybe [EnrichmentStrategy])
HasNakadiDefaultStatistic EventType (Maybe EventTypeStatistics)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods defaultStatistic :: Lens' EventType (Maybe EventTypeStatistics)
HasNakadiCompatibilityMode EventType (Maybe CompatibilityMode)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods compatibilityMode :: Lens' EventType (Maybe CompatibilityMode)
HasNakadiCleanupPolicy EventType (Maybe CleanupPolicy)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods cleanupPolicy :: Lens' EventType (Maybe CleanupPolicy)
HasNakadiCategory EventType (Maybe EventTypeCategory)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods category :: Lens' EventType (Maybe EventTypeCategory)
type Rep EventType Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventType = D1 (MetaData "EventType" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "EventType" PrefixI True) (((S1 (MetaSel (Just "_name") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName) :: S1 (MetaSel (Just "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe ApplicationName))) :: (S1 (MetaSel (Just "_category") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe EventTypeCategory)) :: (S1 (MetaSel (Just "_enrichmentStrategies") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe [EnrichmentStrategy])) :: S1 (MetaSel (Just "_partitionStrategy") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe PartitionStrategy))))) :: ((S1 (MetaSel (Just "_compatibilityMode") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe CompatibilityMode)) :: (S1 (MetaSel (Just "_schema") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeSchema) :: S1 (MetaSel (Just "_partitionKeyFields") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe [PartitionKeyField])))) :: (S1 (MetaSel (Just "_cleanupPolicy") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe CleanupPolicy)) :: (S1 (MetaSel (Just "_defaultStatistic") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe EventTypeStatistics)) :: S1 (MetaSel (Just "_options") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe EventTypeOptions)))))))

data DataChangeEvent a Source #

DataChangeEvent

Constructors

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

Instances

Eq a => Eq (DataChangeEvent a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: DataChangeEvent a -> DataChangeEvent a -> Bool # (/=) :: DataChangeEvent a -> DataChangeEvent a -> Bool #
Show a => Show (DataChangeEvent a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> DataChangeEvent a -> ShowS # show :: DataChangeEvent a -> String # showList :: [DataChangeEvent a] -> ShowS #
Generic (DataChangeEvent a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep (DataChangeEvent a) :: Type -> Type # Methods from :: DataChangeEvent a -> Rep (DataChangeEvent a) x # to :: Rep (DataChangeEvent a) x -> DataChangeEvent a #
ToJSON a => ToJSON (DataChangeEvent a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: DataChangeEvent a -> Value # toEncoding :: DataChangeEvent a -> Encoding # toJSONList :: [DataChangeEvent a] -> Value # toEncodingList :: [DataChangeEvent a] -> Encoding #
FromJSON a => FromJSON (DataChangeEvent a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser (DataChangeEvent a) # parseJSONList :: Value -> Parser [DataChangeEvent a] #
HasNakadiPayload (DataChangeEvent a) a
Instance details Defined in Network.Nakadi.Internal.Lenses Methods payload :: Lens' (DataChangeEvent a) a
HasNakadiMetadata (DataChangeEvent a) EventMetadata
Instance details Defined in Network.Nakadi.Internal.Lenses Methods metadata :: Lens' (DataChangeEvent a) EventMetadata
HasNakadiDataType (DataChangeEvent a) Text
Instance details Defined in Network.Nakadi.Internal.Lenses Methods dataType :: Lens' (DataChangeEvent a) Text
HasNakadiDataOp (DataChangeEvent a) DataOp
Instance details Defined in Network.Nakadi.Internal.Lenses Methods dataOp :: Lens' (DataChangeEvent a) DataOp
type Rep (DataChangeEvent a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep (DataChangeEvent a) = D1 (MetaData "DataChangeEvent" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "DataChangeEvent" PrefixI True) ((S1 (MetaSel (Just "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 a) :: S1 (MetaSel (Just "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventMetadata)) :: (S1 (MetaSel (Just "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 DataOp))))

data DataChangeEventEnriched a Source #

A DataChangeEvent enriched by Nakadi

Constructors

DataChangeEventEnriched
Fields _payload :: a _metadata :: EventMetadataEnriched _dataType :: Text _dataOp :: DataOp

Instances

Eq a => Eq (DataChangeEventEnriched a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: DataChangeEventEnriched a -> DataChangeEventEnriched a -> Bool # (/=) :: DataChangeEventEnriched a -> DataChangeEventEnriched a -> Bool #
Show a => Show (DataChangeEventEnriched a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> DataChangeEventEnriched a -> ShowS # show :: DataChangeEventEnriched a -> String # showList :: [DataChangeEventEnriched a] -> ShowS #
Generic (DataChangeEventEnriched a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep (DataChangeEventEnriched a) :: Type -> Type # Methods from :: DataChangeEventEnriched a -> Rep (DataChangeEventEnriched a) x # to :: Rep (DataChangeEventEnriched a) x -> DataChangeEventEnriched a #
ToJSON a => ToJSON (DataChangeEventEnriched a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: DataChangeEventEnriched a -> Value # toEncoding :: DataChangeEventEnriched a -> Encoding # toJSONList :: [DataChangeEventEnriched a] -> Value # toEncodingList :: [DataChangeEventEnriched a] -> Encoding #
FromJSON a => FromJSON (DataChangeEventEnriched a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser (DataChangeEventEnriched a) # parseJSONList :: Value -> Parser [DataChangeEventEnriched a] #
HasNakadiPayload (DataChangeEventEnriched a) a
Instance details Defined in Network.Nakadi.Internal.Lenses Methods payload :: Lens' (DataChangeEventEnriched a) a
HasNakadiMetadata (DataChangeEventEnriched a) EventMetadataEnriched
Instance details Defined in Network.Nakadi.Internal.Lenses Methods metadata :: Lens' (DataChangeEventEnriched a) EventMetadataEnriched
HasNakadiDataType (DataChangeEventEnriched a) Text
Instance details Defined in Network.Nakadi.Internal.Lenses Methods dataType :: Lens' (DataChangeEventEnriched a) Text
HasNakadiDataOp (DataChangeEventEnriched a) DataOp
Instance details Defined in Network.Nakadi.Internal.Lenses Methods dataOp :: Lens' (DataChangeEventEnriched a) DataOp
type Rep (DataChangeEventEnriched a) Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep (DataChangeEventEnriched a) = D1 (MetaData "DataChangeEventEnriched" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "DataChangeEventEnriched" PrefixI True) ((S1 (MetaSel (Just "_payload") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 a) :: S1 (MetaSel (Just "_metadata") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventMetadataEnriched)) :: (S1 (MetaSel (Just "_dataType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text) :*: S1 (MetaSel (Just "_dataOp") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 DataOp))))

data BusinessEvent a Source #

Type modelling a "Business Event". Their JSON encodings are special since the payload object is directly enriched with a metadata field. "Data Change Events" on the other side are JSON-encoded such that the complete event payload is contained in a seperate object field.

On the Haskell API side we split payload from meta data, which requires us to write custom ToJSON and FromJSON implementations.

Constructors

BusinessEvent
Fields _payload :: a Event Payload. _metadata :: EventMetadata Event Metadata.

Instances

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

data BusinessEventEnriched a Source #

Type modelling a Nakadi-enriched "Business Event". JSON encoding is basically the same as for the non-enriched Business Events.

Constructors

BusinessEventEnriched
Fields _payload :: a _metadata :: EventMetadataEnriched

Instances

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

data DataOp Source #

Type for "data_op" as contained in the DataChangeEvent.

Constructors

DataOpCreation
DataOpUpdate
DataOpDeletion
DataOpSnapshot

Instances

Eq DataOp Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: DataOp -> DataOp -> Bool # (/=) :: DataOp -> DataOp -> Bool #
Ord DataOp Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: DataOp -> DataOp -> Ordering # (<) :: DataOp -> DataOp -> Bool # (<=) :: DataOp -> DataOp -> Bool # (>) :: DataOp -> DataOp -> Bool # (>=) :: DataOp -> DataOp -> Bool # max :: DataOp -> DataOp -> DataOp # min :: DataOp -> DataOp -> DataOp #
Show DataOp Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> DataOp -> ShowS # show :: DataOp -> String # showList :: [DataOp] -> ShowS #
ToJSON DataOp Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: DataOp -> Value # toEncoding :: DataOp -> Encoding # toJSONList :: [DataOp] -> Value # toEncodingList :: [DataOp] -> Encoding #
FromJSON DataOp Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser DataOp # parseJSONList :: Value -> Parser [DataOp] #
HasNakadiDataOp (DataChangeEvent a) DataOp
Instance details Defined in Network.Nakadi.Internal.Lenses Methods dataOp :: Lens' (DataChangeEvent a) DataOp
HasNakadiDataOp (DataChangeEventEnriched a) DataOp
Instance details Defined in Network.Nakadi.Internal.Lenses Methods dataOp :: Lens' (DataChangeEventEnriched a) DataOp

data EventMetadata Source #

Type of published event metadata values.

Constructors

EventMetadata
Fields _eid :: EventId _occurredAt :: Timestamp _parentEids :: Maybe [EventId] _partition :: Maybe PartitionName _partitionCompactionKey :: Maybe PartitionCompactionKey

Instances

Eq EventMetadata Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventMetadata -> EventMetadata -> Bool # (/=) :: EventMetadata -> EventMetadata -> Bool #
Show EventMetadata Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventMetadata -> ShowS # show :: EventMetadata -> String # showList :: [EventMetadata] -> ShowS #
Generic EventMetadata Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventMetadata :: Type -> Type # Methods from :: EventMetadata -> Rep EventMetadata x # to :: Rep EventMetadata x -> EventMetadata #
ToJSON EventMetadata Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventMetadata -> Value # toEncoding :: EventMetadata -> Encoding # toJSONList :: [EventMetadata] -> Value # toEncodingList :: [EventMetadata] -> Encoding #
FromJSON EventMetadata Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventMetadata # parseJSONList :: Value -> Parser [EventMetadata] #
HasNakadiOccurredAt EventMetadata Timestamp
Instance details Defined in Network.Nakadi.Internal.Lenses Methods occurredAt :: Lens' EventMetadata Timestamp
HasNakadiEid EventMetadata EventId
Instance details Defined in Network.Nakadi.Internal.Lenses Methods eid :: Lens' EventMetadata EventId
HasNakadiPartition EventMetadata (Maybe PartitionName)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partition :: Lens' EventMetadata (Maybe PartitionName)
HasNakadiPartitionCompactionKey EventMetadata (Maybe PartitionCompactionKey)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods partitionCompactionKey :: Lens' EventMetadata (Maybe PartitionCompactionKey)
HasNakadiParentEids EventMetadata (Maybe [EventId])
Instance details Defined in Network.Nakadi.Internal.Lenses Methods parentEids :: Lens' EventMetadata (Maybe [EventId])
HasNakadiMetadata (DataChangeEvent a) EventMetadata
Instance details Defined in Network.Nakadi.Internal.Lenses Methods metadata :: Lens' (DataChangeEvent a) EventMetadata
HasNakadiMetadata (BusinessEvent a) EventMetadata
Instance details Defined in Network.Nakadi.Internal.Lenses Methods metadata :: Lens' (BusinessEvent a) EventMetadata
type Rep EventMetadata Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventMetadata = D1 (MetaData "EventMetadata" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "EventMetadata" PrefixI True) ((S1 (MetaSel (Just "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventId) :: S1 (MetaSel (Just "_occurredAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Timestamp)) :: (S1 (MetaSel (Just "_parentEids") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe [EventId])) :: (S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe PartitionName)) :: S1 (MetaSel (Just "_partitionCompactionKey") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe PartitionCompactionKey))))))

data EventMetadataEnriched Source #

Type of event metadata enriched by Nakadi

Constructors

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

Instances

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

data EventTypeStatistics Source #

Type for event type statistics.

Constructors

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

Instances

Eq EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods (==) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (/=) :: EventTypeStatistics -> EventTypeStatistics -> Bool #
Ord EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods compare :: EventTypeStatistics -> EventTypeStatistics -> Ordering # (<) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (<=) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (>) :: EventTypeStatistics -> EventTypeStatistics -> Bool # (>=) :: EventTypeStatistics -> EventTypeStatistics -> Bool # max :: EventTypeStatistics -> EventTypeStatistics -> EventTypeStatistics # min :: EventTypeStatistics -> EventTypeStatistics -> EventTypeStatistics #
Show EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods showsPrec :: Int -> EventTypeStatistics -> ShowS # show :: EventTypeStatistics -> String # showList :: [EventTypeStatistics] -> ShowS #
Generic EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Associated Types type Rep EventTypeStatistics :: Type -> Type # Methods from :: EventTypeStatistics -> Rep EventTypeStatistics x # to :: Rep EventTypeStatistics x -> EventTypeStatistics #
Hashable EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods hashWithSalt :: Int -> EventTypeStatistics -> Int # hash :: EventTypeStatistics -> Int #
ToJSON EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods toJSON :: EventTypeStatistics -> Value # toEncoding :: EventTypeStatistics -> Encoding # toJSONList :: [EventTypeStatistics] -> Value # toEncodingList :: [EventTypeStatistics] -> Encoding #
FromJSON EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service Methods parseJSON :: Value -> Parser EventTypeStatistics # parseJSONList :: Value -> Parser [EventTypeStatistics] #
HasNakadiDefaultStatistic EventType (Maybe EventTypeStatistics)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods defaultStatistic :: Lens' EventType (Maybe EventTypeStatistics)
type Rep EventTypeStatistics Source #
Instance details Defined in Network.Nakadi.Internal.Types.Service type Rep EventTypeStatistics = D1 (MetaData "EventTypeStatistics" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.7.0.0-KOzkX3CyJmv3p5G5yolcIB" False) (C1 (MetaCons "EventTypeStatistics" PrefixI True) ((S1 (MetaSel (Just "_messagesPerMinute") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Int64) :: S1 (MetaSel (Just "_messageSize") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Int64)) :: (S1 (MetaSel (Just "_readParallelism") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Int64) :*: S1 (MetaSel (Just "_writeParallelism") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Int64))))

data EventTypeOptions Source #

Type for event type options.

Constructors

EventTypeOptions
Fields _retentionTime :: Int64

Instances

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