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

Copyright(c) Moritz Clasmeier 2017 2018
LicenseBSD3
Maintainermtesseract@silverratio.net
Stabilityexperimental
PortabilityPOSIX
Safe HaskellNone
LanguageHaskell2010

Network.Nakadi.Subscriptions.Cursors

Description

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

Synopsis

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.

subscriptionCursors Source #

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.