| Copyright | (c) Moritz Schulte 2017 |
|---|---|
| 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 m => Config -> SubscriptionId -> StreamId -> SubscriptionCursorCommit -> m ()
- subscriptionCursorCommitR' :: MonadNakadiEnv r m => SubscriptionId -> StreamId -> SubscriptionCursorCommit -> m ()
- subscriptionCommit :: (MonadNakadi m, MonadCatch m, HasNakadiSubscriptionCursor a) => [a] -> ReaderT SubscriptionEventStreamContext m ()
- subscriptionCursors :: MonadNakadi m => Config -> SubscriptionId -> m [SubscriptionCursor]
- subscriptionCursorsR :: MonadNakadiEnv r m => SubscriptionId -> m [SubscriptionCursor]
- subscriptionCursorsReset :: MonadNakadi m => Config -> SubscriptionId -> [SubscriptionCursorWithoutToken] -> m ()
- subscriptionCursorsResetR :: MonadNakadiEnv r m => SubscriptionId -> [SubscriptionCursorWithoutToken] -> m ()
Documentation
subscriptionCursorCommit' Source #
Arguments
| :: MonadNakadi m | |
| => Config | Configuration |
| -> SubscriptionId | Subsciption ID |
| -> StreamId | Stream ID |
| -> SubscriptionCursorCommit | Subscription Cursor to commit |
| -> m () |
POST to /subscriptions/SUBSCRIPTION-ID/cursors. Commits
cursors using low level interface.
subscriptionCursorCommitR' Source #
Arguments
| :: MonadNakadiEnv r 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. Uses the configuration contained
in the environment.
Arguments
| :: (MonadNakadi m, MonadCatch m, HasNakadiSubscriptionCursor a) | |
| => [a] | Values containing Subscription Cursors to commit |
| -> ReaderT SubscriptionEventStreamContext m () |
POST to /subscriptions/SUBSCRIPTION/cursors. Commits
cursors using high level interface.
Arguments
| :: MonadNakadi m | |
| => Config | Configuration |
| -> SubscriptionId | Subscription ID |
| -> m [SubscriptionCursor] | Subscription Cursors for the specified Subscription |
GET to /subscriptions/SUBSCRIPTION/cursors. Retrieves
subscriptions cursors.
Arguments
| :: MonadNakadiEnv r m | |
| => SubscriptionId | Subscription ID |
| -> m [SubscriptionCursor] | Subscription Cursors for the specified Subscription |
GET to /subscriptions/SUBSCRIPTION/cursors. Retrieves
subscriptions cursors, using the configuration from the
environment.
subscriptionCursorsReset Source #
Arguments
| :: MonadNakadi m | |
| => Config | Configuration |
| -> SubscriptionId | Subscription ID |
| -> [SubscriptionCursorWithoutToken] | Subscription Cursors to reset |
| -> m () |
PATCH to /subscriptions/SUBSCRIPTION/cursors. Resets
subscriptions cursors.
subscriptionCursorsResetR Source #
Arguments
| :: MonadNakadiEnv r m | |
| => SubscriptionId | Subscription ID |
| -> [SubscriptionCursorWithoutToken] | Subscription Cursors to reset |
| -> m () |
PATCH to /subscriptions/SUBSCRIPTION/cursors. Resets
subscriptions cursors, using the configuration from the
environment.