nakadi-client: 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]

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


[Skip to ReadMe]

Properties

Versions0.2.0.0, 0.2.0.1, 0.3.0.0, 0.4.0.0, 0.4.1.0, 0.4.1.0, 0.5.0.0, 0.5.0.1, 0.5.0.3, 0.5.1.0, 0.6.0.0, 0.6.1.0
Change logNone available
Dependenciesaeson, 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, retry, safe-exceptions, scientific, split, template-haskell, text, time, transformers, unordered-containers, uuid, vector [details]
LicenseBSD-3-Clause
Copyright(c) 2017 Moritz Schulte
AuthorMoritz Schulte
Maintainermtesseract@silverratio.net
CategoryNetwork
Home pagehttps://github.com/mtesseract/nakadi-haskell#readme
Bug trackerhttps://github.com/mtesseract/nakadi-haskell/issues
Source repositoryhead: git clone https://github.com/mtesseract/nakadi-haskell
UploadedMon Jan 29 11:36:00 UTC 2018 by mtesseract

Modules

[Index]

Flags

NameDescriptionDefaultType
develDisabledManual

Use -f <flag> to enable a flag, or -f -<flag> to disable that flag. More info

Downloads

Maintainers' corner

For package maintainers and hackage trustees


Readme for nakadi-client-0.4.1.0

[back to package description]

nakadi-client Hackage version Stackage version Build Status

About

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

Please note that the API is not considered stable yet.

nakadi-client provides:

Example

Example using the Subscription API:

import qualified Network.Nakadi as 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