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

Copyright(c) Moritz Schulte 2017
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 m 
=> Config

Configuration

-> 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.

cursorsLagR' Source #

Arguments

:: MonadNakadiEnv r 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, retrieving configuration from environment.

cursorsLag Source #

Arguments

:: MonadNakadi m 
=> Config

Configuration

-> 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.

cursorsLagR Source #

Arguments

:: MonadNakadiEnv r 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, retrieving configuration from environment.