Skip to content

socket_connector

qoa4ml.connector.socket_connector

Classes

SocketConnector

TCP socket connector that publishes reports as UTF-8 bytes.

Any network error (connection refused, timeout, reset, ...) is caught, logged, and swallowed so callers (typically Probe.reporting running in a RepeatedTimer thread) do not die on transient aggregator outages.

Functions
send_report(body_message, log_path=None)

Send body_message to the configured host:port.

Parameters:

Name Type Description Default
body_message str

Report body, sent as UTF-8 bytes.

required
log_path str

If set, append the round-trip time (ms) to this file.

None