fluent-logger-conduit 0.1.0.0 → 0.2.0.0

raw patch · 2 files changed

+7/−7 lines, 2 filesdep ~conduit

Dependency ranges changed: conduit

Files

• Network/Fluent/Conduit.hs +5/−5
• fluent-logger-conduit.cabal +2/−2

@@ -24,14 +24,14 @@ import Network.Fluent.Logger ( FluentSettings, FluentLogger, newFluentLogger, closeFluentLogger, post ) import Control.Monad.IO.Class ( liftIO ) import Data.ByteString ( ByteString )-import Data.Conduit ( MonadResource, GInfSink, bracketP, awaitForever )+import Data.Conduit ( MonadResource, bracketP, awaitForever, Consumer ) import Data.MessagePack ( Packable )  -- | Stream all incoming pair ( label, data ) to the given Fluent. ----- Since 0.1.0.0+-- Since 0.2.0.0 ---sinkFluent :: (MonadResource m, Packable a) => FluentSettings -> GInfSink (ByteString, a) m+sinkFluent :: (MonadResource m, Packable a) => FluentSettings -> Consumer (ByteString, a) m () sinkFluent set = bracketP                  (newFluentLogger set)                  (liftIO . closeFluentLogger)@@ -39,7 +39,7 @@  -- | Stream all incoming pair ( label, data ) to the given Fluent logger. ----- Since 0.1.0.0+-- Since 0.2.0.0 ---sinkFluentWithLogger :: (MonadResource m, Packable a) => FluentLogger -> GInfSink (ByteString, a) m+sinkFluentWithLogger :: (MonadResource m, Packable a) => FluentLogger -> Consumer (ByteString, a) m () sinkFluentWithLogger logger = awaitForever $ liftIO . uncurry (post logger)

@@ -1,5 +1,5 @@ name:                fluent-logger-conduit-version:             0.1.0.0+version:             0.2.0.0 synopsis:            Conduit interface for fluent-logger description:         Conduit interface for fluent-logger license:             OtherLicense@@ -21,6 +21,6 @@   build-depends:       base ==4.*                      , bytestring                      , fluent-logger >=0.1 && <0.2-                     , conduit >=0.5 && <0.6+                     , conduit >= 1.0 && <1.1                      , transformers >=0.2                      , msgpack >=0.7.1 && <0.8