Module stream 

Result streaming + log entry conversion for the guest runtime.

The guest linear task runs a GuestPlugin’s lifecycle sequence (on_start -> execute_sample -> wait -> on_stop) and streams results back over an mpsc channel. Auto-collection of artifacts and external logs is handled after on_stop.

Structs

TaskExecution 🔒

All parameters for a single guest task execution (everything except the generic plugin instance).

Functions

guest_linear_task 🔒

Run a GuestPlugin’s linear lifecycle and stream results back over the task’s result channel.

log_entry_to_proto 🔒

Convert a SDK [LogEntry] to the protobuf LogEntry representation.

message_to_proto 🔒

Convert a TaskResultMessage to the protobuf TaskResult representation.

result_format_to_proto 🔒

send_final_marker 🔒

Send the final-marker TaskResult that signals end-of-stream to the daemon.