Copyright | (c) Moritz Schulte 2017 2018 |
---|---|
License | BSD3 |
Maintainer | mtesseract@silverratio.net |
Stability | experimental |
Portability | POSIX |
Safe Haskell | None |
Language | Haskell2010 |
This module implements the
/event-types/EVENT-TYPE/events
API.
- eventsProcessConduit :: (MonadNakadi b m, MonadMask m, FromJSON a) => Maybe ConsumeParameters -> EventTypeName -> Maybe [Cursor] -> ConduitM (EventStreamBatch a) Void m r -> m r
- eventsProcess :: (MonadNakadi b m, FromJSON a) => Maybe ConsumeParameters -> EventTypeName -> Maybe [Cursor] -> (EventStreamBatch a -> m r) -> m r
- eventsPublish :: (MonadNakadi b m, ToJSON a) => EventTypeName -> [a] -> m ()
Documentation
eventsProcessConduit :: (MonadNakadi b m, MonadMask m, FromJSON a) => Maybe ConsumeParameters -> EventTypeName -> Maybe [Cursor] -> ConduitM (EventStreamBatch a) Void m r -> m r Source #
eventsProcess :: (MonadNakadi b m, FromJSON a) => Maybe ConsumeParameters -> EventTypeName -> Maybe [Cursor] -> (EventStreamBatch a -> m r) -> m r Source #
eventsPublish :: (MonadNakadi b m, ToJSON a) => EventTypeName -> [a] -> m () Source #
POST
to /event-types/NAME/events
. Publishes a batch of
events for the specified event type.