Transfer worker inputs over the socket

[mjc]

Stack 5 of 13. Depends on 03-worker-session-protocol.

This wires Phoenix binary frames into resumable worker input transfers, adds input-resend state, keeps the socket alive while jobs run, and publishes CRF and transfer progress with job identity and throughput.

Workers can receive remote inputs over the existing channel, recover a missing resumed input, and report enough phase/progress metadata for the coordinator to distinguish transfer, search, and failure states.

Tests added in this branch prove Phoenix-enveloped binary chunks decode correctly, malformed framing is rejected, resumed transfers request missing input, pull-work payloads describe local-input availability, CRF progress/result events match the coordinator contract, transfer rates and metadata serialize correctly, and worker phases choose the right local or transferred input path.

[coderabbitai]

Important

Review skipped

Draft detected.

Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

⚙️ Run configuration

Configuration used: Organization UI

Review profile: ASSERTIVE

Plan: Pro Plus

Run ID: e1bf4ffd-b0af-4e54-a7e7-4f6f652834e2

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

• 🔍 Trigger review

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands.}