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

Defined in Network.UI.Kafka

Methods

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

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

Read TopicConnection

Defined in Network.UI.Kafka

Methods

readsPrec :: Int -> ReadS TopicConnection

readList :: ReadS [TopicConnection]

readPrec :: ReadPrec TopicConnection

readListPrec :: ReadPrec [TopicConnection]

Show TopicConnection

Defined in Network.UI.Kafka

Methods

showsPrec :: Int -> TopicConnection -> ShowS

show :: TopicConnection -> String

showList :: [TopicConnection] -> ShowS

Generic TopicConnection

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

Defined in Network.UI.Kafka

Methods

toJSON :: TopicConnection -> Value

toEncoding :: TopicConnection -> Encoding

toJSONList :: [TopicConnection] -> Value

toEncodingList :: [TopicConnection] -> Encoding

FromJSON TopicConnection

Defined in Network.UI.Kafka

Methods

parseJSON :: Value -> Parser TopicConnection

parseJSONList :: Value -> Parser [TopicConnection]

type Rep TopicConnection

Defined in Network.UI.Kafka

type Rep TopicConnection = D1 (MetaData "TopicConnection" "Network.UI.Kafka" "kafka-device-1.0.2.1-7kJVqFIu9rZFmREYnQHF34" 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

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.

rawConsumerLoop

Arguments

:: TopicConnection

The Kafka topic name and connection information.

-> (Message -> a)

The decoder.

-> (a -> IO ())

The consumer callback.

-> IO (ExitAction, LoopAction)

Action to create the exit and loop actions.

Consume messages 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.

rawProducerLoop

Arguments

:: TopicConnection

The Kafka topic name and connection information.

-> (a -> Message)

The encoder.

-> IO [a]

The producer callback.

-> IO (ExitAction, LoopAction)

Action to create the exit and loop actions.

Produce messages for a Kafka topic.