nakadi-client-0.5.0.3: Client library for the Nakadi Event Broker

Copyright(c) Moritz Schulte 2017 2018
LicenseBSD3
Maintainermtesseract@silverratio.net
Stabilityexperimental
PortabilityPOSIX
Safe HaskellNone
LanguageHaskell2010

Network.Nakadi.EventTypes.CursorsLag

Description

This module implements the /event-types/EVENT-TYPE/cursors-lag API.

Synopsis

Documentation

cursorsLag' Source #

Arguments

:: MonadNakadi b m 
=> EventTypeName

Event Type

-> [Cursor]

Cursors for which to compute the lag for

-> m [Partition]

Resulting partition information containing information about unconsumed events.

POST to /event-types/EVENT-TYPE/cursors-lag. Low level interface.

cursorsLag Source #

Arguments

:: MonadNakadi b m 
=> EventTypeName

Event Type

-> Map PartitionName CursorOffset

Cursor offsets associated to partitions.

-> m (Map PartitionName Int64)

Cursor lags associated to partitions.

POST to /event-types/EVENT-TYPE/cursors-lag. High level interface.