nakadi: Client library for the Nakadi Event Broker

This is a package candidate release! Here you can preview how this package release will appear once published to the main package index (which can be accomplished via the 'maintain' link below). Please note that once a package has been published to the main package index it cannot be undone! Please consult the package uploading documentation for more information.

[maintain] [Publish]

This package implements a client library for interacting with the Nakadi event broker system developed by Zalando.

[Skip to Readme]

Properties

Versions	0.2.0.0
Change log	None available
Dependencies	aeson, aeson-casing, base (>=4.7 && <5), bytestring, conduit, conduit-combinators, conduit-extra, containers, hashable, http-client, http-client-tls, http-conduit, http-types, iso8601-time, lens, monad-logger, mtl, resourcet, safe-exceptions, scientific, split, text, time, transformers, unordered-containers, uuid, vector [details]
License	BSD-3-Clause
Copyright	(c) 2017 Moritz Schulte
Author	Moritz Schulte
Maintainer	mtesseract@silverratio.net
Category	Network
Home page	https://github.com/mtesseract/nakadi-haskell#readme
Bug tracker	https://github.com/mtesseract/nakadi-haskell/issues
Source repo	head: git clone https://github.com/mtesseract/nakadi-haskell
Uploaded	by mtesseract at 2017-09-05T21:33:00Z

Modules

Network
- Network.Nakadi
  - Network.Nakadi.Types

Downloads

nakadi-0.2.0.0.tar.gz [browse] (Cabal source package)
Package description (as included in the package)

Maintainer's Corner

Package maintainers

mtesseract

For package maintainers and hackage trustees

edit package information

Readme for nakadi-0.2.0.0

[back to package description]

nakadi-haskell

About

nakadi-haskell is a Haskell client library for interacting with the Nakadi event broker system developed by Zalando. The streaming is built on top of Conduit.

The API is not considered stable yet.

Example

Example using the Subscription API:

import qualified Nakadi

processSubscription :: Nakadi.SubscriptionId -> IO ()
processSubscription subscriptionId = do
  runResourceT $ do
    (connection, source) <- Nakadi.subscriptionSource config Nothing subscriptionId
    Nakadi.runSubscription config connection $
      source .| iterMC processEvent .| Nakadi.subscriptionSink