Skip to content

Reusable workflows

Related guidance: shipped-tooling.

Runnable examples: preflight.py, publish_entity.py, watch_tracks.py, dispatch_task.py.

SymbolSummary
CheckClockResultStructured result of an ECN-relative clock measurement.
ConvertLocationToECEFResultECEF position and optional rotated velocity for a geodetic location.
DecodePublicProtobufResultValidated entity event decoded from public protobuf bytes.
DispatchTaskResultStructured result returned by public task dispatch.
ECNLocationResultThe next terminal-geolocation event observed over MQTT.
EchoRequestBounded request body used by the public task workflow examples.
EchoResultBounded result body returned by the public task workflow examples.
MeshObservationResultEntity and location events retained from routed topic families.
PreflightResultStructured result of the public connectivity preflight.
PublishEntityResultPublished entity and its broker acknowledgement.
PublishLocationResultPublished location and its broker acknowledgement.
ReceiveMeshTaskResultTerminal identity plus retained requests handled before cleanup.
ReceiveTaskResultRegistration and retained requests handled before cleanup.
WatchEntitiesResultEntity events retained by a watch.
check_clockMeasure ECN-relative clock offset and optionally enforce a maximum offset.
convert_location_to_ecefConvert a public WGS-84 location and optional velocity to ECEF coordinates.
decode_public_protobufDecode one public entity-event protobuf payload without a connection.
dispatch_mesh_taskDispatch one typed echo request on an explicit terminal-addressed route.
dispatch_taskDispatch one typed echo request on the direct integration route.
get_ecn_locationWait for the next terminal-geolocation MQTT event.
observe_mesh_dataObserve routed entity and location families until either consumer completes.
preflightRun the public, read-only ECN preflight checks.
publish_entityConstruct and publish one typed public entity.
publish_locationPublish one typed public location for an entity identity.
receive_mesh_taskRegister an echo handler for a terminal-addressed deployment route.
receive_taskRegister an echo handler and clean it up after task_limit requests.
watch_detectionsCollect detection events, with zero meaning an intentionally unbounded watch.
watch_tracksCollect track events, with zero meaning an intentionally unbounded watch.

Version 0.2.0 · branch main