Copyright	(c) Moritz Schulte 2017
License	BSD3
Maintainer	mtesseract@silverratio.net
Stability	experimental
Portability	POSIX
Safe Haskell	None
Language	Haskell2010

Network.Nakadi.Subscriptions

Description

This module implements the /subscriptions API.

Synopsis

Documentation

module Network.Nakadi.Subscriptions.Cursors

module Network.Nakadi.Subscriptions.Events

module Network.Nakadi.Subscriptions.Stats

module Network.Nakadi.Subscriptions.Subscription

subscriptionCreate' :: MonadNakadi m => Config -> Subscription -> m Subscription Source #

POST to /subscriptions. Creates a new subscription. Low level interface.

subscriptionCreateR' :: MonadNakadiEnv r m => Subscription -> m Subscription Source #

POST to /subscriptions. Creates a new subscription. Low level interface. Retrieves configuration from the environment.

subscriptionCreate :: MonadNakadi m => Config -> Subscription -> m Subscription Source #

POST to /subscriptions. Creates a new subscription. Does not fail if the requested subscription does already exist.

subscriptionCreateR :: MonadNakadiEnv r m => Subscription -> m Subscription Source #

POST to /subscriptions. Creates a new subscription. Does not fail if the requested subscription does already exist. Retrieves configuration from the environment.

subscriptionsList' :: MonadNakadi m => Config -> Maybe ApplicationName -> Maybe [EventTypeName] -> Maybe Limit -> Maybe Offset -> m SubscriptionsListResponse Source #

GET to /subscriptions. Retrieves all subscriptions matching the provided filter criteria. Low-level interface using pagination.

subscriptionsListR' :: (MonadNakadiEnv r m, MonadMask m) => Maybe ApplicationName -> Maybe [EventTypeName] -> Maybe Limit -> Maybe Offset -> m SubscriptionsListResponse Source #

GET to /subscriptions. Retrieves all subscriptions matching the provided filter criteria. Uses configuration contained in the environment.

subscriptionsSource :: (MonadNakadi m, MonadMask m) => Config -> Maybe ApplicationName -> Maybe [EventTypeName] -> Source m [Subscription] Source #

GET to /subscriptions. Retrieves all subscriptions matching the provided filter criteria. High-level Conduit interface.

subscriptionsSourceR :: (MonadNakadiEnv r m, MonadMask m) => Maybe ApplicationName -> Maybe [EventTypeName] -> Source m [Subscription] Source #

GET to /subscriptions. Retrieves all subscriptions matching the provided filter criteria. High-level Conduit interface, obtaining the configuration from the environment.

subscriptionsList :: (MonadNakadi m, MonadMask m) => Config -> Maybe ApplicationName -> Maybe [EventTypeName] -> m [Subscription] Source #

GET to /subscriptions. Retrieves all subscriptions matching the provided filter criteria. High-level list interface.

subscriptionsListR :: (MonadNakadiEnv r m, MonadMask m) => Maybe ApplicationName -> Maybe [EventTypeName] -> m [Subscription] Source #

GET to /subscriptions. Retrieves all subscriptions matching the provided filter criteria. High-level Conduit interface, obtaining the configuration from the environment.