Copyright	(c) 2016-19 Brian W Bush
License	MIT
Maintainer	Brian W Bush <code@functionally.io>
Stability	Production
Portability	Portable
Safe Haskell	None
Language	Haskell2010

Network.UI.Kafka

Contents

Types
Consumption
Production

Description

Produce and consume events on Kafka topics.

Synopsis

data TopicConnection = TopicConnection {
- client :: String
- address :: (String, Int)
- topic :: String
}
type Sensor = String
type LoopAction = IO (Either KafkaClientError ())
type ExitAction = IO ()
type ConsumerCallback = Sensor -> Event -> IO ()
consumerLoop :: TopicConnection -> ConsumerCallback -> IO (ExitAction, LoopAction)
type ProducerCallback = IO [Event]
producerLoop :: TopicConnection -> Sensor -> ProducerCallback -> IO (ExitAction, LoopAction)

Types

data TopicConnection Source #

Connection information for a Kafka topic.

Constructors

TopicConnection
Fields client :: String A name for the Kafka client. address :: (String, Int) The host name and port for the Kafka broker. topic :: String The Kafka topic name.

Instances

Eq TopicConnection Source #
Instance details Defined in Network.UI.Kafka Methods (==) :: TopicConnection -> TopicConnection -> Bool # (/=) :: TopicConnection -> TopicConnection -> Bool #
Read TopicConnection Source #
Instance details Defined in Network.UI.Kafka Methods readsPrec :: Int -> ReadS TopicConnection # readList :: ReadS [TopicConnection] # readPrec :: ReadPrec TopicConnection # readListPrec :: ReadPrec [TopicConnection] #
Show TopicConnection Source #
Instance details Defined in Network.UI.Kafka Methods showsPrec :: Int -> TopicConnection -> ShowS # show :: TopicConnection -> String # showList :: [TopicConnection] -> ShowS #
Generic TopicConnection Source #
Instance details Defined in Network.UI.Kafka Associated Types type Rep TopicConnection :: Type -> Type # Methods from :: TopicConnection -> Rep TopicConnection x # to :: Rep TopicConnection x -> TopicConnection #
ToJSON TopicConnection Source #
Instance details Defined in Network.UI.Kafka Methods toJSON :: TopicConnection -> Value # toEncoding :: TopicConnection -> Encoding # toJSONList :: [TopicConnection] -> Value # toEncodingList :: [TopicConnection] -> Encoding #
FromJSON TopicConnection Source #
Instance details Defined in Network.UI.Kafka Methods parseJSON :: Value -> Parser TopicConnection # parseJSONList :: Value -> Parser [TopicConnection] #
type Rep TopicConnection Source #
Instance details Defined in Network.UI.Kafka type Rep TopicConnection = D1 (MetaData "TopicConnection" "Network.UI.Kafka" "kafka-device-1.0.0.0-EqsHhyPPoUkHjkzPUXhYxI" False) (C1 (MetaCons "TopicConnection" PrefixI True) (S1 (MetaSel (Just "client") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 String) :: (S1 (MetaSel (Just "address") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (String, Int)) :: S1 (MetaSel (Just "topic") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 String))))

type Sensor = String Source #

A name for a sensor.

type LoopAction = IO (Either KafkaClientError ()) Source #

Action for iterating to produce or consume events.

type ExitAction = IO () Source #

Action for ending iteration.

Consumption

type ConsumerCallback Source #

Arguments

= Sensor	The name of the sensor producing the event.
-> Event	The event.
-> IO ()	The action for consuming the event.

Callback for consuming events from a sensor.

consumerLoop Source #

Arguments

:: TopicConnection	The Kafka topic name and connection information.
-> ConsumerCallback	The consumer callback.
-> IO (ExitAction, LoopAction)	Action to create the exit and loop actions.

Consume events for a Kafka topic.

Production

type ProducerCallback Source #

Arguments

= IO [Event]

Action for producing events.

Callback for producing events from a sensor.

producerLoop Source #

Arguments

:: TopicConnection	The Kafka topic name and connection information.
-> Sensor	The name of the sensor producing the event.
-> ProducerCallback	The producer callback.
-> IO (ExitAction, LoopAction)	Action to create the exit and loop actions.

Produce events for a Kafka topic.