Liftbridge Streams¶

Liftbridge streams are the one of ways of inter-process communications inside NOC cluster.

Events Pipeline¶

Main Fault Management pipeline. Events pipeline registers various events either by active (pinging and probing) or by passive (various collectors) means. Then, classifier processes events, assigns them Event Classes and detects events which may signal the raising or clearing alarm conditions. Selected events are passed to correlator for further alarm state processing.

graph LR
  ping -->|events.POOL| classifier
  syslogcollector -->|events.POOL| classifier
  trapcollector -->|events.POOL| classifier
  classifier -->|dispose.POOL| correlator

Generic Message Exchange Pipeline¶

Generic Message Exchange Pipeline processes notifications of various system events which may be delivered to outside system. Messages are sent to mx service, which performs translation and templating for messages and routes them to one of *sender services, which perform delivery to outside endpoints.

graph LR
   System((System)) -->|mx| mx
   discovery -->|mx| mx
   datatream -->|mx| mx
   mx -->|kafkasender| kafkasender([kafkasender])

Orchestration Pipeline¶

Orchestration pipeline processes requests for short and long-termed jobs.

graph LR
  System((System)) -->|jobs| worker
  System((System)) -->|submit| runner