Network.UI.Kafka

Produce and consume events on Kafka topics.

Types

data TopicConnection

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

Methods

(==) :: TopicConnection -> TopicConnection -> Bool

(/=) :: TopicConnection -> TopicConnection -> Bool

Read TopicConnection

Methods

readsPrec :: Int -> ReadS TopicConnection

readList :: ReadS [TopicConnection]

readPrec :: ReadPrec TopicConnection

readListPrec :: ReadPrec [TopicConnection]

Show TopicConnection

Methods

showsPrec :: Int -> TopicConnection -> ShowS

show :: TopicConnection -> String

showList :: [TopicConnection] -> ShowS

Generic TopicConnection

Associated Types

type Rep TopicConnection :: * -> *

Methods

from :: TopicConnection -> Rep TopicConnection x

to :: Rep TopicConnection x -> TopicConnection

ToJSON TopicConnection

Methods

toJSON :: TopicConnection -> Value

toEncoding :: TopicConnection -> Encoding

toJSONList :: [TopicConnection] -> Value

toEncodingList :: [TopicConnection] -> Encoding

FromJSON TopicConnection

Methods

parseJSON :: Value -> Parser TopicConnection

parseJSONList :: Value -> Parser [TopicConnection]

type Rep TopicConnection

type Rep TopicConnection = D1 * (MetaData "TopicConnection" "Network.UI.Kafka" "kafka-device-1.0.0.0-7U9qgkxLORxLpEJz1lnLpE" False) (C1 * (MetaCons "TopicConnection" PrefixI True) ((:*:) * (S1 * (MetaSel (Just Symbol "client") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * String)) ((:*:) * (S1 * (MetaSel (Just Symbol "address") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (String, Int))) (S1 * (MetaSel (Just Symbol "topic") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * String)))))

type Sensor = String

A name for a sensor.

type LoopAction = IO (Either KafkaClientError ())

Action for iterating to produce or consume events.

type ExitAction = IO ()

Action for ending iteration.

Consumption

type ConsumerCallback

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

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

Arguments

 = IO [Event]

Action for producing events.

Callback for producing events from a sensor.

producerLoop

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.