| Copyright | (c) Moritz Schulte 2017 2018 |
|---|---|
| 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.
- module Network.Nakadi.Subscriptions.Cursors
- module Network.Nakadi.Subscriptions.Events
- module Network.Nakadi.Subscriptions.Stats
- module Network.Nakadi.Subscriptions.Subscription
- subscriptionCreate' :: MonadNakadi b m => Subscription -> m Subscription
- subscriptionCreate :: (MonadNakadi b m, MonadCatch m) => Subscription -> m Subscription
- subscriptionsList' :: MonadNakadi b m => Maybe ApplicationName -> Maybe [EventTypeName] -> Maybe Limit -> Maybe Offset -> m SubscriptionsListResponse
- subscriptionsSource :: MonadNakadi b m => Maybe ApplicationName -> Maybe [EventTypeName] -> m (ConduitM () [Subscription] m ())
- subscriptionsList :: MonadNakadi b m => Maybe ApplicationName -> Maybe [EventTypeName] -> m [Subscription]
Documentation
subscriptionCreate' :: MonadNakadi b m => Subscription -> m Subscription Source #
POST to /subscriptions. Creates a new subscription. Low
level interface.
subscriptionCreate :: (MonadNakadi b m, MonadCatch m) => Subscription -> m Subscription Source #
POST to /subscriptions. Creates a new subscription. Does not
fail if the requested subscription does already exist.
subscriptionsList' :: MonadNakadi b m => 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.
subscriptionsSource :: MonadNakadi b m => Maybe ApplicationName -> Maybe [EventTypeName] -> m (ConduitM () [Subscription] m ()) Source #
GET to /subscriptions. Retrieves all subscriptions matching
the provided filter criteria. High-level Conduit interface.
subscriptionsList :: MonadNakadi b m => Maybe ApplicationName -> Maybe [EventTypeName] -> m [Subscription] Source #
GET to /subscriptions. Retrieves all subscriptions matching
the provided filter criteria. High-level list interface.