class

JaneHQ::IngestServer

Inherits Reference < Object

Raw-TCP msgpack listener for Jane agents (default port 25900). Each agent opens a connection, writes one message, and closes it — so one connection equals one report and we read to EOF. No framing/auth (matches the agent).

Constants

Log = ::Log.for("ingest")

Constructors

new(storage : Storage, host : String = "0.0.0.0", port : Int32 = 25900)
Source

Instance methods

listen
Source