packages feed

flink-statefulfun 0.1.0.0 → 0.1.0.1

raw patch · 4 files changed

+47/−7 lines, 4 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

CHANGELOG.md view
@@ -0,0 +1,10 @@+# Changelog for flink-statefulfun++## 0.1.1.0++* Update cabal file+* More docblocks++## 0.1.0.0++* Initial release
+ README.md view
@@ -0,0 +1,27 @@+# Flink Stateful Functions Haskell SDK++Provides a typed API for creating [flink stateful functions](https://flink.apache.org/news/2020/04/07/release-statefun-2.0.0.html). Greeter example is in [example/greeter/main/Main.hs](example/greeter/main/Main.hs)++## How to run example++```bash+cd example+docker-compose build+docker-compose up -d+docker-compose logs -f event-generator+```++## How to compile locally++1. [Install nix](https://nixos.org/download.html)+2. [Install cachix](https://github.com/cachix/cachix#installation)+3. Setup nix cache +```bash+cachix use iohk+cachix use static-haskell-nix+cachix use flink-statefulfun+```+4. Compile+```bash+cabal build+```
@@ -1,26 +1,27 @@ cabal-version:       2.4--- Initial package description 'policy.cabal' generated by 'cabal init'.--- For further documentation, see http://haskell.org/cabal/users-guide/  name:                flink-statefulfun-version:             0.1.0.0+version:             0.1.0.1 synopsis:            Flink stateful functions SDK description:     Typeclasses for serving Flink stateful functions     from Haskell.--- bug-reports:++    Checkout the [README for examples](https://github.com/tdbgamer/flink-statefulfun-hs). license:             MPL-2.0 license-file:        LICENSE author:              Timothy Bess maintainer:          tdbgamer@gmail.com--- copyright:--- category: --- build-type:          Simple build-type: Custom  extra-source-files:  CHANGELOG.md+                     README.md                      proto/**/*.proto++source-repository head+  type: git+  location: https://github.com/tdbgamer/flink-statefulfun-hs.git  custom-setup   setup-depends: base, Cabal, proto-lens-setup
src/Network/Flink/Stateful.hs view
@@ -280,9 +280,11 @@ flinkApi :: Proxy FlinkApi flinkApi = Proxy +-- | Takes function table and creates a wai 'Application' to serve flink requests createApp :: FunctionTable -> Application createApp funcs = serve flinkApi (flinkServer funcs) +-- | Takes function table and creates a servant 'Server' to serve flink requests flinkServer :: FunctionTable -> Server FlinkApi flinkServer functions toFunction = do   batch <- getBatch toFunction