| Copyright | (c) Moritz Schulte 2017 2018 |
|---|---|
| License | BSD3 |
| Maintainer | mtesseract@silverratio.net |
| Stability | experimental |
| Portability | POSIX |
| Safe Haskell | None |
| Language | Haskell2010 |
Network.Nakadi.Subscriptions.Cursors
Description
This module implements the /subscriptions/SUBSCRIPTIONS/cursors
API.
- subscriptionCursorCommit' :: MonadNakadi b m => SubscriptionId -> StreamId -> SubscriptionCursorCommit -> m ()
- subscriptionCursorCommit :: (MonadNakadi b m, MonadCatch m, HasNakadiSubscriptionCursor a) => SubscriptionEventStream -> [a] -> m ()
- subscriptionCursors :: MonadNakadi b m => SubscriptionId -> m [SubscriptionCursor]
- subscriptionCursorsReset :: MonadNakadi b m => SubscriptionId -> [SubscriptionCursorWithoutToken] -> m ()
Documentation
subscriptionCursorCommit' Source #
Arguments
| :: MonadNakadi b m | |
| => SubscriptionId | Subsciption ID |
| -> StreamId | Stream ID |
| -> SubscriptionCursorCommit | Subscription Cursor to commit |
| -> m () |
POST to /subscriptions/SUBSCRIPTION-ID/cursors. Commits
cursors using low level interface.
subscriptionCursorCommit Source #
Arguments
| :: (MonadNakadi b m, MonadCatch m, HasNakadiSubscriptionCursor a) | |
| => SubscriptionEventStream | |
| -> [a] | Values containing Subscription Cursors to commit |
| -> m () |
POST to /subscriptions/SUBSCRIPTION/cursors. Commits
cursors using high level interface.
Arguments
| :: MonadNakadi b m | |
| => SubscriptionId | Subscription ID |
| -> m [SubscriptionCursor] | Subscription Cursors for the specified Subscription |
GET to /subscriptions/SUBSCRIPTION/cursors. Retrieves
subscriptions cursors.
subscriptionCursorsReset Source #
Arguments
| :: MonadNakadi b m | |
| => SubscriptionId | Subscription ID |
| -> [SubscriptionCursorWithoutToken] | Subscription Cursors to reset |
| -> m () |
PATCH to /subscriptions/SUBSCRIPTION/cursors. Resets
subscriptions cursors.