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

Copyright(c) Moritz Schulte 2017
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 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.

subscriptionCommit Source #

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.

subscriptionCursors Source #

Arguments

:: MonadNakadi m 
=> Config

Configuration

-> SubscriptionId

Subscription ID

-> m [SubscriptionCursor]

Subscription Cursors for the specified Subscription

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

subscriptionCursorsR Source #

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.