Skip to content

Latest commit

 

History

History
17 lines (14 loc) · 751 Bytes

Architecture.md

File metadata and controls

17 lines (14 loc) · 751 Bytes

Antek Async Architecture

Overview

Antek Async uses a "Hub and Spoke" model where the central BrokerModule receives messages from various Protocols and redistributes them to interested parties.

Data Flow

  1. Ingestion: A Gateway (e.g., MQTTGateway) receives a packet.
  2. Translation: The Gateway parses the raw bytes/text into a logical topic and payload.
  3. Routing: The Gateway calls BrokerModule.publish(topic, payload, source).
  4. Distribution: BrokerModule iterates over subscribers and triggers callbacks (which may write back to sockets).

Gateway Standard

All Gateways must:

  • Import BrokerModule.
  • Log activities via Logger.
  • Handle their own connection lifecycle.
  • Not block the event loop.