Safe Haskell	Safe-Inferred
Language	Haskell2010

Striot.Nodes.Types

Documentation

data Metrics Source #

Constructors

Metrics
Fields _ingressConn :: Gauge _ingressBytes :: Counter _ingressEvents :: Counter _egressConn :: Gauge _egressBytes :: Counter _egressEvents :: Counter

data NetConfig Source #

Constructors

NetConfig
Fields _host :: HostName _port :: ServiceName

Instances

Instances details

Show NetConfig Source #
Instance details Defined in Striot.Nodes.Types Methods showsPrec :: Int -> NetConfig -> ShowS # show :: NetConfig -> String # showList :: [NetConfig] -> ShowS #

port :: Lens' NetConfig ServiceName Source #

host :: Lens' NetConfig HostName Source #

data TCPConfig Source #

Constructors

TCPConfig
Fields _tcpConn :: NetConfig

Instances

Instances details

Show TCPConfig Source #
Instance details Defined in Striot.Nodes.Types Methods showsPrec :: Int -> TCPConfig -> ShowS # show :: TCPConfig -> String # showList :: [TCPConfig] -> ShowS #

tcpConn :: Iso' TCPConfig NetConfig Source #

data KafkaConfig Source #

Constructors

KafkaConfig
Fields _kafkaConn :: NetConfig _kafkaTopic :: String _kafkaConGroup :: String

Instances

Instances details

Show KafkaConfig Source #
Instance details Defined in Striot.Nodes.Types Methods showsPrec :: Int -> KafkaConfig -> ShowS # show :: KafkaConfig -> String # showList :: [KafkaConfig] -> ShowS #

kafkaTopic :: Lens' KafkaConfig String Source #

kafkaConn :: Lens' KafkaConfig NetConfig Source #

kafkaConGroup :: Lens' KafkaConfig String Source #

data MQTTConfig Source #

Constructors

MQTTConfig
Fields _mqttConn :: NetConfig _mqttTopic :: String

Instances

Instances details

Show MQTTConfig Source #
Instance details Defined in Striot.Nodes.Types Methods showsPrec :: Int -> MQTTConfig -> ShowS # show :: MQTTConfig -> String # showList :: [MQTTConfig] -> ShowS #

mqttTopic :: Lens' MQTTConfig String Source #

mqttConn :: Lens' MQTTConfig NetConfig Source #

data ConnectionConfig Source #

Constructors

ConnTCPConfig TCPConfig
ConnKafkaConfig KafkaConfig
ConnMQTTConfig MQTTConfig

Instances

Instances details

Show ConnectionConfig Source #
Instance details Defined in Striot.Nodes.Types Methods showsPrec :: Int -> ConnectionConfig -> ShowS # show :: ConnectionConfig -> String # showList :: [ConnectionConfig] -> ShowS #

data StriotConfig Source #

Constructors

StriotConfig
Fields _nodeName :: String _ingressConnConfig :: ConnectionConfig _egressConnConfig :: ConnectionConfig _chanSize :: Int

Instances

Instances details

Show StriotConfig Source #
Instance details Defined in Striot.Nodes.Types Methods showsPrec :: Int -> StriotConfig -> ShowS # show :: StriotConfig -> String # showList :: [StriotConfig] -> ShowS #
FromEnv StriotConfig Source #
Instance details Defined in Striot.Nodes.Types Methods fromEnv :: Maybe StriotConfig -> Parser StriotConfig
ToEnv StriotConfig Source #
Instance details Defined in Striot.Nodes.Types Methods toEnv :: StriotConfig -> EnvList StriotConfig
HasStriotConfig StriotConfig Source #
Instance details Defined in Striot.Nodes.Types Methods striotConfig :: Lens' StriotConfig StriotConfig Source # chanSize :: Lens' StriotConfig Int Source # egressConnConfig :: Lens' StriotConfig ConnectionConfig Source # ingressConnConfig :: Lens' StriotConfig ConnectionConfig Source # nodeName :: Lens' StriotConfig String Source #
MonadReader StriotConfig StriotApp Source #
Instance details Defined in Striot.Nodes.Types Methods ask :: StriotApp StriotConfig # local :: (StriotConfig -> StriotConfig) -> StriotApp a -> StriotApp a # reader :: (StriotConfig -> a) -> StriotApp a #

class HasStriotConfig c where Source #

Minimal complete definition

striotConfig

Methods

striotConfig :: Lens' c StriotConfig Source #

chanSize :: Lens' c Int Source #

egressConnConfig :: Lens' c ConnectionConfig Source #

ingressConnConfig :: Lens' c ConnectionConfig Source #

nodeName :: Lens' c String Source #

Instances

Instances details

HasStriotConfig StriotConfig Source #
Instance details Defined in Striot.Nodes.Types Methods striotConfig :: Lens' StriotConfig StriotConfig Source # chanSize :: Lens' StriotConfig Int Source # egressConnConfig :: Lens' StriotConfig ConnectionConfig Source # ingressConnConfig :: Lens' StriotConfig ConnectionConfig Source # nodeName :: Lens' StriotConfig String Source #

writeConf :: ConnectType -> ConnectionConfig -> [EnvVar] Source #

readConf :: ConnectType -> Parser ConnectionConfig Source #

nc :: String -> Parser NetConfig Source #

newtype StriotApp a Source #

Constructors

StriotApp
Fields unApp :: ReaderT StriotConfig IO a

Instances

Instances details

MonadIO StriotApp Source #
Instance details Defined in Striot.Nodes.Types Methods liftIO :: IO a -> StriotApp a #
Applicative StriotApp Source #
Instance details Defined in Striot.Nodes.Types Methods pure :: a -> StriotApp a # (<>) :: StriotApp (a -> b) -> StriotApp a -> StriotApp b # liftA2 :: (a -> b -> c) -> StriotApp a -> StriotApp b -> StriotApp c # (>) :: StriotApp a -> StriotApp b -> StriotApp b # (<*) :: StriotApp a -> StriotApp b -> StriotApp a #
Functor StriotApp Source #
Instance details Defined in Striot.Nodes.Types Methods fmap :: (a -> b) -> StriotApp a -> StriotApp b # (<$) :: a -> StriotApp b -> StriotApp a #
Monad StriotApp Source #
Instance details Defined in Striot.Nodes.Types Methods (>>=) :: StriotApp a -> (a -> StriotApp b) -> StriotApp b # (>>) :: StriotApp a -> StriotApp b -> StriotApp b # return :: a -> StriotApp a #
MonadReader StriotConfig StriotApp Source #
Instance details Defined in Striot.Nodes.Types Methods ask :: StriotApp StriotConfig # local :: (StriotConfig -> StriotConfig) -> StriotApp a -> StriotApp a # reader :: (StriotConfig -> a) -> StriotApp a #

data ConnectType Source #

Constructors

INGRESS
EGRESS

Instances

Instances details

Show ConnectType Source #
Instance details Defined in Striot.Nodes.Types Methods showsPrec :: Int -> ConnectType -> ShowS # show :: ConnectType -> String # showList :: [ConnectType] -> ShowS #

data ConnectProtocol Source #

Constructors

TCP
KAFKA
MQTT