Network.Nakadi.Subscriptions.Cursors

This module implements the /subscriptions/SUBSCRIPTIONS/cursors API.

Documentation

subscriptionCursorCommit'

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

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.

subscriptionCursors

Arguments

:: MonadNakadi b m

=> SubscriptionId

Subscription ID

-> m [SubscriptionCursor]

Subscription Cursors for the specified Subscription

GET to /subscriptions/SUBSCRIPTION/cursors. Retrieves subscriptions cursors.

subscriptionCursorsReset

Arguments

:: MonadNakadi b m

=> SubscriptionId

Subscription ID

-> [SubscriptionCursorWithoutToken]

Subscription Cursors to reset

-> m ()

PATCH to /subscriptions/SUBSCRIPTION/cursors. Resets subscriptions cursors.