Telemetry

Telemetry control surface used by the fiona CLI’s send-only child mode. Lets a parent process dump proto payloads to disk via the NUTRIENT_PAYLOAD_PATH environment variable, exit fast, and have a short-lived child re-hydrate and ship them in parallel.

from nutrient_sdk import Telemetry

Construction

Telemetry()

Creates a new Telemetry instance with default settings.

Class Methods

flush

@classmethod
def flush(cls, timeout_milliseconds: int) -> None

Waits up to timeoutMilliseconds for any in-flight telemetry sends to complete. Strategy-dependent: a no-op for the default channel strategy, blocking for the parallel-send strategy.

Parameters:

send_payloads_from_directory

@classmethod
def send_payloads_from_directory(cls, directory: str) -> None

Re-enqueues every *.pb file in directory into the active telemetry strategy as a raw payload, deleting each file on successful enqueue. Intended for the fiona send-only child mode.

Parameters: