| Copyright | (c) Moritz Schulte 2017 |
|---|---|
| License | BSD3 |
| Maintainer | mtesseract@silverratio.net |
| Stability | experimental |
| Portability | POSIX |
| Safe Haskell | None |
| Language | Haskell2010 |
Network.Nakadi.EventTypes.Events
Description
This module implements the
/event-types/EVENT-TYPE/events API.
- eventSource :: (MonadNakadi m, MonadResource m, MonadBaseControl IO m, MonadMask m, FromJSON a) => Config -> Maybe ConsumeParameters -> EventTypeName -> Maybe [Cursor] -> m (ConduitM () (EventStreamBatch a) m ())
- eventSourceR :: (MonadNakadiEnv r m, MonadResource m, MonadBaseControl IO m, MonadMask m, FromJSON a) => Maybe ConsumeParameters -> EventTypeName -> Maybe [Cursor] -> m (ConduitM () (EventStreamBatch a) m ())
- eventPublish :: (MonadNakadi m, ToJSON a) => Config -> EventTypeName -> Maybe FlowId -> [a] -> m ()
- eventPublishR :: (MonadNakadiEnv r m, ToJSON a) => EventTypeName -> Maybe FlowId -> [a] -> m ()
Documentation
Arguments
| :: (MonadNakadi m, MonadResource m, MonadBaseControl IO m, MonadMask m, FromJSON a) | |
| => Config | Configuration parameter |
| -> Maybe ConsumeParameters | Optional parameters for event consumption |
| -> EventTypeName | Name of the event type to consume |
| -> Maybe [Cursor] | Optional list of cursors; by default consumption begins with the most recent event |
| -> m (ConduitM () (EventStreamBatch a) m ()) | Returns a Conduit source. |
GET to /event-types/NAME/events. Returns Conduit source
for event batch consumption.
Arguments
| :: (MonadNakadiEnv r m, MonadResource m, MonadBaseControl IO m, MonadMask m, FromJSON a) | |
| => Maybe ConsumeParameters | Optional parameters for event consumption |
| -> EventTypeName | Name of the event type to consume |
| -> Maybe [Cursor] | Optional list of cursors; by default consumption begins with the most recent event |
| -> m (ConduitM () (EventStreamBatch a) m ()) | Returns a Conduit source. |
GET to /event-types/NAME/events. Returns Conduit source
for event batch consumption. Retrieves configuration from
environment.
eventPublish :: (MonadNakadi m, ToJSON a) => Config -> EventTypeName -> Maybe FlowId -> [a] -> m () Source #
POST to /event-types/NAME/events. Publishes a batch of
events for the specified event type.
eventPublishR :: (MonadNakadiEnv r m, ToJSON a) => EventTypeName -> Maybe FlowId -> [a] -> m () Source #
POST to /event-types/NAME/events. Publishes a batch of
events for the specified event type. Uses the configuration from
the environment.