| Copyright | (c) Moritz Schulte 2017 |
|---|---|
| License | BSD3 |
| Maintainer | mtesseract@silverratio.net |
| Stability | experimental |
| Portability | POSIX |
| Safe Haskell | None |
| Language | Haskell2010 |
Network.Nakadi.EventTypes.CursorsLag
Description
This module implements the
/event-types/EVENT-TYPE/cursors-lag API.
- cursorsLag' :: MonadNakadi m => Config -> EventTypeName -> [Cursor] -> m [Partition]
- cursorsLagR' :: MonadNakadiEnv r m => EventTypeName -> [Cursor] -> m [Partition]
- cursorsLag :: MonadNakadi m => Config -> EventTypeName -> Map PartitionName CursorOffset -> m (Map PartitionName Int64)
- cursorsLagR :: MonadNakadiEnv r m => EventTypeName -> Map PartitionName CursorOffset -> m (Map PartitionName Int64)
Documentation
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.
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.
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.
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.