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

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

Network.Nakadi.Subscriptions

Description

This module implements the /subscriptions API.

Synopsis

Documentation

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.