| 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.
- 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
- subscriptionCreateR' :: MonadNakadiEnv r m => Subscription -> m Subscription
- subscriptionCreate :: MonadNakadi m => Config -> Subscription -> m Subscription
- subscriptionCreateR :: MonadNakadiEnv r m => Subscription -> m Subscription
- subscriptionsList' :: MonadNakadi m => Config -> Maybe ApplicationName -> Maybe [EventTypeName] -> Maybe Limit -> Maybe Offset -> m SubscriptionsListResponse
- subscriptionsListR' :: (MonadNakadiEnv r m, MonadMask m) => Maybe ApplicationName -> Maybe [EventTypeName] -> Maybe Limit -> Maybe Offset -> m SubscriptionsListResponse
- subscriptionsSource :: (MonadNakadi m, MonadMask m) => Config -> Maybe ApplicationName -> Maybe [EventTypeName] -> Source m [Subscription]
- subscriptionsSourceR :: (MonadNakadiEnv r m, MonadMask m) => Maybe ApplicationName -> Maybe [EventTypeName] -> Source m [Subscription]
- subscriptionsList :: (MonadNakadi m, MonadMask m) => Config -> Maybe ApplicationName -> Maybe [EventTypeName] -> m [Subscription]
- subscriptionsListR :: (MonadNakadiEnv r m, MonadMask m) => Maybe ApplicationName -> Maybe [EventTypeName] -> m [Subscription]
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.